FolkMQ(消息中间件) v1.4.2 发布


功能简表

角色 功能
生产者(客户端) 发布消息、定时消息(或叫延时)、顺序消息、可过期消息、事务消息。支持 Qos0、Qos1
   
消费者(客户端) 订阅、取消订阅。消费-ACK(自动、手动)
   
服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed

本次更新

  • 添加 自定义 tid(key) 支持(之前自动生成)
  • 添加 PackagingLoopImpl 新的构造函数
  • 添加 外部配置文件加载支持(./data/app.yml
  • 添加 消息二进制数据支持(可以方便不同的消息数据序列化)
  • 添加 顺序消息分区支持(在集群下才有效)
  • 优化 顺序消息没有消费者时 server 端 cpu 过高的问题
  • 优化 企业版授权控制
  • 优化 Server 预关闭支持
  • 优化 顺序消息的强制派发处理
  • sokcet.d 升为 2.4.10

面向简单编程

1) 启动服务

docker run -p 18602:18602 -p 8602:8602 noearorg/folkmq-server:1.4.2

2) 编写程序

  • 引入一个小依赖
<dependency>
<groupId>org.noear</groupId>
<artifactId>folkmq-transport-netty</artifactId>
<version>1.4.2</version>
</dependency>
  • 写程序喽
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!"));
}
}

代码仓库

  • https://gitee.com/noear/folkmq
  • https://github.com/noear/folkmq

官网

  • https://folkmq.noear.org

相關推薦

2024-01-03

简介 采用 “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"(可选) 基于 Socket.D 网络应用协议 开发。全新设计,自主架构! 角色 功能 生产端 发布消息(Qos0、Qos1)、发布定时消息

2024-02-07

简介 采用 “单线程” + “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"(可选) 基于 Socket.D 网络应用协议 开发。全新设计,自主架构! 角色 功能 生产端 发布消息(Qos0、Qos1)、

2024-05-18

功能简表 角色 功能 生产者(客户端) 发布消息、定时消息(或叫延时)、顺序消息、可过期消息、事务消息。支持 Qos0、Qos1     消费者(客户端) 订阅、取消订阅。消费-ACK(自动、手动

2024-01-18

简介 采用 “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"(可选) 基于 Socket.D 网络应用协议 开发。全新设计,自主架构! 角色 功能 生产端 发布消息(Qos0、Qos1)、定时消息(Qos0

2024-03-08

FolkMQ,作一个最简单的消息中间件(单机版,约 180K TPS)。面向简单,面向未来! 功能简介 角色 功能 生产端(或发起端) 发布消息、定时消息(或叫延时)、顺序消息、可过期消息、事务消息。发送消息

2024-05-18

端也不会 oom(客户端支持) 示例: 启动服务端(中间件): java -Xmx256M -jar folkmq-server.jar 用客户端简单压测一下: public class Test { public static void main(String[] args) throws Exception { MqClient client = FolkMQ.createClient("folkmq://1

2023-11-29

FolkMQ,是一个内存型消息中间件。它采用了类似 Redis 的策略(内存运行 + 快照持久化) 功能 发布消息、发布定时消息(支持 Qos0、Qos1) 订阅、取消订阅 ACK,自动重试、有策略的延时(可做分布式事务应用) 主要特点

2023-12-16

FolkMQ 是一个新起的内存型消息中间件。 简介 采用 “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"(可选)+ 基于 Socket.D 网络应用协议 开发。全新设计,自主架构! 角色 功能 生产端

2024-02-24

群、集群热扩展 特点 高吞吐量、低延迟 FolkMQ 纯内存运行,每秒能处理几十万条消息,最低延迟不到1毫秒。 可扩展性 FolkMQ Broker 集群支持 folkmq-server 节点热扩展。流量高时随时加,流量低时可减 持久性

2024-04-20

Yzncms v1.4.2 已经发布,内容管理系统 此版本更新内容包括: 【优化】php版本最低要求为7.2.5+ 【修复】修复无法添加角色的bug 【修复】修复后台编辑个人资料 退出问题 【新增】添加前后台视图钩子 【新增】后台配置和插件配置

2023-10-18

【源创会预告】1024 程序员节(的前两天),相约开源PHP办公室,我们一起聊 AI!>>> 版本说明 优化特性 在集群列表增加集群版本; 修改Jvm的GC指标名; 解决问题 解决shell脚本换行符的问题; 解决部署历史列表页,

2023-03-15

PicList 是一个云存储管理和图片上传工具,可以进行包括云端目录查看、文件搜索、批量上传下载和删除文件,复制多种格式文件链接和文件预览等操作。 开源地址和软件官网 Github: https://github.com/Kuingsmile/PicList Gitee: https

2023-03-11

PicList 是一个云存储管理和图片上传工具,可以进行包括云端目录查看、文件搜索、批量上传下载和删除文件,复制多种格式文件链接和文件预览等操作。 开源地址和软件官网 Github: https://github.com/Kuingsmile/PicList Gitee: https

2023-12-19

然不在话下,用来做 IM 也未尝不可,开发 MQ 也很简单(FolkMQ 就是用它开发的)。某些特性也可以用来做代理或者网络穿透。 IoT的场景,比如小明的家里有个智能空调,小明想在外面通过手机 APP 来控制空调开关,如何优雅