自定義配置管理

默認情況下，網橋的配置文件和設備證書的映射關系配置文件，都是從固定路徑的固定文件（分別是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);
    }
});