目前我正在使用ZeroMQ实现发布-订阅模式,我有一个单一的工作者来发布消息,并且有8个订阅者(全部都会订阅)订阅相同的模式。
现在我尝试使用多进程来生成订阅者,它可以工作。但我会丢失一些消息。
我使用多进程的原因是为了在收到每个消息时进行处理并处理它们,每秒发布者会发布10-100条消息。
在这种情况下,建议使用 multiprocessing
或 gevent
?
目前我正在使用ZeroMQ实现发布-订阅模式,我有一个单一的工作者来发布消息,并且有8个订阅者(全部都会订阅)订阅相同的模式。
现在我尝试使用多进程来生成订阅者,它可以工作。但我会丢失一些消息。
我使用多进程的原因是为了在收到每个消息时进行处理并处理它们,每秒发布者会发布10-100条消息。
在这种情况下,建议使用 multiprocessing
或 gevent
?