使用客户端证书对MQTT进行压力测试

问题描述

我有一个Scala项目，我希望能够使用加特林测试我们的mqtt代理的性能。

我在github：https://github.com/mnogu/gatling-mqtt中遇到了gatling-mqtt插件。我不确定如何添加客户端证书以连接到MQTT broker。

我尝试了下一个代码，没有证书也可以正常工作，但是我没有找到将客户端证书添加到连接或配置的选项。

package com.github.mnogu.gatling.mqtt.test

import com.github.mnogu.gatling.mqtt.Predef._
import io.gatling.core.Predef._
import org.fusesource.mqtt.client.QoS

import scala.concurrent.duration._

class MqttSimulation extends Simulation {
  val mqttConf = mqtt.host("tcp://mqttbroker:1883")

  val connect = exec(mqtt("connect")
    .connect())

  val publish = repeat(100) {
    exec(mqtt("publish")
      .publish("foo","Hello",QoS.AT_LEAST_ONCE,retain = false))
      .pause(1000 milliseconds)
  }

  val disconnect = exec(mqtt("disconnect")
    .disconnect())

  val scn = scenario("MQTT Test")
    .exec(connect,publish,disconnect)

  setUp(
    scn
      .inject(rampusers(10) over (1 seconds))
  ).protocols(mqttConf)
}

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

gatling scala-gatling