简介
- 采用 “内存运行” + “快照持久化” + “Broker 集群模式”(可选)
- 基于 Socket.D 网络应用协议 开发,使用“多路复用”技术。全新设计,自主架构!
角色 | 功能 |
---|---|
生产端 | 发布消息(Qos0、Qos1)、发布定时消息(Qos0、Qos1)、发布重试 |
消费端 | 订阅、取消订阅 |
消费端 | 消费-ACK(自动、手动) |
服务端 | 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed |
服务端 | 内存运行、快照持久化(自动、停机、手动) |
特点
- 快、是真的快(单机版,180K TPS)。有点像 Redis 之于 MySql。
//使用 MacBook pro 2020 + JDK8 本机测试,单客户端发与收(跑分难免有波动,我是选了好看点的)
本次更新
- 调整 将“消费者”概念调整为“消费者组”概念(与经典概念同步)
- 调整 客户端创建接口,更友好些
- 添加 folkmq-broker 控制台
- 优化 folkmq-broker 答复中转流程(避免对方已关停,还在不断答复)
- 优化 folkmq-server 快照加载机制
- 优化 快照格式设计(兼容旧版)
- 优化 消息派发处理细节
- 简化 folkmq-server 连接 folkmq-broker 的地址
- 修复 broker 集群模式下,folkmq-server 无法触发启动与停目快照事件的问题
代码仓库
- https://gitee.com/noear/folkmq
- https://github.com/noear/folkmq