FolkMQ 首版发布,10 万 TPS!

来源: 投稿
2023-11-28 12:55:00

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!");
    }
}
展开阅读全文
点击加入讨论🔥(9) 发布并加入讨论🔥
本篇精彩评论
9 评论
8 收藏
分享
返回顶部
顶部