文档章节

JMS在Spring框架下的应用

rakshasa
 rakshasa
发布于 2014/12/27 17:16
字数 1239
阅读 61
收藏 2

    上传通讯薄操作,除了向客户端返回好友列表外,还需要将上传的通讯簿存储到数据库中,以便进行后期数据分析。一开始,我的设计是将通讯薄全部插到数据库后再返回客户端,但经过测试,用户访问速度过慢,于是我就采用多线程处理的方式,单开一个线程,在后台慢慢插去吧,不影响客户端访问速度就行。我对多线程也不是太熟悉,代码设计是参考硕硕的,由于时间紧,也没多思考,虽然用得心里有点不踏实。

    今早刚到公司就被游游责问,“通讯薄存数据库开了多线程,你考虑线程安全了吗”,志东也说,“开了多线程,如果线程池满,怎么办,数据会丢失的。。。”我只能实话实说,当时确实没考虑线程安全问题,代码参考自硕硕。。。志东生气了,“张硕是错的你也抄!”。。。我顿时无语,只怨当时开动线程的时候没多考证一下。唉,痛定思痛,根据志东的建议:不要在Spring的Controller里开多线程,如果想进行异步操作,可使用JMS。。。。

    忙完令人超级蛋疼的LBS的bug,着手对上传通讯薄JMS的优化。看了半下午JMS,照着Demo,JMS算是跑起来了。具体配置下面将详细阐述。

    受教育的一天那。。。有时,犯错,确实会使人进点步。


另:Spring的线程问题,到底怎么个情况,需要好好的搞一搞。线程池?多大?怎么设置的?SPring的线程模型?


    对JMS的一些理解:

    JMS有两种工作模式,vm和tcp,使用vm模式时,不必ActiveMQ服务器。使用tcp时,需要使用ActiveMQ,从而建立Tcp链接。

    ActiveMQ官网下载地址:http://activemq.apache.org/download.html

 

1. 使用jms所需的依赖包

 

    activemq-all-5.3.0.jar

    activemq-web-5.3.0.jar

    geronimo-j2ee-management_1.0_spec-1.0.jar

    geronimo-jms_1.1_spec-1.1.1.jar

    geronimo-jta_1.0.1B_spec-1.0.1.jar

 

2. 搭好Spring环境

 

    略

 

3. 配置

 

    这里主要介绍使用Spring监听来实现异步接受消息。

 

    (1) applicationContext-jms.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:util="http://www.springframework.org/schema/util"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
		http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd">
	<!-- 消息中介-->
	<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
		<property name="brokerURL" value="vm://localhost"/>
	</bean>
	<!-- 队列目的地-->
	<bean id="myQueue" class="org.apache.activemq.command.ActiveMQQueue">
		<constructor-arg index="0" value="notifyQueue"/>
	</bean>
	<!-- 订阅目的地-->
	<bean id="myTopic" class="org.apache.activemq.command.ActiveMQTopic">
		<constructor-arg index="0" value="notifyTopic"/>
	</bean>
	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
		<property name="connectionFactory" ref="connectionFactory"/>
		<!-- 设置默认的消息目的地-->
		<property name="defaultDestination" ref="myQueue"/>
		<!-- 由于receiver方法是同步的,所以我们在这里对接收设置超时时间-->
		<property name="receiveTimeout" value="60000"/>
	</bean>
	
	<!-- 消息发送者-->
	<bean id="producer" class="com.sszd.springjms.JMSProducer">
		<property name="jmsTemplate" ref="jmsTemplate"/>
		<!-- 消息目的地,因为jmsTemplate有默认的了,所以这里可以省略
		<property name="destination" ref=" myQueue "/>-->
	</bean>
	
	<!-- 消息接收监听器用于异步接收消息-->
	<bean class="org.springframework.jms.listener.SimpleMessageListenerContainer">
		<property name="connectionFactory" ref="connectionFactory"/>
		<property name="destination" ref="myQueue"/>
		<!--  <property name="messageListener" ref="studentMDP"/>-->
		<property name="messageListener" ref="pureMDPAdapter"/>
		
	</bean>
	<!-- 消息监听实现方法一 -->
	<bean id="studentMDP" class="com.sszd.springjms.StudentMDP"/>
	
	<!-- 消息监听实现方法二,使用POJO -->
	<bean id="pureMDPAdapter" class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
		<property name="delegate" ref="pureStudentMDP"/>
		<property name="defaultListenerMethod" value="process"/>
	</bean>
	<!-- 消息驱动pojo -->
	<bean id ="pureStudentMDP" class="com.sszd.springjms.PureStudentMDP" >
		<!--可以配置Spring的依赖
		<property name="springOperation" ref="springOperation"/>
		-->
	</bean>
	
</beans>

 

    (2) 消息生产者

 

package com.sszd.springjms;

import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.Session;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

import com.neu.edu.model.Student;

/**
 * 利用Spring中的JmsTemplate产生消息
 * 
 */
public class JMSProducer {
	private JmsTemplate jmsTemplate;

	public JmsTemplate getJmsTemplate() {
		return jmsTemplate;
	}

	public void setJmsTemplate(JmsTemplate jmsTemplate) {
		this.jmsTemplate = jmsTemplate;
	}

	// 传送一个Student 对象(重写了toString()方法)
	public void send(final Student student) {
		this.jmsTemplate.send(new MessageCreator() {
			public Message createMessage(Session session) throws JMSException {
				MapMessage message = session.createMapMessage();
				message.setString("key1", student.getName());
				message.setString("key2", student.getAge());
                                //也可以直接发送对象,对象必须是可序列化的
                                //ObjectMessage message = session.createObjectMessage();
                                //message.setObject(student);
				return message;
			}
		});
	}
}

 

    (3) 消息接受监听器实现

 

    方法一:

 

package com.sszd.springjms;

import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.MessageListener;

import com.neu.edu.model.Student;

/**
 * 消息监听类
 * */
public class StudentMDP implements MessageListener {
	public void onMessage(Message message) {
		MapMessage mapMessage = (MapMessage) message;
		Student student = new Student();
		try {
			student.setName(mapMessage.getString("key1"));
			student.setAge(mapMessage.getString("key2"));
			try {
				Thread.sleep(1000);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			System.out.println(student.getName());
		} catch (JMSException e) {
			e.printStackTrace();
		}
	}
}

    

    方法二(使用POJO):

 

package com.sszd.springjms;

import java.util.Map;

import com.neu.edu.model.Student;

/**
 *纯POJO实现消息接收
 * */
public class PureStudentMDP {
	//private PoiDataFromProviderService poiDataFromProviderService;可以添加Spring依赖注入
	public void process(Map map) {
		Student student = new Student();
		student.setName((String) map.get("key1"));
		student.setAge((String) map.get("key2"));
		System.out.println("PureStudentMDP:");
		System.out.println(student);
	}
/*可以直接接收对象
	public void process(Objec obj) {
		Student student = (Student)obj;
		System.out.println(student);
	}
*/

}

 

    (4) 业务层调用及配置

    xml配置

<bean name="jmsLogic" class="com.neu.edu.controllers.JMSLogic">
		<property name="jmsProducer" ref="producer"/>
</bean>

    业务层调用:

。。。
       private JMSProducer jmsProducer;

	public void upload() {
		。。。
		Student student = new Student();
		for (int i = 0; i < 15; i++) {
			student.setName("zzq" + i);
			student.setAge("25");
			jmsProducer.send(student);
			System.out.println("消息已经发送.....");
		}
	}
        。。。

 

4. 说明

    本示例参考自百度文库的资料(见附件Spring中使用JMS.pdf http://wenku.baidu.com/view/98242d75f46527d3240ce0cc.html ),关于JMS的深入学习,将在后续章节补充。

 

http://www.blogjava.net/heyang/archive/2009/09/24/296254.html

本文转载自:http://zzqrj.iteye.com/blog/836229

rakshasa
粉丝 34
博文 142
码字总数 16820
作品 0
昆明
高级程序员
私信 提问
Java新手如何学习Spring、Struts、Hibernate三大框架?

ava三大框架的各自作用 一、Spring Spring是一个解决了许多在J2EE开发中常见的问题的强大框架。 Spring提供了管理业务对象的一致方法并且鼓励了注入对接口编程而不是对类编程的良好习惯。Spr...

懿涌
2017/06/02
926
9
Spring Security 5.0.0.M4 发布,Spring 安全框架

Spring Security 5.0.0.M4 发布了。Spring Security 的前身是 Acegi Security ,是 Spring 项目组中用来提供安全认证服务的框架。 Spring Security 为基于J2EE企业应用软件提供了全面安全服务...

淡漠悠然
2017/09/14
344
3
Spring Security 5.0.0.M1 发布,Spring 安全框架

Spring Security 5.0.0.M1 发布了。Spring Security 的前身是 Acegi Security ,是 Spring 项目组中用来提供安全认证服务的框架。 Spring Security 为基于J2EE企业应用软件提供了全面安全服务...

淡漠悠然
2017/05/11
1K
2
Spring Security 3.1.0.M2 发布

Spring Security 的前身是 Acegi Security ,是 Spring 项目组中用来提供安全认证服务的框架。 Spring Security 为基于J2EE企业应用软件提供了全面安全服务。特别是使用领先的J2EE解决方案-...

红薯
2010/12/22
1K
0
DispatcherServlet的用法

DispatcherServlet实际上是一个Servlet(它从HttpServlet继承而来)。和其它Servlet一样,DispatcherServlet定义在web应用的web.xml文件里。DispatcherServlet处理的请求必须在同一个web.xml文...

sch_1986
2012/08/01
378
0

没有更多内容

加载失败,请刷新页面

加载更多

从零基础到拿到网易Java实习offer,我做对了哪些事

作为一个非科班小白,我在读研期间基本是自学Java,从一开始几乎零基础,只有一点点数据结构和Java方面的基础,到最终获得网易游戏的Java实习offer,我大概用了半年左右的时间。本文将会讲到...

Java技术江湖
昨天
4
0
程序性能checklist

程序性能checklist

Moks角木
昨天
6
0
VUE 计算属性

本文转载于:专业的前端网站▶VUE 计算属性 1、示例代码 <!DOCTYPE html><html lang="zh"> <head> <meta charset="UTF-8" /> <title>vue示例</title> </hea......

前端老手
昨天
5
0
快速搭建LNMT平台和环境部署 Tomcat详解

Tomcat部署的基本概念 1. CATALINA_HOME与CATALINA_BASE分别指什么?     CATALINA_HOME指的是Tomcat的安装目录     bin:\\Tomcat一些脚本存放目录,比如启动脚本startup.bat/start...

网络小虾米
昨天
6
0
float浮动

float浮动 float浮动概念及原理: 文档流:文档流是文档中可显示对象在排列时所占用的位置。 加浮动的元素,会脱离文档流,会沿父容器靠左或靠右排列,如果之前已经有浮动的元素,会挨着浮动...

studywin
昨天
7
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部