java怎么获取到rebbitmq发送过来的数据
时间: 2024-02-21 11:00:14 浏览: 23
要从 RabbitMQ 接收数据,你需要创建一个消费者并订阅队列。以下是一些 Java 代码示例,可以帮助你开始使用 RabbitMQ:
首先,你需要创建一个连接和通道:
```java
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
```
然后,你需要声明要接收消息的队列:
```java
String queueName = "hello";
channel.queueDeclare(queueName, false, false, false, null);
```
接下来,你需要创建一个消费者并实现 `DefaultConsumer` 接口,以便在接收到消息时执行自定义的操作:
```java
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);
}
};
```
最后,你需要在消费者上订阅队列,并开始监听消息:
```java
channel.basicConsume(queueName, true, consumer);
```
这样就可以从 RabbitMQ 接收消息了。当有消息到达队列时,`handleDelivery` 方法将被调用,并且你可以在其中执行自定义的操作。