Moquette源码分析(二)v0.12订阅树

Moquette 0.12(以下简称M12)的订阅树实现在moquette-0.12/broker/src/main/java/io/moquette/broker/subscriptions,包括:

订阅树版本 M10 M12
订阅树增删改查 SubscriptionDirectory CTrieSubscriptionDirectory
订阅树 - CTrie
片段 Token Token
主题 Topic Topic
订阅信息 Subscription Subscription
普通节点 TreeNode CNode
封装节点 - INode
墓碑节点 - TNode

查看源码的时候应该从CTrie开始阅读。

阅读更多

Moquette源码分析(一)v0.10订阅树

一、M10 简介

Moquette 0.10(以下简称M10)的订阅树实现在moquette-0.10/broker/src/main/java/io/moquette/spi/impl/subscriptions,包括:

  • SubscriptionsDirectory:订阅树的增删改查
  • Token:片段,由topicFilter按“/”分割而成的最小字符串单位
  • Topic:主题/主题过滤器,包含一系列方法,比如比较主题和主题过滤器是否匹配
  • Subscription:订阅信息,{clientId, topicFilter,qos,active}
  • TreeNode:树节点

查看源码的时候应该从SubscriptionsDirectory开始阅读。

阅读更多