FluxMQ—2.0.8版本更新内容

FluxMQ—2.0.8版本更新内容

前言

FLuxMQ是一款基于java开发,支持无限设备连接的云原生分布式物联网接入平台。FluxMQ基于Netty开发,底层采用Reactor3反应堆模型,具备低延迟,高吞吐量,千万、亿级别设备连接;方便企业快速构建其物联网平台与应用。

FluxMQ官网:https://www.fluxmq.com

FluxMQ演示系统:http://demo.fluxmq.com/

新增指令消费

在之前版本指令下发途径有两种:

  1. MQTT客户端连接,通过发布订阅方式去发送数据
  2. HTTP接口进行指令下发

在2.0.8版本中,我们新增了多种MQ集成方式,通过配置MQ的主题映射MQTT的主题完成对应指令的下发,方便业务快速集成指令下发,同时我们支持Nacos配置中心,可以方便在SpringCloud-Alibaba项目中直接使用Feign进行服务调用,完成微服务生态的全面融合,而无需开发任何代码。

MQ的集成

目前我们支持Kafka、RocketMQ,RabbitMQ,Pulsar直接集成消费。下面我们以Kafka配置详解如何使用


可以配置从Kafka获取数据的编码,默认使用String的Decoder进行获取数据,可以配置轮询的线程以及周期。数据源的配置就是Kafka的Properties原生配置

可以配置Kafka Topic映射到Mqtt Topic,以及使用的Qos级别以及是否保留消息

Nacos注册中心

如图注册服务后,在SpringCloud可以使用Feign Client进行服务调用。默认我们注册的是 POST /public/mqtt/publish的请求

@FeignClient("fluxmq")//服务名称
public interface MqttPulishService {@PostMapping("/public/mqtt/publish")void send(@RequestBody PublishBody body);
}@Data
public class PublishBody {private String topic;private int qos;private boolean retain;private DataType dataType;private Object message;
}public enum DataType {JSON,STRING,HEX
}

License授权

在2.0.8中,我们新增了标准的License授权,默认我们提供了一个免费永久的License在安装包中(连接数100),方便小客户免费接入使用,也可以用FluxMQ来进行功能测试。

License集成

默认读取启动目录的 License.base64文件


当然也可以在config.yaml进行license文件指定

license: /soft/icense.base64

指定读取license的文件路径。读取启动目录的/soft/license.base64文件

服务启动成功后登录管理平台可以查看到License的信息:

Pool配置改动

修改FluxMQ流量控制配置,最新配置如下

pool:bossThreadSize: 1  # boss线程 默认=cpu核心数workThreadSize: 10  # work线程 默认=cpu核心数+2eventThreadSize: 16  # 业务线程数 默认=cpu核心数bufferSize: 512  #  ringBuffer大小eventMessageSize: 500000 # 最大缓冲消息数lowWaterMark:  32768highWaterMark:  65536globalReadSize: 102400 # 全局读字节数/s 默认不限制globalWriteSize: 102400 #   全局写字节数/s 默认不限制channelReadSize: 1024 #  单连接读字节数/s 默认不限制channelWriteSize: 1024 #  单连接写字节数/s 默认不限制

下面的配置理论上是最优配置,不需要额外设置。

参数名描述默认值
bossThreadSizenetty的bossThreadSize,一般配置1~4 cpu即可必填项
workThreadSizenetty的workThreadSize,处理io事件默认cpu
eventThreadSizeMQTT事件消费线程,主要处理规则引擎等耗时操作,默认cpu+2
bufferSizeMQTT事件消费RIngBufer大小默认1024
eventMessageSize全局读写限制:每秒字节数默认50000
globalReadSize全局读限制:每秒字节数读不推荐配置
globalWriteSize全局写限制:每秒字节数读不推荐配置
channelReadSize单个连接读限制:每秒字节数读不推荐配置
channelWriteSize单个连接写限制:每秒字节数不推荐配置
lowWaterMark默认 32768不推荐配置
highWaterMark当写入缓存字节数达到此值,默认 65536不推荐配置

FluxMQ免费推广

FluxMQ默认提供免费的接入License许可,直接参考我们文档下载即可。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/200388.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

调试GMS应用,报错“此设备未获得play保护机制认证”问题解决

不少同学在调试GMS相关应用时,需登录Google账号,有时会弹出如下通知。 Google登录界面也会出现如下提示 这个报错的原因是设备未通过Google认证,google服务器未配置荣耀设备的型号白名单导致 国内网页有一些指导方法在鸿蒙\荣耀的设备上消除这…

07、pytest指定要运行哪些用例

官方用例 # 目录结构 | |----test_mod.py | |----testing||----test_dir.py# content of test_mod.py import pytestdef func(x):return x 1def test_mod():print("test_mod function was invoked")assert func(3) 5def test_func():print("test_func was in…

【机器学习】聚类(三):原型聚类:高斯混合聚类

文章目录 一、实验介绍1. 算法流程2. 算法解释3. 算法特点4. 应用场景5. 注意事项 二、实验环境1. 配置虚拟环境2. 库版本介绍 三、实验内容0. 导入必要的库1. 全局调试变量2. 调试函数3. 高斯密度函数(phi)4. E步(getExpectation&#xff09…

ssm农业信息管理系统源码和论文

摘 要 网络的广泛应用给生活带来了十分的便利。所以把农业信息管理与现在网络相结合,利用java技术建设农业信息管理系统,实现农业信息管理的信息化。则对于进一步提高农业信息管理发展,丰富农业信息管理经验能起到不少的促进作用。 农业信息…

QT 无法打开包括文件 “xxxx.h”: No such file or direcotry 提升控件后提示找不到头文件

问题复现 UI文件提升控件后,提示找不到头文件。 原因 Qt中的ui文件会经过moc编辑器生成ui_xxx.h头文件。 在主页面的ui文件中因为使用了提升的widget,所以ui的ui头文件因该包含自定义控件的头文件。但是头文件的路径可以看出已经错误了。 #include &…

圣诞节临近,外贸人怎么做才能让客户疯狂下单?

(1)提醒客户即将而至的节假日:圣诞节工厂会很忙,紧接着中国春节也快来了,给采购商制造紧张感! 建议在与海外采购商的沟通中善于运用各种技巧,可以告诉他们,因为假期临近、季节变化等…

消费数据可视化大屏,助力金融机构智慧运维

在今天的数字化时代,消费数据的可视化已经成为了一种重要的趋势。通过将消费数据以图表、图像等形式展现出来,可以帮助我们更直观地了解消费者的行为和趋势。同时,这也为企业提供了更多的分析和决策依据。无论是针对市场营销策略的制定&#…

在vscode下将ipynb文件转成markdown(.md文件)的方法

这里写自定义目录标题 写在最前面安装nbconvert工具vscode界面 or cmd终端 写在最前面 正常情况下,可以在vscode的ipynb界面点击上面的三个点,里面有export导出,可以选择直接输出html和pdf 但是没有markdown(.md文件)…

信号是怎么搞到电磁波上面去的呢?

在之前的文章中,我们曾多次讲到电磁波的美妙,但是有了电磁波就可以通信了吗? No,我们要把信息加载到电磁波上,这个电磁波就可以作为信息的载体来工作了。可是信号是怎么加载到电磁波上的呢? 今天我们一起…

【数据结构与算法篇】八种排序 (C++实现)

多种排序算法的Cpp实现 一. 排序的概念及其运用排序的概念 二. 一图速览常见排序三. 排序的C实现1> 直接插入排序2> 希尔排序希尔排序代码实现(希尔所实现)希尔排序代码实现(优化版) 3> 选择排序选择排序的代码实现(同时选出最大和最小的元素) 4> 堆排序堆排序的代…

multipath

目录 文章目录 目录什么是multipathmultipath配置文件demo1(最小化配置)demo2demo3字段解析 命令**案例:查看多路径设备的信息。(常用)****案例:刷新multipath状态**案例:-v2/-v3 打印信息案例:查看当前活动路径的设备信息案例&am…

第17章 匿名函数

第17.1节 匿名函数的基本语法 [捕获列表](参数列表) mutable(可选) 异常属性 -> 返回类型 { // 函数体 }语法规则:lambda表达式可以看成是一般函数的函数名被略去,返回值使用了一个 -> 的形式表示。唯一与普通函数不同的是增加了“捕获列表”。 …

羊大师讲解鲜羊奶的营养价值

羊大师讲解鲜羊奶的营养价值 鲜羊奶是一种天然、营养丰富的食品,拥有独特的健康价值。它不仅具备高蛋白、低脂肪的特点,还富含各种维生素和矿物质,对人体健康有着卓越的贡献。今天,我们就来一探鲜羊奶的营养奥秘。 鲜羊奶的营养…

Data Linked UI

DataLinkedUl是一个Unity框架,它允许您在为您的应用程序创建用户界面时实现专业的数据驱动方法。使用此资产,您可以创建灵活的基于瓦片的任意大小的复杂接口系统。 核心功能: 灵活性-允许适应和调整数据变化,允许各种结构和功能配置,而不需要对现有系统进行重大破坏。 可伸…

AI封测需求强劲, AMD、英伟达等巨头将助推产业链增长 | 百能云芯

近期,超微(AMD)和英伟达(NVIDIA)相继发布了新一轮AI芯片,为封测产业链注入了新的活力。据业内人士透露,客户端对AI封测的需求愈发强劲,整体量能超过原先的估计,其中日月光…

我有才满足于自媒体行业的知识付费平台课程

行业资讯 实时行业热点新闻、企业动态资讯、社区热门话题,一榜打尽 通过图文、音频、视频、动态在内的多元媒介形式,致力于为企业提供多元化的资讯内容展示方式。 自定义咨询专栏,归类资讯内容,建立结构化内容体系 可以把资讯归…

循环使用接口返回的多值老大难?看我教你使用jmeter掌握72变!

有同学在用jmeter做接口测试的时候,经常会遇到这样一种情况: 就是一个接口请求返回了多个值,然后下一个接口想循环使用前一个接口的返回值。 这种要怎么做呢? 有一定基础的人,可能第一反应就是先提取前一个接口返回…

公有云迁移研究——AWS Route53

大纲 1 什么是Route 532 Route 53能做些什么# 3 通过DNS托管来实现分流3.1 创建DNS托管3.2 对托管创建记录对流量进行分配 4 通过流量策略来对流量进行分流4.1 创建流量策略 5 对比两者的区别6 推荐 在给客户从本地机房往AWS迁移的过程中,我们接到如下需求&#xff…

mysql中year函数有什么用

YEAR()函数用于提取日期或日期时间值中的年份。可以用于提取DATE、DATETIME或TIMESTAMP列中的年份。 SELECT YEAR(date_column) FROM table;# 提取字符串中的数据SELECT YEAR(2023-07-19) FROM table_name;

华容道问题求解第一部分_思路即方案设计

一、前言 华容道是一种传统的益智游戏,通常由一个长方形木板和若干个方块组成。其中包括一个或多个不同颜色的方块(也称为车块)和其他大小相同的方块(也称为障碍块)。游戏的目标是将车块从木板的一个端点移动到另一个…