域名只做邮箱没网站要备案吗,flash网站下载,平面设计素材网站排行榜前十名,合肥微信网站制作FluxMQ—2.0.8版本更新内容
前言
FLuxMQ是一款基于java开发#xff0c;支持无限设备连接的云原生分布式物联网接入平台。FluxMQ基于Netty开发#xff0c;底层采用Reactor3反应堆模型#xff0c;具备低延迟#xff0c;高吞吐量#xff0c;千万、亿级别设备连接#xff1…FluxMQ—2.0.8版本更新内容
前言
FLuxMQ是一款基于java开发支持无限设备连接的云原生分布式物联网接入平台。FluxMQ基于Netty开发底层采用Reactor3反应堆模型具备低延迟高吞吐量千万、亿级别设备连接方便企业快速构建其物联网平台与应用。
FluxMQ官网https://www.fluxmq.com
FluxMQ演示系统http://demo.fluxmq.com/
新增指令消费 在之前版本指令下发途径有两种
MQTT客户端连接通过发布订阅方式去发送数据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事件默认cpueventThreadSizeMQTT事件消费线程主要处理规则引擎等耗时操作默认cpu2bufferSizeMQTT事件消费RIngBufer大小默认1024eventMessageSize全局读写限制每秒字节数默认50000globalReadSize全局读限制每秒字节数读不推荐配置globalWriteSize全局写限制每秒字节数读不推荐配置channelReadSize单个连接读限制每秒字节数读不推荐配置channelWriteSize单个连接写限制每秒字节数不推荐配置lowWaterMark默认 32768不推荐配置highWaterMark当写入缓存字节数达到此值默认 65536不推荐配置
FluxMQ免费推广 FluxMQ默认提供免费的接入License许可直接参考我们文档下载即可。
