<dependency>
  <groupId>com.stanwind</groupId>
  <artifactId>spring-boot-windmq</artifactId>
  <version>1.1.2-RELEASE</version>
</dependency>

<!-- windmq dependency -->
<dependency>
  <groupId>com.stanwind</groupId>
  <artifactId>spring-boot-windmq</artifactId>
  <version>1.1.0-RELEASE</version>
</dependency>

<!-- MQTT -->
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-integration</artifactId>
<dependency>
  <groupId>org.springframework.integration</groupId>
  <artifactId>spring-integration-mqtt</artifactId>
  <exclusions>
    <exclusion>
      <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
      <groupId>org.eclipse.paho</groupId>
    </exclusion>
  </exclusions>
</dependency>
<!-- 1.2.0 版本有bug -->
<dependency>
  <groupId>org.eclipse.paho</groupId>
  <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
  <version>1.2.1</version>
</dependency>

@EnableWindMQ
@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
public class DemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}

void addTopic(String... topic);
void addTopic(String topic, int qos);
void addTopics(String[] topic, int[] qos);
void removeTopic(String... topic);

/**
 * Отправка сообщения устройству, требуется класс payload с аннотацией @Topic
 * @param deviceId
 * @param payload
 */
void notify(String deviceId, Object payload);

/**
 * Отправка сообщения в топик
 * @param topic
 * @param payload
 */
void notifyToTopic(String topic, Object payload);

/**
 * Синхронное подтверждение отправки сообщения на устройство
 * @param deviceId
 * @param payload
 * @return
 */
MqttResponse request(String deviceId, MqttRequest payload);

/**
 * Синхронное подтверждение отправки сообщения на устройство
 * @param deviceId
 * @param payload
 * @param timeout ожидание в мс
 * @return
 */
MqttResponse request(String deviceId, MqttRequest payload, long timeout);

/**
 * Ответ на синхронное сообщение
 * @param message
 * @return
 */
boolean response(Message<MqttResponse> message);

/**
* Общий ответ клиента
* @param messageId
* @param deviceId
* @param result
*/
void sendCommonResponse(Long messageId, String deviceId, Integer result);

/**
* Общий ответ клиенту
* @param messageId
* @param deviceId
*/
void sendCommonResponse(Long messageId, String deviceId);

@TopicHandler(topic = "$SYS/brokers/{node}/clients/{deviceId}/connected")
public void connected(MQTTMsg msg) {
    ClientReqVO clientReqVO = JSONObject.parseObject(msg.getPayload().toString(), ClientReqVO.class);
    process(clientReqVO);
}

@Service
public class DemoHandler extends