現在、pub-subパターンでzeromqを使用しています。公開する単一のワーカーと、同じパターンに多数の(8)サブスクライバー(すべてサブスクライブします)があります。
今、マルチプロセッシングを試して、サブスクライバーを生成しました。いくつかのメッセージが欠落しています。
私がマルチプロセッシングを使用している理由は、各メッセージが到着したときにそれを処理して処理するためです。パブリッシャーは 1 秒ごとに 10 ~ 100 のメッセージを発行します。
この場合、multiprocessing
またはgevent
?を使用することをお勧めします。