Загрузка anysocket - Загрузка исходного кода anysocket

anysocket

Другие категории

v0.4.29

Скачать

AnySocket

Абстрактный сетевой уровень с несколькими транспортами, независимый клиент/сервер с поддержкой E2EE.

Функции
Тесты
Установка
Использование
Документация/API
Предстоящие функции
Лицензия

Важный

Эта работа находится в стадии разработки, и API может быть изменен.

Функции

Независимость от клиента/сервера
Поддержка запроса/ответа
Пользовательский метод аутентификации
E2EE между узлами с прямой секретностью
Поддержка RPC
Поддержка синхронизации NTP между узлами
P2P с использованием прокси-сервера (с поддержкой прямого E2EE между узлами)
Поддержка двоичных файлов ( см. AnySocket.Packer ).
Поддержка браузера — объем 31 КБ ( см.: /dist/anysocket.browser.js )
Множественные транспорты *(реализованный банкомат: ws/wss , http/https )
Все одноранговые узлы имеют связанный UUIDv4.
Обнаружение отключения с помощью пульса
Не проверено в бою ...пока

** HTTP- транспорт является экспериментальным.

Информация: двоичные аргументы и ответы RPC автоматически упаковываются/распаковываются ( AnySocket.Packer.pack / AnySocket.Packer.unpack ).

Тесты

Посмотреть тесты

Установка

 npm install -- save anysocket

или

 < script src =" /dist/anysocket.browser.js " > </ script >

или (при использовании AnySocketHTTP)

 < script src =" @anysocket " > </ script >

Как использовать

В следующем примере сервер веб-сокетов запускается через порт 3000.

 const AnySocket = require ( "anysocket" ) ;
const server = new AnySocket ( ) ;
const PORT = 3000 ;
server . listen ( "ws" , PORT )
    . then ( ( ) => {
        console . log ( "Listening on port:" , PORT ) ;
    } )
    . catch ( ( err ) => {
        console . error ( "Failed to start server:" , err ) ;
    } ) ;
server . on ( "connected" , async ( peer ) => {
    console . log ( "Connected" , peer . id ) ;
    console . log ( await peer . getSyncedTime ( ) ) // { time: 1674671482107, rtt: 2, offset: 0 }
    peer . send ( {
        hello : "world"
    } ) ;
} ) ;
server . on ( "message" , ( packet ) => {
    console . log ( "From:" , packet . peer . id , "Message:" , packet . msg ) ;
} ) ;
server . on ( "disconnected" , ( peer , reason ) => {
    console . log ( "Disconnected" , peer . id , "Reason:" , reason ) ;
} ) ;

В следующем примере выполняется подключение к веб-сокету через порт 3000.

 const AnySocket = require ( "anysocket" ) ;
const client = new AnySocket ( ) ;
const PORT = 3000 ;
client . connect ( "ws" , "127.0.0.1" , PORT )
    . then ( ( ) => {
        console . log ( "Connected to server" ) ;
    } )
    . catch ( ( err ) => {
        console . error ( "Failed to connect to server:" , err ) ;
    } ) ;

// after negotiating the AUTH packet, it will trigger the connect event
client . on ( "connected" , async ( peer ) => {
    console . log ( "Connected" , peer . id ) ;
    console . log ( await peer . getSyncedTime ( ) ) // { time: 1674671482107, rtt: 2, offset: 0 }
    peer . send ( {
        hello : "world"
    } ) ;
} ) ;
client . on ( "message" , ( packet ) => {
    console . log ( "From:" , packet . peer . id , "Message:" , packet . msg ) ;
} ) ;
client . on ( "disconnected" , ( peer , reason ) => {
    console . log ( "Disconnected" , peer . id , "Reason:" , reason ) ;
} ) ;