Deepstream: сервер с открытым исходным кодом для создания приложений реального времени

Он обеспечивает синхронизацию данных, а также pub-sub и классический запрос-ответ и обслуживает широкий спектр функциональных требований, таких как отработка отказа, разрешение, шифрование, согласованность и разрешение конфликтов.

Deepstream разработан для процветания в экосистемах с открытым исходным кодом и поставляется с целым рядом разъемов для популярных баз данных, кэшей или шин сообщений.

Но самое главное: это масштабируемо, надежно и очень быстро.

Использование Deepstream

Все это звучит хорошо и хорошо — но как это на самом деле работает? Давайте быстро коснемся основных моментов.

Установка

Deepstream поставляется в виде исполняемого файла для Mac и Windows, пакета yumaptстранице установки .

конфигурация

Каждый аспект сервера может быть настроен в файле с именем config.yml/etc/deepstream/conf/conf

Запуск сервера

Сервер запускается либо запуском deepstream start

Получение клиентского SDK

Для подключения к Deepstream требуется SDK для данного языка программирования. Например, для браузеров и Node это можно установить с помощью npm install deepstream.io-client-js

Подключение к серверу

Самый простой способ подключения — это вызвать var client = deepstream('localhost:6020').login() В эту строку можно добавить намного больше, например, передачу параметров клиента, параметров аутентификации или ожидание обратного вызова после входа в систему, но давайте просто оставим это в покое.

Использование синхронизации данных

Синхронизация данных Deepstream использует концепцию, называемую «записи» — документы JSON, которыми можно манипулировать и наблюдать, которые синхронизируются между всеми подключенными клиентами, а также сохраняются на серверной части. Это звучит сложнее, чем есть. Записи идентифицируются уникальным именем и создаются или загружаются на лету:

 pizzaGuy = ds.record.getRecord( 'driver/14' )

Значение записи может быть установлено так:

 pizzaGuy.set({
  name: 'John Doe',
  position: { x: 4234, y: 2454 },
  speed: 22
})

… или частично, вот так:

 pizzaGuy.set( 'position.x', 4244 )

Точно так же другие клиенты могут подписаться на изменения всей записи:

 pizzaGuy.subscribe(( data )=>{
  //...
})

… или к пути внутри него:

 pizzaGuy.subscribe( 'position', updateMapMarker )

Использование событий

События — это паб-суб механизм Deepstream. Они обеспечивают эфемерный обмен сообщениями «многие ко многим». Каждый клиент может подписаться на событие:

 ds.event.subscribe( 'something-happened', data => {})

… или испустить это:

 ds.event.emit( 'something-happened', { size: 'big' })

Использование RPC

Удаленные вызовы процедур — это механизм Deepstream для связи запрос-ответ. Deepstream маршрутизирует запросы между поставщиком и запросчиком, управляет аварийным переключением, повторной попыткой и сериализацией данных.

Процессы могут зарегистрироваться в качестве поставщиков RPC:

 ds.rpc.provide( 'add-two', input, ( response ) => {
  response.send( input + 2 )
})

… и попросить их:

 ds.rpc.make( 'add-two', 5, ( err, result ) => { /* result = 7 */})

Аутентификация и разрешение

Deepstream предлагает целый ряд различных стратегий для аутентификации входящих соединений, например, через файлы конфигурации или http-webhooks . Каждый входящий запрос аутентифицируется с использованием языка разрешений в реальном времени под названием Valve .

 record:
  #an auctioned item
  auction/item/$sellerId/$itemId:

    #everyone can see the item and its price
    read: true

    #only users with canBid flag in their authData can bid
    #and bids can only be higher than the current price
    write: "user.data.canBid && data.price > oldData.price"

    #only the seller can delete the item
    delete: "user.id == $sellerId"

Добавление разъемов

Легко добавить базы данных, такие как Mongo , Rethink или Postgres , кэши, такие как Redis , Memcached или Hazelcast , или системы обмена сообщениями, такие как RabbitMQ или Kafka, для глубокого распространения с использованием коннекторов. Все соединители устанавливаются через командную строку — например, с помощью следующего:

 deepstream install cache redis

Собираем все вместе

Подводя итог, можно сказать, что Deepstream — это универсальный, масштабируемый и производительный сервер реального времени, который можно использовать в качестве бэкэнда для вариантов использования, от приложений CRUD до требовательных приложений обмена сообщениями, панели мониторинга в реальном времени или даже многопользовательских игр. Это надежный, безопасный и предоставляет все функции, необходимые для запуска крупномасштабных приложений реального времени в производстве.