ActiveMQ技术预研报告
研究部朱懋柱
1.文档介绍
1.1 文档目的
对前期进行的ActiveMQ研究进行总结和分享ActiveMQ方面的心得。
1.2 文档范围
适合技术中心技术人员，可以作为技术参考。
1.3 参考文档
ActiveMQ官方网站 http://activemq.apache.org/
开源中国社区 http://www.oschina.net/p/activemq
百度百科 http://baike.baidu.com/view/157103.htm?fr=ala0_1_1
1.4 术语与缩写解释
| 缩写、术语 | 解 释 |
| MQ | 消息队列，很多时候指消息中间件服务器 |
| ActiveMQ | ActiveMQ是一个开放源码基于Apache 2.0 licenced 发布并实现了JMS 1.1的消息中间件 |
| JMS | jms即Java消息服务（Java Message Service）,一种协议标准 |
| URI | 资源标志符（Uniform Resource Identifier, 简称”URI”） |
2. 研究背景介绍
为了快速有效的丰富汇讯的功能，减少开发时间和开发成本，我们将web的技术融合起来，技术融合中出现一个问题就是消息实时通知汇讯客户端的处理消 息的流转。简单的方法可以通过web服务器和IM服务器进行直连来完成通信，但这样的架构方案让web和IM过于依赖，为了提供更好的扩展性，降低耦合， 考虑引入消息中间件来作为两者的中介，减少依赖，由此我们需要对消息中间件进行一些分析和研究。
3. 技术说明
ActiveMQ是一个开放源码基于Apache 2.0 licenced 发布并实现了JMS 1.1的消息中间件，应用中引入中间件的好处是减少服务器之间的依赖关系，提高扩展性，在没有引入消息中间件的情况可能出现如下图所示：
出现服务器多依赖的情况，不方面扩展，而引入消息中间件后如
从图中可以看出引入消息中间件后，每个服务器只依赖于消息中间件，而且在应用中这种依赖关系式一种弱依赖关系，为什么这么讲呢？请看下节对消息中间件的分享报告。
4.ActiveMQ的技术分析
ActiveMQ实现了sub/pub（订阅/发布）的机制，实现jms协议，sub/pub属于设计模式中典型的观察者模式，每台服务器只需要订阅自己 希望得到的消息，而不必要轮询服务器是否有自己需要的消息，也不需要知道消息发布者是谁，而发布消息的一端也不需知道谁是消息的接收端，有多少给接受者， 这些都不重要，只要将消息发布到消息中间件就可以了。
ActiveMQ消息发布和订阅的类型分为BytesMessage(二进制消息流的方式)、MapMessage（一种键值对方式的消息）、 ObjectMessage（一种序列化对象的消息形式）、TextMessage（字符流的消息类型），可以根据需要进行消息类型选择，当然对于同一个 消息发布/订阅双方需要采用一致的消息类型，同一个服务器可以采用多种消息格式，不过不同的消息格式需要奖励不同的发布/和订阅者。这样一来应用就相当灵 活，可以根据需要进行类型选择，不过选择ObjectMessage类型的时候应该注意，这个消息类型主要是序列化的Java对象，所以不支持不同的语言 进行类型数据交换。
ActiveMQ应用程序接口(摘自百度百科)
ConnectionFactory 接口（连接工厂）
l 用户用来创建到JMS提供者的连接的被管对象。JMS客户通过可移植的接口访问连接，这样当下层的实现改变时，代码不需要进行修改。 管理员在JNDI名字空间中配置连接工厂，这样，JMS客户才能够查找到它们。根据消息类型的不同，用户将使用队列连接工厂，或者主题连接工厂。
Connection 接口（连接）
l 连接代表了应用程序和消息服务器之间的通信链路。在获得了连接工厂后，就可以创建一个与JMS提供者的连接。根据不同的连接类型，连接允许用户创建会话，以发送和接收队列和主题到目标。
Destination 接口（目标）
l 目标是一个包装了消息目标标识符的被管对象，消息目标是指消息发布和接收的地点，或者是队列，或者是主题。JMS管理员创建这些对象，然后用户通过JNDI发现它们。和连接工厂一样，管理员可以创建两种类型的目标，点对点模型的队列，以及发布者／订阅者模型的主题。
MessageConsumer 接口（消息消费者）
l 由会话创建的对象，用于接收发送到目标的消息。消费者可以同步地（阻塞模式），或异步（非阻塞）接收队列和主题类型的消息。
MessageProducer 接口（消息生产者）
l 由会话创建的对象，用于发送消息到目标。用户可以创建某个目标的发送者，也可以创建一个通用的发送者，在发送消息时指定目标。
Message 接口（消息）
l 是在消费者和生产者之间传送的对象，也就是说从一个应用程序创送到另一个应用程序。一个消息有三个主要部分：
l 消息头（必须）：包含用于识别和为消息寻找路由的操作设置。
l 一组消息属性（可选）：包含额外的属性，支持其他提供者和用户的兼容。可以创建定制的字段和过滤器（消息选择器）。
l 一个消息体（可选）：允许用户创建五种类型的消息（文本消息，映射消息，字节消息，流消息和对象消息）。
l 消息接口非常灵活，并提供了许多方式来定制消息的内容。
Session 接口（会话）
l 表示一个单线程的上下文，用于发送和接收消息。由于会话是单线程的，所以消息是连续的，就是说消息是按照发送的顺序一个一个接收的。会话的好处是它支持事 务。如果用户选择了事务支持，会话上下文将保存一组消息，直到事务被提交才发送这些消息。在提交事务之前，用户可以使用回滚操作取消这些消息。一个会话允 许用户创建消息生产者来发送消息，创建消息消费者来接收消息。
MessageListener接口（消息监听者）
l 这是为一个消息消费者的消息监听接口，生产者必选设置消息监听者，否则消息将不处理，当客户端接收到消息后，会通过调用消息监听者的接口来进行相应的消息处理，一般在开发过程中通过重载的方式重新定义监听着的onMessage虚接口，来完成消息的监听和处理。
5．ActiveMQ的C++客户端的实现
ActiveMQ提供了c++的client开发库支持，这样我们实现起来就比较简单了，下面我们来看看发布和订阅的简单例子。
5.1 pub（发布）端的简单实现过程
首先根据传入的URI创建一个发布接口，创建过程如下：
然后调用发布接口发布消息，发布过程如下：
5.2 sub（订阅）端的简单实现过程
订阅者的创建过程和发布者的创建过程基本一样，不过最后创建的不是生产者接口，而是消息消费者接口（MessageConsumer）,创建流程如下：
在实现时，我们重载消息消费者的监听者，并设置消息消费者的监听接口为我们实现的监听接口，再重载监听者onMessage接口来进行消息处理。这样，只 要客户端接收到消息，就会调用我们的监听者的onMessage接口，我们就可以在这个接口进行相应的处理，完成消息接收处理过程。
5.3 消息处理过程
a) 消息订阅
需要订阅某主题的客户端实现订阅过程，产生消息消费者的监听者实例，并实现消息处理过程。
b) 消息发布
需要发布消息的客户端实现消息发布的过程，等到一个生产者实力，并通过生产者接口向消息中间件发布消息。
c) 服务器消息转发
消息中间件服务器收到生产者发送过来的消息后，查找是否有该类型主题消息的订阅者，有则分别发送消息。
d) 订阅者消息处理
订阅者客户端收到消息中间件服务器发送过来的的消息后，调用监听者onMessage接口完成消息处理
6．总结
对ActiveMQ的研究尚浅，也许有些理解不当之处，欢迎大家指出，一起学习，消息中间件在跨语言和跨平台，服务器间解耦都起到了比较到的作用。值得我们去学习，在此感谢所有提供免费网络资源的网站，感谢开源中国社区。
相关推荐
### SpringCloud微服务预研知识点整理 #### 一、微服务概述 微服务架构是一种将单个应用程序开发成一套小型服务的方法，每项服务都运行在其独立的进程中，并且使用轻量级通信机制（通常是HTTP资源API）进行交互。...
* 解决重要项目中关键架构问题和技术难题，负责项目中关键技术难点攻关和预研 * 对开发团队进行技术指导和培训，规范开发流程 任职资格： * 精通 Java 语言，对相关技术领域开源产品有深入理解 * 精通领域建模，...
1.【内容概要】 微软官方原版PowerShell 7.5.0 x64离线安装包，集成「三件套」企业级解决方案： [1.1] 智能环境配置脚本（自动修复.NET 6依赖/注册表权限）； [1.2] 运维增强组件包（SSH远程管理+日志审计模块）； [1.3] 跨平台脚本兼容方案（支持Linux/Windows混合执行）； 2.【适用人群】 [2.1] 运维工程师：需批量管理Windows Server集群； [2.2] 全栈开发者：构建CI/CD自动化流水线； [2.3] 系统管理员：解决PowerShell 5.1模块兼容性问题； [2.4] IT培训机构：教学环境快速统一部署； 3.【使用场景】 [3.1] 企业内网部署，离线安装+环境自动初始化，内置AutoDeploy.cmd脚本。 [3.2] 跨平台脚本开发，同时操作Linux/Windows设备，集成OpenSSH Client 8.6。 [3.3] 高危操作防护，防止误执行危险命令，内置SafeMode沙箱模块。 4. 【使用目标】快速
内容概要：本文深入探讨了AUTOSAR以太网状态管理器（EthSM），涵盖其在AUTOSAR分层架构中的位置、主要职责、架构设计、接口定义及依赖关系，并详述状态机的具体状态、转换规则与事件处理流程。同时提供了详细的通信序列图解，帮助理解初始化及启动闭合通信等关键过程，并介绍了配置参数设置和错误处理方式。 适合人群：具备嵌入式系统或汽车电子背景的研发人员和技术管理人员。 使用场景及目标：适用于理解和设计复杂的车内以太网通信系统，尤其是基于AUTOSAR平台的开发项目。帮助技术人员掌握以太网状态的管理和故障排查方法，提高车载通信系统的可靠性。 阅读建议：由于内容专业性较强，建议读者对AUTOSAR基础知识有一定了解后再行阅读，在实践中逐步掌握各个概念和知识点的应用技巧，特别注意状态切换的实际案例分析。
特易通国产对讲机TH-UVF9D v1.0中英写频软件
数据结构学习
内容概要：该文档是一份关于‘信息资源整合及应用服务平台’需求规格说明书的详尽描述，涵盖项目的总体介绍、业务分析、系统需求、功能模块需求和部署环境等多个方面。文中明确了项目目标是对异构信息资源进行全面整合，并提供了详细的架构设计，确保用户在统一平台上享受高效的资源配置和服务体验。此外还介绍了平台的关键技术工具如TRSWCM和HyBase的使用，及各子系统间协作流程，强调了信息收集渠道多样化及其智能化管理水平。 适用人群：面向项目建设方（即负责系统建设和部署的组织或团队），相关用户和技术人员。 使用场景及目标：为建设‘信息资源整合及应用服务平台’提供建设指导和功能需求分析，明确项目范围、质量标准及开发任务分工；同时有助于相关人员更好地理解该平台的工作机制和应用场景。其他说明:此需求说明书亦可用于指导平台未来的维护和技术升级工作。 其他说明: 包含对系统管理、登录管理、日志管理等多个模块的详细说明，并对每个模块的功能进行了细致划分与介绍。文档末尾附带需求跟踪矩阵，用来监测各个阶段的任务完成情况和进度管理。
系统基于Spring Boot+Vue.js的B/S架构，采用RESTful API实现前后端解耦，MySQL数据库配合MyBatis-Plus ORM框架构建高性能数据层。通过Spring Boot模块化设计、Vuex状态管理及Element UI组件库，实现开发效率与可维护性双提升，结合数据库索引优化与读写分离机制，保障系统高并发处理能力与扩展性。
数据结构学习
操作系统学习
数据结构学习
特易通国产对讲机TH-UV8000D v1.0中英写频软件
数字化为企业节能降碳提供新动能【22页】
内容概要：本文以某动物园的游客守则、员工守则以及海洋馆的特殊告示为主要框架，呈现了一个充满恐怖与诡异色彩的独特故事。故事围绕游客和员工的行为规范展开，通过种种奇怪的规定，揭示了一个超现实的环境，暗示存在某种未知实体'它’的操控或威胁，其中涉及到了诸如幻视、认知错乱等多种异象，并以‘唯一解’的形式设置了谜题等待解答，整个文本充斥着紧张悬疑氛围。 适用人群：适合喜爱恐怖悬疑风格作品的成人读者，尤其是对超自然题材感兴趣的文学爱好者。 使用场景及目标：①营造神秘惊悚感的故事叙述背景，探讨人性与现实感知之间的复杂关系；②提供解谜元素激发思考，吸引受众深入探究背后的真相。目标在于带给人们非同寻常的心理体验的同时，引导他们探索表象背后隐藏的意义，从而更好地理解作者构建这个世界观的核心意图所在。 其他说明：本文不仅是一份简单的守则指南，更是一场沉浸式的心理游戏，通过对细节的精心编排来增强故事的真实性和代入感。同时，文中提及多个关于兔子、白狮子、山羊等角色的信息交织形成了复杂的情节脉络，进一步增加了叙事深度。然而值得注意的是，尽管文章看似提供了逃生指引，但实际上并未给出明确的结局指向，使得每位读者都能根据自己对文本的理解得出不同的答案，这也是此类作品魅力之一。
基于C语言+STM32开发的人体健康监测装置（检测温度与心率判断健康状态）+源码，适合毕业设计、课程设计、项目开发。项目源码已经过严格测试，可以放心参考并在此基础上延申使用~ 检测当前的温度与心率，同时通过MPU6050检测老人是否摔倒 将摔倒信息发送给子女 基于C语言+STM32开发的人体健康监测装置（检测温度与心率判断健康状态）+源码，适合毕业设计、课程设计、项目开发。项目源码已经过严格测试，可以放心参考并在此基础上延申使用~ 检测当前的温度与心率，同时通过MPU6050检测老人是否摔倒 将摔倒信息发送给子女 基于C语言+STM32开发的人体健康监测装置（检测温度与心率判断健康状态）+源码，适合毕业设计、课程设计、项目开发。项目源码已经过严格测试，可以放心参考并在此基础上延申使用~ 检测当前的温度与心率，同时通过MPU6050检测老人是否摔倒 将摔倒信息发送给子女~
机器学习入门（线性回归）波士顿房价预测代码
特易通国产对讲机MD580 v1.0中英写频软件
数据结构学习
2025年美赛全流程指南
数据结构学习