訊息管理 activemq

2022-01-11 03:35:58 字數 1049 閱讀 6750

1.connectionfactory("tcp:");

本機位址192.168.1.103 也 可以是localhost

訊息的生產者或者說訊息的發布者 並不是服務端,而是稱之為訊息生產者客戶端,

訊息發布者客戶端 跟activemq服務 可以不在同一臺電腦上面;

佇列是在activemq服務裡面

訊息的傳送者和訊息的接收者都不需要有固定ip,只有訊息服務需要固定ip;

這裡的tcp 是否可以修改為別的東西?

這個中間是怎麼來通訊的?????

2.如何講上面的**寫到配置檔案中去?

3.點對點模式又稱之為佇列模式,

訊息生產者 傳送訊息到佇列中,然後訊息消費者從佇列中取出訊息並消費訊息;

生產者傳送一條訊息到queue,只有乙個消費者能收到。

每個訊息只有乙個消費者(consumer)(即一旦被消費,訊息就不再在訊息佇列中)

傳送者和接收者之間在時間上沒有依賴性,也就是說當傳送者傳送了訊息之後,不管接收者有沒有正在執行,它不會影響到訊息被傳送到佇列

接收者在成功接收訊息之後需向佇列應答成功

如果你希望傳送的每個訊息都應該被成功處理的話,那麼你需要p2p模式。

4.點對點模式和 發布/訂閱模式的區別?

發布者傳送到topic的訊息,只有訂閱了topic的訂閱者才會收到訊息

5.點對點模式中,生產者和消費者 是如何來聯絡的?

第一種情況:根據ip和埠

第二種情況:根據ip和埠+ 佇列名稱

第三種情況:根據ip和埠+ 佇列名稱 + 每個訊息設定的過濾條件

目前可以確定的是:

如果生產者和消費者的佇列名稱不一致,那麼他們肯定無法正常連線

如果生產者和消費者的過濾條件不一致,那麼他們無法正常連線

同乙個ip跟埠,同乙個訊息佇列, 消費者的 clientid 必須不能重複;

所有的門店可以共用乙個訊息佇列,通過設定不同的過濾條件來區分不同的門店;

這個時候我應該是通過不同的佇列名稱來區分門店,還是應該通過不同的過濾條件來區分門店?

自己對問題不了解導致了錯誤的結論

ActiveMQ訊息佇列

這個東西沒接觸到的時候挺懵的,用過一次之後,哇哦 public class producter catch jm ception e public void sendmessage string disname,listlist else thread.sleep 1000 int num coun...

Activemq訊息型別

activemq訊息型別 jms規範中的訊息型別包括textmessage mapmessage objectmessage bytesmessage 和streammessage 等五種。activemq也有對應的實現,下面我們結合spring jms分別來看一下五種訊息型別的收發 1 textm...

activeMQ訊息佇列

session.auto acknowledge。當客戶成功的從receive 方法返回的時候,或者從messagelistener.onmessage方法成功返回的時候,會話自動確認客戶收到的訊息。session.client acknowledge。客戶通過訊息的 acknowledge 方法確...