Spring和JMS集成详细解释

【Spring和JMS集成详细解释】要将spring与JMS集成, 你需要创建两个应用程序。

JMS接收器应用程序
JMS Sender应用程序

为了使用spring创建JMS应用程序, 我们使用Apache的Active MQ Server创建队列。
让我们看一下将spring应用程序与JMS集成的简单步骤：
所需的Jar文件
1)你需要添加spring core, spring misc, spring aop, spring j2ee和spring persistence core jar文件。
下载Spring的所有jar文件, 包括aop, mvc, j2ee, remoting, oxm等。
2)添加位于activemq目录内的activemqall5.9.jar文件。
在ActiveMQ Server中创建队列
下载Active MQ服务器下载Active MQ
双击位于apache-activemq-5.9.1-bin \ apache-activemq-5.9.1 \ bin \ win64或win32目录中的activemq.bat文件。
现在, activemq服务器控制台将打开。
通过http：// localhost：8161 / admin / url访问activemq服务器的管理控制台。

文章图片
现在, 单击” 队列” 链接, 在文本字段中写入myqueue, 然后单击” 创建” 按钮。

文章图片
1)JMS接收器应用程序
让我们看一下将spring应用程序与JMS集成的简单步骤：

MyMessageListener.java
TestListener.java
applicationContext.xml

1) MyMessageListener.java

package com.srcmini; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.TextMessage; public class MyMessageListener implements MessageListener{ @Override public void onMessage(Message m) { TextMessage message=(TextMessage)m; try{ System.out.println(message.getText()); }catch (Exception e) {e.printStackTrace(); } } }

2) TestListener.java

package com.srcmini; import org.springframework.context.support.GenericXmlApplicationContext; public class TestListener { public static void main(String[] args) { GenericXmlApplicationContext ctx=new GenericXmlApplicationContext(); ctx.load("classpath:applicationContext.xml"); ctx.refresh(); while(true){} } }

3)applicationContext.xml

< ?xml version="1.0" encoding="UTF-8"?> < beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jms="http://www.springframework.org/schema/jms" xmlns:p="http://www.springframework.org/schema/p" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsd"> < bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory" p:brokerURL="tcp://localhost:61616" /> < bean id="listener" class="com.srcmini.MyMessageListener"> < /bean> < jms:listener-container container-type="default" connection-factory="connectionFactory" acknowledge="auto"> < jms:listener destination="myqueue" ref="listener" method="onMessage"> < /jms:listener> < /jms:listener-container> < /beans>

2)JMS Sender应用程序
让我们看一下创建JMS Sender应用程序的文件：

MyMessageSender.java
TestJmsSender.java
applicationContext.xml

1) MyMessageListener.java

package com.srcmini; import javax.jms.*; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jms.core.JmsTemplate; import org.springframework.jms.core.MessageCreator; import org.springframework.stereotype.Component; @Component("messageSender") public class MyMessageSender { @Autowired private JmsTemplate jmsTemplate; public void sendMessage(final String message){ jmsTemplate.send(new MessageCreator(){@Override public Message createMessage(Session session) throws JMSException { return session.createTextMessage(message); } }); } }

2) TestJmsSender.java

package com.srcmini; import org.springframework.context.support.GenericXmlApplicationContext; public class TestJmsSender { public static void main(String[] args) { GenericXmlApplicationContext ctx=new GenericXmlApplicationContext(); ctx.load("classpath:applicationContext.xml"); ctx.refresh(); MyMessageSender sender=ctx.getBean("messageSender", MyMessageSender.class); sender.sendMessage("hello jms3"); } }

3)applicationContext.xml

< ?xml version="1.0" encoding="UTF-8"?> < beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:jms="http://www.springframework.org/schema/jms" xmlns:p="http://www.springframework.org/schema/p" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsd"> < bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory" p:brokerURL="tcp://localhost:61616" /> < bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> < constructor-arg name="connectionFactory" ref="connectionFactory"> < /constructor-arg> < property name="defaultDestinationName" value="http://www.srcmini.com/myqueue"> < /property> < /bean> < context:component-scan base-package="com.srcmini"> < /context:component-scan> < /beans>

下载JMS接收器示例(使用Myeclipse IDE开发)
下载JMS Sender示例(使用Myeclipse IDE开发)