FolkMQ 消息中间件 v1.0.26（添加 ws 端口支持）

2023 大语言模型技术报告.pdf

简介

采用 “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"（可选）
基于 Socket.D 网络应用协议开发。全新设计，自主架构！

角色	功能
生产端	发布消息（Qos0、Qos1）、发布定时消息（Qos0、Qos1）、发布重试

消费端	订阅、取消订阅
消费端	消费-ACK（自动、手动）

服务端	发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed
服务端	内存运行、快照持久化（自动、停机、手动）
服务端	集群热扩展

特点

高吞吐量、低延迟

FolkMQ 纯内存运行，每秒能处理几十万条消息，最低延迟不到1毫秒。

可扩展性

FolkMQ Broker 集群支持 folkmq-server 节点热扩展。流量高时随时加，流量低时可减

持久性、可靠性

消息被快照持久化（类似于 redis）到本地磁盘，并且支持数据备份防止数据丢失

高可用

集群内任何节点坏掉只要还有“一个”同类节点，仍可提供服务

快（单机版，180K TPS）。有点像 Redis 之于 MySql。

本次更新

添加 folkmq-broker 对 ws 协议的支持
sokcet.d 升为 2.2.2

 //server //docker run -p 18602:18602 -p 8602:8602 noearorg/folkmq-server:1.0.26  //client public class ClientDemo {     public static void main(String[] args) throws Exception {         //客户端         //MqClient client = FolkMQ.createClient("folkmq://127.0.0.1:18602").connect(); //tcp 端口         MqClient client = FolkMQ.createClient("folkmq🇼🇸//127.0.0.1:18603").connect(); //ws 端口          //订阅         client.subscribe("demo", "demoapp", message -> {             System.out.println(message);         });          //发布         client.publishAsync("demo", new MqMessage("helloworld!"));     } }