简介
- 采用 "内存运行" + "快照持久化" + "Broker 集群模式"(可选)
- 基于 Socket.D 网络应用协议 开发,使用“多路复用”技术。全新设计,自主架构!
角色 | 功能 |
---|---|
生产端 | 发布消息(Qos0、Qos1)、发布定时消息(Qos0、Qos1)、发布重试 |
消费端 | 订阅、取消订阅 |
消费端 | 消费-ACK(自动、手动) |
服务端 | 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed |
服务端 | 内存运行、快照持久化(自动、停机、手动) |
特点
- 快、是真的快(单机版,180K TPS)。有点像 Redis 之于 MySql。
//使用 MacBook pro 2020 + JDK8 本机测试,单客户端发与收(跑分难免有波动,我是选了好看点的)
本次更新
- 添加 folkmq-server 最大消息等待时间配置(默认 180s,之前为2h)!!!
- 优化 folkmq-server 快照持久化可用性,增加“临时文件”与“备份文件”概念。更加稳定可靠!!!
- 优化 folkmq-broker 客户端异常断连的恢复速度与性能。异常情况恢复更快!!!
- 调整 folkmq-broker 控制台,会话看板合并到消息看板
- 调整 集群模式下消费者的订阅名字(由 consumerGroup 改为 topic#consumerGroup)!!!
- 调整 服务端派发改为单线程模式(更适合很多队列的情况)!!!
- 调整 客户端分片大小配置(之前为默认16m,现改为1m)
- 取消 发布重试功能(如有需要用户自行处理)
代码仓库
- https://gitee.com/noear/folkmq
- https://github.com/noear/folkmq
还没有评论,来说两句吧...