IoT Platform：Gunakan fitur lanjutan

Tentukan jalur file konfigurasi

Secara default, file konfigurasi untuk jembatan adalah application.conf, sedangkan file konfigurasi pemetaan sertifikat perangkat adalah devices.conf.

IoT as Bridge SDK memungkinkan Anda menentukan jalur file kustom. Sebelum memanggil metode bootstrap(), Anda dapat memanggil metode ConfigFactory.init() untuk menentukan jalur file konfigurasi. Anda juga dapat membuat instance dan mengimplementasikan metode sesuai kebutuhan bisnis Anda.

Contoh kode:

private static DeviceConfigManager selfDefineDeviceConfigManager = new DeviceConfigManager() {
    @Override
    public DeviceIdentity getDeviceIdentity(String originalIdentity) {
        return devicesMap.get(originalIdentity);
    }

    @Override
    public String getOriginalIdentity(String productKey, String deviceName) {
        return null;
    }
};
BridgeBootstrap bridgeBootstrap = new BridgeBootstrap();
ConfigFactory.init(ConfigFactory.getBridgeConfigManager("application-self-define.conf"),selfDefineDeviceConfigManager);
bridgeBootstrap.bootstrap();

Daftarkan jembatan secara dinamis

Saat menyebarkan jembatan pada sejumlah besar server, proses penyebarannya menjadi kompleks jika Anda harus menentukan jembatan berbeda untuk setiap server. Untuk menyederhanakan proses ini, Anda dapat mengonfigurasi file konfigurasi jembatan application.conf untuk mendaftarkan jembatan secara dinamis.

Anda perlu menentukan parameter productKey dan popClientProfile dari sebuah jembatan dalam file konfigurasi. Kemudian, IoT as Bridge SDK akan memanggil Operasi API dari IoT Platform untuk mendaftarkan jembatan dan menggunakan alamat MAC server jembatan sebagai DeviceName dari jembatan tersebut.

Contoh kode berikut menunjukkan cara mengonfigurasi jembatan ukuran kecil. Dalam contoh ini, instans Enterprise Edition digunakan.

// Titik akhir layanan.
http2Endpoint = "https://${IotInstanceId}.http2.iothub.aliyuncs.com:443"
authEndpoint = "https://${IotInstanceId}.auth.iothub.aliyuncs.com/auth/bridge"

// Parameter jembatan.
productKey = ${YourProductKey}

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

Panggil operasi untuk mengirimkan data TSL

IoT as Bridge SDK mengenkapsulasi operasi untuk mengirimkan data. Anda dapat memanggil operasi reportProperty untuk mengirimkan properti, operasi fireEvent untuk mengirimkan peristiwa, dan operasi updateDeviceTag untuk memperbarui tag. Perangkat dapat menggunakan operasi-operasi ini untuk melaporkan properti, melaporkan peristiwa, serta memperbarui tag perangkat.

Contoh kode:

TslUplinkHandler tslUplinkHandler = new TslUplinkHandler();
// Kirim properti.
// Properti testProp telah didefinisikan.
String requestId = String.valueOf(random.nextInt(1000));
// Timestamp tidak disertakan dalam data properti yang dikirimkan.
tslUplinkHandler.reportProperty(requestId, originalIdentity, "testProp", random.nextInt(100));
// Timestamp disertakan dalam data properti yang dikirimkan.
//tslUplinkHandler.reportProperty(requestId, originalIdentity, "testProp", random.nextInt(100), System.currentTimeMillis());

// Kirim peristiwa.
// Peristiwa testEvent telah didefinisikan.
requestId = String.valueOf(random.nextInt(1000));
HashMap<String, Object> params = new HashMap<String, Object>();
params.put("testEventParam", 123);
// Timestamp tidak disertakan dalam data peristiwa yang dikirimkan.
tslUplinkHandler.fireEvent(originalIdentity, "testEvent", ThingEventTypes.INFO, params);
// Timestamp disertakan dalam data peristiwa yang dikirimkan.
//tslUplinkHandler.fireEvent(originalIdentity, "testEvent", ThingEventTypes.INFO, params, System.currentTimeMillis());

// Perbarui tag perangkat.
// Kunci tag diatur menjadi testDeviceTag.
requestId = String.valueOf(random.nextInt(1000));
tslUplinkHandler.updateDeviceTag(requestId, originalIdentity, "testDeviceTag", String.valueOf(random.nextInt(1000)));

Tabel berikut menjelaskan parameter-parameter tersebut.

Panggil operasi untuk mengirimkan beberapa properti dan peristiwa sekaligus

IoT as Bridge SDK mengenkapsulasi operasi untuk mengirimkan beberapa properti dan peristiwa sekaligus. Anda perlu membuat objek BatchPostEventPropertyMessage dan memanggil metode addProperty() serta addEvent() untuk menambahkan data properti dan peristiwa. Kemudian, buat objek TslUplinkHandler dan panggil metode BatchPostEventPropertyMessage() untuk mengirimkan data.

Contoh kode:

TslUplinkHandler tslUplinkHandler = new TslUplinkHandler();
// Kirim beberapa properti dan peristiwa sekaligus.
String requestId = String.valueOf(random.nextInt(1000));
long startTime = System.currentTimeMillis() - 3000;

// Buat pesan untuk mengirimkan data.
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);

// Kirimkan data.
tslUplinkHandler.batchPostEventPropertyMessage(originalIdentity, batchPostEventPropertyMessage);

Tabel berikut menjelaskan parameter-parameter tersebut.

Panggil operasi untuk menetapkan properti dan memanggil layanan

IoT as Bridge SDK mengenkapsulasi operasi PropertySetHandler untuk menetapkan properti dan operasi ServiceInvokeHandler untuk memanggil layanan. Perangkat dapat menggunakan operasi-operasi ini untuk menerima perintah dari IoT Platform guna memperbarui data.

Contoh kode:

BridgeBootstrap bridgeBootstrap = new BridgeBootstrap();
// Tetapkan properti.
bridgeBootstrap.setPropertySetHandler(new PropertySetHandler() {
    @Override
    public void onPropertySet(PropertySetMessage msg) {
        log.info("on property set, {}", msg.getParams());
        // Jika Anda memanggil metode replySuccess(), SDK akan mengirimkan pesan /property/set_reply ke IoT Platform. Kode responsnya adalah 200.
        msg.replySuccess();
        // Jika Anda memanggil metode replyFail(), SDK akan mengirimkan pesan /property/set_reply ke IoT Platform. Anda dapat menentukan kode respons berdasarkan kebutuhan bisnis Anda.
        //msg.replyFail(400);
    }
});

// Panggil layanan.
bridgeBootstrap.setServiceInvokeHandler(new ServiceInvokeHandler() {
    @Override
    public void onServiceInvoke(ServiceInvokeMessage message) {
        log.info("on service invoke, {}", message.getParams());
        // Jika Anda memanggil metode replySuccess(), SDK akan mengirimkan pesan /service/{service.identifier}_reply ke IoT Platform. Kode responsnya adalah 200.
        message.replySuccess();
        // Jika Anda memanggil metode replyFail(), SDK akan mengirimkan pesan /service/{service.identifier}_reply ke IoT Platform. Anda dapat menentukan kode respons berdasarkan kebutuhan bisnis Anda.
        //msg.replyFail(400);
    }
});