使用 gorilla/websocket 订阅 websocket

Question

我想使用Binance API的一些 websocket 流。我在这里发布这个是因为我认为这不是 API 的问题，而是我对 websockets 的一般理解。

我尝试订阅一个流，正如官方 gorilla/websocket 示例所描述的那样：

conn, res, err := websocket.DefaultDialer.Dial("wss://stream.binance.com/ws/BTCUSD@markPrice", nil)

fmt.Println(conn)

fmt.Println(res)

fmt.Println(err)

for {

    _, message, readErr := conn.ReadMessage()

    if readErr != nil {

        fmt.Println(readErr)

        return

    }

    fmt.Println(message)

}

连接创建没有错误，但之后，没有消息被读取。

我认为问题在于 API 要求我订阅这样的流：

{

    "method": "SUBSCRIBE",

    "params": [

        "btcusdt@aggTrade",

        "btcusdt@depth"

    ],

    "id": 1

}

我知道一个 websocket 连接从一个 HTTP 请求开始，据我所知，我发送这个数据。但是我应该在何时何地这样做？Dial除了 HTTP 标头之外，不提供发送任何内容的选项。

更新：

我设法通过使用 Conn.WriteJSON发送正确的请求并获得正确的响应，如此处所述：

type request struct {

    Method string    `json:"method"`

    Params [1]string `json:"params"`

    ID     int       `json:"id"`

}

markPriceReq := request{"SUBSCRIBE", [1]string{"btcusdt@markPrice"}, 1}

conn.WriteJSON(markPriceReq)

但是，在初始响应之后，不再读取任何数据。我从哪里获得实际的标记价格数据？

Answer 1

您的连接网址有问题。流的所有符号都是小写的，并且您发布的文档链接中的 ws 基本端点是wss://stream.binancefuture.com（Perpetual/Perpetual Testnet ws 端点），但您正在使用wss://stream.binance.com（Margin/Spot/Savings/Mining ws 端点）。标记价格流仅适用于Perpetual/Perpetual Testnet ws 端点。我使用原始流网址：wss://stream.binancefuture.com/ws/btcusdt@markPrice没有任何问题此请求用于实时订阅/取消订阅，您仅在已连接到 binance ws 并希望订阅更多流或取消订阅流时使用此请求。{&nbsp; &nbsp; "method": "SUBSCRIBE",&nbsp; &nbsp; "params": [&nbsp; &nbsp; &nbsp; &nbsp; "btcusdt@aggTrade",&nbsp; &nbsp; &nbsp; &nbsp; "btcusdt@depth"&nbsp; &nbsp; ],&nbsp; &nbsp; "id": 1}您不必使用实时订阅/取消订阅，只需使用上面的原始 url就可以了：wss://stream.binancefuture.com/ws/<streamName>（只有一个流）wss://stream.binancefuture.com/stream?streams=<streamName1>/<streamName2>/<streamName3>（组合流）通过使用原始 url，您可以访问<streamName>（您也可以在此之后发送请求以使用实时订阅/取消订阅）