币安websocket没有响应ping

Question

我使用< code>gorilla/websocket拨打了币安websocketendpoint，成功无误。在连接上设置了pong处理程序后，我编写了一个ping控制消息，并等待pong到达pong处理程序，这似乎永远不会发生。我使用一个通道、一个超时上下文和一个< code>select块来检查pong是否到达。

代码：

package main

import (
    "context"
    "fmt"
    "log"
    "time"

    "github.com/gorilla/websocket"
)

func main() {
    ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    defer cancel()

    conn, resp, err := websocket.DefaultDialer.DialContext(ctx, "wss://stream.binance.com:9443/ws", nil)
    if resp != nil {
        log.Printf("status: %s", resp.Status)
    }

    if err != nil {
        panic(err)
    }

    pong := make(chan struct{})
    conn.SetPongHandler(func(appData string) error {
        log.Println(appData)

        pong <- struct{}{}
        return nil
    })

    if err := conn.WriteControl(websocket.PingMessage, []byte("Hello, world!"), time.Now().Add(5*time.Second)); err != nil {
        panic(err)
    }

    select {
    case <-ctx.Done():
        panic(fmt.Errorf("pong wait: %w", ctx.Err()))
    case <-pong:
    }
}

输出：

$ go run ./cmd/ping
2022/02/07 20:01:23 status: 101 Switching Protocols
panic: pong wait: context deadline exceeded

goroutine 1 [running]:
main.main()
        /workspaces/yatgo/cmd/ping/ping.go:39 +0x2ba
exit status 2

根据rfc6455，第-5.5.2节：

5.5.2。平

ping帧包含0x9的操作码。

查验帧可以包括“应用数据”。

收到ping帧后，endpoint必须发送Pong帧作为响应，除非它已经收到了关闭帧。它应该在实际可行的情况下尽快使用Pong帧响应。Pong帧在第5.5.3节中讨论。

endpoint可以在连接建立之后和连接关闭之前的任何时间发送Ping帧。

注意：ping帧可以用作保持活动，也可以用作验证远程endpoint是否仍有响应的方法。

我有点期待这能奏效。Binance webSocket API限制doc确实提到了ping消息：

WebSocket连接每秒最多有5条传入消息。消息被认为是：

< Li > PING帧

所以我想知道：

1. 我的代码有问题吗
2. 还是二进制文件不尊重RFC6455

Answer 1

大猩猩WebSocch留档说：

应用程序必须读取连接才能处理从对等方发送的关闭、ping 和 pong 消息。如果应用程序对来自对等方的消息不感兴趣，则应用程序应启动一个 goroutine 来读取和丢弃来自对等方的消息。

通过启动 goroutine 在 select 语句之前读取连接来修复应用程序：

go func() {
    defer cancel()
    for {
        if _, _, err := conn.NextReader(); err != nil {
            fmt.Println(err)
            return
        }
    }
}()

select {
⋮

这是对问题中显示的应用程序的修复。如果实际应用程序在循环中从连接读取数据，那么不应该添加此处显示的goroutine。应用程序应该使用一个读取循环来处理控制和数据消息。