一、ptp處理模式(queue)
訊息生產者生產訊息傳送到queue中,然後訊息消費者從queue中取出並且消費訊息。
訊息被消費以後,queue中不再有儲存,所以訊息消費者不可能消費到已經被消費的訊息。
queue支援存在多個消費者,但是對乙個訊息而言,只會有乙個消費者可以消費,其他的則不能消費此訊息了。
當消費者不存在時,訊息會一直儲存,直到有消費者消費。
二、publish/subscribe處理模式(topic)
訊息生產者(發布)將訊息發布到topic中,同時有多個訊息消費者(訂閱)消費該訊息。
和點對點方式不同,發布到topic的訊息會被所有訂閱者消費。
當生產者發布訊息,不管是否有消費者,都不會儲存訊息。
一定要現有訊息的消費者,後有訊息的生產者。
三、ptp和pub/sub簡單對比
ActiveMQ發布訂閱模式
訊息監聽 訂閱者一 author administrator public class listener implements messagelistener catch jm ception e 訊息監聽 訂閱者二 author administrator public class listene...
activeMQ搭建佇列模式
生產者 public class produce connection.close system.out.println 訊息傳送完畢 消費者 public class consumercatch exception e 當然開發中不會有這麼複雜的情況,自己用一些比較通俗的語言來描述一下,生產者就是...
ActiveMQ處理積壓的訊息
如果消費者變為慢速消費者,那麼後面可能會導致訊息積壓,導致生產者速度也變慢,甚至停止。我們可以配置訊息的過期時間,並設定訊息過期丟棄策略,以及使用死信佇列來處理訊息的積壓。activemq提供了乙個timestampingbrokerplugin外掛程式,通過此外掛程式,我們可以為持久化訊息設定過期...