activemq持久化之mysql配置

參考：http://blog.csdn.net/zbw18297786698/article/details/52999940

說明：192.168.3.81 CentOS release 6.5 apache-activemq-5.10.1

 

1、拷貝mysql驅動器到activemq環境下

mysql-connector-java-5.1.44-bin.jar

[root@node-01 apache-activemq-5.10.1]# ls /home/apache-activemq-5.10.1/lib/mysql-connector-java-5.1.44-bin.jar

 

2、創建保存activemq消息的數據庫

mysql> CREATE DATABASE test_mq DEFAULT CHARACTER SET utf8 COLLATE utf8_general_ci;

mysql> flush privileges;

mysql> grant all privileges on *.* to 'root'@'192.168.%.%' identified by "!w2";

 

3、配置activemq.xml文件

[root@node-01 apache-activemq-5.10.1]# vim conf/activemq.xml

修改以下2個位置即可，

 

4、重啟activemq服務，查看日志

[root@node-01 apache-activemq-5.10.1]# ./bin/activemq start ;tail -f ./data/activemq.log

此時可能會有報錯，一般是配置文件格式（沒有空格）不對。

正常啟動后，進入數據，會產生3張表。

mysql> show tables;

| Tables_in_test_mq |

| ACTIVEMQ_ACKS |

| ACTIVEMQ_LOCK |

| ACTIVEMQ_MSGS |

mysql> select * from ACTIVEMQ_MSGS;

Empty set (0.00 sec)

此時這里面都是沒有數據的。

 

5、測試數據

activemq發送數據，接收端暫不開啟，可以觀察到有記錄存在ACTIVEMQ_MSGS表中。

以下是測試發送20條記錄，不接收的情況

開啟接收，數據庫中將不會存在記錄值。