私募基金网站建设要求,百度指数是什么意思,室内设计应届生简历,做资讯网站盈利简介
采用 “单线程” “多路复用” “内存运行” “快照持久化” “Broker 集群模式”#xff08;可选#xff09;基于 Socket.D 网络应用协议 开发。全新设计#xff0c;自主架构#xff01;
角色功能生产端发布消息#xff08;Qos0、Qos1#xff09;、定时消息 “多路复用” “内存运行” “快照持久化” “Broker 集群模式”可选基于 Socket.D 网络应用协议 开发。全新设计自主架构
角色功能生产端发布消息Qos0、Qos1、定时消息Qos0、Qos1、可过期消息Qos0、Qos1消费端订阅、取消订阅消费端消费-ACK自动、手动服务端发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed服务端内存运行、快照持久化自动、停机、手动服务端集群热扩展、集群高可用
特点
高吞吐量、低延迟
FolkMQ 纯内存运行每秒能处理几十万条消息最低延迟不到1毫秒。
可扩展性
FolkMQ Broker 集群支持 folkmq-server 节点热扩展。流量高时随时加流量低时可减
持久性、可靠性
消息被快照持久化类似于 redis到本地磁盘并且支持数据备份防止数据丢失
高可用
集群内任何节点坏掉只要还有“一个”同类节点仍可提供服务
快单机版180K TPS。
有点像 Redis 之于 MySql。
支持绝对顺序消息
通过配置实现
本次更新
服务端的消息主处理改为单线程模式
向 redis 学习。消息的主处理基本在内存里进行。所以改成单线程后性能没啥变化。
添加 单机模式下绝对有序支持
//消息绝对有序配置支持发送有序接收有序
MqClient client FolkMQ.createClient(folkmq://127.0.0.1:18601?akak1sksk1,folkmq://127.0.0.1:18602?akak1sksk1).config(c-c.sequenceMode(true).coreThreads(1).maxThreads(1)).connect();添加 集群安全停止支持。实现一端停止另一端完全无感知不异常不卡顿
新的高可用演示视频https://www.bilibili.com/video/BV1Ha4y1R73b/
添加 管理接口支持
//管理接口一般用于用户自己开发管理界面通过接口管理 FolkMQ
String json client.call(MqApis.MQ_QUEUE_VIEW_MESSAGE, token, demo,demoApp).get();代码仓库
https://gitee.com/noear/folkmqhttps://github.com/noear/folkmq
官网
https://folkmq.noear.org
