anysocket下载 - anysocket源码下载

anysocket

其他类别

v0.4.29

下载

任意套接字

多个传输上的抽象网络层，客户端/服务器无关，支持 E2EE

特征
基准测试
安装
用法
文档/API
即将推出的功能
执照

重要的

这是一项正在进行的工作，API 可能会发生变化。

特征

客户端/服务器不可知
支持请求/回复
自定义AUTH方法
具有前向保密性的点对点之间的 E2EE
远程过程调用支持
对等点之间的 NTP 同步支持
使用代理服务器的 P2P（支持对等点之间的直接 E2EE）
二进制支持（请参阅： AnySocket.Packer ）
浏览器支持- 31kb 占用空间（请参阅： /dist/anysocket.browser.js ）
多种传输 *（实现 atm： 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 上启动 Websocket 服务器。

 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 上的 Websocket

 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 ) ;
} ) ;