RabbitMQ 入門實戰：Windows 安裝、核心概念、Java 生產者/消費者 HelloWorld 完整指南

RabbitMQ 從安裝到第一個 Java 程式完整教程

1. Windows 環境安裝部署

1.1 前置依賴：Erlang

• 下載：Erlang OTP 26.0 (64-bit)
• 安裝：預設路徑、預設組件、環境變數自動配置
• 驗證：CMD 執行 erl 進入 Shell，輸入 q(). 退出

1.2 RabbitMQ Server

• 下載：RabbitMQ 3.12.10
• 安裝：預設路徑、啟用管理插件勾選
• 啟動：cd C:\Program Files\RabbitMQ Server\rabbitmq_server-3.12.10\sbin → rabbitmq-server.bat
• 啟用管理介面：rabbitmq-plugins.bat enable rabbitmq_management
• 訪問：https://localhost:15672 (guest/guest)

1.3 Java 客戶端依賴

<!-- Maven -->
<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>5.20.0</version>
</dependency>

2. 核心概念模型

關鍵點：Producer/Consumer/Broker 通常部署在不同機器，解耦合生產與消費速率，提供緩衝、削峰填谷能力。

3. HelloWorld：最簡單的點對點模型

場景：一個生產者發送，一個消費者接收，使用預設 Exchange (空字串，Direct 類型)，Routing Key = Queue Name。

3.1 生產者

public class Send {
    private static final String QUEUE_NAME = "hello";

    public static void main(String[] args) throws Exception {
        // 1. 連線工廠
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setPort(5672);
        factory.setUsername("guest");
        factory.setPassword("guest");
        // factory.setVirtualHost("/"); // 預設 vhost

        // 2. 建立連線與通道
        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {

            // 3. 宣告隊列（冪等：不存在則建立）
            // durable=false: 非持久化，僅測試用
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);

            // 4. 發送消息
            String message = "Hello World! " + LocalDateTime.now();
            // exchange="": 預設直連交換器
            // routingKey=QUEUE_NAME: 直接路由到同名隊列
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes(StandardCharsets.UTF_8));
            System.out.println(" [x] Sent: " + message);
        } // try-with-resources 自動關閉 channel/connection
    }
}

3.2 消費者

public class Recv {
    private static final String QUEUE_NAME = "hello";

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

        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {

            // 防止消費者先啟動導致隊列不存在
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            System.out.println(" [*] Waiting for messages. To exit press CTRL+C");

            // 推模式消費：DeliveryConsumer 內部使用阻塞隊列
            DeliverCallback deliverCallback = (consumerTag, delivery) -> {
                String message = new String(delivery.getBody(), StandardCharsets.UTF_8);
                System.out.println(" [x] Received: " + message);
            };

            // autoAck=true: 自動確認（生產環境建議手動 ACK）
            channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> {});
            
            // 主線程保持存活
            Thread.currentThread().join();
        }
    }
}

4. 關鍵細節補充

5. 進階學習路線

1. Exchange 類型：Direct/Topic/Fanout/Headers 路由規則實戰
2. 可靠性：發布確認、消費者手動 ACK、事務消息、死信隊列、重試機制
3. 高可用：鏡像隊列、Quorum Queues (3.8+)、叢集模式
4. 效能調優：預取數量、懶加載隊列、流控、連線池
5. Spring 整合：Spring AMQP、RabbitTemplate、@RabbitListener、容器管理

總結：RabbitMQ 以 Erlang 架構提供高併發、高可靠消息傳遞。入門關鍵在於理解 Exchange-Queue-Binding 路由模型、掌握連線/通道生命週期、區分自動/手動 ACK 機制。從 HelloWorld 起步，逐步掌握路由模式、可靠性保障、叢集架構，即可應對生產級異步解耦、削峰填谷、事件驅動架構需求。