RabbitMq集成說明 · JeecgCloud 開發文檔

* #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 ![](https://img.kancloud.cn/55/0b/550b434e42ecd93b15c0bd6eea4942f2_1037x694.png) #### 看程序(生產者/消費者)處理消息 jeecg-cloud-mq-send | 實現生產者和消費者 ![](https://img.kancloud.cn/52/b5/52b51c46544de919a3fdccdc2734f68c_1480x375.png) jeecg-cloud-mq-reciver | 只是消費者 ![](https://img.kancloud.cn/19/ee/19ee6c8ae04d1e38b7d7653c01a45445_1503x364.png) 這倆類互斥（需要啟動另外一個，需要注釋掉另外一個） 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)** 消費者（定義消息處理通道） ![](https://img.kancloud.cn/97/60/976071e113676bacddbbe6d4a81ae3a1_1770x666.png) 常見問題：`如何解決重復消費和持久化的問題？` 回答：` 通過設置 group` ![](https://img.kancloud.cn/30/6a/306a55e70353c91848673eb694dc07e3_793x310.png)