FolkMQ 正在参加 2021 年度 OSC 中国开源项目评选,请投票支持!
FolkMQ 在 2021 年度 OSC 中国开源项目评选 中已获得 {{ projectVoteCount }} 票,请投票支持!
2021 年度 OSC 中国开源项目评选 正在火热进行中,快来投票支持你喜欢的开源项目!
2021 年度 OSC 中国开源项目评选 >>> 中场回顾
FolkMQ 获得 2021 年度 OSC 中国开源项目评选「最佳人气项目」 !
授权协议 BSD-3-Clause
开发语言 Java HTML/CSS
操作系统 跨平台
软件类型 开源软件
开源组织
地区 国产
投 递 者 梅子酒好吃
适用人群 未知
收录时间 2023-11-28

软件简介

  • 采用 "内存运行" + "快照持久化" + "Broker 集群模式"(可选)
  • 基于 Socket.D 开发(它有的特性全支持),尤其是单连接“多路复用”!也可增加 udp 之类的协议支持
角色 功能
生产端 发布消息(Qos0、Qos1)、发布定时消息(Qos0、Qos1)
   
消费端 订阅、取消订阅
消费端 消费-ACK(自动、手动)
   
服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed
服务端 内存运行、快照持久化(自动、停机、手动)

特点

  • 快、是真的快(大约 100_000 TPS)。有点像 Redis 之于 MySql。

//使用 MacBook pro 2020 + JDK8 本机测试,单客户端发与收(跑分难免有波动,我是选了好看点的)

展开阅读全文

代码

的 Gitee 指数为
超过 的项目

评论

点击引领话题📣 发布并加入讨论🔥
发表了资讯
今天 13:23

🎉 FolkMQ 作个简单的 MQ(最简单的那种)

FolkMQ 打算作一个简单的消息中间件(全球最简单的那种,要比谁都简单!)。追世间简单为何物,可叫我生死相许! 面向简单编程 1) 启动服务 docker run -p 18602:18602 -p 8602:8602 noearorg/folkmq-server:1.3.1 2) 编写程序 引入一个小依赖 <dependency> <groupId>org.noear</groupId> <artifactId>folkmq-transport-smartsocket</artifactId> <version>1.3.1</version> </dependency> 写程序喽 ...

1
0
发表了资讯
03/02 21:35

FolkMQ 是怎样进行消息的事务处理?

FolkMQ 提供了二段式提交的事务提交的机制(TCC 模型)。允许生产者在发送消息时绑定到一个事务中并接收事务的管理,以确保消息的原子性(要么全成功,要么全失败)。在 FolkMQ 中,事务是通过 MqTransaction 接口实现管理的。一般是通过: 新建事务:在产生者端,可以通过调用 MqTransaction tran = client.newTransaction() 新建一个事务。后续的消息发送与此事务绑定。绑定的消息,即参与此事务;没绑定的消息,则照旧。 发送...

0
0
发表了资讯
02/23 17:38

🎉FolkMQ v1.2 发布(添加事务消息)

简介 采用 “单线程” + “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"(可选) 基于 Socket.D 网络应用协议 开发。全新设计,自主架构! 角色 功能 生产端 发布消息、定时消息、顺序消息、可过期消息、事务消息。发送请求(rpc)。支持 Qos0、Qos1 消费端 订阅、取消订阅。响应请求 消费者 消费-ACK(自动、手动) 服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed 服务端 单...

0
5
发表了资讯
02/06 10:31

FolkMQ "单线程"的消息中间件 v1.0.32

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

0
7
发表了资讯
01/17 15:18

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

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

4
1
发表了资讯
01/02 16:29

FolkMQ 消息中间件 v1.0.26(添加 ws 端口支持)

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

1
2
发表了资讯
2023/12/28 15:29

FolkMQ 新的消息中间件,v1.0.25

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

0
2
发表了资讯
2023/12/21 08:44

FolkMQ 内存型消息中间件,v1.0.23

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

0
2
发表了资讯
2023/12/15 12:52

FolkMQ “多中心”集群部署方案

FolkMQ 是一个新起的内存型消息中间件。 简介 采用 “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"(可选)+ 基于 Socket.D 网络应用协议 开发。全新设计,自主架构! 角色 功能 生产端 发布消息(Qos0、Qos1)、发布定时消息(Qos0、Qos1)、发布重试 消费端 订阅、取消订阅 消费端 消费-ACK(自动、手动) 服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed 服务端 内存运行、...

2
1
发表了资讯
2023/12/14 17:08

FolkMQ 内存型消息中间件,v1.0.21 发布

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

0
1
发表了资讯
2023/12/11 11:47

FolkMQ 内存型消息中间件,v1.0.19 发布

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

10
3
发表了资讯
2023/12/08 10:58

FolkMQ 180K TPS,v1.0.18 发布

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

2
1
发表了资讯
2023/11/28 12:55

FolkMQ 首版发布,10 万 TPS!

FolkMQ,是一个内存型消息中间件。它采用了类似 Redis 的策略(内存运行 + 快照持久化) 功能 发布消息、发布定时消息(支持 Qos0、Qos1) 订阅、取消订阅 ACK,自动重试、有策略的延时(可做分布式事务应用) 主要特点 快、是真的快(大约 100_000 TPS)。有点像 Redis 之于 MySql。 //使用 MacBook pro 2020 + JDK8 本机测试,单客户端发与收(跑分难免有波动,我是选了好看点的) Helloworld 1、启动服务 docker run -p 18...

9
9
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
发表了博客
{{o.pubDate | formatDate}}

{{formatAllHtml(o.title)}}

{{parseInt(o.replyCount) | bigNumberTransform}}
{{parseInt(o.viewCount) | bigNumberTransform}}
没有更多内容
暂无内容
发表了问答
{{o.pubDate | formatDate}}

{{formatAllHtml(o.title)}}

{{parseInt(o.replyCount) | bigNumberTransform}}
{{parseInt(o.viewCount) | bigNumberTransform}}
没有更多内容
暂无内容
暂无内容
0 评论
15 收藏
分享
OSCHINA
登录后可查看更多优质内容
返回顶部
顶部