面试题：什么是 RabbitMQ 中的消费者和生产者？

在 RabbitMQ 中，生产者（Producer） 和 消费者（Consumer） 是消息传递模型中的两个基本角色。它们分别负责消息的发送和接收，共同构成了一个典型的发布/订阅系统。下面是对这两个概念的详细解释：

生产者（Producer）

定义：生产者是指创建消息并将其发送到 RabbitMQ 服务器的应用程序或服务。
职责：
- 创建消息：生产者生成需要传输的数据，并将这些数据封装成消息格式。
- 选择交换机：生产者决定将消息发送到哪个交换机（Exchange）。RabbitMQ 提供了多种类型的交换机，如直接交换机（Direct Exchange）、扇形交换机（Fanout Exchange）、主题交换机（Topic Exchange）等。
- 设置路由键（Routing Key）：根据所选的交换机类型，生产者可能还需要指定一个路由键。路由键决定了消息如何被路由到队列中。
- 发送消息：通过与 RabbitMQ 建立连接，生产者最终将消息发送出去。

示例代码（Java）

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

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

    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            String message = "Hello World!";
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
            System.out.println(" [x] Sent '" + message + "'");
        }
    }
}

消费者（Consumer）

定义：消费者是从 RabbitMQ 服务器接收消息的应用程序或服务。
职责：
- 监听队列：消费者通常会绑定到特定的队列上，等待消息的到来。
- 处理消息：一旦有消息到达，消费者就会接收到这条消息，并对其进行处理。
- 确认机制（ACK）：为了确保消息已经被正确处理，消费者需要向 RabbitMQ 发送确认（ACKnowledgment）。如果消息处理失败，可以选择不发送 ACK，让 RabbitMQ 将消息重新分发给其他消费者或者稍后再试。
- 自动重连与容错：良好的消费者实现应该能够处理网络中断等问题，必要时自动重新连接 RabbitMQ 并继续消费未处理的消息。

示例代码（Java）

import com.rabbitmq.client.*;

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

    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        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");

        DeliverCallback deliverCallback = (consumerTag, delivery) -> {
            String message = new String(delivery.getBody(), "UTF-8");
            System.out.println(" [x] Received '" + message + "'");
        };
        channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> {});
    }
}