2022年ActiveMQ的持久化[归 .pdf

《2022年ActiveMQ的持久化[归 .pdf》由会员分享，可在线阅读，更多相关《2022年ActiveMQ的持久化[归 .pdf（11页珍藏版）》请在淘文阁 - 分享文档赚钱的网站上搜索。

1、利用消息队列的异步策略，可以从很大程序上缓解程序的压力，但是，如果MQ所在的机器 down机了, 又如果队列中的数据不是持久的就会发生数据丢失，后果是可想而知的，所以消息的持久化是不可不讨论的话题。 1) 关于 ActiveMQ 消息队列的持久化， 主要是在 ActiveMQ 的配置文件中设置( 看粗体部分 ). Java 代码1. 17. 18. 25. 26. 27. 28. 29. file:/$activemq.base/conf/credentials.properties 30. 31. 32. 33. 34. 35. 36. 37. 38. 39. memoryLimit=5mb

2、/ 40. memoryLimit=5mb 41. !- you can add other policies too such as these 42. 43. 44. 45. 46. 47. 48. - 49. 50. 51. 52. 名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 2 页，共 11 页 - - - - - - - - - 53. 54. 55. 56. 57. 58. 59. 60. 61. 62. 63. !- Example of a static conf

3、iguration: 64. 65. - 66. 67. 68. 69. 70. 71. 72. 73. !- 74. 75. 76. 77. - 78. 79. 80. 81. 82. 83. 84. 85. 86. 名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 3 页，共 11 页 - - - - - - - - - 87. 88. 89. 90. 91. 92. 93. 94. 95. 96. 97. 98. 99. 100. 101. 102. 103. 104.105.1

4、06. 107. 108. 109. 110. 111. 112. 113.114. 115.116. 122. 123.124. !- You can use a element for each root package to search for Java routes - 125. org.foo.bar 126.127. !- You can use Spring XML syntax to define the routes here using the element - 128. 129. 130. 131. 132. 133.134. 139.140. 141. 142. 1

5、43. 144. 145. 146. 147. 148. 149. 150.151.152.153. 名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 5 页，共 11 页 - - - - - - - - - 154. !- 155. 156. - 157.158.159. 160. 161. 162. 163. 164.165. 166. 167. 168. 169. 170. 171.172. 173.174. 175. !- 176. 177. 178. 179. 180. 18

6、1. 182. 183. 184. 185. 186. - 名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 6 页，共 11 页 - - - - - - - - - 187.188. 189.190. 191. 192. 193. 194. 195. 196. property name=poolPreparedStatements value=true/ 197. 198.199.200. 201. !- 202. 203. 204. 205. 206. 207. 208. 209

7、. 210. - 211.212. 213. !- 214. 215. 216. 217. 218. - 219.220. 名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 7 页，共 11 页 - - - - - - - - - 221. 改动部分主要是设置了mysql 的 datasource 声明, 还有就是采用 mysql 作为 persistenceAdapter,并声明如下。Java 代码1. 2. 3. 4. 5. 6. 7. 8. 9.10. 11. 12. 13. 1

8、4. 2) 把数据库的驱动放入ActiveMQ 的 lib中，使其能够访问相应的数据库，关于数据库的表结构， ActiveMQ 会自动创建，但是前提是当ActiveMQ启动以后，声明的数据库要是存在的。名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 8 页，共 11 页 - - - - - - - - - 测试的时候发现以上条件都满足ActiveMQ 还是会抛异常，看了一下异常，是有一张表（ activemq_acks ）创建的时候出了问题，自己手动创建后好了，把表结构列出来。Jav

9、a 代码1. - phpMyAdmin SQL Dump 2. - version 2.10 . 23. - http:/ 4. - 5. - 主机: localhost 6. - 生成日期 : 2009 年 11 月 06 日 05: 297. - 服务器版本 : 5.0 . 458. - PHP 版本: 5.2 . 39.10.SET SQL_MODE=NO_AUTO_VALUE_ON_ZERO; 11. 12.- 13.- 数据库 : activemq 14.- 15. 16.- - 17. 18.- 19.- 表的结构 activemq_acks 20.- 21. 22.CREATE

10、TABLE activemq_acks ( 23. SUB varchar(250) collate utf8_bin NOT NULL, 24. CONTAINER varchar(250) collate utf8_bin NOT NULL, 25. LAST_ACKED_ID int(11) default NULL, 26. SE_ID int(11) default NULL, 27. SE_CLIENT_ID varchar(250) collate utf8_bin default NULL, 28. SE_CONSUMER_NAME varchar( 250) collate

11、utf8_bin default NULL, 29. SE_SELECTOR varchar( 250) collate utf8_bin default NULL 30.) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_bin; 31. 32.- 33.- 导出表中的数据 activemq_acks 34.- 35. 36. 名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 9 页，共 11 页 - - - - - - - - - 3

12、7.- - 38. 39.- 40.- 表的结构 activemq_lock 41.- 42. 43.CREATE TABLE activemq_lock ( 44. ID bigint(20) NOT NULL, 45. TIME bigint(20) default NULL, 46. BROKER_NAME varchar( 250) collate utf8_bin default NULL, 47. PRIMARY KEY (ID) 48.) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_bin; 49. 50.- 51.- 导出表中

13、的数据 activemq_lock 52.- 53. 54.INSERT INTO activemq_lock (ID, TIME, BROKER_NAME) VALUES 55.( 1, 1257485355546 , NULL); 56. 57.- - 58. 59.- 60.- 表的结构 activemq_msgs 61.- 62. 63.CREATE TABLE activemq_msgs ( 64. ID int(11) NOT NULL, 65. CONTAINER varchar(250) collate utf8_bin default NULL, 66. MSGID_PROD

14、 varchar( 250) collate utf8_bin default NULL, 67. MSGID_SEQ int(11) default NULL, 68. EXPIRATION bigint(20) default NULL, 69. MSG longblob, 70. PRIMARY KEY (ID), 71. KEY ACTIVEMQ_MSGS_MIDX (MSGID_PROD,MSGID_SEQ), 72. KEY ACTIVEMQ_MSGS_CIDX (CONTAINER), 73. KEY ACTIVEMQ_MSGS_EIDX (EXPIRATION) 74.) EN

15、GINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_bin; 75. 76.- 77.- 导出表中的数据 activemq_msgs 78.- 名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 10 页，共 11 页 - - - - - - - - - 当消息发送至 ActiveMQ 时，数据就被持久化到mysql 了，如果消息被消费，数据会自动被删除， down机后重启没影响，有一点不好的是, 这个有点拖数据库，我在本地的 mysql, 一开启 ActiveMQ, 数据库就会变得很慢，不过这个只是在本地的机子上，想必实际应用时应该好很多。名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 11 页，共 11 页 - - - - - - - - -