我们提供安全,免费的手游软件下载!
FolkMQ是一种新型的消息中间件,其设计理念强调“简而强”。该中间件具有内嵌、单机和集群部署的特点,部署包大小仅为9Mb。
功能简表:
角色 | 功能 |
---|---|
生产者(客户端) | 发布普通消息、Qos0消息、定时消息、顺序消息、可过期消息、事务消息、广播消息 |
消费者(客户端) | 订阅、取消订阅。消费-ACK(自动、手动) |
服务端 | 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed |
客户端语言支持: Java、Python、JavaScript(支持node.js后端,web前端)
传输协议支持: tcp、udp、websocket、kcp
本次更新:
面向简单编程:
1) 启动服务
docker run -p 18602:18602 -p 8602:8602 noearorg/folkmq-server:1.6.0
2) 编写程序
org.noear
folkmq-transport-netty
1.6.0
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!"));
client.publish("demo.topic", new MqMessage("helloworld!").qos(0));
client.publish("demo.topic", new MqMessage("helloworld!").sequence(true));
client.publish("demo.topic", new MqMessage("helloworld!").broadcast(true));
client.publish("demo.topic", new MqMessage("helloworld!").scheduled(Datetime.Now().addDay(10)));
//......等
}
}
代码仓库:
官网:
相关资讯
热门资讯