activeMQ指南针_领域模型分析

图一

activeMQ现在越来越复杂了，就像一个武林高手，会的套路是越来越多了，想要看清他的路数，有点不容易。但是如果能把住他的“脉”也许就看清楚了。activeMQ做为软件也有它的“脉象”，也就是我们经常所说的领域模型。

领域模型尤其是象activeMQ这样的中等规模的软件系统，也都是在对问题域不断深入认识的过程中，一次次进化的。我们这次来分析activeMQ的领域模型，也是本着这样的态度，这篇文章是1.0版，随着我们之后的不断认识，该领域模型的分析也会不断深入。

在正式分析前，我要申明一下，图中所出现的类之间的关系，我们希望达到“神似”，并且我们也只是选择了最为重要的一部分领域类。

首先介绍该模型中每个领域类的作用，然后再介绍它们之间的关系。

Broker：activeMQ的一个整体代表

RegionBroker：负责分发broker的操作到相应的消息区域

Region：activeMQ目前有四种主要消息区域：队列域(queueRegion)、主题域(topicRegion)、临时队列域(tempQueueRegion)、临时主题域(tempTopicRegion)

TransportConnection：代表一个通讯连接

Destination：消息的目的地，主要包括两种Queue、Topic两种

Subscription：消息的消费者、订阅者

MessageStore：消息持久化存储，象比较复杂的Kaha存储机制就放在这

PendingMessageCursor：等待发给消费者的消息分发指针

ConnectionContext：用来维护发送请求所需的连接上下文

下面我们把这些领域类的关系进行一个描述：

1、一个RegionBroker拥有4种消息域的对象。

2、RegionBroker拥有所有目的地对象(destination)。

3、每个消息域(Region)也拥有它们对应的0或N个目的地对象(destination)。

4、同时每个Region也拥有它们对应的0或N个消息消费者、订阅者(subscription)。

5、每个目的地都有一个相应的持久化存储方式(messageStore)，以及一个等待发送的消息分发指针(pendingMessageCursor)。

6、消息消费者和目的地可以彼此拥有0或N个。

7、每个消费者都有一个对应的ConnectionContext，ConnectionContext里包括一个TransportConnection对象，通过TransportConnection把真实的消息发给消费者。

8、TransportConnection也可以做为通讯连接，侦听消息生产者发出的信息，所以每个TransportConnection会指向Broker对象。

上面的关系描述是静态的，不便于理解，就像人的筋脉一样，所以下面我们通过消息在activeMQ里的流动过程，来打通activeMQ的“七筋八脉”。

图二

消费生产者进程向activeMQ所在进程发送消息和消费者消费消息的过程如上图所示，消息传递的路径经过了核心领域模型，具体步骤如下：

步骤1：生产者通过向activeMQ为它建立好的TransportConnection发送消息给activeMQ。

步骤2：TransportConnection对象找到RegionBroker。

步骤3：RegionBroker根据消息的类型找到对应的消息区域(Region)。

步骤4：该Region在它自己里面找到相应的消息目的地。

步骤5、6：该目的地首先根据需要进行持久化操作，并使用待发送消息指针对象。

步骤7：当有合适的消息消费者、订阅者来到时，目的地会找到这些消费者。

步骤8、9：通过该消费者对应的TransportConnection，消息从activeMQ中出来，发给相应的消费者进程。

activeMQ指南针_领域模型分析_V1.0相关推荐

问道区块链_区块链学习_v1.0.0_持续更新。。。
本系列内容参考图创建共识网络调用部署挖矿消耗编写超级链组件节点多节点账号智能合约合约账号燃料耗品代币开发者区块尊重原创,转载请注明出处https://blog.csd ...
实战微博互动预测之一_问题分析以及分布式下的事件驱动机制（Pub与Sub模式）
实战微博互动预测之一_问题分析 2017年12月08日 13:21:04 xieyan0811 阅读数:2390 版权声明:本文为博主原创文章,未经博主允许不得转载. https://blog.csd ...
Blueprint代码详细分析-Android10.0编译系统（七）
摘要:Blueprint解析Android.bp到ninja的代码流程时如何走的? 阅读本文大约需要花费18分钟. 文章首发微信公众号:IngresGe 专注于Android系统级源码分析,Andro ...
电路分析导论_生存分析导论
电路分析导论 In our extremely competitive times, all businesses face the problem of customer churn/retenti ...
(原码反码补码的计算)在一个8位的二进制的机器中，补码表示的整数范围是从_(1)_(小)到_(2)_(大)。这两个数在机器中的补码表示为_(3)_(小)到_(4)_(大)。数0的补码为_(5)_。
https://blog.csdn.net/hanhanwanghaha宝藏女孩欢迎您的关注! 欢迎关注微信公众号:宝藏女孩的成长日记如有转载,请注明出处(如不注明,盗者必究) 目录题目分析过 ...
驱动外置+原版安装方式『XLOS_Windows8_Pro_X86纯净版_V1.0』
============================= XLOS_Windows8_Pro_X86纯净版_V1.0============================== ◆◆◆◆◆◆◆本次采 ...
Python爬虫_案例分析（二）
Python爬虫_案例分析(二) 一.电影天堂案例 import scrapy from scrapy_movie.items import ScrapyMovieItem class MvSpide ...
第09章_性能分析工具的使用
第09章_性能分析工具的使用文章目录 1. 数据库服务器的优化步骤 2. 查看系统性能参数 3. 统计SQL的查询成本:last_query_cost 4.定位执行慢的 SQL:慢查询日志 4.1 ...
问道阿里哨兵Sentinel框架_仪表盘_限流_v0.0.2
文件名称版本号作者 qq 版本问道阿里哨兵Sentinel框架_仪表盘_限流 v0.0.2 若布与宫合 8416837 SpringBoot 2.2.2 Spring-cloud-starter ...

activeMQ指南针_领域模型分析_V1.0

activeMQ指南针_领域模型分析_V1.0相关推荐

最新文章

热门文章