FolkMQ

作一个最简单的开源消息中间件（单机版，约 180K TPS）

支持定时、过期、顺序、事务等消息特性。支持确认、重试、延时。 
//server
docker run -p 18602:18602 -p 8602:8602 noearorg/folkmq-server:1.4.2

//client
public class ClientDemo {
    public static void main(String[] args) throws Exception {
        //客户端
        MqClient client = FolkMQ.createClient("folkmq://127.0.0.1:18602")
                                .nameAs("demoapp")
                                .connect();

        //订阅
        client.subscribe("demo.topic", message -> {
            System.out.println(message);
        });
        
        //发布
        client.publish("demo.topic", new MqMessage("helloworld!"));
    }
}
我们的赞助商

暂无...


成为赞助商