james 下的 JMS
james的这个版本--james-server3.0-M2,使用了JMS来控制服务器的邮件队列。
james使用了ActiveMQ来作为它的JMS服务器。
ActiveMQ介绍:
ActiveMQ是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ是一个完全支持JMS1.1和J2EE1.4规范的JMSProvider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。
1.多种语言和协议编写客户端。语言:Java,C,C++,C#,Ruby,Perl,Python,PHP。应用协议:OpenWire,StompREST,WSNotification,XMPP,AMQP
2.完全支持JMS1.1和J2EE1.4规范(持久化,XA消息,事务)
3.对Spring的支持,ActiveMQ可以很容易内嵌到使用Spring的系统里面去,而且也支持Spring2.0的特性
4.通过了常见J2EE服务器(如Geronimo,JBoss4,GlassFish,WebLogic)的测试,其中通过JCA1.5resourceadaptors的配置,可以让ActiveMQ可以自动的部署到任何兼容J2EE1.4商业服务器上
5.支持多种传送协议:in-VM,TCP,SSL,NIO,UDP,JGroups,JXTA
6.支持通过JDBC和journal提供高速的消息持久化
7.从设计上保证了高性能的集群,客户端-服务器,点对点
8.支持Ajax
9.支持与Axis的整合
10.可以很容易得调用内嵌JMSprovider,进行测试
正题来了:
1.引入activemq的xsd
ActiveMQ4.1开始响应spring2.0号召,支持了引入xmlschemanamespace的简单配置语法,简化了配置的语句。
在applicationcontext.xml(spring的配置文件)中引入activemq的xmlscheam配置文件),如下:
<beansxmlns="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/beanshttp://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://activemq.apache.org/schema/corehttp://activemq.apache.org/schema/core/activemq-core-5.4.1.xsd">
2.配置ActiveMQ的broker
<amq:brokeruseJmx="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:policyEntryqueue=">"prioritizedMessages="true"/>
</amq:policyEntries>
</amq:policyMap>
</amq:destinationPolicy>
<amq:managementContext>
<amq:managementContextcreateConnector="false"/>
</amq:managementContext>
<amq:persistenceAdapter>
<amq:amqPersistenceAdapter/>
</amq:persistenceAdapter>
<amq:transportConnectors>
<amq:transportConnectoruri="tcp://localhost:0"/>
</amq:transportConnectors>
</amq:broker>
什么是Broker呢?可以把JMSBrokers看成是服务器端。这个服务器可以独立运行.也可以随着其他容器以内嵌方式运行。
james使用了把ActiveMQ嵌入到它自己服务的方式,所以当james启动,加载spring的配置文件,ActiveMQ也会随之启动。
3.配置ActiveMQ的连接方式
<amq:connectionFactoryid="amqConnectionFactory"brokerURL="vm://james?create=false">
<propertyname="blobTransferPolicy"ref="blobTransferPolicy"/>
</amq:connectionFactory>
上面配置的broker是jvmembedded所以url为:vm://james?create=false
注:
连接ActiveMQ的方式
ActiveMQConnectionFactory提供了多种连接到Broker的方式
常见的有
vm://host:port//vm
tcp://host:port//tcp
ssl://host:port//SSL
stomp://host:port//stomp协议可以跨语言,目前有很多种stompclient库(java,c#,c/c++,ruby,python...);
4.配置JMS的ConnectionFactory
<beanid="jmsConnectionFactory"class="org.springframework.jms.connection.CachingConnectionFactory">
<propertyname="targetConnectionFactory"ref="amqConnectionFactory"/>
<propertyname="sessionCacheSize"value="10"/>
<propertyname="cacheConsumers"value="false"/>
<propertyname="cacheProducers"value="true"/>
</bean>
CachingConnectionFactory继承自SingleConnectionFactory,增加了对Session和MessageProducer缓存的功能。
5.配置JMS事务
<beanid="jmsTransactionManager"class="org.springframework.jms.connection.JmsTransactionManager">
<propertyname="connectionFactory"ref="jmsConnectionFactory"/>
</bean>
这样可以把JMS作为一个事务资源无缝地集成到Spring的事务管理机制中去。
6.邮件队列Factory
<beanid="mailQueueFactory"class="org.apache.james.queue.activemq.ActiveMQMailQueueFactory"depends-on="broker"/>
depends-on="broker"
mailQueueFactory这个bean需要broker先实例化。
另:我的小站:
NB分享:http://www.nbshare.com