Advanced usage

Custom configuration management

By default, the bridge configuration file is read from application.conf, and the device certificate mapping file is read from devices.conf.

The cloud-to-cloud SDK provides a custom configuration feature. Before you call the bootstrap method, you can call the ConfigFactory.init method to customize the path of the configuration file and implement the corresponding interface for your custom instance.

Example code:

private static DeviceConfigManager selfDefineDeviceConfigManager = new DeviceConfigManager() {
    @Override
    public DeviceIdentity getDeviceIdentity(String originalIdentity) {
        // Return device information based on the originalIdentity.
        return devicesMap.get(originalIdentity);
    }

    @Override
    public String getOriginalIdentity(String productKey, String deviceName) {
        // Return the originalIdentity based on the device information.
        return null;
    }
};
BridgeBootstrap bridgeBootstrap = new BridgeBootstrap();
ConfigFactory.init(ConfigFactory.getBridgeConfigManager("application-self-define.conf"),selfDefineDeviceConfigManager);
bridgeBootstrap.bootstrap();

Dynamic creation of a bridge device

If you deploy a bridge application on multiple servers, specifying a different bridge device for each bridge server can be complicated. To solve this issue, you can configure the bridge configuration file application.conf to automatically create bridge devices.

In the configuration file, pass the productKey and popClientProfile parameters. The cloud-to-cloud SDK then calls an IoT Platform API to create a bridge device. The device name is set to the MAC address of the server.

The following code provides an example of the configuration for automatically creating a bridge device for an Enterprise instance:

// Service endpoints
http2Endpoint = "https://${IotInstanceId}.http2.iothub.aliyuncs.com:443"
authEndpoint = "https://${IotInstanceId}.auth.iothub.aliyuncs.com/auth/bridge"

// Bridge device information
productKey = ${YourProductKey}

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

Call TSL model data reporting interfaces

The cloud-to-cloud SDK encapsulates several data reporting interfaces. These include the reportProperty interface for reporting properties, the fireEvent interface for reporting events, and the updateDeviceTag interface for updating device tags. You can use these interfaces to report device messages to IoT Platform.

Example call:

TslUplinkHandler tslUplinkHandler = new TslUplinkHandler();
// Report a property.
// The testProp property is defined.
String requestId = String.valueOf(random.nextInt(1000));
// Report the property without a timestamp.
tslUplinkHandler.reportProperty(requestId, originalIdentity, "testProp", random.nextInt(100));
// Report the property with a timestamp.
//tslUplinkHandler.reportProperty(requestId, originalIdentity, "testProp", random.nextInt(100), System.currentTimeMillis());

// Report an event.
// The testEvent event is defined.
requestId = String.valueOf(random.nextInt(1000));
HashMap<String, Object> params = new HashMap<String, Object>();
params.put("testEventParam", 123);
// Report the event without a timestamp.
tslUplinkHandler.fireEvent(originalIdentity, "testEvent", ThingEventTypes.INFO, params);
// Report the event with a timestamp.
//tslUplinkHandler.fireEvent(originalIdentity, "testEvent", ThingEventTypes.INFO, params, System.currentTimeMillis());

// Report a device tag.
// The device tag key is defined as testDeviceTag.
requestId = String.valueOf(random.nextInt(1000));
tslUplinkHandler.updateDeviceTag(requestId, originalIdentity, "testDeviceTag", String.valueOf(random.nextInt(1000)));

The parameters in the preceding example are described as follows.

Call batch reporting interfaces for device properties and events

The cloud-to-cloud SDK encapsulates a batch data reporting interface. To use this interface, create a BatchPostEventPropertyMessage object instance. Then, chain calls to the addProperty and addEvent methods to add property and event data. Finally, use TslUplinkHandler to call the BatchPostEventPropertyMessage object instance to implement batch reporting of device data.

Example call:

TslUplinkHandler tslUplinkHandler = new TslUplinkHandler();
// Batch report properties and events.
String requestId = String.valueOf(random.nextInt(1000));
long startTime = System.currentTimeMillis() - 3000;

// Construct the message for batch reporting.
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);

// Initiate the report.
tslUplinkHandler.batchPostEventPropertyMessage(originalIdentity, batchPostEventPropertyMessage);

The parameters in the preceding example are described as follows.

Call property setting and service invocation interfaces

The cloud-to-cloud SDK encapsulates the PropertySetHandler interface for setting properties and the ServiceInvokeHandler interface for invoking services. You can use these interfaces to accept instructions sent from IoT Platform and update data.

Example call:

BridgeBootstrap bridgeBootstrap = new BridgeBootstrap();
// Set a property.
bridgeBootstrap.setPropertySetHandler(new PropertySetHandler() {
    @Override
    public void onPropertySet(PropertySetMessage msg) {
        log.info("on property set, {}", msg.getParams());
        // If replySuccess is called, the SDK sends a /property/set_reply message to IoT Platform with code 200.
        msg.replySuccess();
        // If replyFail is called, the SDK sends a /property/set_reply message to IoT Platform with the code specified by the caller.
        //msg.replyFail(400);
    }
});

// Invoke a service.
bridgeBootstrap.setServiceInvokeHandler(new ServiceInvokeHandler() {
    @Override
    public void onServiceInvoke(ServiceInvokeMessage message) {
        log.info("on service invoke, {}", message.getParams());
        // If replySuccess is called, the SDK sends a /service/{service.identifier}_reply message to IoT Platform with code 200.
        message.replySuccess();
        // If replyFail is called, the SDK sends a /service/{service.identifier}_reply message to IoT Platform with the code specified by the caller.
        //msg.replyFail(400);
    }
});