RabbitMQ的Java入门示例代码

以下是基于原生 Java 客户端（amqp-client）的 RabbitMQ 入门示例代码。为了保持代码清晰，我们将分为‌连接工具类‌、‌简单模式（Hello World）‌和‌工作队列模式（Work Queues）‌三个部分。

1. 前置准备

在运行代码前，请确保已在 pom.xml 中引入 RabbitMQ 客户端依赖：

<dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>5.16.0</version><!--建议使用较新版本--></dependency>

2. 连接工具类 (RabbitMQUtils)

为了避免重复创建连接，封装一个通用的连接获取工具。

importcom.rabbitmq.client.Connection;importcom.rabbitmq.client.ConnectionFactory;publicclassRabbitMQUtils{privatestaticfinalStringHOST="127.0.0.1";privatestaticfinalintPORT=5672;privatestaticfinalStringUSERNAME="guest";privatestaticfinalStringPASSWORD="guest";publicstaticConnectiongetConnection()throwsException{// 1. 创建连接工厂ConnectionFactoryfactory=newConnectionFactory();factory.setHost(HOST);factory.setPort(PORT);factory.setUsername(USERNAME);factory.setPassword(PASSWORD);// 2. 创建连接returnfactory.newConnection();}}

3. 模式一：简单模式 (Simple Mode)

最基础的模型：一个生产者发送消息到一个队列，一个消费者从该队列接收消息。

生产者 (SimpleProducer.java)

importcom.rabbitmq