在Spring中使用JMS

http://xiangtui.iteye.com/blog/978674

什么是JMS？

JMS即java消息服务，JMS通过消息的形式来降低组件之间的耦合度。

JMS由两部分组成消息发送者和消息监听者。

JMS的运用场景？

用户系统负责维护用户信息，文档系统负责维护文档信息，但是当用户删除的时候，需要将他所撰写的文档信息也删除的时候，在用户管理模块调用文档管理模块的接口，会造成用户模块和业务模块紧耦合。

这个时候可以使用JMS技术来将紧耦合转化为松耦合，具体做法是用户系统在删除，修改用户的时候往JMS服务器发送更新消息，又业务系统监听这些消息，然后按照自己的业务逻辑来进行相应的处理。

即组件A做了一件事情往消息服务器上发送了一个通知，组件B监听到了消息，处理自己的业务逻辑。

详细步骤：

1：配置消息服务器：配置JMS需要两个对象connectionFactory和 destination。

connectionFactory使用jboss自带的TopicConnectionFactory。

destination可以使用自定义的。

kiral-jms-service.xml 注意：文件名称一定要是-service.xml结尾。这个文件放在部署目录下。

xml 代码

< xml version = "1.0" encoding = "UTF-8" ?>
< server >
< mbean code = "org.jboss.mq.server.jmx.Topic"
name = "jboss.mq.destination:service=Topic,name=kiralJms" >
< depends optional-attribute-name = "DestinationManager" > jboss.mq:service = DestinationManager depends >
< depends optional-attribute-name = "SecurityManager" > jboss.mq:service = SecurityManager depends >
< attribute name = "SecurityConf" >
< security >
< role name = "guest" read = "true" write = "true" />
< role name = "publisher" read = "true" write = "true" create = "false" />
< role name = "durpublisher" read = "true" write = "true" create = "true" />
security >
attribute >
mbean >
server >

2：配置发送消息端

bean-jms.xml

xml 代码

xml version = "1.0" encoding = "GB2312" ?>
< beans >
< bean id = "jmsConnectionFactory"
class = "org.springframework.jndi.JndiObjectFactoryBean" >
< property name = "jndiName" >
< value > TopicConnectionFactory value >
property >
bean >
< bean id = "destination"
class = "org.springframework.jndi.JndiObjectFactoryBean" >
< property name = "jndiName" >
< value > topic/kiralJms value >
property >
bean >
< bean id = "jmsTemplate"
class = "org.springframework.jms.core.JmsTemplate" >
< property name = "connectionFactory" >
< bean
class = "org.springframework.jms.connection.SingleConnectionFactory" >
< property name = "targetConnectionFactory"
ref = "jmsConnectionFactory" />
bean >
property >
bean >
< bean id = "messageProducer"
class = "jms.MessageProducer" >
< property name = "template" ref = "jmsTemplate" />
< property name = "destination" ref = "destination" />
bean >
beans >

java 代码

import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
/***********************************************************
* 消息发送者
*
* @作者：kiral
* @日期：2007-7-3
**********************************************************/
public class MessageProducer {
public void send( final String message) {
template.send(destination, new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
Message m = session.createTextMessage(message);
return m;
}
});
}
private JmsTemplate template;
private Destination destination;
public void setDestination(Destination destination) {
this .destination = destination;
}
public void setTemplate(JmsTemplate template) {
this .template = template;
}
}

发送方调用send方法发送消息。

3：配置消息接收者

xml 代码

< xml version = "1.0" encoding = "UTF-8" ?>
< beans >
< bean id = "jmsConnectionFactory"
class = "org.springframework.jndi.JndiObjectFactoryBean" >
< property name = "jndiName" >
< value > TopicConnectionFactory value >
property >
< bean >
< bean id = "destination"
class = "org.springframework.jndi.JndiObjectFactoryBean" >
< property name = "jndiName" >
< value > topic/kiralJms value >
property >
< bean >
< bean id = "messageListener"
class = "jms.MessageConsumer" >
< property name = "worksheetService" ref = "worksheetService" > property >
< bean >
< bean id = "listenerContainer"
class = "org.springframework.jms.listener.DefaultMessageListenerContainer" >
< property name = "connectionFactory" ref = "jmsConnectionFactory" />
< property name = "destination" ref = "destination" />
< property name = "messageListener" ref = "messageListener" />
< bean >
< beans >

java 代码

import javax.jms.Message;
import javax.jms.MessageListener;
import org.kiral.flow.service.WorksheetService;
/*******************************************************************************
* 消息接收者
*
* @作者：kiral
* @日期：2007-7-3
******************************************************************************/
public class MessageConsumer implements MessageListener {
private WorksheetService worksheetService;
public WorksheetService getWorksheetService() {
return worksheetService;
}
public void setWorksheetService(WorksheetService worksheetService) {
this .worksheetService = worksheetService;
}
public void onMessage(Message message) {
System.out.println(message);
worksheetService.updateRole();
}
}

接受方一旦接收到消息，就会打印在控制台。

在Spring中使用JMS相关推荐

spring 中的JMS是什么？
程序员看源码是成长的必要条件,最近在看spring的源码,看到spring框架中有一个模块是JMS,那么JMS到底是什么呢?那我们分成几个步骤来了解下吧. 1.什么是JMS?以及JMS的作用. JMS ...
Spring中的事务管理详解
在这里主要介绍Spring对事务管理的一些理论知识,实战方面参考上一篇博文: http://www.cnblogs.com/longshiyVip/p/5061547.html 1. 事务简介: 事务 ...
如何在优雅地Spring 中实现消息的发送和消费
本文将对rocktmq-spring-boot的设计实现做一个简单的介绍,读者可以通过本文了解将RocketMQ Client端集成为spring-boot-starter框架的开发细节,然后通过一个 ...
如何在优雅地Spring 中实现消息的发送和消费 1
本文将对rocktmq-spring-boot的设计实现做一个简单的介绍,读者可以通过本文了解将RocketMQ Client端集成为spring-boot-starter框架的开发细节,然后通过一个 ...
spring事务管理器的作用_【面试必问】Spring中的事务管理详解
在这里主要介绍Spring对事务管理的一些理论知识,实战方面参考上一篇博文: http://www.cnblogs.com/longshiyVip/p/5061547.html 1. 事务简介: 事务 ...
spring(7)---深入理解Spring核心技术——Spring中的各模块详解
深入理解Spring核心技术--Spring中的各模块详解 Spring框架的两个基本概念IOC容器和AOP,相信大家现在对Spring中的这两个部分的基本概念有了一定的认识,好了,那么今天我们就来正 ...
Spring中的事务控制
Chapter 1. Spring中的事务控制(Transacion Management with Spring) Table of Contents 1.1. 有关事务(Transaction)的 ...
Spring中的事务控制(Transacion Management with Spring)
1.1. 有关事务(Transaction)的楔子 1.1.1. 认识事务本身1.1.2. 初识事务家族成员 1.2. 群雄逐鹿下的Java事务管理 1.2.1. Java平台的局部事务支持1.2.2 ...
浅谈spring中的设计模式（转）
工厂模式 BeanFactory,从xml或者注解加载BeanDefinition,然后实例化对象,其中AbstractAutowiredCapableBeanFactory实现了主要的逻辑单例模式 ...

在Spring中使用JMS

在Spring中使用JMS相关推荐

最新文章

热门文章