com.feingto.iot.client

类 MqttClient

java.lang.Object

com.feingto.iot.client.service.MqttMessageService

com.feingto.iot.client.MqttClient

所有已实现的接口:

IMqttMessage

public class MqttClient
extends MqttMessageService

MQTT 客户端

作者:

longfei

构造器概要

构造器

构造器和说明
MqttClient(NettyProperties config)

方法概要

限定符和类型	方法和说明
MqttClient	callback(ResponseCallback<SendMessage> callback)
void	connect() 连接服务端
void	destroy() 释放资源
void	publish(String topic, String message) 推送消息至主题
void	publish(String topic, String message, boolean retained) 推送是否保留的消息至主题
void	publish(String topic, String message, boolean retained, int qos) 推送是否保留的Qos消息至主题
void	publish(String topic, String message, int qos) 推送Qos消息至主题
void	reconnect() 重新连接
void	subscribe(SubscribeMessage... messages) 订阅
void	unsubscribe(String... topics) 取消订阅

从类继承的方法 com.feingto.iot.client.service.MqttMessageService

connack, connect, disconnect, exceptionCaught, pingreq, puback, pubcomp, publish, pubrec, pubrel, suback, unsubBack

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

MqttClient

public MqttClient(NettyProperties config)

方法详细资料

callback

public MqttClient callback(ResponseCallback<SendMessage> callback)

connect

public void connect()

连接服务端

reconnect

public void reconnect()

重新连接

publish

public void publish(String topic,
                    String message)

推送消息至主题

publish

public void publish(String topic,
                    String message,
                    int qos)

推送Qos消息至主题

publish

public void publish(String topic,
                    String message,
                    boolean retained)

推送是否保留的消息至主题

publish

public void publish(String topic,
                    String message,
                    boolean retained,
                    int qos)

推送是否保留的Qos消息至主题

subscribe

public void subscribe(SubscribeMessage... messages)

订阅

unsubscribe

public void unsubscribe(String... topics)

取消订阅

destroy

public void destroy()

释放资源