PyZMQ套接字在函数中创建时无法发送(PyZMQ socket's fail to send when created in function)

PyZMQ套接字在函数中创建时无法发送(PyZMQ socket's fail to send when created in function)

使用PyZMQ，当我尝试在函数内创建套接字并使用它发送消息时，永远不会收到消息。

context = zmq.Context() def sender(): sock = context.socket(zmq.PUB) sock.connect("tcp://localhost:44444") sock.send("status good") sender()

但是，如果我在全局范围内创建套接字，它的工作原理如下：

context = zmq.Context() sock = context.socket(zmq.PUB) sock.connect("tcp://localhost:44444") sock.send("status good")

更奇怪的是，检查基础文件描述符上的事件表明事件确实发生了。 但是，使用getsockopt(EVENTS)检查轮询值表示没有任何内容可以从套接字中读取。

我已经尝试在退出之前使函数休眠几秒钟，因此订阅者有足够的时间在套接字被销毁之前读取消息。 但这并没有改变任何事情。

With PyZMQ, when I try to create a socket inside a function and send a message with it, the message is never received.

context = zmq.Context() def sender(): sock = context.socket(zmq.PUB) sock.connect("tcp://localhost:44444") sock.send("status good") sender()

However, if I create the socket in the global scope, it works:

context = zmq.Context() sock = context.socket(zmq.PUB) sock.connect("tcp://localhost:44444") sock.send("status good")

What's even stranger, is that checking for events on the underlying file descriptor shows that an event did occur. However, checking the poll value with getsockopt(EVENTS) indicates that there's nothing to be read from the socket.

I've tried making the function sleep for a few seconds before exiting, so the subscriber has plenty of time to read the message before the socket is destroyed. But this doesn't change anything.

最满意答案

简单解决方案 我忘记了使用ZMQ，您必须在连接之后等待才能发送数据。 一秒睡眠可能就足够了，但在生产代码中使用的方法并不健全。

context = zmq.Context() def sender(): sock = context.socket(zmq.PUB) sock.connect("tcp://localhost:44444") time.sleep(1) sock.send("status good") sender()

在连接完全建立之前发送的任何消息都将被删除。

Simple solution. I forgot that with ZMQ you have to wait after connecting before sending data. A one second sleep is probably sufficient, though not robust method to use in production code.

context = zmq.Context() def sender(): sock = context.socket(zmq.PUB) sock.connect("tcp://localhost:44444") time.sleep(1) sock.send("status good") sender()

Any messages sent before the connection is fully established will just be dropped.