| 角色 | 功能 |
|---|---|
| 生产端 | 发布消息（Qos0、Qos1）、发布定时消息（Qos0、Qos1） |
| 消费端 | 订阅、取消订阅 |
| 消费端 | 消费-ACK（自动、手动） |
| 服务端 | 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed |
| 服务端 | 内存运行、快照持久化（自动、停机、手动） |
//使用 MacBook pro 2020 + JDK8 本机测试，单客户端发与收（跑分难免有波动，我是选了好看点的）
FolkMQ 是个“新式”的消息中间件。强调：“简而强”。可内嵌，可单机，可集群（部署包为 9Mb）。 功能简表 角色 功能 生产者（客户端） 发布普通消息、Qos0消息、定时消息、顺序消息、可过期消息、事务消息、广播消息 消费者（客户端） 订阅、取消订阅。消费-ACK（自动、手动） 服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed 客户端语言支持 Java、Python、JavaScript（支持 node.js 后端，...
之前发了《把 FolkMQ 内嵌到 SpringBoot2 项目里（比如 “诺依” 啊）》。有人说都淘态了，有什么好内嵌的。。。所以再发个 SpringBoot3 FolkMQ 是一个 “纯血国产” 的消息中间件。支持内嵌、单机、集群、多重集群等多种部署方式。 内嵌版，就相当于 H2 或 SQLite 数据库一样。给一些小项目（或者特别需求）带来了方便。 大项目，则可以使用独立部署的 “单机版” 或 “集群版” 内嵌个消息中间件，体积会不会太大啦？！！不会...
FolkMQ 是个“新式”的消息中间件。强调：“简而强”。可内嵌，可单机，可集群（部署包为 9Mb）。 功能简表 角色 功能 生产者（客户端） 发布普通消息、Qos0消息、定时消息、顺序消息、可过期消息、事务消息、广播消息 消费者（客户端） 订阅、取消订阅。消费-ACK（自动、手动） 服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed 客户端语言支持 Java、Python、JavaScript（支持 node.js 后端，...
FolkMQ （消息中间件）支持内嵌、单机、集群、多重集群等多种部署方式。 内嵌版，就相当于 H2 或 SQLite 数据库一样。给一些小项目（或者特别需求）带来了方便。 大项目，则可以使用独立部署的 “单机版” 或 “集群版” 内嵌个消息中间件，体积会不会太大啦？！！不会，单机版只有9Mb，内嵌版才7Mb。超级小的啦！ 1、了解 FolkMQ 内嵌版 FolkMQ 内嵌版（带 Web 控制台界面的），体积增加 7Mb，就可以附加完整消息中间件的能力喽...
FolkMQ 是个“新式”的消息中间件。强调：“小而巧”、“简而强”。可内嵌，可单机，可集群（部署包为 9Mb）。 功能简表 角色 功能 生产者（客户端） 发布普通消息、Qos0消息、定时消息、顺序消息、可过期消息、事务消息、广播消息 消费者（客户端） 订阅、取消订阅。消费-ACK（自动、手动） 服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed 客户端语言支持 Java、Python、JavaScript（支持 no...
FolkMQ 是个“新式”的消息中间件。强调：“小而巧”、“简而强”。 功能简表 角色 功能 生产者（客户端） 发布普通消息、Qos0消息、定时消息、顺序消息、可过期消息、事务消息、广播消息 消费者（客户端） 订阅、取消订阅。消费-ACK（自动、手动） 服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed 客户端语言支持 Java、Python、JavaScript（支持 node.js 后端，web 前端） 传输协议支持 tcp、...
folkmq 提供了一个内存保护模式。当内存使用超过 80% 时，开始拒收对端的消息（通过告警异常反馈）。此特性，直接由 socket.d 提供支持。好处是： 服务端不会 oom（服务端支持） 客户端也不会 oom（客户端支持） 示例： 启动服务端（中间件）： java -Xmx256M -jar folkmq-server.jar 用客户端简单压测一下： public class Test { public static void main(String[] args) throws Exception { MqClient cli...
功能简表 角色 功能 生产者（客户端） 发布消息、定时消息（或叫延时）、顺序消息、可过期消息、事务消息。支持 Qos0、Qos1 消费者（客户端） 订阅、取消订阅。消费-ACK（自动、手动） 服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed 客户端语言支持 for Java for JavaScript for Python 传输协议支持（基于 socket.d 开发，所以同时支持） tcp udp websocket kcp 本次更新 新增 python clien...
功能简表 角色 功能 生产者（客户端） 发布消息、定时消息（或叫延时）、顺序消息、可过期消息、事务消息。支持 Qos0、Qos1 消费者（客户端） 订阅、取消订阅。消费-ACK（自动、手动） 服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed 本次更新 添加 自定义 tid(key) 支持（之前自动生成） 添加 PackagingLoopImpl 新的构造函数 添加 外部配置文件加载支持（./data/app.yml） 添加 消息二进制数...
功能简表 角色 功能 生产者（客户端） 发布消息、定时消息（或叫延时）、顺序消息、可过期消息、事务消息。支持 Qos0、Qos1 消费者（客户端） 订阅、取消订阅。消费-ACK（自动、手动） 服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed 本次更新 调整 控制台发布消息后保持在原界面 调整 添加流转批小工具 sokcet.d 升为 2.4.7 面向简单编程 1) 启动服务 docker run -p 18602:18602 -p 8602:...
FolkMQ，作一个最简单的消息中间件（单机版，约 180K TPS）。面向简单，面向未来！ 功能简介 角色 功能 生产端（或发起端） 发布消息、定时消息（或叫延时）、顺序消息、可过期消息、事务消息。发送消息（rpc） 支持 Qos0、Qos1 消费端（或接收端） 订阅、取消订阅。消费-ACK（自动、手动）。监听（rpc） 服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed 服务端 单线程、内存运行、快照持久化（...
FolkMQ 打算作一个简单的消息中间件（全球最简单的那种，要比谁都简单！）。追世间简单为何物，可叫我生死相许！ 面向简单编程 1) 启动服务 docker run -p 18602:18602 -p 8602:8602 noearorg/folkmq-server:1.3.1 2) 编写程序 引入一个小依赖 <dependency> <groupId>org.noear</groupId> <artifactId>folkmq-transport-smartsocket</artifactId> <version>1.3.1</version> </dependency> 写程序喽 ...
FolkMQ 提供了二段式提交的事务提交的机制（TCC 模型）。允许生产者在发送消息时绑定到一个事务中并接收事务的管理，以确保消息的原子性（要么全成功，要么全失败）。在 FolkMQ 中，事务是通过 MqTransaction 接口实现管理的。一般是通过： 新建事务：在产生者端，可以通过调用 MqTransaction tran = client.newTransaction() 新建一个事务。后续的消息发送与此事务绑定。绑定的消息，即参与此事务；没绑定的消息，则照旧。 发送...
简介 采用 “单线程” + “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"（可选） 基于 Socket.D 网络应用协议 开发。全新设计，自主架构！ 角色 功能 生产端 发布消息、定时消息、顺序消息、可过期消息、事务消息。发送请求（rpc）。支持 Qos0、Qos1 消费端 订阅、取消订阅。响应请求 消费者 消费-ACK（自动、手动） 服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed 服务端 单...
简介 采用 “单线程” + “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"（可选） 基于 Socket.D 网络应用协议 开发。全新设计，自主架构！ 角色 功能 生产端 发布消息（Qos0、Qos1）、定时消息（Qos0、Qos1）、可过期消息（Qos0、Qos1） 消费端 订阅、取消订阅 消费端 消费-ACK（自动、手动） 服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed 服务端 内存运行、快照持久化（自...
简介 采用 “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"（可选） 基于 Socket.D 网络应用协议 开发。全新设计，自主架构！ 角色 功能 生产端 发布消息（Qos0、Qos1）、定时消息（Qos0、Qos1）、可过期消息（Qos0、Qos1） 消费端 订阅、取消订阅 消费端 消费-ACK（自动、手动） 服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed 服务端 内存运行、快照持久化（自动、停机、手动...
简介 采用 “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"（可选） 基于 Socket.D 网络应用协议 开发。全新设计，自主架构！ 角色 功能 生产端 发布消息（Qos0、Qos1）、发布定时消息（Qos0、Qos1）、发布重试 消费端 订阅、取消订阅 消费端 消费-ACK（自动、手动） 服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed 服务端 内存运行、快照持久化（自动、停机、手动） 服务端 ...
简介 采用 “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"（可选）+ 基于 Socket.D 网络应用协议 开发。全新设计，自主架构！ 角色 功能 生产端 发布消息（Qos0、Qos1）、发布定时消息（Qos0、Qos1）、发布重试 消费端 订阅、取消订阅 消费端 消费-ACK（自动、手动） 服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed 服务端 内存运行、快照持久化（自动、停机、手动） 服务端 ...
简介 采用 “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"（可选）+ 基于 Socket.D 网络应用协议 开发。全新设计，自主架构！ 角色 功能 生产端 发布消息（Qos0、Qos1）、发布定时消息（Qos0、Qos1）、发布重试 消费端 订阅、取消订阅 消费端 消费-ACK（自动、手动） 服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed 服务端 内存运行、快照持久化（自动、停机、手动） 服务端 ...
FolkMQ 是一个新起的内存型消息中间件。 简介 采用 “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"（可选）+ 基于 Socket.D 网络应用协议 开发。全新设计，自主架构！ 角色 功能 生产端 发布消息（Qos0、Qos1）、发布定时消息（Qos0、Qos1）、发布重试 消费端 订阅、取消订阅 消费端 消费-ACK（自动、手动） 服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed 服务端 内存运行、...
评论