Rabbitmq 简明教程
RabbitMQ - Consumer Application
现在,让我们创建一个将从 RabbitMQ 队列接收消息的消费程序应用程序。
Create Project
使用 Eclipse 选择 File → New * → *Maven Project 。勾选 创建简单项目(跳过原型选择),然后单击下一步。
输入详细信息,如下所示:
-
groupId − com.tutorialspoint
-
artifactId − consumer
-
version − 0.0.1-SNAPSHOT
-
name − RabbitMQ Consumer
单击“完成”按钮,将创建新项目。
pom.xml
现在,更新 pom.xml 的内容,以包含 ActiveMQ 的依赖关系。
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.tutorialspoint.activemq</groupId>
<artifactId>consumer</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>RabbitMQ Consumer</name>
<properties>
<java.version>11</java.version>
</properties>
<dependencies>
<dependency>
<groupId>com.rabbitmq</groupId>
<artifactId>amqp-client</artifactId>
<version>5.14.2</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.26</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-simple</artifactId>
<version>1.7.26</version>
</dependency>
</dependencies>
</project>
现在创建一个将从 RabbitMQ 队列接收消息的消费者类。
package com.tutorialspoint.rabbitmq;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.TimeoutException;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DeliverCallback;
public class Consumer {
private static String QUEUE = "MyFirstQueue";
public static void main(String[] args) throws IOException, TimeoutException {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
channel.queueDeclare(QUEUE, 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(), StandardCharsets.UTF_8);
System.out.println("Received '" + message + "'");
};
channel.basicConsume(QUEUE, true, deliverCallback, consumerTag -> { });
}
}
消费者类创建一个连接,创建一个通道,如果不存在则创建一个队列,然后从队列接收消息(如果有)并保持轮询队列以获取消息。一旦消息被传递,它将由 basicConsume() 方法使用 deliverCallback 处理。
我们在 RabbitMQ - Test Application 章节中运行此应用程序。