Publish/subscribe:發佈訂閱模式
發佈訂閱模式:
一、每一個消費者監聽本身的隊列。
二、生產者將消息發給broker,由交換機將消息轉發到綁定此交換機的每一個隊列,每一個綁定交換機的隊列都將接收
到消息
中間多了個交換機
一個消息生產者先發送給交換機,由交換機把消息發送給各個隊列。每一個隊列都有不一樣的消費者在監聽
實現了發佈一個消息 多個消費者均可以接收到這個消息了
若是把下面的隊列幹掉。那麼紅色圈出的部分和工做模式是相同的。工做對壘雖然沒有交換機也會有一個默認的交換機。
因此說發佈於訂閱能夠實現工做隊列的功能。可是它比工做隊列更強大,它就能夠實現多個消費者同時來接受同一條消息
測試
案例:
用戶通知,當用戶充值成功或轉帳完成系統通知用戶,通知方式有短信、郵件多種方法 。
兩個消息隊列分別表明了email和sms就是短信
定義一個新的生產者
把原來的代碼邏輯複製到新的類裏面
有一個交換機和兩個隊列
在聲明隊列的時候,聲明兩個隊列
3d
Ctrl+T 找到實現類
這就是方法的參數
替換機有不少的常量類型
幾種類型
blog
裏面有不少的重載方法
綁定短信隊列。
隊列
每次發5條消息
第一個參數是交換機。第二個參數路由key仍是設置爲空,
路由