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

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

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

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

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

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

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

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

有幾點注意的情況：

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

        <!-- 添加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> -->

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

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

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