* #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`
