我一直在尝试共享线程之间的连接,并且仅在创建线程时才打开通道,但经过更多研究后,我想我也想尝试connection pooling
. 我怎样才能在rabbitmq上做到这一点?或者这是我可以普遍应用的一般想法?我的目标是生成 X 线程,然后让它们不必打开新通道(这需要在客户端和服务器之间建立循环)。
由于线程是它们自己的类,我不确定是否需要将池放在产生线程的类本身或它们去哪里?我也有多种类型的线程我想在它们之间共享这些连接(不是只有一个)。那可能吗?
只是给你一个大致的想法,这里是连接/通道是如何在 rabbitmq 中建立的:
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel(); //I want to share several of these between threads