RabbitMQ消费者

介绍

RabbitMQ 中的消费者是一个消费者端的程序，用于从 RabbitMQ 中接收消息并进行处理。消费者需要连接到 RabbitMQ，订阅指定的队列，然后阻塞地等待消息到达。一旦有消息到达，消费者就会从队列中获取该消息并进行处理。

消费者需要使用 RabbitMQ 的 Java 客户端库来实现。通常情况下，消费者需要创建一个 Connection（连接）对象、一个 Channel（通道）对象和一个 Consumer（消费者）对象。

示例

以下是一个简单的 Java 示例程序，用于从 RabbitMQ 中接收消息：

import com.rabbitmq.client.*;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class RabbitMQConsumerExample {

    private static final String QUEUE_NAME = "my_queue";

    public static void main(String[] args) throws IOException, TimeoutException {
        // 创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setUsername("guest");
        factory.setPassword("guest");

        // 创建连接
        Connection connection = factory.newConnection();

        // 创建通道
        Channel channel = connection.createChannel();

        // 声明要消费的队列
        channel.queueDeclare(QUEUE_NAME, true, false, false, null);

        // 创建消费者对象
        Consumer consumer = new DefaultConsumer(channel) {
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                String message = new String(body, "UTF-8");
                System.out.println("Received message: " + message);
            }
        };

        // 开始消费消息
        channel.basicConsume(QUEUE_NAME, true, consumer);
    }
}

这个程序将连接到本地 RabbitMQ 服务器，声明一个名为 "my_queue" 的队列，然后创建一个消费者对象。此消费者对象将处理从队列中接收到的任何消息。当有消息到达时，消费者将打印出消息内容。最后，程序调用 basicConsume 方法开始消费消息。