我正在使用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();
}
}
从主类调用这个类,看到只有一个线程在工作。
当我创建一个与我的消费者类相同的新类并将其作为新线程运行时,我接收消息的速度提高了两倍。