ActiveMQ-part2 - SpringSide Wiki - SpringSide...

来源:百度文库 编辑:神马文学网 时间:2024/04/27 20:52:22
Dashboard >SpringSide Wiki >...Home > Other Features > ActiveMQ > ActiveMQ-part2
 SpringSide WikiLog In |Sign Up  
ActiveMQ-part2
 Browse Space   Add PageViewEditAttachments (0)Info
Added byWei Su, last edited bySpringSideTeam on 2007-01-15  (view change) Labels:
(None)EDIT
Add Labels

Enter labels to add to this page:
Tip: Looking for a label? Just start typing.

ActiveMQ4.1 +Spring2.0的POJO JMS方案(下)
版权声明:本文作者cctvx1(SpringSide保留版权,转载请注明出处:http://wiki.springside.org.cn/display/springside/ActiveMQ-part2)
1. 说明
请先阅读ActiveMQ4.1 +Spring2.0的POJO JMS方案(上)
本篇将补充说明了:
1) 使用数据库持久化消息,保证服务器重启时消息不会丢失
2) 使用Jencks作正宗的JCA Container。
2.持久化消息
2.1 给Broker加入Persistence 配置
在配置文件applicationContext-activemq-embedded-persitence.xml中的节点加入

请注意MSSQL(2000/2005)和HSQL由于不支持[SELECT  * ACTIVEMQ_LOCK FOR UPDATE ]语法,因此不能使用默认的userDatabaseLock="true",只能设置成useDatabaseLock="false"
2.2 配置多种数据源
配置多种数据源,给jdbcPersistenceAdapter使用,SpringSide 中使用的内嵌HSQL

2. 3 说明
笔者仅仅使用了jdbcPersistenceAdapter,其实在ActiveMQ的XSD已经描述了多种PersistenceAdapter,可以参考对应的XSD文件.
另外对于数据库的差异主要表现在设置了userDatabaseLock="true"之后,ActiveMQ使用的[SELECT * ACTIVEMQ_LOCK FOR UPDATE] 上面,会导致一些数据库出错(测试中MSSQL2000/2005,HSQL都会导致出错)。另外HSQL的脚本请参见activemq.script。
3. Jenck(JCA Container)
Spring 2.0本身使用DefaultMessageListenerContainer 可以充当MDP中的Container角色,但是鉴于Jencks是JCA标准的,它不仅仅能够提供jms的jca整合,包括其他资源比如jdbc都可以做到jca管理
所以,同时完成了这个ActiveMQ+Spring+Jencks 配置演示,更多的针对生产系统的JCA特性展示,会在稍后的开发计划讨论中确定。
此文档适用于说明使用 Jecncks 和 使用Spring 2.0(DefaultMessageListenerContainer)  充当MDP Container时的区别,同时演示Jecnks 的Spring 2.0 新配置实例。
3.1 引入ActiveMQ ResourceAdapter 和Jencks 的XSD
在ApplicationContext.xml(Spring的配置文件)中引入ActiveMQ ResourceAdapter 和Jencks 的XML Scheam 配置文件),如下:
ActiveMQ4.1 响应Spring 2.0号召,支持了引入XML Schema namespace的简单配置语法,简化了配置的语句。
在ApplicationContext.xml(Spring的配置文件)中引入ActiveMQ的XML Scheam 配置文件),如下:

由于ActiveMQ RA和Jencks 那个XSD 仍然有部分错误,因此使用的是自行修改过的XSD。(是xs:any元素引起的错误)
先在ClassPath根目录放一个修改过的activemq-ra-4.1-incubator-SNAPSHOT.xsd和jencks-1.3.xsd。
同样修改 ClassPath 下面META-INF\spring.schemas 增加内容如下。这个spring.schemas是spring自定义scheam的配置文件,请注意"http:\://"部分写法
http\://people.apache.org/repository/org.apache.activemq/xsds/activemq-ra-4.1-incubator-SNAPSHOT.xsd=/activemq-ra-4.1-incubator-SNAPSHOT.xsd http\://repository.codehaus.org/org/jencks/jencks/1.3/jencks-1.3.xsd=/jencks-1.3.xsd
3.2  配置方案
3.2.1 基础零件
1. 配置ActiveMQ Broker  参见ActiveMQ+Spring
2. 配置ActiveMQ Resource Adapter

3. 配置Jencks 基础配置
具体的配置可以参见Jencks的XSD
      
4. 配置给JmsTemplate使用的connectionFactory (主要是生成者/发送者 使用)
这里注意下,在配置jmsTemplate的使用的targetConnectionFactory就是使用jencks配置的connectionManager
                                                                
5. 配置Spring 2.0的MessageListenerAdapter,保证不需要用户实现MessageListener
见ActiveMQ+Spring
6.配置Jecnks 充当MDP的Container
就是把上面的MessageListenerAdapter配置到Jencks里面,完成整个MDP的配置
                                                             
Site powered by a free Open Source Project / Non-profit License (more) ofConfluence - the Enterprise wiki.
Learn more orevaluate Confluence for your organisation.
Powered byAtlassian Confluence, theEnterprise Wiki. (Version: 2.2.9 Build:#527 2006-09-07) -Bug/feature request -Contact Administrators
',1)">