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!"); } }