<ruby id="bdb3f"></ruby>

    <p id="bdb3f"><cite id="bdb3f"></cite></p>

      <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
        <p id="bdb3f"><cite id="bdb3f"></cite></p>

          <pre id="bdb3f"></pre>
          <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

          <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
          <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

          <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                <ruby id="bdb3f"></ruby>

                * #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)
                  <ruby id="bdb3f"></ruby>

                  <p id="bdb3f"><cite id="bdb3f"></cite></p>

                    <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
                      <p id="bdb3f"><cite id="bdb3f"></cite></p>

                        <pre id="bdb3f"></pre>
                        <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

                        <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
                        <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

                        <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                              <ruby id="bdb3f"></ruby>

                              哎呀哎呀视频在线观看