6

我是 NodeJS 的新手。假设我有一个使用 Golang 的 websocket 包实现的回显服务器：

包主

进口 （
    “code.google.com/p/go.net/websocket”
    “日志”
    “网络/http”
)

func EchoServer(ws *websocket.Conn) {
    var 消息字符串
    websocket.Message.Receive(ws, &msg)
    log.Printf("收到的消息：%s\n", msg)
    websocket.Message.Send(ws, msg)
}

功能主要（）{
    http.Handle("/echo", websocket.Handler(EchoServer))
    错误 := http.ListenAndServe(":8082", nil)
    如果错误！= nil {
        恐慌（错误。错误（））
    }
}

nodejs 客户端代码应该是什么样的？

4

2 回答 2

23

作为 WebSocket-Node 库的作者，我可以向您保证，您无需为了不使用子协议而修改 WebSocket-Node 库代码。

上面的示例代码错误地显示为 connect() 函数的 subprotocol 参数传递了一个空字符串。如果您选择不使用子协议，则应将 JavaScript 的 null 值作为第二个参数传递，或者传递一个空数组（该库能够按需求降序向远程服务器建议多个支持的子协议），但不能为空细绳。

于 2013-12-19T01:15:04.913 回答
9

我想这就是你要找的。使用您的服务器代码的快速示例：

var WebSocketClient = require('websocket').client;

var client = new WebSocketClient();

client.on('connectFailed', function(error) {
    console.log('Connect Error: ' + error.toString());
});

client.on('connect', function(connection) {
    console.log('WebSocket client connected');
    connection.on('error', function(error) {
        console.log("Connection Error: " + error.toString());
    });
    connection.on('close', function() {
        console.log('echo-protocol Connection Closed');
    });
    connection.on('message', function(message) {
        if (message.type === 'utf8') {
            console.log("Received: '" + message.utf8Data + "'");
        }
    });

    connection.sendUTF("Hello world");
});

client.connect('ws://127.0.0.1:8082/echo', "", "http://localhost:8082");

要使其正常工作，您需要修改lib/WebSocketCLient.js. 注释掉这些行（我机器上的第 299-300 行）：

        //this.failHandshake("Expected a Sec-WebSocket-Protocol header.");
        //return;

由于某种原因，您提供的 websocket 库似乎没有发送“Sec-Websocket-Protocol”标头，或者至少客户端没有找到它。我没有做太多的测试，但可能应该在某个地方提交错误报告。

这是一个使用 Go 客户端的示例：

package main

import (
    "fmt"
    "code.google.com/p/go.net/websocket"
)

const message = "Hello world"

func main() {
    ws, err := websocket.Dial("ws://localhost:8082/echo", "", "http://localhost:8082")
    if err != nil {
        panic(err)
    }
    if _, err := ws.Write([]byte(message)); err != nil {
        panic(err)
    }
    var resp = make([]byte, 4096)
    n, err := ws.Read(resp)
    if err != nil {
        panic(err)
    }
    fmt.Println("Received:", string(resp[0:n]))
}
于 2013-02-19T16:07:54.240 回答