0

我正在使用rabbitMQ,并希望异步运行两个消费者实例以提高接收消息的速度。我在消费者类中实现了 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();
    }
}

从主类调用这个类,看到只有一个线程在工作。

当我创建一个与我的消费者类相同的新类并将其作为新线程运行时,我接收消息的速度提高了两倍。

4

0 回答 0