Go ZMQ4 - 关闭在 Recv 上阻塞的套接字?

标签 go zeromq

我正在使用这个库:https://github.com/pebbe/zmq4用于 ZeroMQ 的 Go 绑定(bind)。

我的问题是,如何安全地关闭正在等待消息的套接字?我正在考虑为每个套接字创建一个新的上下文,然后我可以终止上下文。

但是 pebbe/zmq4 库不允许我创建新的上下文(或者在我看来是这样)。

感谢您的帮助。

最佳答案

我将采纳一位教授的简单而有效的建议。

关闭时,我向套接字发送一个唯一的终止代码并等待直到套接字读取它并自行关闭。

关于Go ZMQ4 - 关闭在 Recv 上阻塞的套接字?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/21381441/

相关文章:

java - Go 的并发 Java 示例

zeromq - 使用ZMQ进行双向线程间通信

zeromq - 为什么 ZeroMQ PUB 在没有连接订阅者的情况下对消息进行排队? (好吧, "disconnected"SUB-s)

go - 处理 go 例程中的 panic

caching - GroupCache 是否支持像 memcached delete 这样的显式缓存逐出?为什么?

go - 如何检查具体类型由哪些嵌入类型组成?

go - 为什么 fasthttp 比 net/http 快?

python - 多核 Python : multiprocessing Vs. zeroMQ?

python - 如何使用 ZeroMQ 从父进程中的多个线程收集数据,同时保持解决方案尽可能简单且可扩展?

c++ - ZeroMQ模式查询