第二章:ActiveMQ与spring的整合使用

第二章:ActiveMQ与spring的整合使用第二章:ActiveMQ与spring的整合使用

大家好,又见面了,我是你们的朋友全栈君。

在之前建好的工程的主目录下建一个resource目录,然后建一个配置文件,我这里是activeMq.xml

配置文件的内容如下:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"  
xmlns:context="http://www.springframework.org/schema/context"  
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:amq="http://activemq.apache.org/schema/core"  
xmlns:jms="http://www.springframework.org/schema/jms"  
xsi:schemaLocation="http://www.springframework.org/schema/beans     
        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd     
        http://www.springframework.org/schema/context     
        http://www.springframework.org/schema/context/spring-context-4.0.xsd  
        http://www.springframework.org/schema/jms  
        http://www.springframework.org/schema/jms/spring-jms-4.0.xsd  
        http://activemq.apache.org/schema/core  
        http://activemq.apache.org/schema/core/activemq-core-5.8.0.xsd">  
	 <!-- 真正可以产生Connection的ConnectionFactory,由对应的 JMS服务厂商提供 -->  
	 <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
	 	<property name="brokerURL" value="tcp://192.168.72.133:61616"></property>
	 </bean>
	  <!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory -->  
	  <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
	  	 <!-- 目标ConnectionFactory对应真实的可以产生JMS Connection的ConnectionFactory -->
	  	 <property name="targetConnectionFactory" ref="targetConnectionFactory"></property>
	  </bean>
	   <!-- 配置生产者 -->  
       <!-- Spring提供的JMS工具类,它可以进行消息发送、接收等 -->  
       <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
       		<!-- 这个connectionFactory对应的是我们定义的Spring提供的那个ConnectionFactory对象 -->  
       		<property name="connectionFactory" ref="connectionFactory"></property>
       </bean>
        <!--这个是队列目的地,点对点的 -->  
        <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
        	<constructor-arg value="spring-queue"></constructor-arg>
        </bean>
         <!--这个是主题目的地,一对多的 --> 
         <bean id="topicDestination" class="org.apache.activemq.command.ActiveMQQueue">
         		<constructor-arg value="topic"/>
         </bean>
</beans>

maven pom文件如下:

<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>com.xiaoyexinxin</groupId>
	<artifactId>activeMQTest</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<packaging>jar</packaging>

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

	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		 <springframework>4.3.6.RELEASE</springframework>
	</properties>

	    <dependencies>  
          <dependency>
              <groupId>junit</groupId>
              <artifactId>junit</artifactId>
              <version>3.8.1</version>
              <scope>test</scope>
          </dependency>
  
  
          <dependency>
              <groupId>jstl</groupId>
              <artifactId>jstl</artifactId>
              <version>1.2</version>
          </dependency>
  
          <dependency>
              <groupId>javax.servlet</groupId>
              <artifactId>javax.servlet-api</artifactId>
              <version>3.1.0</version>
          </dependency>
  
          <!-- spring -->
  
          <dependency>
              <groupId>org.springframework</groupId>
              <artifactId>spring-core</artifactId>
              <version>${springframework}</version>
          </dependency>
  
          <dependency>
              <groupId>org.springframework</groupId>
              <artifactId>spring-context</artifactId>
              <version>${springframework}</version>
          </dependency>
  
          <dependency>
              <groupId>org.springframework</groupId>
              <artifactId>spring-tx</artifactId>
              <version>${springframework}</version>
          </dependency>
  
          <dependency>
              <groupId>org.springframework</groupId>
              <artifactId>spring-webmvc</artifactId>
              <version>${springframework}</version>
          </dependency>
  
          <dependency>
              <groupId>org.springframework</groupId>
              <artifactId>spring-web</artifactId>
              <version>${springframework}</version>
          </dependency>
  
          <dependency>
              <groupId>org.springframework</groupId>
              <artifactId>spring-jms</artifactId>
              <version>${springframework}</version>
          </dependency>
  
  
          <!-- xbean -->
  
          <dependency>
              <groupId>org.apache.xbean</groupId>
              <artifactId>xbean-spring</artifactId>
              <version>3.16</version>
          </dependency>
  
          <dependency>
              <groupId>com.thoughtworks.xstream</groupId>
              <artifactId>xstream</artifactId>
              <version>1.3.1</version>
          </dependency>
  
          <!-- activemq -->
  
          <dependency>
              <groupId>org.apache.activemq</groupId>
              <artifactId>activemq-all</artifactId>
              <version>5.14.3</version>
          </dependency> 
  </dependencies>  
</project>

这里如果工程有感叹号,那么可能跟之前的jar有冲突,这里建议修改mavend本地仓库地址,即setting文件的配置:

第二章:ActiveMQ与spring的整合使用

换一个重新maven update试试。

测试代码:

package com.xiaoyexinxin.activeMQTest;



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

import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

/**
 * 
 * @author liuxin
 * @date   2018年4月12日
 */
public class TestSpringActiveMq {

	@Test
	public void test() {
		//初始化一个spring容器
		ApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath:activeMq.xml"); 
		//从容器中获的JSMTemplate对象
		JmsTemplate jmsTemplate=(JmsTemplate) applicationContext.getBean("jmsTemplate");
		//从容器中获得一个Destination对象
		Queue queue=(Queue) applicationContext.getBean("queueDestination");
		//使用jmsTemplate对象发送消息,需要知道destination
		jmsTemplate.send(queue,new MessageCreator() {
			
			public Message createMessage(Session arg0) throws JMSException {
				// TODO Auto-generated method stub
				TextMessage message=arg0.createTextMessage("spring activemq test");
				return message;
			}
		});
	}
}

 运行上面的代码,我们可以看到我们刚才发送的消息在activemq的后台管理系统可以看到。

第二章:ActiveMQ与spring的整合使用


二,下面测试接收消息


工作中我们的项目都是由几个工程组成的,这几个工程之间的通讯就会用到mq了。所以这里我们新建一个用来接收消息的工程。建好后如下:

第二章:ActiveMQ与spring的整合使用

通发送一样加上pom依赖


<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>com.xiaoyexinxin</groupId>
  <artifactId>activeMQTestConsumer</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>jar</packaging>

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

	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		 <springframework>4.3.6.RELEASE</springframework>
	</properties>

	    <dependencies>  
          <dependency>
              <groupId>junit</groupId>
              <artifactId>junit</artifactId>
              <version>3.8.1</version>
              <scope>test</scope>
          </dependency>
  
  
          <dependency>
              <groupId>jstl</groupId>
              <artifactId>jstl</artifactId>
              <version>1.2</version>
          </dependency>
  
          <dependency>
              <groupId>javax.servlet</groupId>
              <artifactId>javax.servlet-api</artifactId>
              <version>3.1.0</version>
          </dependency>
  
          <!-- spring -->
  
          <dependency>
              <groupId>org.springframework</groupId>
              <artifactId>spring-core</artifactId>
              <version>${springframework}</version>
          </dependency>
  
          <dependency>
              <groupId>org.springframework</groupId>
              <artifactId>spring-context</artifactId>
              <version>${springframework}</version>
          </dependency>
  
          <dependency>
              <groupId>org.springframework</groupId>
              <artifactId>spring-tx</artifactId>
              <version>${springframework}</version>
          </dependency>
  
          <dependency>
              <groupId>org.springframework</groupId>
              <artifactId>spring-webmvc</artifactId>
              <version>${springframework}</version>
          </dependency>
  
          <dependency>
              <groupId>org.springframework</groupId>
              <artifactId>spring-web</artifactId>
              <version>${springframework}</version>
          </dependency>
  
          <dependency>
              <groupId>org.springframework</groupId>
              <artifactId>spring-jms</artifactId>
              <version>${springframework}</version>
          </dependency>
  
  
          <!-- xbean -->
  
          <dependency>
              <groupId>org.apache.xbean</groupId>
              <artifactId>xbean-spring</artifactId>
              <version>3.16</version>
          </dependency>
  
          <dependency>
              <groupId>com.thoughtworks.xstream</groupId>
              <artifactId>xstream</artifactId>
              <version>1.3.1</version>
          </dependency>
    <!-- activemq -->
    <dependency>
        <groupId>org.apache.activemq</groupId>
        <artifactId>activemq-all</artifactId>
        <version>5.14.3</version>
    </dependency> 
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>3.8.1</version>
      <scope>test</scope>
    </dependency>
  </dependencies>
</project>

  
下面我们新建一个监听器类,该类继承自MessageListener,如下图所示。

package com.xiaoyexinxin.activeMQTestConsumer;

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

/**
 * 接收ActiveMQ发送的消
 * @author liuxin
 * @date   2018年4月14日
 */
public class MqConsumer implements MessageListener{

	public void onMessage(Message arg0) {
		// TODO Auto-generated method stub
		TextMessage textMessage=(TextMessage) arg0;
		String text;
		try {
			text = textMessage.getText();
			System.out.println(text);
		} catch (JMSException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
	}

}

 
最后新建一个测试类,如下图所示。

package com.xiaoyexinxin.activeMQTestConsumer;


import java.io.IOException;


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


/**
 * 
 * @author liuxin
 * @date   2018年4月14日
 */
public class TestSpringActiveMQ {
	
	public static void main(String[] args) {
	  //初始化Spring容器  
        ApplicationContext context = new ClassPathXmlApplicationContext("classpath:applicationContext-activemq.xml");  
        
	}


}

直接运行测试类就能够接收到上面生产的消息了。


版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/106158.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 达人评测小米平板5怎么样[通俗易懂]

    达人评测小米平板5怎么样[通俗易懂]小米平板5系列将推出三款新机,均会搭载高通处理器,分别为骁龙870、骁龙860和骁龙768G,分别对应高、中、低三个档位,无论是学习还是娱乐、工作,小米平板5都能提供匹配的体验。骁龙870大家此前已经非常熟悉,目前市面上已经有多款搭载该芯片的产品亮相,而骁龙860目前还未在国内上市。据悉,骁龙860处理器是此前骁龙855Plus的增强版,采用7nm工艺打造,CPU主频为2.96GHz,为1+3+4的三丛集架构设计,超大核为Kryo485,并且在5G、内存等和方面带来了全新提升,性能更..

  • 云服务器高io是什么_云主机购买

    云服务器高io是什么_云主机购买1:数据读取速度ucloud云主机最低224.8MB/S,最高508.8MB/S,平均410.7MB/S阿里云主机最低17.4MB/S,最高189.6MB/S,平均170.6MB/S万根云主机最低

  • hook技术截取服务器信息,Windows Hook技术

    hook技术截取服务器信息,Windows Hook技术0x01简介有人称它为“钩子”,有人称它为“挂钩”技术。谈到钩子,很容易让人联想到在钓东西,比如鱼钩就用于钓鱼。编程技术的钩子也是在等待捕获系统中的某个消息或者动作。钩子的应用范围非常广泛,比如输入监控、API拦截、消息捕获、改变程序执行流程等方面。杀毒软件会用Hook技术钩住一些API函数,比如钩住注册表读写函数,从而防止病毒对注册表进行写入;病毒使用Hook技术有针对性的捕获键盘的输入,从而…

  • 【Android】 RecyclerView、ListView实现单选列表的优雅之路.

    【Android】 RecyclerView、ListView实现单选列表的优雅之路.转载请标明出处:http://blog.csdn.net/zxt0601/article/details/52703280本文出自:【张旭童的博客】一概述:这篇文章需求来源还是比较简单的,但做的优雅仍有值得挖掘的地方。需求来源:一个类似饿了么这种电商优惠券的选择界面:其实就是一个普通的列表,实现了单选功能,效果如图:(不要怪图渣了,我撸了四五遍,公司录出来的GIF就这么

  • aliddns ipv6_群晖使用阿里云DDNS(ipv4和ipv6)「建议收藏」

    aliddns ipv6_群晖使用阿里云DDNS(ipv4和ipv6)「建议收藏」复制,写成sh脚本,添加进群晖定时任务即可。ipv4注意前四个需要自己填入,还有获取ip那里要注意网络接口,我的是ppp0。#!/bin/shApiId=”***************”ApiKey=”***************”Domain=’************’SubDomain=’********’#这四个自己写Nonce=$(date-u”+%N”)Timest…

  • java中JDBC是什么?[通俗易懂]

    java中JDBC是什么?[通俗易懂]JDBC是什么?JDBC即(javadatabaseconnectivity数据连接)。JDBC是Sun公司编的一堆类和方法,都封装在java.sql包中。你可以利用这堆类和方法来把你的程序和数据库连通。JDBC的优点:跨数据库性通过使用JDBC,开发人员可以将SQL语句传送给几乎任何一种数据库。不必单独写一个程序访问Sybase,Oracle,或Microsoft的SQLServ…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号