开始使用

mqttx conn -h 'broker.emqx.io' -p 1883 -u 'admin' -P 'public'

mqttx sub -t 'hello' -h 'broker.emqx.io' -p 1883

# 发布单个消息
mqttx pub -t 'hello' -h 'broker.emqx.io' -p 1883 -m '来自MQTTX CLI的消息'

# 发布多个消息（多行）
mqttx pub -t 'hello' -h 'broker.emqx.io' -p 1883 -s -M

# Connect Benchmark
mqttx bench conn -c 5000

# Subscribe Benchmark
mqttx bench sub -c 5000 -t bench/%i

# Publish Benchmark
mqttx bench pub -c 5000 -t bench/%i

# 指定一个本地内置的场景并开始模拟
mqttx simulate -sc tesla -c 10

# 指定一个场景文件并开始模拟
mqttx simulate -f <scenario file path> -c 10

# 列出内置模拟数据的场景
mqttx ls -sc

mqttx check

mqttx --help

mqttx conn --help

mqttx sub --help

mqttx pub --help

mqttx bench conn --help

mqttx bench sub --help

mqttx bench pub --help

mqttx bench conn -c 10000 -i 10 -I "mqttx-bench-%i"

tcp:default
  listen_on       : :1883
  acceptors       : 16
  proxy_protocol  : false
  running         : true
  current_conn    : 10000
  max_conns       : 1024000

mqttx bench sub -c 500 -t mqttx/bench/t

mqttx bench pub -c 20 -im 100 -t mqttx/bench/t -m "mqttx bench test"

Received total: 10989500, rate: 100000/s

mqttx simulate --help

/**
 * MQTTX 场景文件示例
 * 
 * 此脚本生成随机的温度和湿度数据。
 */
function generator (faker, options) {
  return {
    // 如果没有返回主题，则使用命令行参数中的主题。
    // 主题格式：'mqttx/simulate/myScenario/' + clientId,
    message: JSON.stringify({
      temp: faker.datatype.number({ min: 20, max: 80 }),  // 在 20 到 80 之间生成随机温度。
      hum: faker.datatype.number({ min: 40, max: 90 }),   // 在 40 到 90 之间生成随机湿度。
    })
  }
}
// 导出场景模块
module.exports = {
  name: 'myScenario',  // 场景名称
  generator,          // 生成器函数
}

mqttx simulate --scenario tesla

mqttx ls --scenarios

mqttx simulate --scenario <场景名称>

mqttx list --help

# 保存到默认路径
mqttx conn --save

# 保存到指定路径
mqttx conn --save ../custom/mqttx-cli.json

# 保存到指定路径，并指定格式为 yaml
mqttx conn --save ../custom/mqttx-cli.yaml

# 从默认路径导入配置
mqttx conn --config

# 从指定路径导入配置
mqttx conn --config ../custom/mqttx-cli.json

# 从指定路径导入格式为 yaml 的配置
mqttx conn --config ../custom/mqttx-cli.yaml

mqttx sub -t topic --output-mode clean | jq '.payload'  

mqttx sub -t topic --output-mode clean | jq '{topic, payload, retain: .packet.retain, userProperties: .packet.properties.userProperties}'