如何使用PyZMQ在ZeroMQ PUB套接字上设置INVERT_MATCHING？

作者: 啊这回彻底死了
发布时间: 2024-12-15 12:37:29 (7天前)
转自：

3 条回复

0#
回复此人
WL | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <H2> 我们走了：使用 <code> .setsockopt() </code> </H2> <pre> <code> print( "ZeroMQ version ought be 4.2+ ... Hope it is... " ) print( zmq.version() ) print( pubsock.setsockopt.__doc__ ) pass; pubsock.setsockopt( zmq.INVERT_MATCHING, 1 ) </code> </pre> <HR /> <H2> 另外最好重新阅读文档： </H2> <BLOCKQUOTE> <P> 颠倒过滤行为的<strong> <code> PUB-SUB </code> </强> 套接字，设置为1时。 </p> <P> 上的<strong> <code> PUB </code> </强> 和的<strong> <code> XPUB </code> </强> 套接字，这会导致消息被发送到所有连接的套接字，除了那些订阅了与消息匹配的前缀的套接字。上的<strong> <code> SUB </code> </强> 套接字，这只会导致用户只接收与任何套接字订阅不匹配的传入消息。 <BR/> <BR/> 的<strong> 每当 <code> ZMQ_INVERT_MATCHING </code> 在a上设置为1 <code> PUB </code> 套接字，全部 <code> SUB </code> 连接到它的套接字也必须将选项设置为1.如果不这样做，将具有 <code> SUB </code> 套接字拒绝一切 <code> PUB </code> socket发送它们 </强> 。 <BR/> <BR/> 的<strong> <code> XSUB </code> </强> 套接字不需要这样做，因为它们不会过滤传入的消息。 </p> </BLOCKQUOTE> </DIV>

编辑
1#
回复此人
部落用户 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> ZeroMQ 的<strong> <code> PUB </code> </强> -sockets只支持反转匹配 <a href="http://api.zeromq.org/4-2:zmq-setsockopt#toc22" rel="nofollow noreferrer"> 版本4.2 </A> 。您需要更新ZeroMQ。 </p> <P> 请注意，PyZMQ捆绑了预编译的ZeroMQ 4.1.6。因此，根据您安装PyZMQ的方式，您可能实际上并未使用系统的ZeroMQ。 </p> <P> 尝试以下操作重新安装PyZMQ并强制重新编译ZeroMQ后端。 </p> <pre> <code> $ pip install pyzmq --ignore-installed --no-use-wheel </code> </pre> </DIV>

编辑

登录后才能参与评论