java监听rabbitmq消费
时间: 2023-09-02 21:11:35 浏览: 48
要在Java中监听RabbitMQ消费,可以使用RabbitMQ 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");
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");
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(" [x] Received '" + message + "'");
}
};
channel.basicConsume(QUEUE_NAME, true, consumer);
}
}
```
在上面的代码中,我们首先创建一个连接工厂,然后创建一个连接和一个通道。接下来,我们声明要消费的队列,创建一个消费者对象并实现`handleDelivery`方法以处理接收到的消息。最后,我们调用`basicConsume`方法开始消费。
这只是一个最基本的消费者示例,你可以根据你的需求来扩展它。