首页 > 系统相关 >FolkMQ 内存型消息中间件,v1.0.21 发布

FolkMQ 内存型消息中间件,v1.0.21 发布

时间:2023-12-14 20:22:05浏览次数:31  
标签:订阅 21 FolkMQ v1.0 发布 添加 内存 消息中间件 folkmq

简介

  • 采用 “多路复用” + "内存运行" + "快照持久化" + "Broker 集群模式"(可选)+
  • 基于 Socket.D 网络应用协议 开发。全新设计,自主架构!
角色 功能
生产端 发布消息(Qos0、Qos1)、发布定时消息(Qos0、Qos1)、发布重试
消费端 订阅、取消订阅
消费端 消费-ACK(自动、手动)
服务端 发布-Confirm、订阅-Confirm、取消订阅-Confirm、派发-Retry、派发-Delayed
服务端 内存运行、快照持久化(自动、停机、手动)
服务端 集群热扩展

特点

  • 高吞吐量、低延迟

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

  • 可扩展性

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

  • 持久性、可靠性

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

  • 快(单机版,180K TPS)。有点像 Redis 之于 MySql。

//使用 MacBook pro 2020 + JDK8 本机测试,单客户端发与收(跑分难免有波动,我是选了好看点的)

本次更新

  • 添加 集群热扩展机制(重要新特性)
  • 添加 folkmq-server 控制台消息手动发布功能
  • 添加 folkmq-broker 控制台消息手动发布功能
  • 添加 mq.event.join 新指令(用于加入集群时,同步订阅)
  • 添加 client 批量订阅支持(连接前的订阅,在连接时批量提交)
  • 添加 client::unpublish 取消发布接口中
  • 添加 client::unpublishAsync 取消发布异步接口
  • 调整 各端打开时的日志打印
  • sokcet.d 升为 2.1.13

代码仓库

标签:订阅,21,FolkMQ,v1.0,发布,添加,内存,消息中间件,folkmq
From: https://www.cnblogs.com/noear/p/17901932.html

相关文章

  • C1021 无效的预处理器命令“warning”(CGAL)
    1、错误:fatalerrorC1021:无效的预处理器命令“warning” 2、错误定位:\cgal\include\CGAL\internal\enable_third_party_libraries.h3、错误原因:未包含“gmp.h”文件的include路径4、解决方式:添加“gmp.h”文件的include路径 ......
  • springboot虚拟线程(jdk21,springboot3.2.0)
    1.什么是虚拟线程虚拟线程是JDK21版本正式发布的一个新特性。虚拟线程和平台线程主要区别在于,虚拟线程在运行周期内不依赖操作系统线程:它们与硬件脱钩,因此被称为“虚拟”。这种解耦是由JVM提供的抽象层赋予的。虚拟线程的运行成本远低于平台线程。它们消耗的内存要少得多。这就......
  • 11.21
    Java是一门面向对象编程语言,不仅吸收了C++语言的各种优点,还摒弃了C++里难以理解的多继承、指针等概念,因此Java语言具有功能强大和简单易用两个特征。Java语言作为静态面向对象编程语言的代表,极好地实现了面向对象理论,允许程序员以优雅的思维方式进行复杂的编程。......
  • [20231213]tmux与环境变量PTAH.txt
    [20231213]tmux与环境变量PTAH.txt--//昨天给一台机器安装配置tmux,发现登陆tmux后环境变量PATH特别长,问题在于tmux登陆后要重复执行.bash_profile的内容.--//以前遇到过,主要问题在于.bash_profile在配置PATH时写法不合理.exportPATH=$PATH;...exportPATH=$PATH;...exportPAT......
  • CF213E Two Permutation 题解
    CF213ETwoPermutations题解题意:给出两个排列$a,b$,长度分别为\(n,m\),你需要计算有多少个$x$,使得\(a_1+x,a_2+x,...a_n+x\)是\(b\)的子序列。\(n\leqm\leq2\times10^5\)分析:一个很自然的思路是直接枚举\(x\),然后只保留\(b\)中值域在\([x+1,x+n]\)......
  • test1211
    别急。先更一波T2,T3。七管荧光灯可以状压打表可以发现:一种局面为必败状态当且仅当满足\(a_{1}=x,a_{2}=x,a_{3}=x,a_{4}=y,a_{5}={z},a_{6}=z,a_{7}=z\)且\(x\oplusy\oplusz=0\)。然后就可以数位dp了,记个\(f_{i,0/1,0/1,0/1,0/1,0/1,0/1}\)。随便跑跑就行。字符串......
  • Swin Transformer 马尔奖论文(ICCV 2021最佳论文)
    目录简介作者之一的微软亚研院的首席研究员胡瀚老师在bibili讲过该论文swintransformer比ViT做的更好的原因之一就是它将图片的一些特性嵌入到了网络模型之中,比如说平移不变性和尺寸不变性等,这样使得网络能够在cv领域做的更好。该文章提出的SwinTransformer可以被当做通用的......
  • 4412 设备树 没有eth0 没有加载 dm9621 驱动。
    问题: 在4412的板卡上烧写完,设备树的镜像之后,系统启动之后,发现没有网络。 这种情况,在从新烧写一遍镜像就可以了,具体原因不清楚,可能跟设备树的uboot的烧写命令有关。  总结:4412 8G以及16Gemmc的核心板在设备树的镜像上网络上都是可以的,主要就是需要多烧......
  • 1211 | 和PAI一起,每周玩转AI,活动开始了
    【和PAI一起,每周玩转AI】系列活动上线了!人工智能平台PAI提供近万元免费云上资源,助力开发者们体验AIGC能力。参与每周AIGC主题活动,有机会赢取小米手环8、小米充电宝等多重好礼!加入AIGC活动钉群,及时了解每周最新AI活动!......
  • 20231213matlab问题资料汇总
    https://bbs.csdn.net/topics/390064770https://www.ilovematlab.cn/forum.php?mod=viewthread&tid=455375&_dsign=7812fb23https://blog.csdn.net/fmber/article/details/85858771https://www.mathworks.com/help/dotnetbuilder/MWArrayAPI/html/T_MathWorks_MATL......