構建基于SpringCloudStream的消息驅動微服務用于處理第三方開發(fā)者接受微信大量推送消息的解決方法

構建基于SpringCloudStream的消息驅動微服務用于處理第三方開發(fā)者接受微信大量推送消息的解決方法，相信很多沒有經驗的人對此束手無策，為此本文總結了問題出現(xiàn)的原因和解決方法，通過這篇文章希望你能解決這個問題。

事情的起因源于在使用微信公眾號服務的時候，作為一個第三方的服務商，騰訊會將各種業(yè)務消息推送到第三方開發(fā)者的服務器上，而之前的方案是消息直接進到服務上，當使用到一些業(yè)務，比如發(fā)券等操作時，騰訊服務器會向開發(fā)者發(fā)送大量的消息，由于消息服務的處理能力有限，尤其是高峰的時候，消息請求會直接壓到服務上，導致服務線程繁忙，這時候會報大量服務超時，觸發(fā)微信的服務報警，服務不可用，或者服務超時，這時公眾號內的消息服務將無法繼續(xù)為用戶提供服務。鑒于此問題，我們重新梳理并構建了基于Spring Cloud Stream的消息驅動的微服務

我們采用 Spring Cloud Finchley.SR2，Spring Boot 2.0.6.RELEASE 版本來開發(fā)，系統(tǒng)的初步設計思路，是利用

消息隊列rabbitmq來解耦服務，來減緩消息直接到服務上的壓力，我們沒有直接對接mq來使用，而是采用了Spring Cloud Stream, 簡單的來說，Spring Cloud Stream是構建消息驅動的微服務應用程序的框架，將消息整合的處理操作進行了進一步的抽象操作， 實現(xiàn)了更加簡化的消息處理， 可以使用不同的代理中間件，它抽象了事件驅動的一些概念,對于消息中間件的進一步封裝,可以做到代碼層面對中間件的無感知，甚至于動態(tài)的切換中間件，切換topic。使得微服務開發(fā)的高度解耦，服務可以關注更多自己的業(yè)務流程。

Spring Cloud Stream的一些基本概念可以自行搜索，這里不做過多描述，下面只是講述一下具體方案和配置方法及遇到的問題。

基本結構是一個非常簡單的消息訂閱發(fā)布模式

至此整個消息處理的基本結構就描述完成了，當然實際的開發(fā)過程中，還要考慮消息的異步處理，多線程去處理等，這里就不詳盡描述了，需要根據(jù)自己的業(yè)務需要來實現(xiàn)相應的開發(fā)，

有幾點注意的情況：

@StreamListener(ReceiveInputChannel.MSG_RECEIVER) 這個方法只能放到Application 服務啟動的類中，放到別的地方會報錯：Disp org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers，可能和類的加載順序有關系。這樣在啟動類中接受消息，然后可以再通過業(yè)務拆分，將消息轉到其他的類中實現(xiàn)各自業(yè)務邏輯開發(fā)。

        <!-- 添加Spring Cloud Stream與RabbitMQ消息中間件的依賴。 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
        </dependency>
        <!-- 添加Spring Cloud Stream與Kafaka消息中間件的依賴。 -->
        <!-- <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-stream-kafka</artifactId> 
            </dependency> -->

根據(jù)不同的消息中間件，選擇不同的依賴。

當接收消息過多的時候，可以增加消息生產者實例來加大消息的接受能力，當消費者處理大量阻塞消息時，處理能力下降，可以通過增加負載的消費者服務實例數(shù)量來加大消費能力，這個需要通過實際情況找到平衡點，消息隊列作為緩存，降低了由于消息直接壓到服務器上而導致的服務崩潰問題的風險。

看完上述內容，你們掌握構建基于SpringCloudStream的消息驅動微服務用于處理第三方開發(fā)者接受微信大量推送消息的解決方法的方法了嗎？如果還想學到更多技能或想了解更多相關內容，歡迎關注億速云行業(yè)資訊頻道，感謝各位的閱讀！