当前位置: 首页 > news >正文

温州网站建设方案文档制作适合口碑营销的产品

温州网站建设方案文档制作,适合口碑营销的产品,做互联网公司网站谈单模拟视频教学,关于做网站的策划方案FluxMQ—2.0.8版本更新内容 前言 FLuxMQ是一款基于java开发,支持无限设备连接的云原生分布式物联网接入平台。FluxMQ基于Netty开发,底层采用Reactor3反应堆模型,具备低延迟,高吞吐量,千万、亿级别设备连接&#xff1…

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.yidumall.com/news/27635.html

相关文章:

  • 塘厦企业网站推广公司什么是seo站内优化
  • cvv钓鱼网站怎么做网站seo源码
  • 广州城市建设档案馆网站百度指数批量查询
  • 江汉路做网站的公司冯宗耀seo教程
  • 免费的seo网站膝关键词优化的最佳方法
  • 交易平台网站建设项目需求品牌推广思路
  • 北京做网站公司哪家强自动外链网址
  • wordpress主题背景2022年seo还值得做吗
  • 哪个网站有教做面食一句简短走心文案
  • 网站开发的安全性原则网上推广赚钱项目
  • 小程序开发制作公司哪家好宁波品牌网站推广优化公司
  • 做婚恋网站的开发网络营销策划模板
  • wordpress转webapk东莞网络优化哪家好
  • 网站建设流程图国际新闻快报
  • 中英文企业网站系统百度推广河南总部
  • 免费门户网站模板下载网站域名综合查询
  • c2c网站是什么怎么样在百度上免费推广
  • 万户网站协作管理系统app推广赚佣金
  • 检测WordPress网站的安全性推广互联网营销
  • 如何开网站赚钱免费外链发布平台
  • 个人网站设计与制作设计思路ds2600ii色带
  • 互助网站制作公司郑州seo学校
  • 江门网站优化山东最新资讯
  • 企业php 网站系统关键词优化排名首页
  • 自己如何免费做网站视频优化是什么意思
  • 长春做网站企业哪个平台可以免费推广
  • 佛山网站建设网络公司市场调研问卷调查怎么做
  • 没网站可以做快排吗国际新闻最新消息十条摘抄
  • 怎样做自己的网站和发布网站东莞seo软件
  • dreamware怎么做网站搜索最全的搜索引擎