认证与连接
本文主要介绍如何进建立设备与云端的连接。
设备认证
SDK支持的设备认证方案如下：
设备秘钥认证方式（根据iot实际情况填写）
如：设备密钥认证方式指设备在连接物联网平台时需要使用平台颁发的ProductKey、DeviceName、DeviceSecret进行设备认证，每个设备的设备密钥不能一样，否则会出现一个设备上线导致另外一个设备下线的情况。
注：有时候设备密钥也被称为三元组。
开发者需要实现初始化失败的设备连接平台重试逻辑，如果设备连接物联网平台成功，SDK发现MQTT连接断开时会自动尝试连接物联网平台。
初始化代码如下：
一.注册消息监听器
实现Listener继承XIotTopicCallback，用于接收服务端下发消息
public void XIotMqttClient.getInstance().registerMsgListener(XIotTopicCallback userCallback)
二.与服务端建立连接
1.非阻塞式连接：
/**
* 建立客户端sdk与服务端的连接。
* 这是非阻塞式的连接
*
* @param listener 连接状态回调，可在XIotConnectionListener单独监听
* @throws XIotException 连接操作失败时抛出的异常
*/
public void XIotMqttClient.getInstance().connect(IMqttConnectionListener listener) throws XIotException
2.阻塞式连接：
/**
* 建立客户端sdk与服务端的连接。
* 这是阻塞式的连接，因此线程会被阻塞，直到操作成功/失败或者超时。
*
* @param timeout 建立连接时，线程等待时间
* @param listener 连接状态回调，可在XIotConnectionListener单独监听
* @throws XIotException 连接操作失败向外抛出的异常
* @throws XIotTimeoutException 连接操作超时抛出的异常
*/
public void XIotMqttClient.getInstance().connect(long timeout, IMqttConnectionListener listener) throws XIotException, XIotTimeoutException
3.自由选择连接方式(阻塞or非阻塞)：
/**
* 建立客户端sdk与服务端的连接。
* 该请求既可以是阻塞式也可以是非阻塞式。
*
* @param timeout 线程等待时间
* @param blocking 设置是否为阻塞式
* @param listener 连接状态回调，可在XIotConnectionListener单独监听
* @throws XIotException 连接操作失败抛出异常
* @throws XIotTimeoutException 连接超时抛出异常
*/
public void XIotMqttClient.getInstance().connect(long timeout, boolean blocking, IMqttConnectionListener listener)
throws XIotException, XIotTimeoutException
三.与服务端断开连接
1.非阻塞式断开连接：
/**
* 与服务端断开连接。该接口为非阻塞
*/
public void XIotMqttClient.getInstance().disconnect()
2.阻塞式断开连接：
/**
* 与服务端断开连接。该接口为阻塞式，因此该操作线程会被阻塞住，直到操作结果返回，
* 无论成，失败或者超时
*
* @param timeout the timeout in milliseconds that the calling thread will wait
* @throws XIotException exception thrown if the operation fails
* @throws XIotTimeoutException exception thrown if the operation times out
*/
public void XIotMqttClient.getInstance().disconnect(long timeout) throws XIotException, XIotTimeoutException
3.自由选择连接方式(阻塞or非阻塞)：
/**
* 与服务端断开连接，该API支持阻塞式和非阻塞式，通过参数blocking进行控制。
* 非阻塞式情况下，即便当前连接正在被中断的情况下，该线程不会被阻塞住。
* @param timeout the timeout in milliseconds that the calling thread will wait
* @param blocking whether the call should be blocking or non-blocking
* @throws XIotException exception thrown if the operation fails
* @throws XIotTimeoutException exception thrown if the operation times out
*/
public void XIotMqttClient.getInstance().disconnect(long timeout, boolean blocking) throws XIotException,
XIotTimeoutException
四.其他设置
1.设置当前固件版本：
/**
* 设置当前固件版本
*
* @param version 版本号
*/
public void XIotMqttClient.getInstance().setFirmwareVer(String version)
2.设置远程配置版本号：
/**
* 设置远程配置版本号
*
* @param version 版本号
*/
public int XIotMqttClient.getInstance().setRemoteConfigVer(String version)
3.设置重连间隔时间：
/**
* 设置重连间隔时间，单位毫秒。该接口需要在{@link #connect(IMqttConnectionListener)}之前调用。
* 如果重连一直失败，重连间隔时间会随着重连次数增加，可以设置最大值见下文
* @param baseRetryDelay the new base retry delay. The default value is 3,000ms.
*/
public void XIotMqttClient.getInstance().setBaseRetryDelay(int baseRetryDelay)
4.设置最大重连间隔时间：
/**
* 设置最大重连间隔时间，单位毫秒。该接口需要在{@link #connect(IMqttConnectionListener)}之前调用。
*
* @param maxRetryDelay the new max retry delay. The default value is 30,000ms.
*/
public void setMaxRetryDelay(int maxRetryDelay)
5.设置连接的超时时间：
/**
* 设置连接的超时时间，必须在调用 XIotMqttClient.getInstance().connect 之前设置
*
* @param connectionTimeout the new connection timeout. The default value is 30,000ms.
*/
public void XIotMqttClient.getInstance().setConnectionTimeout(int connectionTimeout)
6.设置最大重连次数：
/**
* 设置最大重连次数。默认值5，若设置小于或者等于0 表示可以无限制尝试重连
* 该值必须在 XIotMqttClient.getInstance().connect 之前调用
*
* @param maxConnectionRetries the new max connection retries. The default value is 5.
*/
public void XIotMqttClient.getInstance().setMaxConnectionRetries(int maxConnectionRetries)
7.网络状态改变时是否主动网络重连：
/**
* 网络状态改变时是否主动网络重连
* @param netChangeToTryConnect
*/
@Override
public void XIotMqttClient.getInstance().setNetChangeToTryConnect(boolean netChangeToTryConnect)
五.日志开关
/**
* 日志开关
* @param flag true打开日志,默认关闭
*/
public void XIotMqttClient.getInstance().setDebugOn(boolean flag)
代码示例
//注册消息监听器
XIotMqttClient.getInstance().registerMsgListener(new BaseTopicListener());
//设置当前固件版本，用于ota升级业务
XIotMqttClient.getInstance().setFirmwareVer("1.0.4");
//设置远程配置版本号
XIotMqttClient.getInstance().setRemoteConfigVer("1.0");
//设置连接的超时时间
XIotMqttClient.getInstance().setConnectionTimeout(60000);
//设置最大重连次数
XIotMqttClient.getInstance().setMaxConnectionRetries(11111);
//网络状态改变时是否主动网络重连
XIotMqttClient.getInstance().setNetChangeToTryConnect(true);
//建立客户端sdk与服务端的连接，这是非阻塞式的连接
XIotMqttClient.getInstance().connect(new IMqttConnectionListener() {
@Override
public void onConnectionStatus(int code, String status) {
Log.e(TAG,code+ "：-----:"+status);
}
});
......
//与服务端断开连接
if (XIotMqttClient.getInstance() != null) {
XIotMqttClient.getInstance().disconnect();
}