目前我正在使用带有发布-订阅模式的 Zeromq,我有一个要发布的工作人员和许多(8)个订阅者(所有人都会订阅)相同的模式。
现在我尝试使用多处理来生成订阅者,它可以工作。我错过了一些消息。
我使用多重处理的原因是在每条消息到达时对其进行处理,每隔一个发布者就会发布 10 - 100 条消息。
在这种情况下,建议使用multiprocessing
or gevent
?
多处理显然会具有更高的内存开销,但会利用另一个核心(并且您不必担心缺乏抢占),所以..这取决于您的需求。
使用 gevent 的多个进程很可能会为您带来最高的吞吐量/最低的延迟。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)