个性化阅读
专注于IT技术分析

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服务器的管理控制台。

打开activemq服务器

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

在activemq服务器中创建队列

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开发)

赞(0) 打赏
未经允许不得转载:srcmini » Spring和JMS集成详细解释
分享到: 更多 (0)

评论 抢沙发

评论前必须登录!

 

觉得文章有用就打赏一下文章作者

微信扫一扫打赏