深入浅出 RabbitMQ：简单队列实战指南

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

public class Send {
    // 队列名称（生产者和消费者需使用相同名称）
    private final static String QUEUE_NAME = "hello";

    public static void main(String[] argv) throws Exception {
        // 1. 创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        // 配置连接参数
        factory.setHost("192.168.229.128");    // 服务器地址
        factory.setPort(5672);             // 端口（默认5672）
        factory.setUsername("admin");      // 用户名
        factory.setPassword("password");   // 密码
        factory.setVirtualHost("/dev");    // 虚拟主机（需提前创建）

        // 2. 创建连接和信道（使用try-with-resources自动关闭资源）
        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {

            // 3. 声明队列（不存在则创建）
            /**
             * 参数说明：
             * 1. queue：队列名称
             * 2. durable：是否持久化（重启RabbitMQ后队列依然存在）
             * 3. exclusive：是否独占（仅当前连接可访问，连接关闭后自动删除）
             * 4. autoDelete：是否自动删除（当最后一个消费者断开后自动删除）
             * 5. arguments：额外参数（如队列长度限制等）
             */
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);

            // 4. 发送消息
            String message = "Hello World!";
            /**
             * 参数说明：
             * 1. exchange：交换机名称（使用默认交换机""）
             * 2. routingKey：路由键（默认交换机下需与队列名称一致）
             * 3. props：消息属性（如优先级、过期时间等）
             * 4. body：消息体（字节数组）
             */
            channel.basicPublish("", QUEUE_NAME, null, 
                               message.getBytes(StandardCharsets.UTF_8));
            System.out.println(" [x] 已发送消息: '" + message + "'");
        }
    }
}

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

    public static void main(String[] argv) throws Exception {
        // 1. 创建连接工厂（配置与生产者一致）
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("192.168.229.128");
        factory.setUsername("admin");
        factory.setPassword("password");
        factory.setVirtualHost("/dev");  // 注意：需与生产者使用相同虚拟主机
        factory.setPort(5672);

        // 2. 创建连接和信道（消费者通常保持长连接，不使用自动关闭）
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();

        // 3. 声明队列（与生产者保持一致，确保队列存在）
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        System.out.println(" [*] 等待接收消息中...（按CTRL+C退出）");

        // 4. 定义消息处理回调
        Consumer consumer = new DefaultConsumer(channel) {
            @Override
            public void handleDelivery(String consumerTag, 
                                      Envelope envelope, 
                                      AMQP.BasicProperties properties, 
                                      byte[] body) throws IOException {
                // 消费标识（可用于标识当前会话）
                System.out.println("消费标识: " + consumerTag);
                // 消息元数据（包含交换机、路由键、消息ID等）
                System.out.println("元数据: " + envelope);
                // 消息属性（如发送时间、优先级等）
                System.out.println("属性: " + properties);
                // 消息内容
                System.out.println("接收内容: " + new String(body, "UTF-8"));
            }
        };

        // 5. 开始消费消息
        /**
         * 参数说明：
         * 1. queue：队列名称
         * 2. autoAck：是否自动确认消息（消费成功后自动通知MQ删除消息）
         * 3. consumer：消息处理回调
         */
        channel.basicConsume(QUEUE_NAME, true, consumer);
    }
}