RabbitMQ案例

1. 导入依赖

2. <!--AMQP依赖，包含RabbitMQ-->
3.         <dependency>
4.             <groupId>org.springframework.boot</groupId>
5.             <artifactId>spring-boot-starter-amqp</artifactId>
6.         </dependency>

复制代码

发送消息

---

注入RabbitTemplate

2. @Autowired
3. RabbitTemplate rabbitTemplate;

复制代码

---

2.   //队列
3.         String queueName = "test.query";
4.         //消息
5.         String message = "hello rabbitmq";
6.         //发送消息
7.         rabbitTemplate.convertAndSend(queueName,message);

复制代码

监听吸取消息

只必要在方法上添加注解即可

2. @RabbitListener(queues = "test.query")

复制代码

3. @RabbitListener(queues = "test.query")
4.     void contextLoads(Object msg) {
5.         System.out.println("msg = " + msg);
6.     }

复制代码

work模子

1. 多个消耗者绑定同一个队列，提升处置惩罚消息的速率
2. 同一个消息只会被同一个消耗者处置惩罚
3. 通过prefetch限定一次只能消耗一条消息，处置惩罚完才气处置惩罚下一条，实现能者多劳

2. spring:
3.   rabbitmq:
4.     host: localhost
5.     port: 5672
6.     virtual-host: /hmall
7.     username: hmall
8.     password: 123
9.     listener:
10.       simple:
11.         prefetch: 1 # 每个消费者一次消费一个消息

复制代码

嘿嘿嘿李博文到此一游