ActiveMQ的持久化(数据库)

1、利用消息队列的异步策略，可以从很大程序上缓解程序的压力，但是，如果mq所在的机器 down机了, 又如果队列中的数据不是持久的就会发生数据丢失，后果是可想而知的，所以消息的持久化是不可不讨论的话题。 1) 关于 activemq 消息队列的持久化， 主要是在 activemq 的配置文件中设置( 看粗体部分 ). java 代码1. 17. 18. 25. 26. 27. 28. 29. file:/$activemq.base/conf/perties 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. 53. 54. 55. 56. 57. 58. 59. 60. 61. 62. 63. !- example of a static configuration: 64. 65. - 66. 67. 68. 69. 70. 71. 72. 73. !- 74. 75. 76. 77. - 78. 79. 80. 81. 82. 83. 84. 85. 86.

3、 87. 88. 89. 90. 91. 92. 93. 94. 95. 96. 97. 98. 99. 100. 101. 102. 103. 104.105.106. 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 rout

4、es here using the element - 128. 129. 130. 131. 132. 133.134. 139.140. 141. 142. 143. 144. 145. 146. 147. 148. 149. 53. 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. 181. 182. 183. 184. 185. 186.

5、 - 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. 210. - 211.212. 213. !- 214. 215. 216. 217. 218. - 219.220. 221. 改动部分主要是设置了mysql 的 datasource 声明, 还有就是采用 mysql 作为 persistenceadapter,并

6、声明如下。java 代码1. 2. 3. 4. 5. 6. 7. 8. 9.10. 11. 12. 13. 14. 2) 把数据库的驱动放入activemq 的 lib中，使其能够访问相应的数据库，关于数据库的表结构， activemq 会自动创建，但是前提是当activemq启动以后，声明的数据库要是存在的。测试的时候发现以上条件都满足activemq 还是会抛异常，看了一下异常，是有一张表（ activemq_acks ）创建的时候出了问题，自己手动创建后好了，把表结构列出来。java 代码1. - phpmyadmin sql dump 2. - version 2.10 . 23. -

7、 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 table activemq_acks ( 23. sub varchar(250) collate utf

8、8_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 utf8_bin default null, 29. se_selector varchar( 250) c

9、ollate utf8_bin default null 30.) engine=myisam default charset=utf8 collate=utf8_bin; 31. 32.- 33.- 导出表中的数据 activemq_acks 34.- 35. 36. 37.- - 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 varch

10、ar( 250) collate utf8_bin default null, 47. primary key (id) 48.) engine=myisam default charset=utf8 collate=utf8_bin; 49. 50.- 51.- 导出表中的数据 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 6

11、1.- 62. 63.create table activemq_msgs ( 64. id int(11) not null, 65. container varchar(250) collate utf8_bin default null, 66. msgid_prod 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.) engine=myisam default charset=utf8 collate=utf8_bin; 75.