读书人

james 上的 JMS

发布时间: 2012-08-22 09:50:34 作者: rapoo

james 下的 JMS
james的这个版本--james-server 3.0-M2,使用了JMS来控制服务器的邮件队列。

james使用了ActiveMQ来作为它的JMS服务器。

ActiveMQ介绍:
ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。

1. 多种语言和协议编写客户端。语言: Java, C, C++, C#, Ruby, Perl, Python, PHP。应用协议: OpenWire,Stomp REST,WS Notification,XMPP,AMQP   
2. 完全支持JMS1.1和J2EE 1.4规范 (持久化,XA消息,事务)   
3. 对Spring的支持,ActiveMQ可以很容易内嵌到使用Spring的系统里面去,而且也支持Spring2.0的特性   
4. 通过了常见J2EE服务器(如 Geronimo,JBoss 4, GlassFish,WebLogic)的测试,其中通过JCA 1.5 resource adaptors的配置,可以让ActiveMQ可以自动的部署到任何兼容J2EE 1.4 商业服务器上   
5. 支持多种传送协议:in-VM,TCP,SSL,NIO,UDP,JGroups,JXTA   
6. 支持通过JDBC和journal提供高速的消息持久化   
7. 从设计上保证了高性能的集群,客户端-服务器,点对点   
8. 支持Ajax   
9. 支持与Axis的整合   
10. 可以很容易得调用内嵌JMS provider,进行测试


正题来了:
1.引入activemq的xsd

ActiveMQ4.1 开始 响应spring 2.0号召,支持了引入xml schema namespace的简单配置语法,简化了配置的语句。
在applicationcontext.xml(spring的配置文件)中引入activemq的xml scheam 配置文件),如下:
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:amq="http://activemq.apache.org/schema/core"
xsi:schemaLocation="
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core-5.4.1.xsd">



2.配置ActiveMQ 的 broker
<amq:broker useJmx="true" persistent="true" brokerName="james" dataDirectory="filesystem=file://var/store/activemq/brokers" useShutdownHook="false" schedulerSupport="false" id="broker">
<amq:destinationPolicy>
<amq:policyMap>
<amq:policyEntries>
<amq:policyEntry queue=">" prioritizedMessages="true"/>
</amq:policyEntries>
</amq:policyMap>
</amq:destinationPolicy>
<amq:managementContext>
<amq:managementContext createConnector="false"/>
</amq:managementContext>
<amq:persistenceAdapter>
<amq:amqPersistenceAdapter/>
</amq:persistenceAdapter>
<amq:transportConnectors>
<amq:transportConnector uri="tcp://localhost:0" />
</amq:transportConnectors>
</amq:broker>

什么是Broker呢?可以把JMS Brokers 看成是服务器端。这个服务器可以独立运行.也可以随着其他容器以内嵌方式运行。
james使用了把ActiveMQ嵌入到它自己服务的方式,所以当james启动,加载spring的配置文件,ActiveMQ也会随之启动。



3.配置ActiveMQ的连接方式

<amq:connectionFactory id="amqConnectionFactory" brokerURL="vm://james?create=false">
<property name="blobTransferPolicy" ref="blobTransferPolicy"/>
</amq:connectionFactory>

上面配置的broker是jvm embedded 所以url为:vm://james?create=false
注:
连接ActiveMQ的方式
ActiveMQConnectionFactory 提供了多种连接到Broker的方式

常见的有
vm://host:port //vm
tcp://host:port //tcp
ssl://host:port //SSL
stomp://host:port //stomp协议可以跨语言,目前有很多种stomp client 库(java,c#,c/c++,ruby,python...);



4.配置JMS的ConnectionFactory

<bean id="jmsConnectionFactory" ref="amqConnectionFactory"/>
<property name="sessionCacheSize" value="10"/>
<property name="cacheConsumers" value="false"/>
<property name="cacheProducers" value="true"/>
</bean>

CachingConnectionFactory继承自SingleConnectionFactory,增加了对Session和MessageProducer缓存的功能。


5.配置JMS事务

<bean id="jmsTransactionManager" ref="jmsConnectionFactory"/>
</bean>

这样可以把JMS作为一个事务资源无缝地集成到Spring的事务管理机制中去。



6.邮件队列Factory

<bean id="mailQueueFactory" depends-on="broker"/>

depends-on="broker"
mailQueueFactory这个bean需要broker先实例化。





另:我的小站:
NB分享:http://www.nbshare.com

读书人网 >软件架构设计

热点推荐