0

私は 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 倍速くなります。

4

0 に答える 0