Skip to content

WebSocket

WebSocket客户端和服务器通信。

输入

WebSocket out节点:要发送的消息对象 WebSocket in节点:无输入

输出

WebSocket out节点:无输出 WebSocket in节点:接收到的WebSocket消息

详细说明

WebSocket节点包含两种类型:WebSocket in(接收)和WebSocket out(发送)。

支持客户端和服务器模式。

WebSocket in节点

接收WebSocket消息。

配置选项

  • 类型: 监听(服务器)或连接(客户端)
  • 路径/URL: 服务器路径或客户端URL
  • 发送/接收: 消息格式
    • 载荷
    • 整个消息对象

输出消息格式

javascript
msg = {
    payload: "消息内容",
    _session: {
        type: "websocket",
        id: "client123"
    }
}

WebSocket out节点

发送WebSocket消息。

配置选项

  • 类型: 监听(服务器)或连接(客户端)
  • 路径/URL: 服务器路径或客户端URL
  • 发送/接收: 消息格式

输入消息格式

javascript
msg = {
    payload: "要发送的消息",
    _session: {          // 可选,指定发送目标
        type: "websocket",
        id: "client123"
    }
}

服务器配置

  • 路径: WebSocket端点路径(如 /ws)
  • 验证: 连接验证函数

客户端配置

  • URL: WebSocket服务器地址
  • 子协议: WebSocket子协议
  • 头部: 连接头部信息

示例

服务器模式:

javascript
// WebSocket in节点(服务器)
// 路径: /chat
// 客户端连接后接收消息
msg = {
    payload: "Hello from client",
    _session: {
        type: "websocket",
        id: "client_abc123"
    }
}

// WebSocket out节点(服务器)
// 向所有客户端广播
msg = {
    payload: "广播消息"
}

// 向特定客户端发送
msg = {
    payload: "私人消息",
    _session: {
        type: "websocket", 
        id: "client_abc123"
    }
}

客户端模式:

javascript
// WebSocket in节点(客户端)
// URL: ws://localhost:1880/chat
// 接收服务器消息
msg = {
    payload: "Hello from server"
}

// WebSocket out节点(客户端)
// 发送消息到服务器
msg = {
    payload: "Hello server"
}

JSON数据:

javascript
// 发送JSON对象
msg = {
    payload: {
        type: "chat",
        user: "张三",
        message: "大家好!",
        timestamp: Date.now()
    }
}

// 接收JSON对象
msg = {
    payload: {
        type: "notification",
        content: "新用户加入聊天室"
    }
}

应用场景

  • 实时聊天应用
  • 实时数据推送
  • 游戏通信
  • 协作应用

注意事项

  • 处理连接断开和重连
  • 管理多个客户端连接
  • 注意消息格式一致性
  • 处理网络异常情况

蜀ICP备2025139593号