代码拉取完成，页面将自动刷新
同步操作将从 noear/folkmq 强制同步，此操作会覆盖自 Fork 仓库以来所做的任何修改，且无法恢复！！！
确定后同步将在后台操作，完成时将刷新页面，请耐心等待。
一个内存型消息中间件（支持快照持久化、Broker 集群）
| 角色 | 功能 |
|---|---|
| 生产端 | 发布消息（Qos0、Qos1）、发布定时消息（Qos0、Qos1）、发布重试 |
| 消费端 | 订阅、取消订阅 |
| 消费端 | 消费-ACK |
| 服务端 | 派发-Retry、派发-Delayed |
| 服务端 | 内存运行、快照持久化（自动、停机、手动） |
//使用 MacBook pro 2020 + JDK8 本机测试，单客户端发与收（跑分难免有波动，我是选了好看点的）
| QQ交流群：316697724 | 微信交流群（申请时输入：FolkMQ） |
|---|---|
 |
docker run -p 18602:18602 -p 8602:8602 noearorg/folkmq-server:1.0.12
<dependencies>
<!-- 可选包：java-tcp（90kb左右）, smartsocket（260Kb左右）, netty（2.5Mb左右） -->
<dependency>
<groupId>org.noear</groupId>
<artifactId>folkmq-transport-java-tcp</artifactId>
<version>1.0.12</version>
</dependency>
</dependencies>
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!").get();
}
}
| 派发次数 | 自动延时 | |
|---|---|---|
| 0 | 0s | 相当于马上发 |
| 1 | 5s | |
| 2 | 30s | |
| 3 | 3m | |
| 4 | 9m | |
| 5 | 15m | |
| 6 | 30m | |
| 7 | 1h | |
| n.. | 2h | 第8次之后都是2小时 |
详见：《API.md》
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
