* #rabbitmq服务访问(guest/guest)
[http://127.0.0.1:15672](http://127.0.0.1:15672)
guest/guest
## 测试步骤
#### 项目介绍
| 项目 | 用途 | 启动类 |
| --- | --- | --- |
| jeecg-cloud-mq-send | 消息发送和处理(既是生产者和消费者) | org.jeecg.JeecgStreamRevierApplication |
| jeecg-cloud-mq-reciver | 消息接受处理(只是消费者) | org.jeecg.JeecgStreamRevierApplication |
#### 启动项目
* jeecg-cloud-mq-send | 8003 端口
* jeecg-cloud-mq-reciver| 8004 端口
#### 发送MQ消息
[http://localhost:8003/send?message=455](http://localhost:8003/send?message=455)
#### 查看MQ接受消息
http://127.0.0.1:15672/#/queues/%2F/jeecgCloudExchange.jeecgCloudConsumers
#### 看程序(生产者/消费者)处理消息
jeecg-cloud-mq-send | 实现生产者和消费者
jeecg-cloud-mq-reciver | 只是消费者
这俩类互斥（需要启动另外一个，需要注释掉另外一个）
org.jeecg.stream.controller.MQSendController | 仅是生产者
org/jeecg/stream/controller/MQSendhanderController.java | 既是生成者又是消费者
*****
* #官方文档
[spring-cloud-stream-rabbitmq](https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/2.1.3.RELEASE/single/spring-cloud-stream.html)
* #常用注解
**@EnableBinding(Processor.class)** 生产者和消费者
**@EnableBinding(Source.class)** 生产者（定义消息源头）
**@EnableBinding(Sink.class)** 消费者（定义消息处理通道）
常见问题：`如何解决重复消费和持久化的问题？`
回答：` 通过设置 group`
