com.supermap.messagequeue

类 MQTTClient

java.lang.Object

com.supermap.messagequeue.InternalHandle

com.supermap.messagequeue.MQTTClient

public class MQTTClient
extends InternalHandle

MQTT客户端类，基于MQTT协议的消息总线客户端方案

采用主题订阅方式实现消息收发的机制，

构造器概要

构造器

构造器和说明
MQTTClient() 构造函数

方法概要

限定符和类型	方法和说明
boolean	create(java.lang.String uri, java.lang.String userName, java.lang.String password, java.lang.String clientID) 创建连接
void	dispose() 析构函数，释放资源
MQTTReturnMessage	receiveMessage() 接收消息 需在子线程执行该操作
void	resume() 唤醒
boolean	sendMessage(java.lang.String topic, java.lang.String message) 发送消息
boolean	subscribe(java.lang.String topicName, int qos) 订阅某一主题
void	suspend() 挂起
boolean	unsubscribe(java.lang.String topicName) 取消某一主题的订阅

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

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

构造器详细资料

MQTTClient

public MQTTClient()

构造函数

方法详细资料

create

public boolean create(java.lang.String uri,
                      java.lang.String userName,
                      java.lang.String password,
                      java.lang.String clientID)

创建连接

参数:

uri - 服务地址

userName - 用户名

password - 用户密码

clientID - 客户端ID

返回:

创建成功返回true,否则返回false

dispose

public void dispose()

析构函数，释放资源

subscribe

public boolean subscribe(java.lang.String topicName,
                         int qos)

订阅某一主题

参数:

topicName - 主题名

qos - 消息质量

返回:

订阅成功返回true,否则返回false

unsubscribe

public boolean unsubscribe(java.lang.String topicName)

取消某一主题的订阅

参数:

topicName - 主题名

返回:

返回是否取消成功

sendMessage

public boolean sendMessage(java.lang.String topic,
                           java.lang.String message)

发送消息

参数:

topic - 主题名

message - 消息内容

返回:

发送成功返回true,否则返回false

receiveMessage

public MQTTReturnMessage receiveMessage()

接收消息

需在子线程执行该操作

返回:

接收到的消息

resume

public void resume()

唤醒

suspend

public void suspend()

挂起