ActiveMQ處理模式

2022-06-19 07:51:07 字數 646 閱讀 6998

一、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外掛程式,通過此外掛程式,我們可以為持久化訊息設定過期...