RabbitMQ的Java入门示例代码

以下是基于原生 Java 客户端（amqp-client）的 RabbitMQ 入门示例代码。为了保持代码清晰，我们将分为‌连接工具类‌、‌简单模式（Hello World）‌和‌工作队列模式（Work Queues）‌三个部分。1. 前置准备在运行代码前，请确保已在 pom.xml 中引入 RabbitMQ 客户端依赖：dependencygroupIdcom.rabbitmq/groupIdartifactIdamqp-client/artifactIdversion5.16.0/version!--建议使用较新版本--/dependency2. 连接工具类 (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