Spring和JMS集成详细解释

要将spring与JMS集成, 你需要创建两个应用程序。

1. JMS接收器应用程序
2. 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集成的简单步骤：

1. MyMessageListener.java
2. TestListener.java
3. 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应用程序的文件：

1. MyMessageSender.java
2. TestJmsSender.java
3. 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="myqueue"></property>
</bean>

<context:component-scan base-package="com.srcmini"></context:component-scan>

</beans>

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

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