SCSt傳感器
圖6. Spring Cloud Stream Publish-Subscribe
傳感器向HTTP端點報告的數據將發送到名為raw-sensor-data的公共目標。從目的地，它由微服務應用程序獨立處理，該應用程序計算時間窗口平均值，以及另一個將原始數據導入HDFS的微服務應用程序。

為了處理數據，兩個應用程序在運行時將主題聲明為它們的輸入。

發布訂閱通信模型降低了生產者和消費者的復雜性，並允許將新應用程序添加到拓撲中，而不會中斷現有流。例如，在平均計算應用程序的下遊，您可以添加一個計算顯示和監視的最高溫度值的應用程序。

然後，您可以添加另一個解釋相同的故障檢測平均流程的應用程序。通過共享主題而不是點對點隊列進行所有通信可以減少微服務之間的耦合。

雖然發布訂閱消息的概念不是新的，但是Spring Cloud Stream需要額外的步驟才能使其成為其應用模型的一個有意義的選擇。通過使用本地中間件支持，Spring Cloud Stream還簡化了在不同平臺上使用發布訂閱模型。

從現在開始，我這邊會將近期研發的spring cloud微服務雲架構的搭建過程和精髓記錄下來，幫助更多有興趣研發spring cloud框架的朋友，希望可以幫助更多的好學者。大家來一起探討spring cloud架構的搭建過程及如何運用於企業項目。

Spring Cloud Stream教程（三）持續發布 - 訂閱支持