前言

FluxMQ配置文件

完整配置文件如下：

allowEmptyMessage: true # 是否允许空消息传递规则引擎
allowAnonymousAccess: true # 是否允许匿名访问
logAll: false # 支持开启全量日志，开启后日志追踪功能将失效
pool:
  # bossThreadSize: 4  # 默认 4 不建议配置
  # workThreadSize: 20 # 默认cpu核心数 不建议配置
  # eventThreadSize: 24 # 默认cpu核心数+2 不建议配置
  bufferSize: 4096
  # eventThreadSize: 业务线程数默认CPU+2
  # eventMessageSize: 500000 # 业务线程队列大小
  # ruleEngineAsync 规则引擎异步 默认开启
  # ruleEngineThreadSize 规则引擎线程数 默认CPU数
  # ruleEngineMessageSize 规则引擎线程队列大小
  # ruleEngineMetrics 规则引擎性能监控 默认开启
  # ruleEngineMetricsInterval 规则引擎性能监控间隔 默认60秒
  # lowWaterMark:  低水位： 默认32768 不建议配置
  # highWaterMark: 高水位: 默认65536 不建议配置
  # channelReadSize: 单连接读字节数/s ，默认不限制，不建议配置
  # channelWriteSize: 单连接写字节数/s，默认不限制， 不建议配置
mqtt: ## 支持多端口
  - port: 1883 # mqtt端口号
    wiretap: false  # 二进制日志
    messageMaxSize: 4194304 # 接收消息的最大限制 默认4194304(4M)
    proxy: false # 是否开启proxy协议
    enableAuth: true #  是否开启认证
    enableAcl: true  #  是否开启ACL  
    enableBridge: true #  是否开启桥接（规则引擎） 
    maxSendWindowSize: 100 #  单个连接发送确认消息窗口（qos1+qos2）
    maxReceiveWindowSize: 100 # 单个连接接收确认窗口（qos2）
    maxConnectionPerSecond: 1000  # 连接速率 
    sessionPersistence: false  # 开启session消息持久化，建议使用离线消息
    maxSessionSize: 100  # 开启session后 单个连接持久化最大消息数
  - port: 8999 # 端口
    useWebsocket: true # 是否使用websocket
    messageMaxSize: 4194304 # 接收消息的最大限制 默认4194304(4M)
    path: /mqtt # ws 的访问path mqtt.js请设置此选项
    enableAuth: true #  是否开启认证
    enableAcl: true  #  是否开启ACL  
    enableBridge: true #  是否开启桥接（规则引擎） 
    maxSendWindowSize: 100 #  单个连接发送确认消息窗口（qos1+qos2）
    maxReceiveWindowSize: 100 # 单个连接接收确认窗口（qos2）
    maxConnectionPerSecond: 1000  # 连接速率 
    sessionPersistence: false  # 开启session消息持久化，建议使用离线消息
    maxSessionSize: 100  # 开启session后 单个连接持久化最大消息数
http: # http相关配置 端口固定60000
  host: 127.0.0.1
  port: 8080
  accessLog: false # http访问日志
  username: fluxmq # 访问用户名
  password: fluxmq # 访问密码
  bridge: false # 走规则引擎(publish消息)
cluster: # 集群配置
  localAddress: 127.0.0.1
  addresses: ["127.0.0.1"]
meter:
  meterType: PROMETHEUS # INFLUXDB , PROMETHEUS
eventbus:
  compressed: true
  batch: true
  batchSize: 2000
  batchDuration: 50
shareSubscribe:
  strategy: RANDOM
  maxShareSubscribeSize: 100
store:
  storeType: MEMORY # MYSQL,LOCAL,MEMORY,POSTGRESQL
  datasource:
    url: jdbc:mysql://127.0.0.1:3306/fluxmq?useSSL=false
    username:  root
    password:  root
application:
  name: fluxmq