Activemq訊息持久化

2021-09-06 23:35:28 字數 799 閱讀 1914

官方文件:

activemq持久化相關配置:/usr/local/apache-activemq-5.11.1/conf/activemq.xml

官方預設的持久化為kahadb:

可以稍作調優:

indexwritebatchsize="1000"journalmaxfilelength="32mb"enableindexwriteasync="true"enablejournaldisksyncs="false"/>

例項展示使用mysql持久化:

修改persistenceadapter節點:

在節點前面增加mysql的相關配置資訊
class="org.apache.commons.dbcp.basicdatasource" destroy-method="close">

新增依賴的dbcp和mysql驅動包到lib

建立activemq資料庫重啟activemq,可以看到在activemq庫中增加了三個表

傳送queue型別訊息:

訊息被消費了之後持久化的記錄會刪除.

問題: 測試過程中持久化感覺效能不好,而且訊息消費容易鎖住.希望得到好的意見和建議 共同學習.

ActiveMQ 訊息持久化

可持久化機制 兩種機制 用一句話簡單明瞭來說,就是將mq中的資料儲存乙份,資料被傳送,則將儲存的資料刪除,如果沒有傳送成功則重新傳送。先不說具體的實現,整體的思路是這樣的,如果mq是一台伺服器,我們最好做到物理上的備份,這樣在機器出問題的時候,我們能夠恢復資料。一般將資料儲存到第三方雲上。或者說另外...

Activemq訊息持久化

官方文件 activemq持久化相關配置 usr local apache activemq 5.11.1 conf activemq.xml 官方預設的持久化為kahadb 可以稍作調優 indexwritebatchsize 1000 journalmaxfilelength 32mb enab...

ActiveMQ訊息持久化訂閱

在之前的介紹中,我們了解到在activemq中預設的queue模式下,我們的訊息是會進行持久化的,我們也介紹了其相關的機制,見activemq儲存的持久化機制,而在topic模式下,訊息在消費者消費的情況下,以及activemq服務重啟的時候,會傳送丟失的情況的。在activemq儲存的持久化機制中...