Descarga anysocket - Descarga del código fuente anysocket

anysocket

Otras categorias

v0.4.29

Descargar

CualquierSocket

Una capa de red abstracta sobre múltiples transportes, independiente del cliente/servidor con soporte para E2EE

Características
Puntos de referencia
Instalación
Uso
Documentación/API
Próximas funciones
Licencia

Importante

Este es un trabajo en progreso y la API está sujeta a cambios.

Características

Independiente del cliente/servidor
Soporte para solicitud/respuesta
Método de autenticación personalizado
E2EE entre pares con secreto directo
soporte RPC
Soporte de sincronización NTP entre pares
P2P usando un servidor proxy (con soporte para E2EE directo entre pares)
Soporte binario ( ver: AnySocket.Packer )
Compatibilidad con navegador : espacio de 31 kb ( consulte: /dist/anysocket.browser.js )
Múltiples transportes *(cajero automático implementado: ws/wss , http/https )
Todos los pares tienen un UUIDv4 asociado
Desconectar la detección mediante un latido del corazón
No probado en batalla ... todavía

** El transporte http es experimental.

Información: Los argumentos y respuestas de RPC binarios se empaquetan/desempaquetan automáticamente ( AnySocket.Packer.pack / AnySocket.Packer.unpack ).

Puntos de referencia

Ver puntos de referencia

Instalación

 npm install -- save anysocket

o

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

o (si usa AnySocketHTTP)

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

como usar

El siguiente ejemplo inicia un servidor websocket en el puerto 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 ) ;
} ) ;

El siguiente ejemplo se conecta a un websocket en el puerto 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 ) ;
} ) ;