目前我正在使用 zeromq 和 pub-sub 模式,我有单个工作人员要发布,并且许多(8)个订阅者(都将订阅)到相同的模式。
现在我尝试了多处理来产生它工作的订阅者。我错过了几条消息。
为什么我使用多处理是在每条消息到达并处理它们时处理它们,每第二个发布者发布 10 - 100 条消息。
在这种情况下,建议使用multiprocessing
or gevent
?
目前我正在使用 zeromq 和 pub-sub 模式,我有单个工作人员要发布,并且许多(8)个订阅者(都将订阅)到相同的模式。
现在我尝试了多处理来产生它工作的订阅者。我错过了几条消息。
为什么我使用多处理是在每条消息到达并处理它们时处理它们,每第二个发布者发布 10 - 100 条消息。
在这种情况下,建议使用multiprocessing
or gevent
?