FolkMQ v1.7.8

FolkMQ v1.1 更新与兼容说明

本次版本发布,把整体架构改成了"单线程"架构,并增加了"顺序消息"的支持。

兼容说明

本次更新,向下兼容。新增的顺序消息功能,需要新版服务端支持。

更新说明

  • 调整 消息流处理改为单线程架构!
  • 添加 “绝对顺序”消息支持(同时支持单机模式与集群模式)!
  • 修复 客户端问题:同一个项目内,用不同的 consumerGroup 订阅同一个topic 会被覆盖的问题
  • sokcet.d 升为 2.4.0

新功能示例:

//同步
client.publish("demo.topic", new MqMessage("hello").sequence(true)));
//异步
client.publishAsync("demo.topic", new MqMessage("hello").sequence(true)));

架构调整参考:《单线程及顺序保障架构图》