Golang ending (Binance) web服务流使用go例程

Question

我正在将 Binance API 集成到一个现有系统中，虽然大部分都是直截了当的，但数据流 API 触及了我对 go-routines 的有限理解。我不认为 Binance 的 golang SDK 有什么特别之处，但本质上我只需要两个函数，一个启动数据流并使用事件处理程序作为参数处理事件，另一个结束数据流无需实际关闭客户端，因为它会关闭所有其他连接。在之前的项目中，有两种消息类型，但 binance SDK 使用了一种实现，即 returns 两个通道，一个用于错误，另一个，我从名字猜，用于停止数据流。

我为启动数据流编写的代码如下所示：


func startDataStream(symbol, interval string, wsKlineHandler futures.WsKlineHandler, errHandler futures.ErrHandler) (err error){

    doneC, stopC, err := futures.WsKlineServe(symbol, interval, wsKlineHandler, errHandler)
    if err != nil {
        fmt.Println(err)
        return err
    }

    return nil
}

这按预期工作并流式传输数据。一个简单的测试验证了它：


func runWSDataTest() {
    symbol := "BTCUSDT"
    interval := "15m"
    errHandler := func(err error) {fmt.Println(err)}

    wsKlineHandler := func(event *futures.WsKlineEvent) {fmt.Println(event)}

    _ = startDataStream(symbol, interval, wsKlineHandler, errHandler)
}

我不太清楚的事情，主要是由于不完全理解，真的是我如何停止流。我认为返回的 stopC 通道可用于以某种方式发出类似于系统级信号项的结束信号，然后流应该结束。

比如说，我有一个以符号作为参数的 stopDataStream 函数

func stopDataStream(symbol){

}

假设我为五个符号启动了 5 个数据流，现在我只想停止其中一个数据流。这就引出了一个问题：

如何跟踪所有这些 stopC 频道？
我可以使用以符号为键的集合，拉出 stopC 通道，然后只发出一个信号来结束该数据流吗？
如何从停止函数实际写入 stopC 通道？

同样，我不认为这特别难，只是我还无法从文档中弄清楚，所以任何帮助将不胜感激。

谢谢

Answer 1

（答案原由@Marvin.Hansen撰写）

事实证明，只需保存并关闭频道即可解决所有问题。我真的很惊讶这是多么容易，但这里是更新函数的代码：

func startDataStream(symbol, interval string, wsKlineHandler futures.WsKlineHandler, errHandler futures.ErrHandler) (err error) {

    _, stopC, err := futures.WsKlineServe(symbol, interval, wsKlineHandler, errHandler)
    if err != nil {
        fmt.Println(err)
        return err
    }
    // just save the stop channel 
    chanMap[symbol] = stopC
    return nil
}

然后，停止函数真的变得尴尬琐碎了：

func stopDataStream(symbol string) {
    stopC := chanMap[symbol]  // load the stop channel for the symbol
    close(stopC) // just close it. 
}

最后，全面测试：


var (
    chanMap map[string]chan struct{}
)

func runWSDataTest() {
    chanMap = make(map[string]chan struct{})

    symbol := "BTCUSDT"
    interval := "15m"
    errHandler := func(err error) { fmt.Println(err) }
    wsKlineHandler := getKLineHandler()

    println("Start stream")
    _ = startDataStream(symbol, interval, wsKlineHandler, errHandler)

    time.Sleep(3 * time.Second)

    println("Stop stream")
    stopDataStream(symbol)

    time.Sleep(1 * time.Second)
}

就是这个。

Golang ending (Binance) web服务流使用go例程

Golang ending (Binance) web service stream using go routine

go

event-handling

goroutine

binance

binance-api-client