阿里云物联网平台：实例迁移服务端修改示例

开发环境说明

开发环境如下：

• JDK版本：JDK8及以上版本

• 集成开发环境：IntelliJ IDEA社区版

示例代码说明

更新设备数据的示例代码

您需依赖AMQP客户端接入的SDK，开发更新设备数据的方法。AMQP客户端接入示例，请参见Java SDK接入示例。

更新处理实例迁移消息的方法：processMessage方法，替换为如下代码。其中updateDeviceInstanceId(productKey, deviceName, targetInstanceId)和recoverDeviceInstanceId(productKey, deviceName)是实现数据库更新数据的方法，需开发者根据实际场景自行完成开发。

private static void processMessage(Message message) {
        try {
            byte[] body = message.getBody(byte[].class);
            String content = new String(body);
            String topic = message.getStringProperty("topic");
            String messageId = message.getStringProperty("messageId");
            logger.info("receive message"
                + ",\n topic = " + topic
                + ",\n messageId = " + messageId
                + ",\n content = " + content);

            if (null == content) {
                logger.error("content is null");
            }

            JSONObject object = JSON.parseObject(content);
            String status = object.getString("status");

            // 更新迁移成功的设备实例ID。
            String targetInstanceId = object.getString("targetInstance");

            // 处理迁移成功的设备, 更新为目标企业实例ID。
            if (StringUtils.equals(status, "GRAY_EXECUTING") || StringUtils.equals(status, "ALL_EXECUTING")) {
                JSONArray successDevices = object.getJSONArray("successDevices");

                if (successDevices == null) {
                    return;
                }

                for (int i = 0; i < successDevices.size(); i++) {
                    JSONObject device = successDevices.getJSONObject(i);
                    if (null == device) {
                        return;
                    }

                    String deviceName = device.getString("deviceName");
                    String productKey = device.getString("productKey");

                    // todo：根据productKey和deviceName, 按照target更新数据库中迁移成功的设备实例ID。
                    // updateDeviceInstanceId(productKey, deviceName, targetInstanceId)


                }
            }

            // 处理回滚成功的设备，恢复为原有实例ID。
            if (StringUtils.equals("status", "ROLL_BACK_EXECUTING")) {
                JSONArray successDevices = object.getJSONArray("successDevices");
                if (successDevices == null) {
                    return;
                }

                for (int i = 0; i < successDevices.size(); i++) {
                    JSONObject device = successDevices.getJSONObject(i);
                    if (null == device) {
                        return;
                    }

                    String deviceName = device.getString("deviceName");
                    String productKey = device.getString("productKey");

                    // todo：根据productKey和deviceName, 恢复数据库中的instanceId. 恢复策略具体需要区分业务场景。
                    // 1、原有公共实例调用业务没有存实例ID, 恢复实例ID为null。
                    // 2、原有公共实例调用存了实例ID特定值, 恢复实例ID为原有默认值。
                    // recoverDeviceInstanceId(productKey, deviceName)
                }
            }
        } catch (Exception e) {
            logger.error("processMessage occurs error ", e);
        }
    }

控制设备服务的示例代码

您需依赖物联网平台云端SDK，开发调用设备相关业务API的方法。云端SDK使用示例，请参见Java SDK使用说明。

配置依赖的接口调用方法：以Pub接口为例，如下代码新增调用接口方法pub(client, productKey, deviceName)。其中getInstanceId(productKey, deviceName)方法实现逻辑，需开发者根据实际场景自行完成开发。

  public static void main(String[] args) {
        String accessKey = "${accessKey}";
        String accessSecret = "${accessSecret}";
        String productKey = "${productKey}";
        String deviceName = "${deviceName}";
        IClientProfile profile = DefaultProfile.getProfile("cn-shanghai", accessKey, accessSecret);
        DefaultAcsClient client = new DefaultAcsClient(profile);

        pub(client, productKey, deviceName);
    }

    private static void pub(DefaultAcsClient client, String productKey, String deviceName) {
        PubRequest request = new PubRequest();
        //从数据库中获取实例ID。
        String instanceId = getInstanceId(productKey, deviceName);

        //如果实例ID不为空，传参设置实例ID。注意只有企业实例需要传入此参数，公共实例无需传入此参数。
        if (!StringUtils.isEmpty(instanceId)) {
            request.setIotInstanceId(instanceId);
        }

        request.setProductKey("${productKey}");
        request.setMessageContent(Base64.encodeBase64String("hello world".getBytes()));
        request.setTopicFullName("/${productKey}/${deviceName}/user/get");
        request.setQos(0); //目前支持QoS0和QoS1。
        try {
            PubResponse response = client.getAcsResponse(request);
            System.out.println(response.getSuccess());
            System.out.println(response.getCode());
            System.out.println(response.getErrorMessage());
        } catch (ServerException e) {
            e.printStackTrace();
        } catch (ClientException e) {
            System.out.println("ErrCode:" + e.getErrCode());
            System.out.println("ErrMsg:" + e.getErrMsg());
            e.printStackTrace();
        }
    }

    /**
     * 从数据库中获取实例ID。
     *
     * @param productKey
     * @param deviceName
     * @return
     */
    private static String getInstanceId(String productKey, String deviceName) {
        String instanceId = "";
        // todo：按照 productKey和deviceName从数据库中查询梳理信息。
        // instanceId = query(productKey, deviceName);

        return instanceId;
    }