dsdxlibt98300 2013-02-18 09:39
浏览 324
已采纳

使用nodejs客户端访问golang websocket服务器

I am a newbie to NodeJS. Assume that I have a echo server implemented with Golang's websocket package:

package main

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

func EchoServer(ws *websocket.Conn) {
    var msg string
    websocket.Message.Receive(ws, &msg)
    log.Printf("Message Got: %s
", msg)
    websocket.Message.Send(ws, msg)
}

func main() {
    http.Handle("/echo", websocket.Handler(EchoServer))
    err := http.ListenAndServe(":8082", nil)
    if err != nil {
        panic(err.Error())
    }
}

What should the nodejs client code look like ?

  • 写回答

2条回答 默认 最新

  • doulu2576 2013-02-19 16:07
    关注

    I think this is what you're looking for. Quick example using your server code:

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

    To get this to work, you'll need to modify the WebsocketClient code in lib/WebSocketCLient.js. Comment these lines out (lines 299-300 on my machine):

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

    For some reason the websocket library you provided doesn't seem to send the "Sec-Websocket-Protocol" header, or at least the client doesn't find it. I haven't done too much testing, but a bug report should probably be filed somewhere.

    Here's an example using a Go client:

    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]))
    }
    
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(1条)

报告相同问题?

悬赏问题

  • ¥15 求差集那个函数有问题,有无佬可以解决
  • ¥15 【提问】基于Invest的水源涵养
  • ¥20 微信网友居然可以通过vx号找到我绑的手机号
  • ¥15 寻一个支付宝扫码远程授权登录的软件助手app
  • ¥15 解riccati方程组
  • ¥15 display:none;样式在嵌套结构中的已设置了display样式的元素上不起作用?
  • ¥15 使用rabbitMQ 消息队列作为url源进行多线程爬取时,总有几个url没有处理的问题。
  • ¥15 Ubuntu在安装序列比对软件STAR时出现报错如何解决
  • ¥50 树莓派安卓APK系统签名
  • ¥65 汇编语言除法溢出问题