FolkMQ 作一个简单的消息中间件（最简单的那种）

FolkMQ 打算作一个简单的消息中间件（全球最简单的那种，要比谁都简单！）。追世间简单为何物，可叫我生死相许！

面向简单编程

1) 启动服务

docker run -p 18602:18602 -p 8602:8602 noearorg/folkmq-server:1.3.1
1

2) 编写程序

• 引入一个小依赖

<dependency>
    <groupId>org.noeargroupId>
    <artifactId>folkmq-transport-smartsocketartifactId>
    <version>1.3.1version>
dependency>
1
2
3
4
5

• 写程序喽

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", message -> {
            System.out.println(message);
        });

        //发布消息
        client.publish("demo", new MqMessage("helloworld!"));
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

简单的才是未来的

简单！简单！还是简单！昨天有人说，简单的才是未来的。我吧：

• “源码简单”
• “架构简单”
• “部署简单”
• “使用简单”

我也是五脏具全：什么顺序(FIFO)、事务、延时、过期(TTL)，持久化，确认(ACK)，集群、超大规模集群等等…