Download anysocket - download do código-fonte anysocket

anysocket

Outras categorias

v0.4.29

Baixar

QualquerSocket

Uma camada de rede abstrata sobre vários transportes, independente de cliente/servidor e com suporte para E2EE

Características
Referências
Instalação
Uso
Documentação/API
Próximos recursos
Licença

Importante

Este é um trabalho em andamento e a API está sujeita a alterações.

Características

Agnóstico cliente/servidor
Suporte para solicitação/resposta
Método AUTH personalizado
E2EE entre pares com sigilo de encaminhamento
Suporte RPC
Suporte NTP Sync entre pares
P2P usando um servidor proxy (com suporte para E2EE direto entre pares)
Suporte binário ( veja: AnySocket.Packer )
Suporte ao navegador - área ocupada de 31 KB ( consulte: /dist/anysocket.browser.js )
Vários transportes *(atm implementado: ws/wss , http/https )
Todos os pares têm um UUIDv4 associado
Desconecte a detecção usando uma pulsação
Não testado em batalha ... ainda

** transporte http é experimental

Informações: Argumentos e respostas RPC binários são compactados/descompactados automaticamente ( AnySocket.Packer.pack / AnySocket.Packer.unpack ).

Referências

Ver benchmarks

Instalação

 npm install -- save anysocket

ou

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

ou (se estiver usando AnySocketHTTP)

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

Como usar

O exemplo a seguir inicia um servidor websocket na porta 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 ) ;
} ) ;

O exemplo a seguir se conecta a um websocket na porta 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 ) ;
} ) ;