mqtt配置
quickmsg
# main启动参数详解
构建
BootstrapConfig.TcpConfig
配置文件BootstrapConfig .TcpConfig .builder() .port(8888) .build()
1
2
3
4
5
Bootstrap.TcpConfig
参数说明:
参数 | 说明 | 必传 | 默认值 |
---|---|---|---|
port | MQTT端口 | 否 | 1883 |
wiretap | 二进制日志 | 否 | false |
bossThreadSize | 核心线程数 | 否 | cpu核心数 |
workThreadSize | 工作线程数 | 否 | cpu核心数*2 |
businessThreadSize | 业务线程数 | 否 | cpu核心数*10 |
businessQueueSize | 业务队列数 | 否 | 100000 |
lowWaterMark | 低水位 | 否 | 32768 |
highWaterMark | 高水位 | 否 | 65536 |
globalReadWriteSize | 全局读写大小限制 | 否 | 无 |
channelReadWriteSize | 单个channel读写大小限制 | 否 | 无 |
ssl | ssl证书 | 否 | 参考ssl配置参数 |
options | server channel options | 否 | 无 |
childOptions | child client channel options | 否 | 无 |
启动Bootstrap时候设置
BootstrapConfig.TcpConfig
Bootstrap bootstrap = Bootstrap.builder() .rootLevel(Level.DEBUG) .tcpConfig(BootstrapConfig.TcpConfig) .build() .startAwait();
1
2
3
4
5
# 配置文件启动(docker,jar,springboot)
smqtt:
logLevel: DEBUG # 系统日志
tcp: # tcp配置
port: 1883 # mqtt端口号
wiretap: true # 二进制日志 前提是 smqtt.logLevel = DEBUG
bossThreadSize: 4 # boss线程 默认=cpu核心数
workThreadSize: 8 # work线程 默认=cpu核心数*2
businessThreadSize: 16 # 业务线程数 默认=cpu核心数*10
businessQueueSize: 100000 #业务队列 默认=100000
lowWaterMark: 4000000 # 不建议配置 默认 32768
highWaterMark: 80000000 # 不建议配置 默认 65536
# globalReadWriteSize: 10000000,100000000 全局读写大小限制
# channelReadWriteSize: 10000000,100000000 单个channel读写大小限制
options: # netty option设置
SO_BACKLOG: 200
childOptions: #netty child option设置
SO_REUSEADDR: true
ssl: # ssl配置
enable: false # 开关
key: /user/server.key # 指定ssl文件 默认系统生成
crt: /user/server.crt # 指定ssl文件 默认系统生成
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21