mqtt-test/test02/src/main/java/com/huimv/controller/PublishController.java

package com.huimv.controller;


import com.huimv.publish.PublishMQTT;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.Map;

@RestController
@RequestMapping("/test")
public class PublishController {

    @RequestMapping("/send")
    public void test(@RequestBody Map<String, String> paramsMap) {
        String message = paramsMap.get("message");
        PublishMQTT client = new PublishMQTT();
        client.start();
        System.out.println("ss");
        client.pubMessage(message,"test");
    }
}