我正在将 Binance API 集成到现有系统中,虽然大多数部分都是直截了当的,但数据流 API 触及了我对 go-routines 的有限理解。我不相信币安的 golang SDK 有什么特别之处,但基本上我只需要两个函数,一个是启动数据流并使用作为参数给出的事件处理程序处理事件,另一个是结束数据流没有实际关闭客户端,因为它会关闭所有其他连接。在之前的项目中,有两种消息类型,但币安 SDK 使用的实现返回两个 go 通道,一个用于错误,另一个(我从名称猜测)用于停止数据流。
我为启动数据流编写的代码如下所示:
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 通道可用于以某种方式发出类似于系统级别的 sigterm 的结束信号,然后流应该结束。
说,我有一个 stopDataStream 函数,它以一个符号作为参数
func stopDataStream(symbol){
}
假设我为五个符号启动 5 个数据流,现在我只想停止其中一个流。这就引出了以下问题:
如何跟踪所有这些 stopC 频道?
我可以使用一个以符号为键的集合,拉出 stopC 通道,然后发出一个信号来结束该数据流吗?
我如何从停止函数实际写入 stopC 通道?
同样,我不认为这特别难,只是我还无法从文档中弄清楚,所以任何帮助都将不胜感激。
谢谢