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