连接 Connection 与通道 Channel

Connection是客户端与RabbitMQ的TCP连接，Channel是建立在Connection之上的轻量级逻辑通道，两者配合实现高效的消息通信。

基本概念

Connection（连接）：

• 建立在客户端与RabbitMQ之间的TCP连接
• 创建/销毁连接的开销较大
• 建议复用同一连接，避免频繁建立断开

Channel（通道）：

• 建立在连接之上的虚拟连接
• 共享同一TCP连接，无需额外网络开销
• 可创建多个Channel实现并发操作
• 所有RabbitMQ操作都通过Channel执行

Client                     RabbitMQ Server
  │                           │
  ├─── TCP Connection ────────│
  │   ├── Channel 1 ──────────│──> 队列操作
  │   ├── Channel 2 ──────────│──> 发送消息
  │   └── Channel 3 ──────────│──> 消费消息
  │                           │

Java Client 示例

Maven依赖：

<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>5.18.0</version>
</dependency>

创建连接与通道：

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

public class ConnectionChannelExample {
    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setPort(5672);
        factory.setUsername("guest");
        factory.setPassword("guest");

        // 创建TCP连接
        Connection connection = factory.newConnection();
        System.out.println("连接已建立");

        // 创建逻辑通道
        Channel channel = connection.createChannel();
        System.out.println("通道已创建");

        // 通过通道执行操作
        channel.queueDeclare("demo_queue", true, false, false, null);
        System.out.println("队列已声明");

        // 关闭通道和连接
        channel.close();
        connection.close();
        System.out.println("连接已关闭");
    }
}

连接复用模式：

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

public class ConnectionReuseExample {
    private static Connection connection;

    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");

        // 建立一次连接
        connection = factory.newConnection();

        // 复用连接创建多个通道
        Channel channel1 = connection.createChannel();
        Channel channel2 = connection.createChannel();

        // 不同通道执行不同操作
        channel1.queueDeclare("queue_a", true, false, false, null);
        channel2.queueDeclare("queue_b", true, false, false, null);

        // 使用完毕后关闭
        channel1.close();
        channel2.close();
        connection.close();
    }
}

为什么需要Channel

每个Channel是独立的执行上下文，一个Channel的异常不会影响其他Channel。

注意事项

1. Connection是线程安全的，可在多线程间共享；Channel不是线程安全的，每个线程应使用独立Channel
2. 关闭连接会自动关闭其下所有Channel，应先关闭Channel再关闭Connection
3. Channel创建开销极小（微秒级），但也不建议无限制创建，建议复用或按需创建后关闭
4. ConnectionFactory是线程安全的，应用中建议单例模式复用
5. 连接超时默认10秒，可通过 factory.setConnectionTimeout() 调整

要点总结

• Connection是TCP物理连接，Channel是建立在连接之上的逻辑通道
• 所有RabbitMQ操作都通过Channel执行，Connection仅负责网络传输
• 建议复用Connection，按需创建和关闭Channel
• Connection线程安全可共享，Channel非线程安全需独立使用
• ConnectionFactory应单例复用，避免频繁创建连接

文章存放路径：D:\git2\jwdev\articles\RABBITMQ\入门\核心概念入门\连接 Connection 与通道 Channel.md