一、JMS简介
JMS消息可以有效的调动程序中的各种动作,例如,当我们完成一个动作后,我们需要一些程序完成他们自己相应的动作,这时候我们只需要发送一个消息出来,当他们接收到这个消息时,就可以完成自己的事情,是一个很方便的技术,现在用到的JMS消息一般都是通过ActiveMQ来完成,ActIveMQ是一个成熟的框架,可以通过tcp发送JMS,还可以在程序内发送JMS,下面来通过一个实例来介绍。
二、环境搭建
这个实例是在Spring的基础上完成的,所以需要导入spring的所有jar包,当然还需要导入activemq的jar包,下载activemq以后就可以找到一个activemq-all.jar的jar包,导入即可
三、配置文件简介
首先application.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:amq="http://activemq.apache.org/schema/core" xmlns:aop="http://www.springframework.org/schema/aop" xsi:schemaLocation=" http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core-5.8.0.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd"> <!-- 激活组件扫描功能,在包cn.ysh.studio.spring.aop及其子包下面自动扫描通过注解配置的组件 --> <context:annotation-config /> <context:component-scan base-package="main.java.com"/> <!-- 激活自动代理功能 --> <aop:aspectj-autoproxy proxy-target-class="true"/> <import resource="jms_client.xml"/> </beans>
这里的spring就是完成了组件扫描以及aop代理的一些配置,然后就是导入配置activemq的配置文件,如下
<?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:amq="http://activemq.apache.org/schema/core" xmlns:aop="http://www.springframework.org/schema/aop" xsi:schemaLocation=" http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core-5.8.0.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd"> <!-- 激活组件扫描功能,在包cn.ysh.studio.spring.aop及其子包下面自动扫描通过注解配置的组件 --> <bean id="broker" class="org.apache.activemq.xbean.BrokerFactoryBean"> <property name="config" value="classpath:main/java/conf/ActiveMQConfig.xml" /> <property name="start" value="true" /> </bean> <bean id="myamqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL" value="tcp://10.10.11.37:61616"/> <property name="trustedPackages"> <list> <value>main.java</value> </list> </property> </bean> <bean id="myconnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory"> <property name="targetConnectionFactory" ref="myamqConnectionFactory"></property> <property name="sessionCacheSize" value="100" /> </bean> <bean id="myjmsQueueTemplate" class="org.springframework.jms.core.JmsTemplate"> <constructor-arg ref="myconnectionFactory" /> <property name="pubSubDomain" value="false" /> </bean> <bean id="myjmsTopicTemplate" class="org.springframework.jms.core.JmsTemplate"> <constructor-arg ref="myconnectionFactory" /> <property name="pubSubDomain" value="true" /> </bean> </beans>
这里第一步因为不是完整的activemq,是spring嵌入式activemq,所以需要启动一个broker来启动activemq,这里需要用到的是一个另外的activemq配置,内容如下:
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:amq="http://activemq.apache.org/schema/core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd"> <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer" /> <broker useJmx="false" persistent="false" xmlns="http://activemq.apache.org/schema/core"> <transportConnectors> <transportConnector uri="tcp://10.10.11.37:61616"/> </transportConnectors> </broker> </beans>
启动完broker之后就算是完成了acrivemqmq的启动,接下来就开始定义连接工厂了,连接工厂需要制定brokerURL和信任包(不知道有什么卵用),接着就是吧activemq的连接工厂转换成spring的连接工厂,最后两个就不多说了,一个是队列消息templete一个是主题消息template,都是非常简单的,其中如果我们把tcp改为vm则是在程序内发送JMS消息
四、一个服务
在这里我们需要写一个服务用来注册消息监听器,发送消息 , 先把代码贴出来吧
package main.java.com.consumer; import java.io.Serializable; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageConsumer; import javax.jms.Queue; import javax.jms.Session; import javax.jms.Topic; import org.apache.activemq.command.ActiveMQQueue; import org.apache.activemq.command.ActiveMQTopic; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.jms.core.JmsTemplate; import org.springframework.jms.core.MessageCreator; import org.springframework.stereotype.Component; @Component("msgService") public class MsgServiceImpl { //存放注册了的监听器 private Map<String ,Object> consumers = new ConcurrentHashMap<String , Object>(); @Autowired @Qualifier("myjmsQueueTemplate") private JmsTemplate queueTemplate ; @Autowired @Qualifier("myjmsTopicTemplate") private JmsTemplate topicTemplate ; @Autowired @Qualifier("myconnectionFactory") private ConnectionFactory connectionFactory ; public void sendMsg(String destation ,final Serializable message){ if(consumers.containsKey(destation)){ if(consumers.get(destation) instanceof Queue){ queueTemplate.send(destation , new MessageCreator() { @Override public Message createMessage(Session session) throws JMSException { return session.createObjectMessage(message); } }); return ; } if(consumers.get(destation) instanceof Topic){ topicTemplate.send(destation , new MessageCreator() { @Override public Message createMessage(Session session) throws JMSException { return session.createObjectMessage(message); } }); } return ; } } public void registerConsumer(Consumer consumer , JMSConstant type){ try { Connection connection = connectionFactory.createConnection() ; connection.start(); Session session = connection.createSession( false, Session.AUTO_ACKNOWLEDGE) ; if(type != null && type.equals(JMSConstant.TYPE_TOPIC)){ Topic topic = new ActiveMQTopic(consumer.getName()) ; MessageConsumer messageConsumer = session.createConsumer(topic) ; messageConsumer.setMessageListener(new JmsMessageListener(consumer)); consumers.put(consumer.getName(), topic) ; }else{ Queue queue = new ActiveMQQueue(consumer.getName()) ; MessageConsumer messageConsumer = session.createConsumer(queue) ; messageConsumer.setMessageListener(new JmsMessageListener(consumer)); consumers.put(consumer.getName(), queue) ; } } catch (JMSException e) { e.printStackTrace(); } } }
简单说一下吧,首先把这个类注册到spring中,名字为msgService 然后定义一个map来存放目的地,接着就是开始定义的template和从测测提哦你Factory了这些都不多说,都是开始定义了的东西
第一个方法:
sendMsg
可以看到他的参数有两个,一个为目的地,一个为消息内容 ,如果目的地未注册则返回不发送消息,发送消息我们选择发送Object消息,当然所有的Object实例都需要实现Serializable序列化,然后创建消息发送出去
第二个方法
registerConsumer
注册监听器,这里先介绍接口Consumer
package main.java.com.consumer; import java.io.Serializable; public interface Consumer { public String getName() ; public void onMessage(Serializable msg); }
所有的监听器都需要实现这个接口,
然后自己定义一个JmsMessageListener :
package main.java.com.consumer; import java.io.Serializable; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.ObjectMessage; public class JmsMessageListener implements MessageListener{ private Consumer consumer ; public JmsMessageListener(Consumer consumer){ this.consumer = consumer ; } @Override public void onMessage(Message msg) { if(msg != null){ try{ consumer.onMessage(createObjectMsg(msg)) ; }catch(Exception e){ e.printStackTrace() ; } } } private Serializable createObjectMsg(Message msg) throws Exception { Serializable message = ((ObjectMessage) msg).getObject() ; return message ; } }
这个很简单不多说,这是这个服务两个简单必须的方法、
这样我们只需定义一个监听器,
package main.java.com.consumer; import java.io.Serializable; public class JmsConsumer1 implements Consumer{ @Override public String getName() { return MsgTypeInfo.TEST.name(); } @Override public void onMessage(Serializable msg) { System.out.println("JmsConsumer1 收到 消息 "+ msg); } }
然后把它注册到服务,msgService.registerConsumer(new JmsConsumer1(), JMSConstant.TYPE_TOPIC) ;
我们发送一条消息:
msgService.sendMsg(MsgTypeInfo.TEST.name(), "132") ;
就可以看到控制台打印到了接收到的消息。
相关推荐
这些提供商提供了实现JMS规范的具体库,使得我们可以通过Java API与其交互。 2. **创建ConnectionFactory**:ConnectionFactory是创建JMS连接的工厂类。在连接池实现中,我们需要一个池化的ConnectionFactory,这...
**Spring与JMS消息传递** 在Java世界中,Java Message Service (JMS) 是一个标准接口,用于在分布式环境中...在实际项目中,结合具体的业务需求,可以灵活选择合适的模式和策略来利用Spring和JMS实现高效的消息通信。
在这个主题中,我们将深入探讨JMS消息的发送和订阅,以及如何通过Apache Camel这一集成框架来实现。 **JMS核心概念** 1. **消息**: JMS中的基本单元,它包含了要传递的数据。 2. **生产者**: 创建并发送消息的应用...
WebLogic Server是一款由Oracle公司提供的企业级应用服务器,它支持Java Message Service (JMS) 规范,允许在分布式环境中可靠地发送和接收消息。JMS是Java平台上的标准接口,用于实现应用程序间的异步通信。本文将...
本话题主要探讨如何在Spring框架下与WebLogic 9.2集成,实现JMS(Java Message Service)消息的发送。 首先,JMS是一种标准的API,用于在分布式环境中传递消息。通过JMS,应用可以在异步和解耦的方式下进行通信,...
OSB 中的 JMS 配置及队列使用是实现消息队列的重要手段,本文将详细介绍 OSB 中 JMS 配置及队列使用的步骤。 环境准备 在开始配置 JMS 之前,需要安装 Oracle Service Bus (OSB) 10.3.1 和 Weblogic 服务器。同时...
**J2EE中的JMS消息服务** Java Message Service(JMS)是Java平台上的一个标准接口,用于在分布式环境中提供异步的消息传递...在实际项目中,配合使用源码和工具,如`MessageDriverBean`,可以更好地实现JMS的功能。
1. **消息对象**:实现JMS接口,如`MessageProducer`和`MessageConsumer`,以及各种特定类型的消息如`TextMessage`和`ObjectMessage`。 2. **连接管理**:如何建立和管理与消息服务器的连接,包括连接工厂...
在Java世界中,ActiveMQ和Spring的整合是企业级应用中常见的消息中间件解决方案,用于实现JMS(Java Message Service)消息传递。本教程将深入探讨如何将这两个强大的工具结合在一起,以创建一个简单的发送JMS消息的...
在本篇讨论中,我们将关注如何利用Spring框架和ActiveMQ来实现JMS消息队列。 首先,我们需要理解Spring框架中的JMS支持。Spring提供了一个强大的抽象层,简化了与各种MQ提供商(如ActiveMQ、RabbitMQ等)的集成。它...
标题中的“Spring整合Blazeds实现ActiveMQ JMS消息服务”指的是在Java应用程序中使用Spring框架与Blazeds(一个Flex和Java之间的消息传递中间件)集成,通过ActiveMQ(一个流行的开源JMS提供商)来实现消息队列服务...
在这个测试中,你可以看到如何使用Spring JMS API来发送和接收消息,验证ActiveMQ配置的正确性,以及消息传递的有效性。 总的来说,这个示例涵盖了以下关键知识点: 1. ActiveMQ的安装和运行。 2. Spring框架中JMS...
在本文中,我们将深入探讨如何使用SpringBoot、...通过理解这些技术的工作原理和集成方式,你可以更好地实现后台消费者的监听、生产者的发送,以及消息接口和服务的实现,从而在你的项目中构建出强大的消息处理能力。
而JMS(Java Message Service)是Java平台中用于创建、发送、接收和读取消息的标准API,它支持异步通信和解耦应用程序。JTA(Java Transaction API)则是处理分布式事务的标准,能够协调多个资源管理器(如数据库和...
通过Spring框架,我们可以方便地在应用程序中集成JMS,实现消息的异步处理,提高系统的解耦性和容错性。这不仅有助于提升系统性能,还能使代码更加清晰、易于维护。在实际项目中,结合Spring Boot和ActiveMQ等开源...
1. **创建JMS测试步骤**:在soapUI项目中,右键点击测试套件或测试步骤,选择“Add New Step” -> “JMS Request”。在这里,你需要配置JMS连接工厂、目的地类型(队列或主题)、目的地名称等参数。 2. **配置JMS...
在本文中,我们将深入探讨如何使用Spring Boot与Java消息服务(JMS)来发送电子邮件,包括文本、HTML、图片和附件。Spring Boot以其强大的依赖管理和自动化配置能力,使得集成各种功能变得异常简单,包括集成JMS进行...
在Java环境中实现JMS发送端时,通常需要依赖一些特定的jar包。下面我们将详细讨论这些jar包以及它们在JMS发送端中的作用。 1. **JMS API**:这是核心的JMS接口,定义了生产者(发送者)、消费者(接收者)以及消息...
同时,正确配置JMS连接工厂、目的地(如队列或主题)、以及消费者和生产者的实现是成功接收和发送消息的关键。记得在部署环境中添加这些依赖,并在代码中正确引用,以实现高效、可靠的JMS通信。