结束 (Binance) Web 服务流程的 Golang 并发处理

本篇文章向大家介绍《结束 (Binance) Web 服务流程的 Golang 并发处理》，主要包括，具有一定的参考价值，需要的朋友可以参考一下。

我正在将 binance api 集成到现有系统中，虽然大部分部分都是直截了当的，但数据流 api 触及了我对 go 例程的有限理解。我不认为 binance 的 golang sdk 有什么特别之处，但本质上我只需要两个函数，一个函数启动数据流并使用作为参数给出的事件处理程序处理事件，第二个函数结束数据流无需实际关闭客户端，因为它会关闭所有其他连接。在之前的项目中，有两种消息类型，但 binance 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 个符号启动 5 个数据流，现在我只想停止其中一个数据流。这就引出了一个问题：

1. 如何跟踪所有这些 stopc 渠道？

2. 我可以使用带有符号的集合，拉动 stopc 通道，然后发出信号来结束该数据流吗？

3. 如何从 stop 函数实际写入 stopc 通道？

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

谢谢

正确答案

（答案最初由@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)
}

就是这样。

终于介绍完啦！小伙伴们，这篇关于《结束 (Binance) Web 服务流程的 Golang 并发处理》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！