设备影子
更新时间:2018-10-23 21:25:39
如果当前产品不具备物模型的能力,可以通过设备影子将当前设备的最新状态缓存到云端。云端缓存的是一个最新的 JSON 格式数据,需要用户自己根据实际情况做解析。物模型具备更高级的设备影子能力,能根据各个属性、事件、服务做独立展示,并具有所有操作的历史记录。
说明 设备影子相关接口参见设备 IDeviceShadow
数据上行
获取云端设备影子
更新云端设备影子
删除云端设备影子
// 获取设备影子 具体业务可参考 Demo
String data = "{" + "\"method\": \"get\"" + "}";
// 更新设备影子 需要根据获得到的设备影子读取返回的 version值,在更新的时候 {ver} 替换为version+1
// String data = "{" + "\"method\": \"update\"," + "\"state\": {" + "\"reported\": {" +
// "\"color\": \"red\"" + "}" + "}," + "\"version\": {ver}" + "}";
//删除设备影子 color 属性 {ver}需要替换
// String data = "{" + "\"method\": \"delete\"," + "\"state\": {" + "\"reported\": {" +
// "\"color\": \"null\"" + "}" + "}," + "\"version\": {ver}" + "}";
LinkKit.getInstance().getDeviceShadow().shadowUpload(data, new IConnectSendListener() {
@Override
public void onResponse(ARequest aRequest, AResponse aResponse) {
// 设备影子更新成功
// 数据解析参考数据下行或 Demo
}
@Override
public void onFailure(ARequest aRequest, AError aError) {
// 设备影子更新失败
}
});
数据下行
// 监听云端设备影子更新
LinkKit.getInstance().getDeviceShadow().setShadowChangeListener(new IShadowRRPC() {
@Override
public void onSubscribeSuccess(ARequest aRequest) {
// 订阅设备影子下行数据成功
}
@Override
public void onSubscribeFailed(ARequest aRequest, AError aError) {
// 订阅设备影子下行数据失败
}
@Override
public void onReceived(ARequest aRequest, AResponse aResponse, IConnectRrpcHandle iConnectRrpcHandle) {
// 接收到云端数据下行,下行数据在 aResponse 想里面
try {
if (aRequest != null) {
String dataStr = null;
if (aResponse.data instanceof byte[]) {
dataStr = new String((byte[]) aResponse.data, "UTF-8");
} else if (aResponse.data instanceof String) {
dataStr = (String) aResponse.data;
} else {
dataStr = String.valueOf(aResponse.data);
}
Log.d(TAG, "dataStr = " + dataStr);
ShadowResponse<String> shadowResponse = JSONObject.parseObject(dataStr, new TypeReference<ShadowResponse<String>>() {
}.getType());
if (shadowResponse != null && shadowResponse.version != null && TextUtils.isDigitsOnly(shadowResponse.version)) {
version = Long.valueOf(shadowResponse.version);
}
AResponse response = new AResponse();
// TODO 用户实现控制设备
// 用户控制设备之后 上报影子的值到云端
// 上报设置之后的值到云端
// 根据当前实际值上报
response.data = shadowUpdate.replace("{ver}", String.valueOf(version + 1));
// 第一个值 replyTopic 有默认值 用户不需要设置
iConnectRrpcHandle.onRrpcResponse(null, response);
}
} catch (Exception e) {
e.printStackTrace();
}
}
@Override
public void onResponseSuccess(ARequest aRequest) {
// 下行处理之后上报成功
}
@Override
public void onResponseFailed(ARequest aRequest, AError aError) {
// 下行处理之后上报失败
}
});