Statement
文章目录
- 一、队列总览
- 1.1. 图示
- 1.2. 说明
- 二、简单队列
- 2.1. 图示
- 2.2. 导入RabbitMQ的客户端依赖
- 2.3. 获取MQ的连接
- 2.4. 生产者发送消息到队列
- 2.5. 管理工具中查看消息
- 2.6. 消费者从队列中获取消息
一、队列总览
1.1. 图示
1.2. 说明
| 说明 | 模式 |
|---|---|
| ① | 简单队列 |
| ② | work模式 多劳多得 |
| ③ | 消息的确认模式 |
| ④ | 订阅模式 |
| ⑤ | 路由模式 |
| ⑥ | 通配符模式 |
二、简单队列
2.1. 图示
P：消息的生产者
C：消息的消费者
红色：队列
生产者将消息发送到队列，消费者从队列中获取消息。
2.2. 导入RabbitMQ的客户端依赖
<dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>3.4.1</version></dependency>
2.3. 获取MQ的连接
2.4. 生产者发送消息到队列
运行生产者main方法，发送消息
2.5. 管理工具中查看消息
点击上面的队列名称，查询具体的队列中的信息：
2.6. 消费者从队列中获取消息
运行消费者main方法
从上图可以看出，可以成功的接收到消息！！！
但是，为什么服务没有停止呢？
因为有监听程序
// 监听队列
channel.basicConsume(QUEUE_NAME, true, consumer);
