Skip to content

Commit 1812d5d

Browse files
committed
refactor(cluster): 使用Hessian替代默认序列化提升集群消息性能
- 替换ClusterMessage序列化和反序列化逻辑,采用Hessian二进制协议 - 删除不再使用的Java默认序列化相关导入和代码 - 优化MqttClusterManager中nodeToString方法,改为获取节点主机地址 - 注释MqttClusterManager中节点晚加入时全量状态同步请求,改为懒加载同步策略 - 维护ClusterMqttSessionManager客户端-节点映射及订阅同步的功能无变化,只调整代码格式 - 添加hessian-lite依赖以支持序列化功能
1 parent 6c14d3a commit 1812d5d

File tree

3 files changed

+511
-522
lines changed

3 files changed

+511
-522
lines changed

mica-mqtt-broker/pom.xml

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,11 @@
1919
<groupId>net.dreamlu</groupId>
2020
<artifactId>mica-net-core</artifactId>
2121
</dependency>
22+
<dependency>
23+
<groupId>org.apache.dubbo</groupId>
24+
<artifactId>hessian-lite</artifactId>
25+
<version>4.0.5</version>
26+
</dependency>
2227
<dependency>
2328
<groupId>org.junit.jupiter</groupId>
2429
<artifactId>junit-jupiter-engine</artifactId>

0 commit comments

Comments
 (0)