文档章节

ActiveMQ入门教程(五) - ActiveMQ与Spring整合

kt431128
 kt431128
发布于 2015/04/03 17:34
字数 706
阅读 87
收藏 0

在前面我们已经可以基本使用ActiveMQ来实现基本的功能了,在网上有很多关于ActiveMQ与Spring整合的例子,在这里的话,也分享一下吧。

与Spring整合开发的话,非常方便。

1. pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>

	<groupId>org.ygy</groupId>
	<artifactId>activemq</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<packaging>jar</packaging>

	<name>activemq</name>
	<url>http://maven.apache.org</url>

	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<spring.version>3.1.1.RELEASE</spring.version>
	</properties>

	<dependencies>
		<dependency>
			<groupId>junit</groupId>
			<artifactId>junit</artifactId>
			<version>4.10</version>
			<scope>test</scope>
		</dependency>

		<!-- activemq,学习中 -->
		<dependency>
			<groupId>org.apache.activemq</groupId>
			<artifactId>activemq-core</artifactId>
			<version>5.7.0</version>
		</dependency>

		<dependency>
			<groupId>org.slf4j</groupId>
			<artifactId>slf4j-api</artifactId>
			<version>1.5.6</version>
		</dependency>

		<dependency>
			<groupId>org.slf4j</groupId>
			<artifactId>slf4j-log4j12</artifactId>
			<version>1.5.6</version>
		</dependency>

		<!-- 与Spring集成 -->
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-context</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-jms</artifactId>
			<version>${spring.version}</version>
		</dependency>

		<dependency>
			<groupId>org.apache.activemq</groupId>
			<artifactId>activemq-spring</artifactId>
			<version>5.8.0</version>
		</dependency>

	</dependencies>
</project>

2. 生产者

package org.ygy.mq.lesson03;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;

import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

/**
 * 
 * @author yuguiyang
 *
 */
public class SpringProducer {
	
	//Spring的模板,封装了很多功能
	private JmsTemplate jmsTemplate;
	
	public void setJmsTemplate(JmsTemplate jmsTemplate) {
		this.jmsTemplate = jmsTemplate;
	}
	
	
	public void send() {
		//使用JMSTemplate可以很简单的实现发送消息
		jmsTemplate.send(new MessageCreator() {
			public Message createMessage(Session session) throws JMSException {
				return session.createTextMessage("地瓜!地瓜!");
			}
		});
	}

}


3. 消费者

package org.ygy.mq.lesson03;

import javax.jms.TextMessage;

import org.springframework.jms.core.JmsTemplate;

/**
 * 
 * @author yuguiyang
 * @description 消费者
 * @time 2013-10-14
 * @version V1.0
 */
public class SpringConsumer {
	private JmsTemplate jmsTemplate;

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

	//接收消息
	public void recive() {
		while (true) {
			try {
				//使用JMSTemplate接收消息
				TextMessage txtmsg = (TextMessage) jmsTemplate.receive();
				if (null != txtmsg) {
					System.out.println("--- 收到消息内容为: " + txtmsg.getText());
				} else {
					break;
				}
			} catch (Exception e) {
				e.printStackTrace();
			}

		}
	}

}


4. 配置文件

其他的代码基本上就是Spring的配置文件了

<?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"
	xsi:schemaLocation="http://www.springframework.org/schema/beans 
        http://www.springframework.org/schema/beans/spring-beans-2.5.xsd 
        http://www.springframework.org/schema/context 
        http://www.springframework.org/schema/context/spring-context-2.5.xsd">


	<!-- 1.配置connectionFactory -->
	<bean id="jmsFactory" class="org.apache.activemq.pool.PooledConnectionFactory" destroy-method="stop">
		<property name="connectionFactory">
			<bean class="org.apache.activemq.ActiveMQConnectionFactory">
				<property name="brokerURL">
					<value>tcp://127.0.0.1:61616</value>
				</property>
			</bean>
		</property>
		<property name="maxConnections" value="100"></property>
	</bean>
	
	<!-- 2.定义消息目标 -->
	<bean id="destination" class="org.apache.activemq.command.ActiveMQQueue">
		<constructor-arg index="0" value="queue_temp"></constructor-arg>
	</bean>
	

	<!-- 3.配置Spring JMS Template -->
	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
		<!-- 3.1 注入jmsFactory -->
		<property name="connectionFactory" ref="jmsFactory"></property>
		
		<!-- 3.2 配置消息目标 -->
		<property name="defaultDestination" ref="destination" />
	</bean>
	
	<!-- 4.配置生产者 -->
	<bean id="springProducer" class="org.ygy.mq.lesson03.SpringProducer">
		<property name="jmsTemplate" ref="jmsTemplate"/>
	</bean>

	<!-- 5.配置消费者 -->
	<bean id="springConsumer" class="org.ygy.mq.lesson03.SpringConsumer">
		<property name="jmsTemplate" ref="jmsTemplate"></property>
	</bean>

</beans>

5. 测试

package org.ygy.mq.lesson03;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

/**
 * ActiveMQ与Spring整合 ===初步整合
 * 1.消费者
 * 2.生产者
 * 3.配置文件
 * 
 * @author Administrator
 *
 */
public class JMSTest {

    public static void main(String[] args) {
        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext-jms.xml");
        
        SpringProducer producer = (SpringProducer)applicationContext.getBean("springProducer");
        producer.send();
        
        SpringConsumer consumer = (SpringConsumer) applicationContext.getBean("springConsumer");
        consumer.recive();
        
    }

}


就这样,整合就算是完成了,Spring将多数的代码封装起来,通过配置文件,就可以了。

这里的消费者,是通过调用JMSTemplate的receive()方法来接收消息的,还有一种是实现监听的方式。

下一篇博客,会分享一下。


本文转载自:http://blog.csdn.net/yuguiyang1990/article/details/12714291

kt431128
粉丝 14
博文 149
码字总数 68823
作品 0
海淀
程序员
私信 提问
Spring Cloud Stream Binder 实现

Spring Cloud Stream Binder 实现 JMS 实现 ActiveMQ 1.增加Maven依赖

xiaoshuaiv5
04/01
0
0
Spring整合ActiveMQ,无相关activemq日志输出

以内嵌的方式整合Spring和ActiveMQ,用的是ActiveMQ5.8.0版本,导入的jar有: activemq-broker-5.8.0.jar activemq-client-5.8.0.jar activemq-console-5.8.0.jar activemq-pool-5.8.0.jar a......

哎哎哎哎啊
2013/09/15
1K
1
ActiveMQ入门,ActiveMQ与RocketMQ的对比

ActiveMQ入门 前面的文章已经写过MQ的相关概念,这里不再赘述。 1.1 ActiveMQ是什么 ActiveMQ是Apache下的开源项目,完全支持JMS1.1和J2EE1.4规范的JMS Provider实现。 1.2 ActiveMQ的特点 ...

LinkedBear
2018/08/04
502
0
JMS配置说明-----activeMQ-5.6

1 简介 activeMQ是一个完全支持JMS1.1 和J2EE规范的JMS Provider实现; 尽管规范出台已经是很久的事情了,但JMS在当今的J2EE应用中仍然扮演着特殊的地位; 特性列表 多种语言和协议编写客户端...

次渠龙哥
2018/06/26
0
0
ActiveMQ启动

自己在本机虚拟机搭建ActiveMQ正常也做了很多测试,但是在测试环境中搭建是发现jdk是1.6于是就把mq的jdk改成单独的jdk,启动正常: INFO: Loading '/usr/local/server/ActiveMQ/apache-activ...

跌倒了爬起来再哭
2016/10/09
499
1

没有更多内容

加载失败,请刷新页面

加载更多

只需一步,在Spring Boot中统一Restful API返回值格式与统一处理异常

统一返回值 在前后端分离大行其道的今天,有一个统一的返回值格式不仅能使我们的接口看起来更漂亮,而且还可以使前端可以统一处理很多东西,避免很多问题的产生。 比较通用的返回值格式如下:...

晓月寒丶
昨天
59
0
区块链应用到供应链上的好处和实际案例

区块链可以解决供应链中的很多问题,例如记录以及追踪产品。那么使用区块链应用到各产品供应链上到底有什么好处?猎头悬赏平台解优人才网小编给大家做个简单的分享: 使用区块链的最突出的优...

猎头悬赏平台
昨天
28
0
全世界到底有多少软件开发人员?

埃文斯数据公司(Evans Data Corporation) 2019 最新的统计数据(原文)显示,2018 年全球共有 2300 万软件开发人员,预计到 2019 年底这个数字将达到 2640万,到 2023 年达到 2770万。 而来自...

红薯
昨天
65
0
Go 语言基础—— 通道(channel)

通过通信来共享内存(Java是通过共享内存来通信的) 定义 func service() string {time.Sleep(time.Millisecond * 50)return "Done"}func AsyncService() chan string {retCh := mak......

刘一草
昨天
58
0
Apache Flink 零基础入门(一):基础概念解析

Apache Flink 的定义、架构及原理 Apache Flink 是一个分布式大数据处理引擎,可对有限数据流和无限数据流进行有状态或无状态的计算,能够部署在各种集群环境,对各种规模大小的数据进行快速...

Vincent-Duan
昨天
60
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部