用人話說就是 : 致力於簡化MQ通訊的框架html
◆ Destination Binder (目標綁定器)spring
◆ Destination Bindings (目標綁定)
Binding是鏈接應用程序跟消息中間件的橋樑,用於消息的消費和生產,由binder建立
◆ Message(消息)
可見該編程模型異常強大,短短几行代碼,就實現了消息的對接和處理
input/output就是微服務接收和發出消息編程
下面開始對內容中心編碼segmentfault
編碼用戶中心mybatis
注意,因爲mybatis會掃描啓動類註解上scan註解所限制路徑下的全部接口,因此一旦有接口未被xml mapper,即拋異常,因此編碼時必須將掃描註解範圍限定死在mapper包下!
用戶中心編碼app
當咱們定義好Source/Sink接口後,在啓動類使用EnableBinding指定了接口後,就會使用IOC建立對應名字的代理類,因此配置文件中也必須同名框架
Spring Cloud Stream實現消息過濾消費分佈式
記得多看端點哦!
output/input其實就是一個channel微服務
Stream自己並未考慮分佈式事務問題,都是RocketMQ的能力
對內容中心一頓操做:刪除沒必要要代碼
而咱們以前使用rocketmqtemplate傳遞參數時能夠帶個arg
那如今咱們該怎麼傳arg呢???
記得前面埋下的伏筆,header也是頗有用處的!
咱們能夠將要傳的參數放入header中,以下:
rocketmqtemplate功成身退,咱們可使用stream編程模型徹底替代了
由於從header中獲取的都是字符串哦!切記!
對用戶中心刪除沒必要要代碼,與內容中心相似,再也不詳述
MyTestStreamConsumer
改成AddBonusStreamConsumer
本文由博客一文多發平臺 OpenWrite 發佈!