中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Apache ActiveMQ 的消息持久化到MySQL數據庫詳細步驟

發布時間:2020-05-09 15:16:32 來源:億速云 閱讀:253 作者:三月 欄目:數據庫

下文主要給大家帶來Apache ActiveMQ 的消息持久化到MySQL數據庫詳細步驟,希望Apache ActiveMQ 的消息持久化到MySQL數據庫詳細步驟能夠帶給大家實際用處,這也是我編輯這篇文章的主要目的。好了,廢話不多說,大家直接看下文吧。

ActiveMQ提供多種數據持久化方式:可以持久化到文件,也可以持久化到數據庫,其中數據庫可以支持MySQL和Oracle兩種類型。

默認提供的是持久化到文件的方式,即activemq.xml文件中的:

<persistenceAdapter>

<kahaDBdirectory="${activemq.base}/data/kahadb"/>

</persistenceAdapter>

2.  步驟

本文重點接收的是持久化到MySQL中的配置方式:

2.1    添加MySQL驅動

首先需要把MySql的驅動放到ActiveMQ的Lib目錄下,我用的文件名字是:

mysql-connector-java-5.1.30-bin.jar

 commons-pool-1.6.jar

commons-dbcp-1.4.jar

2.2    修改配置文件activemq.xml

將其中的這段配置:

<persistenceAdapter>
<kahaDB directory="${activemq.base}/data/kahadb"/>
</persistenceAdapter>

修改為下面這段內容:

<persistenceAdapter>

        <jdbcPersistenceAdapter  dataSource="# mysql-ds "/>

</persistenceAdapter>

 Apache ActiveMQ 的消息持久化到MySQL數據庫詳細步驟

在</broker>結點之后,增加數據源的配置,如下:

   <!-- MySql DataSource Sample Setup -->  

 <bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">  

      <property name="driverClassName" value="com.mysql.jdbc.Driver"/>  

      <property name="url" value="jdbc:mysql://localhost/activemq?relaxAutoCommit=true"/>  

      <property name="username" value="root"/>  

      <property name="password" value="123456"/>  

      <property name="poolPreparedStatements" value="true"/>  

    </bean>  

        

    <!-- Oracle DataSource Sample Setup -->  

    <!--  

    <bean id="oracle-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">  

      <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/>  

      <property name="url" value="jdbc:oracle:thin:@localhost:1521:AMQDB"/>  

      <property name="username" value="root"/>  

      <property name="password" value="123456"/>  

      <property name="poolPreparedStatements" value="true"/>  

    </bean>  

 -->  

   

2.3    新建數據庫

從配置中可以看出數據庫的名稱是test_mq,需要手動在MySql中新建一個test_mq的空數據庫。

此時,重新啟動MQ,就會發現test_mq庫中多了三張表:activemq_acks,activemq_lock,activemq_msgs,OK,說明已經持久化成功啦!

對于以上關于Apache ActiveMQ 的消息持久化到MySQL數據庫詳細步驟,大家是不是覺得非常有幫助。如果需要了解更多內容,請繼續關注我們的行業資訊,相信你會喜歡上這些內容的。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

乐昌市| 广州市| 南投县| 景宁| 永泰县| 杂多县| 维西| 武汉市| 宣城市| 海宁市| 横峰县| 东平县| 山东| 理塘县| 灌云县| 礼泉县| 邵阳市| 荃湾区| 化州市| 定结县| 河津市| 明溪县| 遂平县| 彭山县| 安平县| 垣曲县| 新疆| 湖州市| 邵东县| 来宾市| 枣庄市| 汝阳县| 泰安市| 五原县| 清徐县| 家居| 内江市| 揭阳市| 绥芬河市| 温宿县| 浦县|