RabbitMq中使用自定义的线程池

✅ 方法定义

ConnectionFactory factory = new ConnectionFactory();
ExecutorService executor = Executors.newFixedThreadPool(4); // 你管理的线程池
Connection connection = factory.newConnection(executor);

或新版（推荐）形式：

factory.newConnection(ExecutorService executor)

✅ 用途说明

默认情况下，如果你不传 ExecutorService，RabbitMQ 客户端内部会自己创建一个线程池用于：

• 网络读写（I/O）
• 连接维护（如心跳检测）
• 回调处理（如 Consumer 回调、Confirm 等）

而使用 factory.newConnection(managedExecutor)：

你可以将线程池的生命周期管理权交给你自己的应用程序，更方便统一管理线程资源，避免资源泄漏。

🔍 典型使用场景

ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
factory.setUsername("guest");
factory.setPassword("guest");

// 你自己管理的线程池（也可用 Spring 管理）
ExecutorService executor = Executors.newCachedThreadPool();

// 用自定义线程池建立连接
Connection connection = factory.newConnection(executor);
Channel channel = connection.createChannel();

🚨 注意事项

🧠 推荐封装（现代 Java 风格）

public class RabbitMQConnectionManager {
    private final ExecutorService executor;
    private final Connection connection;

    public RabbitMQConnectionManager() throws Exception {
        this.executor = Executors.newFixedThreadPool(4);
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        this.connection = factory.newConnection(executor);
    }

    public Channel createChannel() throws IOException {
        return connection.createChannel();
    }

    public void close() throws Exception {
        connection.close();
        executor.shutdown();
    }
}

✅ 总结