初次使用activeMQ主題模型的一點配置分享

2021-09-03 02:26:42 字數 424 閱讀 9531

最近由於剛練手訊息中介軟體,就拿了乙個activemq試試,在練習的過程中遇到了比較明顯的問題:就是主題模型下的訊息佇列,持久化訂閱者的實現。具體表象就是,我的接收者重啟後接收不到傳送者已傳送而未消費的訊息,非得接收者先啟動好,然後傳送者推送訊息,才可以接收到。這不是我想要的,實際是要求接收者重啟後能主動拉取傳送者已傳送而未消費的訊息。另外進入messages dequeued的訊息無法再次消費。

實現訂閱者持久化,前提有:傳送者訊息持久化、開啟發布/訂閱者模式、進行持久化模式,接收者 工廠(cachingconnectionfactory或singleconnectionfactory)指定接收者id屬性值clientid,訊息佇列容器開啟發布/訂閱者模式、訊息持久化設定、接收者id。

分享配置如下:

<?xml version="1.0" encoding="utf-8"?>  

ActiveMQ使用總結

1 activemq支援訊息過濾設定規則和用法 selector支援下列幾種方式 1 string literals color blue 2 byte strings mybytes 0x0afc23 3 numeric values noltemsinstock 20 4 boolean lit...

activemq 使用總結

2 錯誤 channel was inactive for too long 伺服器訊息較長時間沒有訊息傳送時,客戶端會報這個錯誤 解決方法 在建立連線的uri中加入 wireformat.maxinactivityduration 0 3 採用failover方式連線導致卡死 解決方法 不採用fa...

ActiveMQ使用總結

1 activemq支援訊息過濾設定規則和用法 selector支援下列幾種方式 1 string literals color blue 2 byte strings mybytes 0x0afc23 3 numeric values noltemsinstock 20 4 boolean lit...