分類彙整: RabbitMQ

筆記:使用 Spring Cloud Stream 和 RabbitMQ 發送與接收訊息 (2) – fanout 模式

Spring Cloud Stream 預設是使用 RabbitMQ 的 Exchange: topic 模式,但是如果我們想把資料傳送 (廣播) 到每個訂閱該 Exchange 的 Consumer 上,也就是俗稱的 Publish/Subscribe 模式,那我們需要使用 RabbitMQ 的 Exchange: fanout 模式才能做到,本文將介紹如何實作一個簡單的 fanout 模式範例程式。

Exchange: fanout 模式
閱讀全文

筆記:使用 Spring Cloud Stream 和 RabbitMQ 發送與接收訊息

Spring Cloud Stream 提供 Spring 應用程式建立以事件驅動為主的微服務系統,並可跟 RabbitMQ、Kafka 等 Message Queue 系統進行整合。本文將介紹如何使用 Spring Cloud Stream 加上 RabbitMQ 撰寫一個小型的事件驅動範例應用程式。

Spring Cloud Stream 和 RabbitMQ 主要是使用 Producer-Processor-Consumer 架構來處理訊息,Producer 傳送資料,Processor 接收並處理資料,然後 Consumer 接收處理過的資料並輸出結果:

閱讀全文