文档章节

activemq自己理解

一夜
 一夜
发布于 2018/06/19 15:33
字数 245
阅读 1
收藏 0

今日了解一下activeMQ的运行流程,主要就是消费者和提供者,这两者分开各操作不同的操作,例如以银行网关异步回传为例,银行回调方法只是用来操作银行返回结果,对于数据的处理可以放在activeMQ的监听器里进行处理(实现接口MessageListener 方法onMessage()),提供者方法处理

参数设置:respData存放需要推送的数据,MessageDto是工具类

MessageDto messageDto = new MessageDto();
        messageDto.setRespData(respData);
        messageDto.setType("0");

//topic获取

Destination topic = (Destination)SpringContextUtils.getBeanById("queueDestination");

JmsTemplate topicJmsTemplate;topicJmsTemplate.send(topic, new MessageCreator() {
            public Message createMessage(Session session) throws JMSException {
                MapMessage  map = session.createMapMessage();
                map.setString("messageDto", JSONObject.fromObject(messageDto).toString());
                return map;
            }
        });

处理;

参数获取在监听器的实现方法里

MapMessage map = (MapMessage) message;
String messageDtoJson = map.getString("messageDto");

异步处理数据,减少处理操作时间.进入activemq监控接口信息,一旦消费将自动进行清理,管理接口使用的情况,主要用在大并发数据交互上

© 著作权归作者所有

一夜
粉丝 1
博文 32
码字总数 3456
作品 0
东城
私信 提问
初识ActiveMQ消息中间件

ActiveMQ官方网站:https://activemq.apache.org/ 关于ActiveMQ消息传递的方式详见: https://segmentfault.com/a/1190000014958916 https://www.cnblogs.com/cyfonly/p/6380860.html 本篇博......

帅得拖网速
05/12
33
0
Ubuntu下安装ActiveMQ

主要参考http://www.jmkg.co.uk/2010/08/31/installing-activemq-on-ubuntu/,略有补充 1. 下载安装包,建立activemq用户,安装 下载最新的activemq,写此文时为5.7。 cd /opt/tar xvzf xxx...

RuralHunter
2013/01/22
3.4K
0
ActiveMQ 持久化(数据库),查询队列剩余消息数、出队数的实现

《ActiveMQ 持久化(文件),查询队列剩余消息数、出队数的实现》分析了消息队列持久化保存,假如activemq服务器突然停止,服务器启动后,还可以继续查找队列中的消息。现在分析队列中的消息...

cookqq
2013/03/04
4.1K
0
ActiveMQ安装配置和使用简例

本文作者:Zhang Phil 原文链接:http://blog.csdn.net/zhangphil/article/details/48173665 ActiveMQ安装配置和使用简例 ActiveMQ是一套JMS(Java Message Service)开源消息服务实现的组件...

开开心心过
2015/09/02
0
0
[ActiveMQ]初识ActiveMQ

初识ActiveMQ ActiveMQ介绍 官方网站:http://activemq.apache.org/ 最新版本:ActiveMQ 5.14.1(2016-10-28) 最新版本下载链接:http://activemq.apache.org/download.html 历史版本下载链接...

candy-yun
2016/10/29
0
0

没有更多内容

加载失败,请刷新页面

加载更多

【TencentOS tiny】深度源码分析(4)——消息队列

消息队列 在前一篇文章中【TencentOS tiny学习】源码分析(3)——队列 我们描述了TencentOS tiny的队列实现,同时也点出了TencentOS tiny的队列是依赖于消息队列的,那么我们今天来看看消息...

杰杰1号
26分钟前
6
0
Hive

这就是那个 JAVA 类 package cn.itcast.bigdata;import java.util.HashMap;import org.apache.hadoop.hive.ql.exec.UDF;public class PhoneNbrToArea extends UDF{privat......

Garphy
26分钟前
7
0
Springboot开发,第二天

SpringBoot学习,第二天 目录:1、Springboot整合Listener 2、Springboot访问静态资源 3、异常处理 4、热部署 一、SpringBoot整合Listener 两种方式完成组件的注册 1、通过注解扫描完成组件的...

有一个小阿飞
30分钟前
7
0
BeginnersBook Perl 教程

来源:ApacheCN BeginnersBook 翻译项目 译者:飞龙 协议:CC BY-NC-SA 4.0 贡献指南 本项目需要校对,欢迎大家提交 Pull Request。 请您勇敢地去翻译和改进翻译。虽然我们追求卓越,但我们并...

ApacheCN_飞龙
42分钟前
5
0
我的Java秋招面经大合集

阿里面经 阿里中间件研发面经 蚂蚁金服研发面经 岗位是研发工程师,直接找蚂蚁金服的大佬进行内推。 我参与了阿里巴巴中间件部门的提前批面试,一共经历了四次面试,拿到了口头offer。 然后我...

Java技术江湖
47分钟前
8
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部