提交 78860064 编写于 作者: 如梦技术's avatar 如梦技术 🐛

mica-mqtt-spring-boot-starter client 完善。

上级 87691568
......@@ -22,12 +22,14 @@ import net.dreamlu.iot.mqtt.codec.MqttQoS;
import net.dreamlu.iot.mqtt.core.client.IMqttClientMessageListener;
import net.dreamlu.iot.mqtt.core.client.MqttClient;
import net.dreamlu.iot.mqtt.core.client.MqttClientCreator;
import net.dreamlu.iot.mqtt.core.client.MqttClientSubscription;
import org.springframework.beans.factory.DisposableBean;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.core.Ordered;
import org.tio.client.ClientChannelContext;
import java.nio.ByteBuffer;
import java.util.List;
/**
* mqtt client 模板
......@@ -85,16 +87,48 @@ public class MqttClientTemplate implements InitializingBean, DisposableBean, Ord
return client.subscribe(mqttQoS, topicFilter, listener);
}
/**
* 订阅
*
* @param topicFilters topicFilter 数组
* @param mqttQoS MqttQoS
* @param listener MqttMessageListener
* @return MqttClient
*/
public MqttClient subscribe(String[] topicFilters, MqttQoS mqttQoS, IMqttClientMessageListener listener) {
return client.subscribe(topicFilters, mqttQoS, listener);
}
/**
* 批量订阅
*
* @param subscriptionList 订阅集合
* @return MqttClient
*/
public MqttClient subscribe(List<MqttClientSubscription> subscriptionList) {
return client.subscribe(subscriptionList);
}
/**
* 取消订阅
*
* @param topicFilter topicFilter
* @return MqttClient
*/
public MqttClient unSubscribe(String topicFilter) {
public MqttClient unSubscribe(String... topicFilter) {
return client.unSubscribe(topicFilter);
}
/**
* 取消订阅
*
* @param topicFilters topicFilter 集合
* @return MqttClient
*/
public MqttClient unSubscribe(List<String> topicFilters) {
return client.unSubscribe(topicFilters);
}
/**
* 发布消息
*
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册