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