ActiveMQ学习总结（3）——spring整合ActiveMQ

2019独角兽企业重金招聘Python工程师标准>>> hot3.png

1.参考文献

  1. Spring集成ActiveMQ配置
  2. Spring JMS异步发收消息 ActiveMQ

2.环境

在前面的一篇 ActiveMQ入门实例中我们实现了消息的异步传送，这篇博文将如何在spring环境下集成ActiveMQ。如果要在spring下集成ActiveMQ，那么就需要将如下jar包导入项目：

本文有两篇参考文献，因此有两个实例，项目结构如下图所示：

3.实例1

信息发送者：HelloSender.java

复制代码 
package edu.sjtu.erplab.springactivemq;

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

import javax.jms.Destination;
import javax.jms.Message;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

public class HelloSender {

/**
     * @param args
     * jmsTemplate和destination都是在spring配置文件中进行配制的
     * Sender只使用了配置文件中的jmsFactory，jmsTemplate，还有destination这三个属性
*/
public static void main(String[] args) {
        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext-jms.xml");
        JmsTemplate template = (JmsTemplate) applicationContext.getBean("jmsTemplate");
        Destination destination = (Destination) applicationContext.getBean("destination");
        template.send(destination, new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
return session.createTextMessage("发送消息：Hello ActiveMQ Text Message2！");
            }
        });
        System.out.println("成功发送了一条JMS消息");
    }
}
复制代码

信息接受者：ProxyJMSConsumer.java

复制代码 
package edu.sjtu.erplab.springactivemq;

import javax.jms.Destination;
import javax.jms.TextMessage;

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

/**
 * JMS消费者
 * 消息题的内容定义
 * 消息对象 接收消息对象后： 接收到的消息体* <p> 
*/
public class ProxyJMSConsumer {

public ProxyJMSConsumer() {

    }
private JmsTemplate jmsTemplate;

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

/**
     * 监听到消息目的有消息后自动调用onMessage(Message message)方法
*/
public void recive() {
        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext-jms.xml");
        Destination destination = (Destination) applicationContext.getBean("destination");
while (true) {
try {
                TextMessage txtmsg = (TextMessage) jmsTemplate
                        .receive(destination);
if (null != txtmsg) {
                    System.out.println("[DB Proxy] " + txtmsg);
                    System.out.println("[DB Proxy] 收到消息内容为: "
                            + txtmsg.getText());
                } else
break;
            } catch (Exception e) {
                e.printStackTrace();
            }

        }
    }

}
复制代码

客户端：JMSTest.java

复制代码 
package edu.sjtu.erplab.springactivemq;

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

public class JMSTest {

/**
     * @param args
*/
public static void main(String[] args) {
        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext-jms.xml");
        ProxyJMSConsumer proxyJMSConsumer = (ProxyJMSConsumer) applicationContext.getBean("messageReceiver");
        proxyJMSConsumer.recive();

        System.out.println("初始化消息消费者");
    }

}
复制代码

Spring配置文件：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"
    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"
    default-autowire="byName">


<!-- 配置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>

<!-- Spring JMS Template -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory">
<ref local="jmsFactory" />
</property>
<property name="defaultDestinationName" value="subject" />
<!-- 区别它采用的模式为false是p2p为true是订阅 -->
<property name="pubSubDomain" value="true" />
</bean>

<!-- 发送消息的目的地（一个队列） -->
<bean id="destination" class="org.apache.activemq.command.ActiveMQTopic">
<!-- 设置消息队列的名字 -->
<constructor-arg index="0" value="subject" />
</bean>




<bean id="messageReceiver" class="edu.sjtu.erplab.springactivemq.ProxyJMSConsumer">
<!--class="edu.sjtu.erplab.springactivemq.ProxyJMSConsumer">-->
<property name="jmsTemplate" ref="jmsTemplate"></property>
</bean>



</beans>
复制代码

测试方法：首先运行JMSTest，然后运行HelloSender。

4.实例2

消息发送者： Sender

复制代码 
package edu.sjtu.erplab.springactivemq2;

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;

public class Sender {
private JmsTemplate jmsTemplate;
//getter and setter
    public JmsTemplate getJmsTemplate() {
return jmsTemplate;
    }
public void setJmsTemplate(JmsTemplate jmsTemplate) {
this.jmsTemplate = jmsTemplate;
    }

public void sendInfo() {
        jmsTemplate.send(new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
                MapMessage message = session.createMapMessage();
                message.setString("lastName", "ppp");
return message;
            }

        });
    }
}
复制代码

消息发送客户端：SenderTest

复制代码 
package edu.sjtu.erplab.springactivemq2;

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

public class SenderTest {
public static void main(String[] args) {
// TODO 自动生成方法存根
        ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
        Sender sender = (Sender) context.getBean("sender");
        sender.sendInfo();
    }
}
复制代码

消息接收者：Receiver

复制代码 
package edu.sjtu.erplab.springactivemq2;

import javax.jms.JMSException;
import javax.jms.MapMessage;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.support.JmsUtils;

public class Receiver {
private JmsTemplate jmsTemplate;
//getter and setter
    public JmsTemplate getJmsTemplate() {
return jmsTemplate;
    }
public void setJmsTemplate(JmsTemplate jmsTemplate) {
this.jmsTemplate = jmsTemplate;
    }

/**
     * 构造函数
*/
public Receiver() {
    }

public String receiveMessage() {
        String my = "";
        MapMessage message = (MapMessage) jmsTemplate.receive();
try {
            my = message.getString("lastName");
        } catch (JMSException e) {
throw JmsUtils.convertJmsAccessException(e);
        }
return my;
    }


}
复制代码

消息接收客户端：ReceiverTest

复制代码 
package edu.sjtu.erplab.springactivemq2;

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

public class ReceiverTest {
public static void main(String[] args) {
// TODO 自动生成方法存根
        ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
        Receiver receiver = (Receiver) context.getBean("receiver");
        System.out.print(receiver.receiveMessage());
    }
}
复制代码

Spring配置文件：applicationContext.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"
    xsi:schemaLocation="http://www.springframework.org/schema/beans

    http://www.springframework.org/schema/beans/spring-beans-2.0.xsd">
<!--创建连接工厂-->
<bean id="connectionFactory"
        class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"></property>
</bean>
<!-- 声明ActiveMQ消息目标,目标可以是一个队列，也可以是一个主题ActiveMQTopic-->
<bean id="destination" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg index="0" value="edu.sjtu.erplab.springactivemq2"></constructor-arg>
</bean>
<!---->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory"></property>
<property name="defaultDestination" ref="destination"></property>
<property name="receiveTimeout" value="600"></property>

</bean>
<bean id="sender" class="edu.sjtu.erplab.springactivemq2.Sender">
<property name="jmsTemplate" ref="jmsTemplate"></property>

</bean>
<bean id="receiver" class="edu.sjtu.erplab.springactivemq2.Receiver">
<property name="jmsTemplate" ref="jmsTemplate"></property>
</bean>
</beans>
复制代码

转载于:https://my.oschina.net/zhanghaiyang/blog/606519

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/536377.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Pots【广搜，模拟】

Pots【广搜，模拟】

Pots POJ - 3414 You are given two pots, having the volume of A and B liters respectively. The following operations can be performed: FILL(i) fill the pot i (1 ≤ i ≤ 2) from the tap;DROP(i) empty the pot i to the drain;POUR(i,j) pour fro…
阅读更多...
非常可乐【广搜，模拟】

非常可乐【广搜，模拟】

非常可乐 HDU - 1495 大家一定觉的运动以后喝可乐是一件很惬意的事情&#xff0c;但是seeyou却不这么认为。因为每次当seeyou买了可乐以后&#xff0c;阿牛就要求和seeyou一起分享这一瓶可乐&#xff0c;而且一定要喝的和seeyou一样多。但seeyou的手中只有两个杯子&#xff0…
阅读更多...
问题 A: 深度学习

问题 A: 深度学习

问题 A: 深度学习 时间限制: 1 Sec 内存限制: 128 MB 提交: 53 解决: 42 [提交] [状态] [讨论版] [命题人:admin] 题目描述 小 A 最近在研究深度学习&#xff0c;他自己搭建了一个很牛逼的神经网络&#xff0c;现在他手头一共有 n 组训练数据&#xff0c;一开始他会给自己的…
阅读更多...
堆树

堆树

一、堆树的定义 堆树的定义如下&#xff1a; &#xff08;1&#xff09;堆树是一颗完全二叉树&#xff1b; &#xff08;2&#xff09;堆树中某个节点的值总是不大于或不小于其孩子节点的值&#xff1b; &#xff08;3&#xff09;堆树中每个节点的子树都是堆树。 当父节点的键…
阅读更多...
问题 D: 最小生成树II

问题 D: 最小生成树II

问题 D: 最小生成树II 时间限制: 1 Sec 内存限制: 128 MB 提交: 89 解决: 44 [提交] [状态] [讨论版] [命题人:admin] 题目描述 小A有一张n个点的带权无向图&#xff0c;这张无向图非常特别&#xff0c;首先第i个点有一个点权ai&#xff0c;之后这张无向图是一张完全图&…
阅读更多...
问题 G: 区间权值

问题 G: 区间权值

问题 G: 区间权值 时间限制: 1 Sec 内存限制: 128 MB 提交: 112 解决: 49 [提交] [状态] [讨论版] [命题人:admin] 题目描述 小Bo有n个正整数a1..an&#xff0c;以及一个权值序列w1…wn&#xff0c;现在他定义 现在他想知道的值&#xff0c;需要你来帮帮他 你只需要输出答案…
阅读更多...
问题 I: 连通块计数

问题 I: 连通块计数

问题 I: 连通块计数 时间限制: 1 Sec 内存限制: 128 MB 提交: 108 解决: 45 [提交] [状态] [讨论版] [命题人:admin] 题目描述 小A有一棵长的很奇怪的树&#xff0c;他由n条链和1个点作为根构成&#xff0c;第i条链有ai个点&#xff0c;每一条链的一端都与根结点相连。 现在…
阅读更多...
telnet 功能启用并测试端口是否正常

telnet 功能启用并测试端口是否正常

记录日期&#xff1a;2019年6月21日 13点52分 操作系统&#xff1a;Windows 10 由于 Ping命令可以检查网络是否连通&#xff0c;但无法准确判断某个端口是否连通&#xff0c;因此需要使用 Telnet协议。 1、打开控制面板中的程序和功能。 2、侧边栏&#xff0c;启用或关闭Window…
阅读更多...
步步为营 SharePoint 开发学习笔记系列 七、SharePoint Timer Job 开发

步步为营 SharePoint 开发学习笔记系列 七、SharePoint Timer Job 开发

概要 项目需求要求我们每天晚上同步员工的一些信息到sharepoint 的user List &#xff0c;我们决定定制开发sharepoint timer Job,Sharepoint timer Job是sharePoint的定时作业Job,需要安装、布曙到服务器上,而这里我只是介绍下Job开发的例子&#xff0c;以供大家学习用。 开发…
阅读更多...
问题 J: 寻找复读机【模拟】

问题 J: 寻找复读机【模拟】

问题 J: 寻找复读机 时间限制: 1 Sec 内存限制: 128 MB 提交: 131 解决: 50 [提交] [状态] [讨论版] [命题人:admin] 题目描述 某个QQ群里一共有n个人&#xff0c;他们的编号是1..n&#xff0c;其中有一些人本质上是复读机。 小A发现&#xff0c;如果一个人的本质是复读机&…
阅读更多...
windows下jenkins常见问题填坑

windows下jenkins常见问题填坑

没有什么高深的东西&#xff0c;1 2天的时间大多数人都能自己摸索出来&#xff0c;这里将自己遇到过的问题分享出来避免其他同学再一次挖坑. 目录 1. 主从节点 2. Nuget自动包还原 3. powershell部署 4. 内网机器实现基于变化的构建 5. Github私有项目pull时限 所谓主从&#x…
阅读更多...
Cow Contest【最短路-floyd】

Cow Contest【最短路-floyd】

Cow Contest POJ - 3660 N (1 ≤ N ≤ 100) cows, conveniently numbered 1..N, are participating in a programming contest. As we all know, some cows code better than others. Each cow has a certain constant skill rating that is unique among the competitors. …
阅读更多...
【学习Android NDK开发】Type Signatures（类型签名）

【学习Android NDK开发】Type Signatures（类型签名）

类型签名&#xff08;Type Signatures&#xff09; (<Parameter 1 Type Code>[<Parameter 1 Class>];...)<Return Type Code> The JNI uses the Java VM’s representation of type signatures. Following Table shows these type signatures. Type Signatur…
阅读更多...
Symantec(赛门铁克）非受管检测

Symantec(赛门铁克）非受管检测

为了查找局域网内没有安装赛门铁克客户端的IP&#xff0c;采用Symantec Endpoint Protect Manager 的非受管检测机制进行网段扫描。 非受管检测机制的原理是&#xff1a;每台电脑开机时都会向同网段电脑发arp&#xff0c;当非受管检测器接到arp请求时&#xff0c;会写入本地的a…
阅读更多...
SQL语句性能优化操作

SQL语句性能优化操作

1、对查询进行优化&#xff0c;应尽量避免全表扫描&#xff0c;首先应考虑在where及order by涉及的列上建立索引。 2、应尽量避免在where子句中对字段进行null值判断&#xff0c;创建表时NULL是默认值&#xff0c;但大多数时候应该使用NOT NULL&#xff0c;或者使用一个特殊的值…
阅读更多...
sql语言特殊字符处理

sql语言特殊字符处理

我们都知道SQL Server查询过程中&#xff0c;单引号“”是特殊字符&#xff0c;所以在查询的时候要转换成双单引号“”。但这只是特殊字符的一个&#xff0c;在实际项目中&#xff0c;发现对于like操作还有以下特殊字符&#xff1a;下划线“_”&#xff0c;百分号“%”&#xf…
阅读更多...
小节

小节

算法导论已学两部分&#xff0c;第一部分是基础知识&#xff0c;第二部分是排序。基础知识介绍如何分析证明算法以及求时间复杂度。第二部分的排序学了很长时间。先是从简单排序到复杂排序的一个过渡&#xff0c;打开了很多思路。然后就是无尽的算法分析。算法分析的时间比理解…
阅读更多...
SPS2003升级到MOSS2007相关资料及问题总结

SPS2003升级到MOSS2007相关资料及问题总结

这几天要把客户的SPS2003门户升级到MOSS2007的&#xff0c;客户SPS2003门户&#xff0c;数据26G&#xff0c;使用了自定义WebPart、自定义页面、SSO等功能。升级过程中碰到大量问题。其中主要的问题有几个&#xff0c;在这里把它们整理一下> 1、sps2003升级时&#xff0c;升…
阅读更多...
Milking Time【动态规划-dp】

Milking Time【动态规划-dp】

Milking Time POJ - 3616 Bessie is such a hard-working cow. In fact, she is so focused on maximizing her productivity that she decides to schedule her next N (1 ≤ N ≤ 1,000,000) hours (conveniently labeled 0..N-1) so that she produces as much milk as po…
阅读更多...
HTTP首部（1）

HTTP首部（1）

1、报文首部 HTTP协议的请求和响应必定包含HTTP首部&#xff0c;它包括了客户端和服务端分别处理请求和响应提供所需要的信息。报文主体字儿是所需要的用户和资源的信息都在这边。　 HTTP请求报文组成 方法&#xff0c;URL&#xff0c;HTTP版本&#xff0c;HTTP首部字段 HTTP响…
阅读更多...
最新文章

Copyright @ 2022~2023