阿里云物联网平台：进阶用法

自定义配置管理

默认情况下，网桥的配置文件和设备证书的映射关系配置文件，都是从固定路径的固定文件（分别是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);
    }
});