FolkMQ v1.7.8

FolkMQ v1.5 更新与兼容说明

本次版本发布,增加了“广播消息”,"带控制台的内嵌版","js sdk 单文件"

兼容说明

  • 本次更新,向下兼容。
  • 其中 "fokmq:ws" 增加了子协议验证,需要同时升级客户端与服务端。

更新说明

  • 新增 广播消息
  • 新增 folkmq-embedded (带控制台的内嵌版)
  • 新增 folkmq.js(客户端浏览器版)
  • 添加 "server-broker" 的 folkmq.maxConsumeWaiting 配置支持
  • 添加 "server-broker" 后台集群节点(内存用率)
  • 添加 "fokmq:ws" 适配 websocket 子协议验证(避免乱连)
  • 优化 server-broker 许可证配置改为可视界面
  • 优化 强制派送条件,对正在派发中或超过1次的消息有效(之前为2次)
  • 优化 强制派空处理
  • 优化 异步消息发送端的内存控制
  • 优化 客户端锁处理(无锁改为顺序锁)
  • 优化 消息事务增加对“延时消息”、“时效消息”支持
  • 修复 "Qos0消息"、"广播消息" 失效的问题(1.5.0 出现的)
  • socket.d 升为 2.5.3

新功能示例(广播消息):

MqClient client = FolkMQ.createClient("folkmq://127.0.0.1:18602")
    .nameAs("demoapp") 
    .connect();
    
client.publish("demo.topic", new MqMessage("demo1").broadcast(true));