搜索
ActiveMQ与Spring整合标签：activemqspring|发表时间：2011-12-3009:44|作者：bincrack分享到：出处：是Apache出品，是最流行和最强大的开源消息总线。同时完全支持JMS1.1和J2EE1.4规范。ActiveMQ特性1.支持多种编程语言和协议编写客户端。2.在JMS客户端和消息代理完全支持企业集成模式3.完全支持JMS1.1和J2EE1.4规范(持久化,XA消息,事务)。4.对Spring的支持,ActiveMQ可以很容易内嵌到使用Spring的系统里面去,而且也支持Spring2.0的特性。5.测试通过常见的J2EE服务器。如：Geronimo,JBoss4,GlassFish,WebLogic。6.支持多种传送协议：in-VM,TCP,SSL,NIO,UDP,JGroups,JXTA。7.支持通过JDBC和journal提供高速的消息持久化。8.从设计上保证了高性能的集群,客户端-服务器,点对点。9.支持Ajax10.支持与Axis的整合11.可以很容易得调用内嵌JMSprovider,进行测试。通过网络搜索及个人理解，整理出ActiveMQ与Spring整合的文章。相关jar包activemq-core-5.5.1.jargeronimo-j2ee-management_1.1_spec-1.0.1.jargeronimo-jms_1.1_spec-1.1.1.jargeronimo-jta_1.0.1B_spec-1.0.1.jarkahadb-5.5.1.jarxbean-spring-3.7.jarcommons-beanutils.jarcommons-codec.jarcommons-collections.jarcommons-fileupload.jarcommons-httpclient.jarcommons-io.jarcommons-lang.jarcommons-logging.jarcommons-validator.jardom4j-1.6.1.jarjavaee.jarjsf-api.jarjsf-impl.jarjstl.jarlog4j-1.2.15.jarslf4j-api-1.5.8.jarslf4j-log4j12-1.5.8.jaraspectjrt.jaraspectjweaver.jarspring.jarspring.xml?xmlversion=1.0encoding=UTF-8?beansxmlns=:xsi=:p=:tx=:aop=:context=:util=:jee=:amq=:schemaLocation=://://://://://://://://://://://://activemq.apache.org/schema/core!--AnnotationConfig--context:annotation-config/!--CompoentScan--context:component-scanbase-package=com.uu.web.*/!--PropertyPlaceholder--context:property-placeholderlocation=classpath:config.properties/!--AopConfig--aop:aspectj-autoproxy/!--beanid=mysql-dsdestroy-method=closepropertyname=driverClassNamevalue=${dirver}/propertyname=urlvalue=${url}/propertyname=usernamevalue=${username}/propertyname=passwordvalue=${password}//bean--!--使用spring的listenerContainer消息用持久化保存，服务器重启不会丢失也可以配置在${ACTIVEMQ_HOME}/conf/activemq.xml内消息的保存方式文件持久化和数据库持久化此配置是文件持久化--!--EmbeddedActiveMQBroker--amq:brokeruseJmx=falsepersistent=trueamq:persistenceAdapteramq:amqPersistenceAdapterdirectory=G:/amq/!--使用数据库持久化--!--amq:jdbcPersistenceAdapterdataSource=#mysql-ds/--/amq:persistenceAdapteramq:transportConnectorsamq:transportConnectoruri=tcp://localhost:61616//amq:transportConnectors/amq:broker!--ActiveMQconnectionFactory--amq:connectionFactoryid=jmsConnectionFactorybrokerURL=vm://localhost/!--ActiveMQdestinations--!--TOPIC：发布订阅消息无状态，不保证每条消息被消费只有监听该TOPIC地址才能收到消息并消费，否则该消息将会丢失一对多的发布接受策略，可以同时消费多个消息--amq:topicname=TOPICphysicalName=JMS-TOPIC/!--QUEUE：点对点消息数据被持久化，每条消息都能被消费没有监听QUEUE地址也能被消费，数据不会丢失一对一的发布接受策略，保证数据完整--amq:queuename=QUEUEphysicalName=JMS-QUEUE/!--ConnectionFactory--beanid=singleConnectionFactoryclass=org.springframework.jms.connection.SingleConnectionFactorydestroy-method=destroypropertyname=targetConnectionFactoryref=jmsConnectionFactory//bean!--添加事务--beanid=jmsTransactionManagerclass=org.springframework.jms.connection.JmsTransactionManagerpropertyname=connectionFactoryref=singleConnectionFactory//bean!--SpringJmsTemplateconfig--beanid=jmsTemplateclass=org.springframework.jms.core.JmsTemplate!--letswrapinapooltoavoidcreatingaconnectionpersend--propertyname=connectionFactoryref=singleConnectionFactory/!--customMessageConverter--propertyname=messageConverterref=defaultMessageConverter/propertyname=sessionTransactedvalue=true//bean!--converter--beanid=defaultMessageConverterclass=com.uu.activemq.DefaultMessageConverter/!--生产消息配置--!--POJOwhichsendMessageusesSpringJmsTemplate--beanid=topicMessageProducerclass=com.uu.activemq.TopicMessageProducerpropertyname=templateref=jmsTemplate/propertyname=destinationref=TOPIC//beanbeanid=queueMessageProducerclass=com.uu.activemq.QueueMessageProducerpropertyname=templateref=jmsTemplate/propertyname=destinationref=QUEUE//bean!--消费消息配置--!--MessageDrivenPOJO(MDP)--!--consumer1fortopic--beanid=topicConsumerclass=com.uu.activemq.TopicConsumer/!--consumerforqueue--beanid=queueConsumerclass=com.uu.activemq.QueueConsum