使用 RabbitMQ 的 java 客户端,我创建了一个连接池机制,该机制具有一组已建立和可用的 rabbitmq 连接。一旦客户端租用一个连接,客户端就会创建一个通道。如果我必须发送执行任务并发送 100 条消息,对于这些消息中的每一条,客户端将租用一个连接并使用 API 创建一个通道,例如:
rqConnection = MyPoolManager.leaseConnection();
rqChannel = rqConnection.createChannel();
我是否可以在我的池中预先建立一个通道作为每个连接一个通道,或者始终可以在发送消息之前创建一个通道?我担心在频道上创建频道可能会消耗资源。我可以让通道与包含连接和通道的类共存,因此它总是在使用需要之前预先创建。如果通道创建没有资源消耗或泄漏影响,那么我可以继续我目前的方法。