私は rabbitMQ を使用しており、コンシューマーの 2 つのインスタンスを非同期で実行して、メッセージの受信速度を上げたいと考えています。コンシューマ クラスに Runnable を実装します。次のことを行います。
public class ConsumerRun {
public ConsumerRun(){
Runnable consumerOne = new App();
Runnable consumerTwo = new App();
Thread threadOne = new Thread(consumerOne);
Thread threadTwo = new Thread(consumerTwo);
threadOne.start();
threadTwo.start();
}
}
メイン クラスからこのクラスを呼び出して、1 つのスレッドだけが機能していることを確認します。
コンシューマ クラスと同じ新しいクラスを作成し、それを新しいスレッドとして実行すると、メッセージの受信速度が 2 倍速くなります。