Skip to main content
Version: 2.5.1

Mqtt Plugin

Description#

  • The current implementation of the MQTT protocol is version 3.1, which implements the following identifiers: connect, publish, subscribe, unsubscribe, disconnect, PingReq, PingResp, and QoS 0.

  • The implementation is missing retain, implementation of QoS (1,2), and cluster mode.

  • For more information, please see the content at http://public.dhe.ibm.com/software/dw/webservices/ws-mqtt/mqtt-v3r1.html.

Introducing Plugin Support of Mqtt Gateway#

  • Introducing those dependencies in the pom.xml file of the gateway.
<!-- apache shenyu mqtt plugin start--><dependency>    <groupId>org.apache.shenyu</groupId>    <artifactId>shenyu-spring-boot-starter-plugin-mqtt</artifactId>    <version>${project.version}</version></dependency>

Plugin Setting#

  • port: MQTT BS port designation.

  • bossGroupThreadCount: default 1.

  • maxPayloadSize: Maximum packet size.

  • workerGroupThreadCount: default 12.

  • username: default shenyu.

  • password: default shenyu.

  • isEncryptPassword: The default is false , whether to encrypt the password.

  • encryptMode: encryption mode, currently only MD5 is implemented, the encryption mode can be customized, org.apache.shenyu.protocol.mqtt.utils.EncryptUtil view the implementation of this encryption class.

  • leakDetectorLevel: default DISABLED, resource target detection or detection level.

Notice#

  • Mqtt does not have selector and ruler configurations.