ActiveMQ4.1 +Spring2.0的POJO JMS方案

ActiveMQ4.1+Spring2.0的POJOJMS方案[整理版].概述1.1JMS与ActiveMQ特性JMS始终在JavaEE五花八门的协议里，WebService满天飞的时候占一位置，是因为：它可以把不影响用户执行结果又比较耗时的任务（比如发邮件通知管理员）异步的扔给JMS服务端去做，而尽快的把屏幕返还给用户。服务端能够多线程排队响应高并发的请求，并保证请求不丢失。可以在Java世界里达到最高的解耦。客户端与服务端无需直连，甚至无需知晓对方是谁、在哪里、有多少人，只要对流过的信息作响应就行了，在企业应用环境复杂时作用明显。ActiveMQ的特性：完全支持JMS1.1和J2EE1.4规范的JMSProvider实现，也是ApacheGeronimo默认的JMSprovider。POJOwithdoutEJBContainer，不需要实现EJB繁琐复杂的MessageBean接口和配置。SpringBase，可以使用Spring的各种特性如IOC、AOP。Effective，基于Jencks的JCAContainer实现poolconnection，controltransactionsandmanagesecurity。1.2SpringSide的完全POJO的JMS方案SpringSide2.0在BookStore示例中，演示了用户下订单时，将发通知信到用户邮箱的动作，通过JMS交给JMS服务端异步完成，避免了邮件服务器的堵塞而影响用户的下订。全部代码于examples\bookstore\src\java\org\springside\bookstore\components\activemq目录中。一个JMS场景通常需要三者参与：一个POJO的的MessageProducer，负责使用Spring的JMSTemplate发送消息。一个MessageConverter，负责把Java对象如订单(Order)转化为消息，使得Producer能够直接发送POJO。一个MDPMessageConsumer，负责接收并处理消息。SpringSide2.0采用了ActiveMQ4.1-incubator与Spring2.0集成，对比SS1.0M3，有三个值得留意的地方，使得代码中几乎不见一丝JMS的侵入代码：1.采用Spring2.0的Schema式简化配置。2.实现MessageConverter转化消息与对象，使得Producer能够直接发送POJO而不是JMSMessage。3.使用了Spring2.0的DefaultMessageListenerContainer与MessageListenerAdapter，消息接收者不用实现MessageListener接口。4.同时，Spring2.0的DefaultMessageListenerContainer代替了SS1.0M3中的Jenck(JCAContainer)，充当MDPContainer的角色。2.引入ActiveMQ的XSDActiveMQ4.1响应Spring2.0号召，支持了引入XMLSchemanamespace的简单配置语法，简化了配置的语句。在ApplicationContext.xml(Spring的配置文件)中引入ActiveMQ的XMLScheam配置文件),如下:beansxmlns=:amq=:xsi=:schemaLocation=://://activemq.org/config/1.0由于ActiveMQ4.1SnapShot的那个XSD有部分错误，因此使用的是自行修改过的XSD。先在ClassPath根目录放一个修改过的activemq-core-4.1-incubator-SNAPSHOT.xsd。在ClassPath下面建立META-INF\spring.schemas内容如下。这个spring.schemas是spring自定义scheam的配置文件,请注意http:\://部分写法http\://people.apache.org/repository/org.apache.activemq/xsds/activemq-core-4.1-incubator-SNAPSHOT.xsd=/activemq-core-4.1-incubator-SNAPSHOT.xsd3.配置方案3.1基础零件1.配置ActiveMQBroker暂时采用在JVM中嵌入这种最简单的模式，当spring初始化时候，ActiveMQembeddedBroker就会启动了。!--letscreateanembeddedActiveMQBroker--amq:brokeruseJmx=falsepersistent=falseamq:transportConnectorsamq:transportConnectoruri=tcp://localhost:0//amq:transportConnectors/amq:broker2.配置(A)ConnectionFactory由于前面配置的Broker是JVMembedded所以URL为:vm://localhost!--ActiveMQconnectionFactorytouse--amq:connectionFactoryid=jmsConnectionFactorybrokerURL=vm://localhost/3配置(B)Queue!--ActiveMQdestinationstouse--amq:queuename=destinationphysicalName=org.apache.activemq.spring.Test.spring.embedded/4.配置(C)Converter配置Conveter，使得Producer能够直接发送Order对象，而不是JMS的Message对象。!--OrderMessageconverter--beanid=orderMessageConverterclass=org.springside.bookstore.components.activemq.OrderMessageConverter/3.2发送端1配置JmsTemplateSpring提供的Template，绑定了(A)ConnectionFactory与(C)Converter。!--SpringJmsTemplateconfig--beanid=jmsTemplateclass=org.springframework.jms.core.JmsTemplatepropertyname=connectionFactory!--letswrapinapooltoavoidcreatingaconnectionpersend--beanclass=org.springframework.jms.connection.SingleConnectionFactorypropertyname=targetConnectionFactoryref=jmsConnectionFactory//bean/property!--customMessageConverter--propertyname=messageConverterref=orderMessageConverter//bean2.Producer消息发送者，使用JmsTemplate发送消息，绑定了JmsTemplate(含A、C)与(B)Queue。!--POJOwhichsendMessageusesSpringJmsTemplate，绑定JMSTemplate与Queue--beanid=orderMessageProducerclass=org.springside.bookstore.components.activemq.OrderMessageProducerpropertyname=templateref=jmsTemplate/propertyname=destinationref=destination//bean3.3接收端1.接收处理者(MDP)使用Spring的MessageListenerAdapter，指定负责处理消息的POJO及其方法名，绑定(C)Converter。!--MessageDrivenPOJO(MDP)，绑定Converter--beanid=messageListenerclass=org.springframework.jms.listener.adapter.MessageListenerAdapterconstructor-argbeanclass=org.springside.bookstore.components.activemq.OrderMessageConsumerpropertyname=mailServiceref=mailService//bean/constructor-arg!--maybeothermethod--propertyname=defaultListenerMethodvalue=sendEmail/!--customMessageConverterdefine--propertyname=messageConverterref=orderMessageConverter//bean2.listenerContainer负责调度MDP，绑定(A)connectionFactory,(B)Queue和MDP。!--thisistheattendantmessagelistenercontainer--beanid=listenerContainerclass=org.springframework.jms.listener.DefaultMessageListenerContainerpropertyname=connectionFactoryref=jmsConnectionFactory/propertyname=destinationref=destination/propertyname=messageListenerref=messageListener//bean互相绑定的关系有点晕，发送端和接收端都以不同形式绑定了(A)connectionFactory,(B)Queue和(C)Converter。4.下篇1.说明请先阅读ActiveMQ4.1+Spring2.0的POJOJMS方案(上)本篇将补充说明了：1)使用数据库持久化消息，保证服务器重启时消息不会丢失2)使用Jencks作正宗的JCAContainer。2.持久化消息2.1给Broker加入Persistence配置在配置文件applicationContext-activemq-embedded-persitence.xml中的amq:broker节点加入amq:persistenceAdapter