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 方法確...