网关与子设备功能
一.监听下发消息
XIotMqttClient新增addSubDevicesListener与removeSubDevicesListener
/**
* 添加监听网关与子设备功能下发消息
* @param callback
*/
void addSubDevicesListener(XIotSubDevicesCallback callback)
/**
* 移除下发消息监听
* @param callback
*/
void removeSubDevicesListener(XIotSubDevicesCallback callback)
代码示例
1.实现XIotSubDevicesCallbacki接口
private XIotSubDevicesCallback subDeviceListener = new XIotSubDevicesCallback() {
/**
* 网关与子设备的拓扑关系
* @param message 消息载体
* @param data 具体操作协议内容
* @param subDevices 子设备 List
*/
@Override
public void onSubDeviceTopo(XIotMessage message, XiotPayload.Data data, List<SubDeviceBean> subDevices) {
XiotLog.d("[onSubDeviceTopo] ", message.getStringPayload());
runOnUiThread(new Runnable() {
@Override
public void run() {
txt_topo_relation.setText("");
if (subDevices != null && subDevices.size() > 0) {
for (int i = 0; i < subDevices.size(); i++) {
SubDeviceBean bean = subDevices.get(i);
String msg = "subDevices"+ i+"："+ bean.getdName();
XiotLog.d("[onSubDeviceTopo] ", msg);
txt_topo_relation.append(msg);
txt_topo_relation.append("\n");
}
}
}
});
}
/**
* 子设备注册下发消息
* @param message 消息载体
* @param data 具体操作协议内容
* @param subDevices 子设备 List
*/
@Override
public void onSubDeviceRgister(XIotMessage message, XiotPayload.Data data, List<SubDeviceBean> subDevices) {
XiotLog.d("[onSubDeviceRgister] ", message.getStringPayload());
if (subDevices != null && subDevices.size() > 0) {
for (int i = 0; i < subDevices.size(); i++) {
SubDeviceBean bean = subDevices.get(i);
XiotLog.d("[onSubDeviceRgister] ", "subDevices"+ i+":" + bean.getpKey() + "," + bean.getdName());
}
}
}
/**
* 子设备上线下发消息
* @param message 消息载体
* @param data 具体操作协议内容
* @param pKey 子设备productKey
* @param dName 子设备deviceName
*/
@Override
public void onSubDeviceOnline(XIotMessage message, XiotPayload.Data data,String pKey,String dName) {
XiotLog.d("[onSubDeviceOnline] ", message.getStringPayload());
if (data.getRet().equals(XiotPayload.OK)){
XiotLog.d("[onSubDeviceOnline] ", "pKey:"+pKey+",dName:"+dName);
}
}
/**
* 子设备离线下发消息
* @param message 消息载体
* @param data 具体操作协议内容
* @param pKey 子设备productKey
* @param dName 子设备deviceName
*/
@Override
public void onSubDeviceOffline(XIotMessage message, XiotPayload.Data data,String pKey,String dName) {
XiotLog.d("[onSubDeviceOffline] ", message.getStringPayload());
if (data.getRet().equals(XiotPayload.OK)){
XiotLog.d("[onSubDeviceOffline] ", "pKey:"+pKey+",dName:"+dName);
}
}
/**
* 子设备删除下发消息
* @param message 消息载体
* @param data 具体操作协议内容
* @param pKey 子设备productKey
* @param dName 子设备deviceName
*/
@Override
public void onSubDeviceDelete(XIotMessage message, XiotPayload.Data data,String pKey,String dName) {
XiotLog.d("[onSubDeviceDelete] ", message.getStringPayload());
if (data.getRet().equals(XiotPayload.OK)){
XiotLog.d("[onSubDeviceDelete] ", "pKey:"+pKey+",dName:"+dName);
}
}
};
2.注册与反注册下发消息监听
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
XIotMqttClient.getInstance().addSubDevicesListener(subDeviceListener);
}
@Override
protected void onDestroy() {
super.onDestroy();
if (subDeviceListener != null) {
XIotMqttClient.getInstance().removeSubDevicesListener(subDeviceListener);
}
}
二.获取网关与子设备的拓扑关系
/**
* XIotMqttClient
* 获取网关与子设备的拓扑关系
* @param eventMsg 要发布的消息载体
*/
public void subDeviceGetTopo(XIotMessage eventMsg)
代码示例
XIotMqttClient.getInstance().subDeviceGetTopo(new XIotMessage());
三.子设备注册协议
/**
* XIotMqttClient
* 子设备注册协议
* @param eventMsg 要发布的消息载体
* @param subDevices 子设备List
*/
public void subDeviceRegister(XIotMessage eventMsg,List<SubDeviceBean> subDevices)
代码示例
List<SubDeviceBean> subDevices = new ArrayList<>();
subDevices.add(new SubDeviceBean("子设备1productKey","子设备1deviceName"));
subDevices.add(new SubDeviceBean("子设备2productKey","子设备2deviceName"));
try {
XIotMqttClient.getInstance().subDeviceRegister(new XIotMessage(), subDevices);
} catch (XIotException | JSONException e) {
e.printStackTrace();
}
四.子设备上线
/**
* 子设备上线消息
* @param eventMsg 发布的消息载体
* @param pKey 子设备productKey
* @param dName 子设备deviceName
* @param secret 子设备DeviceSecret
* @param deviceId 子设备唯一标识
*/
public void subDeviceOnline(XIotMessage eventMsg,String pKey,String dName,String secret,String deviceId)
子设备的deviceId建议使用mac地址或SN码，64个字符内
代码示例
XIotMqttClient.getInstance().subDeviceOnline(new XIotMessage(),"pKey","dName", "deviceSecret", "2c:69:78:b9:2b:ad");
五.子设备离线
/**
* XIotMqttClient
* 子设备离线消息
* @param eventMsg 发布的消息载体
* @param pKey 子设备ProductKey
* @param dName 子设备DeviceName
*/
public void subDeviceOffline(XIotMessage eventMsg,String pKey,String dName)
代码示例
XIotMqttClient.getInstance().subDeviceOffline(new XIotMessage(), "子设备ProductKey", "子设备DeviceName");
六.删除子设备
/**
* XIotMqttClient
* 删除子设备
* @param eventMsg 发布的消息载体
* @param pKey 子设备ProductKey
* @param dName 子设备DeviceName
*/
void subDeviceDelete(XIotMessage eventMsg,String pKey,String dName)
代码示例
XIotMqttClient.getInstance().subDeviceDelete(new XIotMessage(), "子设备ProductKey", "子设备DeviceName");
七.子设备发布属性
/**
* @param attributeMsg 要发布的消息载体
* @param params 设备属性组装而成的HashParam结构参数
* @param deviceInfo 子设备的三元组信息(传null代表本设备)
*/
public String publishProperty(XIotMessage attributeMsg, HashParam params, DeviceInfo deviceInfo)
代码示例
HashParam param = new HashParam();
param.putParam("Brightness", (int) (Math.random() * 100));
XIotMqttClient.getInstance().publishProperty(new XIotMessage(), param,new DeviceInfo( "子设备ProductKey", "子设备DeviceName"));