FolkMQ "新型"消息中间件 v1.0.29


简介

  • 采用 “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"(可选)
  • 基于 Socket.D 网络应用协议 开发。全新设计,自主架构!
角色 功能
生产端 发布消息(Qos0、Qos1)、定时消息(Qos0、Qos1)、可过期消息(Qos0、Qos1)
   
消费端 订阅、取消订阅
消费端 消费-ACK(自动、手动)
   
服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed
服务端 内存运行、快照持久化(自动、停机、手动)
服务端 集群热扩展

特点

  • 高吞吐量、低延迟

FolkMQ 纯内存运行,每秒能处理几十万条消息,最低延迟不到1毫秒。

  • 可扩展性

FolkMQ Broker 集群支持 folkmq-server 节点热扩展。流量高时随时加,流量低时可减

  • 持久性、可靠性

消息被快照持久化(类似于 redis)到本地磁盘,并且支持数据备份防止数据丢失

  • 高可用

集群内任何节点坏掉只要还有“一个”同类节点,仍可提供服务

  • 快(单机版,180K TPS)。有点像 Redis 之于 MySql。

本次更新

  • 添加 消息过期时间支持(对物联网是个有用的特性)
  • 添加 管理后台“强制派发”和“强制删除”功能
  • 优化 快照保存的速度
  • 减少 快照保存时的内存使用
let msg = new MqMessage("hello").expiration(new Date(System.currentTimeMillis() + 5000));
client.publish("demo", msg);

代码仓库

  • https://gitee.com/noear/folkmq
  • https://github.com/noear/folkmq

官网

  • https://folkmq.noear.org

相關推薦

2024-06-05

FolkMQ 是个“新式”的消息中间件。强调:“小而巧”、“简而强”。可内嵌,可单机,可集群(部署包为 9Mb)。 功能简表 角色 功能 生产者(客户端) 发布普通消息、Qos0消息、定时消息、顺序消息、可过

2024-06-14

FolkMQ 是个“新式”的消息中间件。强调:“简而强”。可内嵌,可单机,可集群(部署包为 9Mb)。 功能简表 角色 功能 生产者(客户端) 发布普通消息、Qos0消息、定时消息、顺序消息、可过期消息、事务

2024-06-27

FolkMQ 是个“新式”的消息中间件。强调:“简而强”。可内嵌,可单机,可集群(部署包为 9Mb)。 功能简表 角色 功能 生产者(客户端) 发布普通消息、Qos0消息、定时消息、顺序消息、可过期消息、事务

2024-05-28

FolkMQ 是个“新式”的消息中间件。强调:“小而巧”、“简而强”。 功能简表 角色 功能 生产者(客户端) 发布普通消息、Qos0消息、定时消息、顺序消息、可过期消息、事务消息、广播消息    

2024-01-03

简介 采用 “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"(可选) 基于 Socket.D 网络应用协议 开发。全新设计,自主架构! 角色 功能 生产端 发布消息(Qos0、Qos1)、发布定时消息

2024-02-07

简介 采用 “单线程” + “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"(可选) 基于 Socket.D 网络应用协议 开发。全新设计,自主架构! 角色 功能 生产端 发布消息(Qos0、Qos1)、

2024-04-17

功能简表 角色 功能 生产者(客户端) 发布消息、定时消息(或叫延时)、顺序消息、可过期消息、事务消息。支持 Qos0、Qos1     消费者(客户端) 订阅、取消订阅。消费-ACK(自动、手动

2024-05-18

功能简表 角色 功能 生产者(客户端) 发布消息、定时消息(或叫延时)、顺序消息、可过期消息、事务消息。支持 Qos0、Qos1     消费者(客户端) 订阅、取消订阅。消费-ACK(自动、手动

2024-03-08

FolkMQ,作一个最简单的消息中间件(单机版,约 180K TPS)。面向简单,面向未来! 功能简介 角色 功能 生产端(或发起端) 发布消息、定时消息(或叫延时)、顺序消息、可过期消息、事务消息。发送消息

2024-05-18

端也不会 oom(客户端支持) 示例: 启动服务端(中间件): java -Xmx256M -jar folkmq-server.jar 用客户端简单压测一下: public class Test { public static void main(String[] args) throws Exception { MqClient client = FolkMQ.createClient("folkmq://1

2023-11-29

FolkMQ,是一个内存型消息中间件。它采用了类似 Redis 的策略(内存运行 + 快照持久化) 功能 发布消息、发布定时消息(支持 Qos0、Qos1) 订阅、取消订阅 ACK,自动重试、有策略的延时(可做分布式事务应用) 主要特点

2023-12-16

FolkMQ 是一个新起的内存型消息中间件。 简介 采用 “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"(可选)+ 基于 Socket.D 网络应用协议 开发。全新设计,自主架构! 角色 功能 生产端

2024-02-24

群、集群热扩展 特点 高吞吐量、低延迟 FolkMQ 纯内存运行,每秒能处理几十万条消息,最低延迟不到1毫秒。 可扩展性 FolkMQ Broker 集群支持 folkmq-server 节点热扩展。流量高时随时加,流量低时可减 持久性

2023-12-05

元资金。 而该基金被迫撤资的情况也可能会增加 Rain 将新型芯片技术推向市场的挑战,并有可能推迟 OpenAI 兑现其 5100 万美元预付款订单的日期。