IoT Platform：進階用法

自訂組態管理

預設情況下，橋接器的設定檔和裝置認證的映射關係設定檔，都是從固定路徑的固定檔案（分別是application.conf和devices.conf）中讀取的。

云云對接SDK提供自訂配置能力，您只需在調用bootstrap方法前，先調用ConfigFactory.init方法，自訂設定檔的路徑，自訂執行個體實現對應的介面。

程式碼範例：

private static DeviceConfigManager selfDefineDeviceConfigManager = new DeviceConfigManager() {
    @Override
    public DeviceIdentity getDeviceIdentity(String originalIdentity) {
        // 根據originalIdentity返回裝置資訊
        return devicesMap.get(originalIdentity);
    }

    @Override
    public String getOriginalIdentity(String productKey, String deviceName) {
        // 根據裝置資訊返回originalIdentity
        return null;
    }
};
BridgeBootstrap bridgeBootstrap = new BridgeBootstrap();
ConfigFactory.init(ConfigFactory.getBridgeConfigManager("application-self-define.conf"),selfDefineDeviceConfigManager);
bridgeBootstrap.bootstrap();

動態建立橋接器裝置

當在大量的伺服器上部署橋接器應用，如果為每一個橋接器伺服器指定不同的橋接器裝置，資訊會比較繁瑣。為解決此問題，您可配置橋接器資訊檔application.conf，動態建立橋接器裝置。

您需在設定檔中，傳入參數productKey和popClientProfile，云云對接SDK將調用物聯網平台開放的API，以伺服器MAC地址作為裝置名稱，建立一個橋接器裝置。

以企業版執行個體為例，動態建立小型橋接器裝置的配置代碼如下：

// 服務地址
http2Endpoint = "https://${IotInstanceId}.http2.iothub.aliyuncs.com:443"
authEndpoint = "https://${IotInstanceId}.auth.iothub.aliyuncs.com/auth/bridge"

// 橋接器裝置資訊
productKey = ${YourProductKey}

popClientProfile = {
    accessKey = ${YourAliyunAccessKey}
    accessSecret = ${YourAliyunAccessSecret}
    name = cn-shanghai
    region = cn-shanghai
    product = Iot
    endpoint = iot.cn-shanghai.aliyuncs.com
}

調用物模型資料上報介面

云云對接SDK中封裝了部分資料上報介面，包括屬性上報介面 reportProperty、事件上報介面fireEvent和更新裝置標籤介面updateDeviceTag。裝置可通過以上介面向物聯網平台上報相應訊息。

調用樣本：

TslUplinkHandler tslUplinkHandler = new TslUplinkHandler();
//上報屬性。
//已定義testProp屬性。
String requestId = String.valueOf(random.nextInt(1000));
//上報屬性時，不攜帶時間戳記。
tslUplinkHandler.reportProperty(requestId, originalIdentity, "testProp", random.nextInt(100));
//上報屬性時，攜帶時間戳記。
//tslUplinkHandler.reportProperty(requestId, originalIdentity, "testProp", random.nextInt(100), System.currentTimeMillis());

//上報事件。
//已定義testEvent事件。
requestId = String.valueOf(random.nextInt(1000));
HashMap<String, Object> params = new HashMap<String, Object>();
params.put("testEventParam", 123);
//上報事件時，不攜帶時間戳記。
tslUplinkHandler.fireEvent(originalIdentity, "testEvent", ThingEventTypes.INFO, params);
//上報事件時，攜帶時間戳記
//tslUplinkHandler.fireEvent(originalIdentity, "testEvent", ThingEventTypes.INFO, params, System.currentTimeMillis());

//上報裝置標籤。
//已定義裝置標籤key為testDeviceTag。
requestId = String.valueOf(random.nextInt(1000));
tslUplinkHandler.updateDeviceTag(requestId, originalIdentity, "testDeviceTag", String.valueOf(random.nextInt(1000)));

以上樣本中參數說明如下。

調用裝置屬性、事件批量上報介面

云云對接SDK封裝了資料批量上報介面，通過BatchPostEventPropertyMessage 對象執行個體，鏈式調用addProperty和addEvent方法，分別添加屬性和事件數目據後，再通過TslUplinkHandler調用對象執行個體BatchPostEventPropertyMessage ，實現裝置資料批量上報。

調用樣本：

TslUplinkHandler tslUplinkHandler = new TslUplinkHandler();
//批量上報屬性和事件
String requestId = String.valueOf(random.nextInt(1000));
long startTime = System.currentTimeMillis() - 3000;

//構造批量上報的報文
BatchPostEventPropertyMessage batchPostEventPropertyMessage = new BatchPostEventPropertyMessage();
Map<String, Object> aiEventParams = new HashMap<>();
aiEventParams.put("EventContent", "hello world");
batchPostEventPropertyMessage
    .addProperty("PowerConsumption", 1000, startTime)
    .addProperty("PowerConsumption", 123, startTime + 1000)
    .addProperty("LightAdjustLevel", 23, startTime)
    .addProperty("LightAdjustLevel", 44, startTime + 1000)
    .addProperty("LightAdjustLevel", 47, startTime + 2000)
    .addEvent("AIEvent", aiEventParams, startTime);
batchPostEventPropertyMessage.setId(requestId);

//發起上報
tslUplinkHandler.batchPostEventPropertyMessage(originalIdentity, batchPostEventPropertyMessage);

以上樣本中參數說明如下。

調用屬性設定、服務調用介面

云云對接SDK中封裝了屬性設定介面PropertySetHandler和服務調用介面ServiceInvokeHandler。裝置端可通過以上介面接收物聯網平台下發的指令，實現資料更新。

調用樣本：

BridgeBootstrap bridgeBootstrap = new BridgeBootstrap();
//屬性設定
bridgeBootstrap.setPropertySetHandler(new PropertySetHandler() {
    @Override
    public void onPropertySet(PropertySetMessage msg) {
        log.info("on property set, {}", msg.getParams());
        //如果調用replySuccess，則SDK會向物聯網平台發送/property/set_reply訊息，code為200
        msg.replySuccess();
        //如果調用replyFail，則SDK會向物聯網平台發送/property/set_reply訊息，code為調用方指定的code
        //msg.replyFail(400);
    }
});

//服務調用
bridgeBootstrap.setServiceInvokeHandler(new ServiceInvokeHandler() {
    @Override
    public void onServiceInvoke(ServiceInvokeMessage message) {
        log.info("on service invoke, {}", message.getParams());
        //如果調用replySuccess，則SDK會向物聯網平台發送/service/{service.identifier}_reply訊息，code為200
        message.replySuccess();
        //如果調用replyFail，則SDK會向物聯網平台發送/service/{service.identifier}_reply訊息，code為調用方指定的code
        //msg.replyFail(400);
    }
});