rabiit mq 消费的java怎么写

下面是一个简单的 RabbitMQ 消费者示例，使用 Java 编写：

import com.rabbitmq.client.*;

public class RabbitMQConsumer {

    private final static String QUEUE_NAME = "hello";

    public static void main(String[] argv) throws Exception {
        // 创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost"); // 设置 RabbitMQ 服务器地址

        // 创建连接
        Connection connection = factory.newConnection();
        // 创建通道
        Channel channel = connection.createChannel();

        // 声明要消费的队列
        channel.queueDeclare(QUEUE_NAME, false, 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 服务器，并从名为 "hello" 的队列中读取消息。处理收到的消息的方法是通过覆盖 Consumer 接口中的 handleDelivery() 方法来实现的。最后，调用 basicConsume() 方法开始消费消息。