<!-- https://mvnrepository.com/artifact/net.dreamlu/mica-mqtt-client-spring-boot-starter -->
        <dependency>
            <groupId>net.dreamlu</groupId>
            <artifactId>mica-mqtt-client-spring-boot-starter</artifactId>
            <version>2.2.8</version>
        </dependency>

mqtt:
  server:    
    enabled: false              # 是否開啟服務(wù)端，默認(rèn)：false
  client:
    enabled: true               # 是否開啟客戶端，默認(rèn)：false
    ip: 172.16.10.203   # 連接的服務(wù)端 ip ，默認(rèn)：127.0.0.1
    port: 1883                  # 端口：默認(rèn)：1883
    name: Mica2-Mqtt2-Client      # 名稱，默認(rèn)：Mica-Mqtt-Client
    clientId: coalface_safety_3d            # 客戶端Id（非常重要，一般為設(shè)備 sn，不可重復(fù)）
    user-name: admin           # 認(rèn)證的用戶名 你的用戶名
    password: 3@!cHy@j       # 認(rèn)證的密碼
    timeout: 5                  # 連接超時時間，單位：秒，默認(rèn)：5秒
    reconnect: true             # 是否重連，默認(rèn)：true
    re-interval: 5000           # 重連時間，默認(rèn) 5000 毫秒
    version: MQTT_3_1           # mqtt 協(xié)議版本，默認(rèn)：3.1.1
    read-buffer-size: 8092      # 接收數(shù)據(jù)的 buffer size，默認(rèn)：8092
    max-bytes-in-message: 8092  # 消息解析最大 bytes 長度，默認(rèn)：8092
    buffer-allocator: heap      # 堆內(nèi)存和堆外內(nèi)存，默認(rèn)：堆內(nèi)存
    keep-alive-secs: 60         # keep-alive 心跳維持時間，單位：秒
    clean-session: false         # mqtt clean session，默認(rèn)：true
    will-message:                # 消息遺囑
      qos: at_least_once
    ssl:
    enabled: false            # 是否開啟 ssl 認(rèn)證，2.1.0 開始支持雙向認(rèn)證
    keystore-path:            # 可選參數(shù)：ssl 雙向認(rèn)證 keystore 目錄，支持 classpath:/ 路徑。
    keystore-pass:            # 可選參數(shù)：ssl 雙向認(rèn)證 keystore 密碼
    truststore-path:          # 可選參數(shù)：ssl 雙向認(rèn)證 truststore 目錄，支持 classpath:/ 路徑。
    truststore-pass:          # 可選參數(shù)：ssl 雙向認(rèn)證 truststore 密碼

import com.alibaba.fastjson.JSONObject;
import net.dreamlu.iot.mqtt.spring.client.MqttClientSubscribe;
import org.springframework.messaging.handler.annotation.Header;
import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.stereotype.Component;
import org.tio.utils.buffer.ByteBufferUtil;
/**
 * @author tarzan
 */
@Component
@Slf4j
public class SimulationSubscriber {
    @MqttClientSubscribe("tuoyuan/publish/zj/#")
    public void zjOne(String topic, byte[] payload){
        String[] strs=topic.split("/");
        String ID=strs[strs.length-1];
        log.info("topic:{} payload:{} ID:{}", topic, new String(payload, StandardCharsets.UTF_8),ID);
    }
	 @MqttClientSubscribe("/sys/${deviceName}/thing/sub/register")
	  public void thingSubRegister(String topic, byte[] payload) {
	    // 1.3.8 開始支持，@MqttClientSubscribe 注解支持 ${} 變量替換，會默認(rèn)替換成 +
	    // 注意：mica-mqtt 會先從 Spring boot 配置中替換參數(shù) ${}，如果存在配置會優(yōu)先被替換。
	    logger.info("topic:{} payload:{}", topic, new String(payload, StandardCharsets.UTF_8));
	  }
    @MqttClientSubscribe("/tianma/publish/cmj")
    public void cmj(@Header("topic") String topic,@Payload byte[] payload) {
        System.out.println("*****************gc**************************************"+topic);
        JSONObject jsonObject = JSONObject.parseObject(ByteBufferUtil.toString(payload));
        //業(yè)務(wù)的處理
        System.out.println("*****************test**************************************"+jsonObject);
    }
    @MqttClientSubscribe("/tianma/publish/zj")
    public void zj(@Header("topic") String topic,@Payload byte[] payload) {
        System.out.println("*****************gc**************************************"+topic);
        JSONObject jsonObject = JSONObject.parseObject(ByteBufferUtil.toString(payload));
        //業(yè)務(wù)的處理
        System.out.println("*****************test**************************************"+jsonObject);
    }
    @MqttClientSubscribe("/tianma/publish/gbj")
    public void gbj(@Header("topic") String topic,@Payload byte[] payload) {
        System.out.println("*****************gc**************************************"+topic);
        JSONObject jsonObject = JSONObject.parseObject(ByteBufferUtil.toString(payload));
        //業(yè)務(wù)的處理
        System.out.println("*****************test**************************************"+jsonObject);
    }
    @MqttClientSubscribe("/tianma/publish/ltl")
    public void ltl(@Header("topic") String topic,@Payload byte[] payload) {
        System.out.println("*****************gc**************************************"+topic);
        JSONObject jsonObject = JSONObject.parseObject(ByteBufferUtil.toString(payload));
        //業(yè)務(wù)的處理
        System.out.println("*****************test**************************************"+jsonObject);
    }
    @MqttClientSubscribe("/tianma/publish/ntl")
    public void ntl(@Header("topic") String topic,@Payload byte[] payload) {
        System.out.println("*****************gc**************************************"+topic);
        JSONObject jsonObject = JSONObject.parseObject(ByteBufferUtil.toString(payload));
        //業(yè)務(wù)的處理
        System.out.println("*****************test**************************************"+jsonObject);
    }
    @MqttClientSubscribe("/tianma/publish/ccl")
    public void ccl(@Header("topic") String topic,@Payload byte[] payload) {
        System.out.println("*****************gc**************************************"+topic);
        JSONObject jsonObject = JSONObject.parseObject(ByteBufferUtil.toString(payload));
        //業(yè)務(wù)的處理
        System.out.println("*****************test**************************************"+jsonObject);
    }
}

import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import net.dreamlu.iot.mqtt.spring.client.MqttClientTemplate;
import org.springblade.core.secure.annotation.NoToken;
import org.springblade.core.tool.api.R;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.nio.charset.StandardCharsets;
/**
 * @author tarzan
 */
@RestController
@Api(tags = "mqtt測試")
@NoToken
@RequestMapping("/mqtt")
@AllArgsConstructor
@Slf4j
public class MqttTestController {
    private final MqttClientTemplate mqttClientTemplate;
    @ApiOperation(value = "消息發(fā)送")
    @PostMapping("/publish")
    private R<Boolean> publish(String topic, String msg) {
        return R.status(mqttClientTemplate.publish(topic, msg.getBytes(StandardCharsets.UTF_8)));
    }
}