单体架构使用rabbit mq

### 单体架构中集成和使用 RabbitMQ #### 1. 添加依赖项 为了在Java项目中使用RabbitMQ，需要引入相应的库。如果采用Maven构建工具，则可以在`pom.xml`文件里加入如下依赖： ```xml <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> ``` 此操作使得能够轻松地与RabbitMQ交互并利用其功能。 #### 2. 配置连接参数 接着，在项目的资源目录下找到或者创建名为`application.properties`（也可以是YAML格式）的配置文件，并设置必要的服务器地址及其他选项： ```properties spring.rabbitmq.host=localhost spring.rabbitmq.port=5672 spring.rabbitmq.username=guest spring.rabbitmq.password=guest ``` 这些属性指定了如何定位以及认证到本地运行着默认用户名密码实例的服务[^4]。 #### 3. 定义消息生产者组件 对于发送方而言，通常会有一个专门负责构造并推送数据至指定交换机(exchange)的方法。下面给出一个简单的例子展示怎样编码实现这一点： ```java import org.springframework.amqp.core.AmqpTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @Component public class Producer { @Autowired private AmqpTemplate rabbitTemplate; public void sendMessage(String message){ System.out.println("[x] Sending message..."); this.rabbitTemplate.convertAndSend("test_exchange", "routing.key", message); System.out.println("[x] Message sent."); } } ``` 这里调用了`convertAndSend()`函数来完成实际的数据传输过程[^1]。 #### 4. 创建消费者类处理接收到的信息 接收端同样要定义好监听特定队列(queue)，一旦有新条目到来就触发回调逻辑执行业务流程。以下是关于订阅模式的一个基本示范： ```java import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; @Component public class Consumer { @RabbitListener(queues = {"${queue.name}"}) public void receiveMessage(String msg){ System.out.println("[*] Received message : '" +msg+"'"); } } ``` 上述代码片段展示了当匹配上的队列中有新的消息到达时将会被自动拉取出来打印日志[^2]。 通过以上几个方面的工作就可以实现在单一应用程序内部集成了RabbitMQ作为异步通讯机制的一部分了。值得注意的是虽然这里是按照单体结构描述整个方案的设计思路，但是同样的原理也适用于更复杂的分布式环境中部署多个独立节点的情况。