active mq 整合spring 並持久化到資料庫
阿新 • • 發佈:2018-12-31
active mq 整合spring 就直接看程式碼即可。
github :https://github.com/734839030/spring-amq.git
下載講如何持久化到資料庫
找到 conf/activemq.xml
找到broker 節點註釋掉預設的持久化到檔案。
<persistenceAdapter> <!-- <kahaDB directory="${activemq.data}/kahadb"/> --> <jdbcPersistenceAdapter dataSource="#mysql-ds" useDatabaseLock="false"/> </persistenceAdapter>
然後再broker節點上加入
<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://10.4.1.210:3306/activemq?relaxAutoCommit=true"/> <property name="username" value="root"/> <property name="password" value="123"/> <property name="poolPreparedStatements" value="true"/> </bean>
在lib/下新增mysql 驅動 和 連線池的驅動。
mysql-connector-java-5.1.30.jar
commons-pool-1.6.jar
commons-dbcp-1.4.jar
csdn 部落格中傳附件不方便 直接在maven中心庫搜尋下載即可。