FluxMQ—2.0.8版本更新内容

2023-12-13 20:47:01

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核心数+2
  eventThreadSize: 16  # 业务线程数 默认=cpu核心数
  bufferSize: 512  #  ringBuffer大小
  eventMessageSize: 500000 # 最大缓冲消息数
  lowWaterMark:  32768
  highWaterMark:  65536
  globalReadSize: 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许可,直接参考我们文档下载即可。

文章来源:https://blog.csdn.net/weixin_36133625/article/details/134819114
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。