Activemq5.2.0的spring开发

  在本篇我要做一个spring和Activemq结合的例子。将activemq和spring无缝衔接,并且将activemq的信息持久化到mysql数据库中。这里使用queue

一、依赖的jar,这些是开发的必备jar

 A、activemq的jar:activemq-all-5.2.0.jar

 B、xbean.jar:用来解析xsd之类的东东

 C、xbean-spring-3.1.jar

 

二、开发步骤

 1、用来存储消息的pojo,一定要序列化

 2、消息产生器,用来向队列发送消息:Producter

 3、将pojo转化成可以发送到队列的形式:MessageConverter

 4、消息处理器:Consumer

 5、调用jms发送消息,将下边的代码嵌入到相关的触发地。通过我们consumer的延迟处理,我们的队列被处理效果将很容易在控制台看到

 

6、相关配置文件(我将内置的activemq5.2服务器直接写入到一个配置文件中,并将相关的jms配置放到一起)

7、相关的property配置文件(我的持久化jdbc和ssh项目用的jdbc都用单独的配置文件管理)

 

三、常见问题处理

 1、用mysql的时候无法直接生成相关监控表ACTIVEMQ_ACKS没有创建(mysql5)。这个可能是因为你将表的默认字符集设置为utf-8,如果你使用latin1就不会有这个问题。将activemq的持久化到mysql数据库的时候一定要设定合适的字符集

上一篇:
下一篇:

发表评论

电子邮件地址不会被公开。 必填项已用*标注

昵称 *