我试图使用gorilla/websocket包将一个建立并维护与第三方服务器的Websocket连接的NodeJS脚本移植到Go中。在Node脚本中，收到ping后会收到pong，并且连接会无限期保持活动状态。在Go脚本中，ping/pong有效，但是服务器在约30秒后断开连接。
我怀疑使用Go websocket包发送的pings格式不正确，但我无法确定原因。比较运行这些程序时捕获的加密网络流量显示TCP请求和响应的响应长度没有差异，因此可能不是问题所在。非常感谢任何帮助！
我怀疑使用Go websocket包发送的pings格式不正确，但我无法确定原因。比较运行这些程序时捕获的加密网络流量显示TCP请求和响应的响应长度没有差异，因此可能不是问题所在。非常感谢任何帮助！
websocket.js
#!/usr/bin/env node
// npm install websocket@1.0.25 --save
const WebSocketClient = require('websocket').client;
const client = new WebSocketClient();
let lastPing = new Date().getTime();
client.on('connectFailed', function(error) {
console.log('Connect Error: ' + error.toString());
});
client.on('connect', function(connection) {
console.log('Connected to Server...');
connection.on('error', function(error) {
console.log("Connection Error: " + error.toString());
});
connection.on('close', function() {
console.log('Connection Closed');
});
connection.on('message', function(message) {
if (message.type === 'utf8') {
console.log(message.utf8Data);
}
});
connection.on('pong', function(){
console.log('[pingpong] response took', (new Date().getTime() - lastPing) + 'ms');
})
function send(message) {
if (connection.connected) {
connection.sendUTF(message);
}
}
// Send a ping every 10s
// to keep the connection live
setInterval(function(){
lastPing = new Date().getTime();
connection.ping();
}, 10000);
});
client.connect('wss://ws.radarrelay.com/0x/v0/ws');
websocket.go
package main
import (
"flag"
"log"
"os"
"os/signal"
"time"
"github.com/gorilla/websocket"
)
var addr = "wss://api.radarrelay.com/0x/v0/ws"
func main() {
flag.Parse()
log.SetFlags(0)
timeoutDuration := 2 * time.Minute
interrupt := make(chan os.Signal, 1)
signal.Notify(interrupt, os.Interrupt)
c, _, err := websocket.DefaultDialer.Dial(addr, nil)
if err != nil {
log.Fatal("dial:", err)
} else {
log.Println("Connected to server")
}
c.SetPongHandler(func(str string) error {
log.Println("pong received", str)
return nil
})
defer c.Close()
done := make(chan struct{})
go func() {
defer c.Close()
defer close(done)
for {
c.SetReadDeadline(time.Now().Add(timeoutDuration))
_, message, err := c.ReadMessage()
if err != nil {
log.Println("read:", err)
return
}
if len(message) >= 2 {
message = message[2:]
}
log.Printf("recv: %s", message)
}
}()
ticker := time.NewTicker(10 * time.Second)
defer ticker.Stop()
for {
select {
case _ = <-ticker.C:
err := c.WriteMessage(websocket.PingMessage, []byte{})
if err != nil {
log.Println("write:", err)
return
} else {
log.Println("ping sent")
}
case <-interrupt:
log.Println("interrupt")
// To cleanly close a connection, a client should send a close
// frame and wait for the server to close the connection.
err := c.WriteMessage(
websocket.CloseMessage,
websocket.FormatCloseMessage(websocket.CloseNormalClosure, ""))
if err != nil {
log.Println("write close:", err)
return
}
select {
case <-done:
case <-time.After(time.Second):
}
c.Close()
return
}
}
}
fmt.Println("frame: %x %x\n", buf0, buf1)（https://github.com/gorilla/websocket/blob/eb925808374e5ca90c83401a40d711dc08c0c0f6/conn.go#L376），并在JS代码中添加`console.log(output);`（https://github.com/theturtle32/WebSocket-Node/blob/d941f975e8ef6b55eafc0ef45996f4198013832c/lib/WebSocketFrame.js#L270）。 - Charlie Tumahai