ActiveMQ源码解析（一）（聊聊broker） JAVA学习

一、Broker 消息队列核心，相当于一个控制中心，负责路由消息、保存订阅和连接、消息确认和控制事务 1.Broker接口定义了一些获取broker本身相关信息，添加connection、destination、session、消息生产者、控制事务的接口 1.1 CompositeDestinationBroker 多目的地Broker，Producer可以通过它将生产的消息传给多个destination 1.2 EmptyBroker 空broker 1.3 ErrorBroker 调用的它的方法会抛出BrokerStoppedException 1.4 TransactionBroker 为broker的每个方法提供分布式事务XA支持
2、BrokerFactory（抽象工厂模式） public static BrokerService createBroker(URI brokerURI, boolean startBroker) throws Exception { if (brokerURI.getScheme() == null) { throw new IllegalArgumentException("Invalid broker URI, no scheme specified: " + brokerURI); } //根据url创建工厂实例 BrokerFactoryHandler handler = createBrokerFactoryHandler(brokerURI.getScheme()); //利用工厂handler创建broker（产品） BrokerService broker = handler.createBroker(brokerURI); if (startBroker) { broker.start(); } return broker; } 3、BrokerContext 上下文环境，参考spring的ApplicationContext 4、BrokerContextAware 获取上下文环境接口 5、BrokerFilter Broker的子类，用户可以在broker的操作前后加入一些自己的逻辑以实现像安全这样的逻辑 6、BrokerPlugin和BrokerPluginSupport BrokerPlugin只有一个方法： BrokerPluginSupport继承自 MutableBrokerFilter并实现BrokerPlugin，实现机制跟BrokerFilter类似。 7、BrokerRegistry 很明显，这里有一个单例模式，一个互斥信号量mutex和一个保存所有BrokerService的map brokers。它是一个注册中心，负责维护所有BrokerSerevice，完成获取、绑定和解绑等操作。 8、BrokerService和BrokerServiceAware 后者是获取BrokerService的接口，前者是一个核心的类，它有自己的声明周期，连接了Connector，Broker，Region等组件，包括创建、注册和移除相关的组件。
8.1、SslBrokerService 在创建连接时提供ssl安全链接
9、TransportConnector 提供通信服务
10、ProductorBrokerExchange和ConsumerBrokerExchange 对Broker和Producer、Broker和Consumer之间的流进行控制，并跟踪记录信息
总结 1、ActiveMQ的特性基本上都是通过BrokerFilter模式加上去的

ActiveMQ源码解析（一）（聊聊broker）

推荐阅读

永嘉风光永嘉哪里好玩

劳动是意思相近的词吗快乐是意思相近的词语吗

没开封茶叶会不会过期

迷你世界手机版怎么去竹桃林桃林地形码迷你世界分享

画图工具怎么手绘一款简笔画蛋糕？画图工具手绘简笔画蛋糕的方法

win10epic遭遇了网络连接问题解决方法

荷包蛋面条怎么做荷包蛋面条怎么做视频

4s店样品车可以买吗现在 4s店样品车可以买吗

汽车新四化是什么谈谈汽车新四化

聪明的梅花鹿告诉了我们什么道理一只梅花鹿告诉我们什么道理

周公解梦梦见骨灰盒是什么意思梦见骨灰盒好不好

皮肤瘙痒冷敷多久最好

毛衣可以和其他衣服一起用洗衣机洗吗

十一岁的男孩怎么教育

win101909声卡没声音解决方法

3dmax怎么做雪景关于3DMAX制作雪景的详细操作

品牌规划的流程

手机里库乐队删了怎么办手机库乐队没了怎么办

准备从事棋牌游戏人员必读

审议不通过怎么写会议纪要如何写会议纪要