1
2
3
4
5
6
7
8
9
10
11
12
13
| package com.zy.integration.iot.client;
|
| public interface IotMqttClient {
|
| void ensureConnected() throws Exception;
|
| void publish(String topic, String payload) throws Exception;
|
| boolean isConnected();
|
| /** 重新读库并断开/重建连接，用于后台改配置后生效。 */
| void reconnectFromDbConfig();
| }
|
|
