我正在使用这个库:https://github.com/pebbe/zmq4用于 ZeroMQ 的 Go 绑定(bind)。
我的问题是,如何安全地关闭正在等待消息的套接字?我正在考虑为每个套接字创建一个新的上下文,然后我可以终止上下文。
但是 pebbe/zmq4 库不允许我创建新的上下文(或者在我看来是这样)。
感谢您的帮助。
最佳答案
我将采纳一位教授的简单而有效的建议。
关闭时,我向套接字发送一个唯一的终止代码并等待直到套接字读取它并自行关闭。
关于Go ZMQ4 - 关闭在 Recv 上阻塞的套接字?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/21381441/