FolkMQ 首版发布,10 万 TPS!


FolkMQ,是一个内存型消息中间件。它采用了类似 Redis 的策略(内存运行 + 快照持久化)

功能

  • 发布消息、发布定时消息(支持 Qos0、Qos1)
  • 订阅、取消订阅
  • ACK,自动重试、有策略的延时(可做分布式事务应用)

主要特点

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

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

Helloworld

1、启动服务

docker run -p 18602:18602 -p 8602:8602 noearorg/folkmq-server:1.0.8 

2、编写客户端代码

  • maven import
<dependencies>
<!-- 可选包:java-tcp(90kb左右), smartsocket(260Kb左右), netty(2.5Mb左右) -->
<dependency>
<groupId>org.noear</groupId>
<artifactId>folkmq-transport-java-tcp</artifactId>
<version>1.0.8</version>
</dependency>
</dependencies>
  • client(consumer + producer) use
public class ClientDemo1 {
public static void main(String[] args) throws Exception {
//客户端(鉴权为可选。服务端,不添加则不鉴权)
MqClient client = FolkMQ.createClient("folkmq://127.0.0.1:18602?ak=folkmq&sk=YapLHTx19RlsEE16")
.connect();

//订阅(consumer = ip or cluster name)
client.subscribe("demo", "demoapp", message -> {
System.out.println(message);
});

//发布
client.publish("demo", "helloworld!");
}
}

相關推薦

2024-03-08

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

2024-01-03

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

2024-01-18

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

2023-12-16

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

2024-02-07

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

2024-02-24

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

2023-02-23

ZQPool 是一个可以替代 pgbouncer 的连接池软件 ,在 1.2 版本中主要做了一下改进: 1. 之前的版本不支持文本大小超过64K的SQL语句,新版本没有此限制了; 2. 连接池上增加了参数msg_buf_size,可以指定接收或发送消息的缓冲区默认大

2023-02-11

ZQPool 是一个可以替代 pgbouncer 的连接池软件 ,在1.1版本中主要做了一下改进: 之前的版本,前端连接过来的用户名和数据库名称必须与后端数据库中的完全一样,现在可以不一样。例如原先的版本如果使用scott用户连接ZQPool

2023-12-05

有用户说,“Socket.D 之于 Socket,尤如 Vue 之于 Js、Mvc 之于 Http” 主要特性 基于事件,每个消息都可事件路由 所谓语义,通过元信息进行语义描述 流关联性,有相关的消息会串成一个流 语言无关,使用二进制输传数据

2023-09-08

le 开发者在线课程 开始学习 CNCF 与 Wasm 社区合作发布了首版 Wasm landscape,旨在帮助更好地了解 Wasm 生态系统范围。“最初的 Cloud Native Landscape 帮助我们描绘了围绕云原生技术的庞大生态系统,我们相信,随着生态系统的发展和

2024-05-28

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

2023-09-14

商业化产品作为 TDMQ 产品家族的新成员在本次大会上重磅发布。 TDMQ RocketMQ 版是一款分布式高可用的消息队列服务,兼容 Apache RocketMQ 的各个组件与概念,支持开源客户端零改造接入,同时具备计算存储分离,灵活扩缩容的底

2024-04-17

编程 1) 启动服务 docker run -p 18602:18602 -p 8602:8602 noearorg/folkmq-server:1.4.2 2) 编写程序 引入一个小依赖 <dependency> <groupId>org.noear</groupId> <artifactId>folkmq-transport-netty</artifactId> <version>1.4.2</version> &

2024-06-05

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