国产特黄特色在线视频,看全色黄全色大全免费久久,日本久久久精品影院

使用MQTT協(xié)議接入的設備和物聯(lián)網(wǎng)平臺，通過訂閱Topic或向Topic發(fā)布消息的方式進行通信。Topic分為系統(tǒng)Topic、物模型Topic和自定義Topic，其中自定義Topic需要用戶在控制臺定義。本文為您介紹設備使用自定義Topic與物聯(lián)網(wǎng)平臺進行上下行通信，以及物聯(lián)網(wǎng)平臺和業(yè)務服務器之間通信的步驟。

背景信息

本示例中，電子溫度計通過訂閱自定義Topic接收指令，通過向自定義Topic發(fā)布消息從而上報溫度，物聯(lián)網(wǎng)平臺將收到的溫度信息通過AMQP服務端轉(zhuǎn)發(fā)到用戶服務器，用戶服務器調(diào)用Pub接口向自定義Topic發(fā)布消息從而實現(xiàn)對設備的遠程精度設置。

自定義Topic通信

準備開發(fā)環(huán)境

本示例中，設備端和云端均使用Java語言的SDK，需先準備Java開發(fā)環(huán)境。您可從Java官方網(wǎng)站下載并安裝Java開發(fā)環(huán)境。

本示例使用環(huán)境如下：

操作系統(tǒng)：Windows 10 64位
JDK版本：JDK8
集成開發(fā)環(huán)境：IntelliJ IDEA社區(qū)版

創(chuàng)建產(chǎn)品和設備

登錄物聯(lián)網(wǎng)平臺控制臺。
在實例概覽頁簽的全部環(huán)境下，找到對應的實例，單擊實例卡片。
在左側(cè)導航欄，單擊設備管理 > 產(chǎn)品。
單擊創(chuàng)建產(chǎn)品，創(chuàng)建溫度計產(chǎn)品，獲取productKey，例如a1uzcH0****。
詳細操作指導，請參見創(chuàng)建產(chǎn)品。
創(chuàng)建產(chǎn)品成功后，單擊該產(chǎn)品對應的查看。
在產(chǎn)品詳情頁面的Topic類列表頁簽下，單擊自定義Topic，增加自定義Topic類。
詳細操作指導，請參見使用自定義Topic通信。
本示例中，定義了以下兩個Topic類：
- 設備發(fā)布消息Topic：/a1uzcH0****/${deviceName}/user/devmsg，權(quán)限為發(fā)布。
- 設備訂閱消息Topic：/a1uzcH0****/${deviceName}/user/cloudmsg，權(quán)限為訂閱。
在服務端訂閱頁簽下，單擊創(chuàng)建訂閱，設置AMQP服務端訂閱，訂閱設備上報消息到默認消費組。
設備上報消息包含自定義Topic消息和物模型消息。詳細操作和說明，請參見配置AMQP服務端訂閱。
在左側(cè)導航欄，選擇設備管理 > 設備，然后在剛創(chuàng)建的溫度計產(chǎn)品下，添加設備device1，獲取設備證書ProductKey、DeviceName和DeviceSecret。
詳細操作指導，請參見單個創(chuàng)建設備。

設備發(fā)送消息給服務器

流程圖：

自定義Topic通信

在整個流程中：

服務器通過AMQP客戶端接收消息，需配置AMQP客戶端接入物聯(lián)網(wǎng)平臺，監(jiān)聽設備消息。具體操作，請參見Java SDK接入示例。
重要
AMQP訂閱消息的消費組，必須與設備在相同的物聯(lián)網(wǎng)平臺實例下。

配置設備端SDK接入物聯(lián)網(wǎng)平臺，并發(fā)送消息。

配置設備認證信息。

final String productKey = "a1uzcH0****";
final String deviceName = "device1";
final String deviceSecret = "uwMTmVAMnxB****";
final String region = "cn-shanghai";
final String iotInstanceId = "iot-2w****";

實際業(yè)務場景中，您需修改以下參數(shù)值。

參數(shù)	示例	說明
productKey	a1uzcH0****	設備證書信息。您可在物聯(lián)網(wǎng)平臺控制臺的設備詳情頁面查看。具體操作，請參見查看具體設備信息。
deviceName	device1
deviceSecret	uwMTmVAMnxB****
region	cn-shanghai	您物聯(lián)網(wǎng)平臺設備所在地域的Region ID。Region ID表達方法，請參見地域列表。
iotInstanceId	iot-2w****	設備所屬實例的ID。您可在控制臺的實例概覽頁面查看。若有ID值，必須傳入該ID值。若無實例概覽頁面或ID值，傳入空值，即`iotInstanceId = ""`。

設置初始化連接參數(shù)，包括MQTT連接配置、設備信息和初始物模型屬性。

LinkKitInitParams params = new LinkKitInitParams();
//LinkKit底層是MQTT協(xié)議，設置MQTT的配置。
IoTMqttClientConfig config = new IoTMqttClientConfig();
config.productKey = productKey;
config.deviceName = deviceName;
config.deviceSecret = deviceSecret;
config.channelHost = productKey + ".iot-as-mqtt." + region + ".aliyuncs.com:1883";
//設備的信息。
DeviceInfo deviceInfo = new DeviceInfo();
deviceInfo.productKey = productKey;
deviceInfo.deviceName = deviceName;
deviceInfo.deviceSecret = deviceSecret;
//報備的設備初始狀態(tài)。
Map<String, ValueWrapper> propertyValues = new HashMap<String, ValueWrapper>();

params.mqttClientConfig = config;
params.deviceInfo = deviceInfo;
params.propertyValues = propertyValues;

實際業(yè)務場景中，您需修改以下參數(shù)值。

參數(shù)

示例

說明

config.channelHost

config.channelHost = productKey + ".iot-as-mqtt." + region + ".aliyuncs.com:1883";

MQTT設備接入域名。

舊版公共實例：config.channelHost = productKey + ".iot-as-mqtt." + region + ".aliyuncs.com:1883";。
新版公共實例和企業(yè)版實例：config.channelHost = iotInstanceId + ".mqtt.iothub.aliyuncs.com:1883";。

初始化連接。

//連接并設置連接成功以后的回調(diào)函數(shù)。
LinkKit.getInstance().init(params, new ILinkKitConnectListener() {
     @Override
     public void onError(AError aError) {
         System.out.println("Init error:" + aError);
     }

     //初始化成功以后的回調(diào)。
     @Override
     public void onInitDone(InitResult initResult) {
         System.out.println("Init done:" + initResult);
     }
 });

設備發(fā)送消息。

設備端連接物聯(lián)網(wǎng)平臺后，向自定義的Topic發(fā)送消息。您需將onInitDone函數(shù)內(nèi)容替換為以下內(nèi)容：

@Override
 public void onInitDone(InitResult initResult) {
     //設置Pub消息的Topic和內(nèi)容。
     MqttPublishRequest request = new MqttPublishRequest();
     request.topic = "/" + productKey + "/" + deviceName + "/user/devmsg";
     request.qos = 0;
     request.payloadObj = "{\"temperature\":35.0, \"time\":\"sometime\"}";
     //發(fā)送消息并設置成功以后的回調(diào)。
     LinkKit.getInstance().publish(request, new IConnectSendListener() {
         @Override
         public void onResponse(ARequest aRequest, AResponse aResponse) {
             System.out.println("onResponse:" + aResponse.getData());
         }

         @Override
         public void onFailure(ARequest aRequest, AError aError) {
             System.out.println("onFailure:" + aError.getCode() + aError.getMsg());
         }
     });
 }

實際業(yè)務場景中，您需修改以下參數(shù)值。

參數(shù)	示例	說明
request.topic	"/" + productKey + "/" + deviceName + "/user/devmsg"	具有發(fā)布權(quán)限的自定義Topic。
request.payloadObj	"{\"temperature\":35.0, \"time\":\"sometime\"}"	自定義的消息內(nèi)容。

服務器收到消息如下：

Message
{payload={"temperature":35.0, "time":"sometime"},
topic='/a1uzcH0****/device1/user/devmsg',
messageId='1131755639450642944',
qos=0,
generateTime=1558666546105}

服務器發(fā)送消息給設備

流程圖：

自定義Topic通信

配置設備端SDK訂閱Topic。

配置設備認證信息、設置初始化連接參數(shù)、初始化連接，請參見設備發(fā)送消息給服務器中的相應示例代碼。

設備要接收服務器發(fā)送的消息，還需訂閱消息Topic。

配置設備端訂閱Topic示例如下：

//初始化成功以后的回調(diào)。
@Override
public void onInitDone(InitResult initResult) {
    //設置訂閱的Topic。
    MqttSubscribeRequest request = new MqttSubscribeRequest();
    request.topic = "/" + productKey + "/" + deviceName + "/user/cloudmsg";
    request.isSubscribe = true;
    //發(fā)出訂閱請求并設置訂閱成功或者失敗的回調(diào)函數(shù)。
    LinkKit.getInstance().subscribe(request, new IConnectSubscribeListener() {
        @Override
        public void onSuccess() {
            System.out.println("");
        }

        @Override
        public void onFailure(AError aError) {

        }
    });

    //設置訂閱的下行消息到來時的回調(diào)函數(shù)。
    IConnectNotifyListener notifyListener = new IConnectNotifyListener() {
        //此處定義收到下行消息以后的回調(diào)函數(shù)。
        @Override
        public void onNotify(String connectId, String topic, AMessage aMessage) {
            System.out.println(
                "received message from " + topic + ":" + new String((byte[])aMessage.getData()));
        }

        @Override
        public boolean shouldHandle(String s, String s1) {
            return false;
        }

        @Override
        public void onConnectStateChange(String s, ConnectState connectState) {

        }
    };
    LinkKit.getInstance().registerOnNotifyListener(notifyListener);
}

其中，request.topic值需修改為具有訂閱權(quán)限的自定義Topic。

配置云端SDK調(diào)用物聯(lián)網(wǎng)平臺接口Pub發(fā)布消息。參數(shù)說明，請參見Pub，使用說明，請參見Java SDK使用說明。

設置身份認證信息。

 String regionId = "cn-shanghai";
 String accessKey = "LTAI4GFGQvKuqHJhFaj****";
 String accessSecret = "iMS8ZhCDdfJbCMeA005sieKe****";
 final String productKey = "a1uzcH0****";
 final String deviceName = "device1";
 final String iotInstanceId = "iot-2w****";

實際業(yè)務場景中，您需修改以下參數(shù)值。

參數(shù)	示例	說明
accessKey	LTAI4GFGQvKuqHJhFaj****	您的阿里云賬號的AccessKey ID和AccessKey Secret。登錄物聯(lián)網(wǎng)平臺控制臺，將鼠標移至賬號頭像上，然后單擊AccessKey管理，獲取AccessKey ID和AccessKey Secret。說明如果使用RAM用戶，您需授予該RAM用戶管理物聯(lián)網(wǎng)平臺的權(quán)限（AliyunIOTFullAccess），否則將連接失敗。授權(quán)方法請參見授權(quán)RAM用戶訪問物聯(lián)網(wǎng)平臺。
accessSecret	iMS8ZhCDdfJbCMeA005sieKe****
productKey	a1uzcH0****	設備證書信息。您可在物聯(lián)網(wǎng)平臺控制臺的設備詳情頁面查看。具體操作，請參見查看具體設備信息。
deviceName	device1
region	cn-shanghai	您物聯(lián)網(wǎng)平臺設備所在地域的Region ID。Region ID表達方法，請參見地域列表。
iotInstanceId	iot-2w****	設備所屬實例的ID。您可在控制臺的實例概覽頁面查看。若有ID值，必須傳入該ID值。若無實例概覽頁面或ID值，傳入空值，即`iotInstanceId = ""`。

設置連接參數(shù)。

//設置client的參數(shù)。
DefaultProfile profile = DefaultProfile.getProfile(regionId, accessKey, accessSecret);
IAcsClient client = new DefaultAcsClient(profile);

設置消息發(fā)布參數(shù)。

PubRequest request = new PubRequest();
request.setIotInstanceId(iotInstanceId);
request.setQos(0);
//設置發(fā)布消息的Topic。
request.setTopicFullName("/" + productKey + "/" + deviceName + "/user/cloudmsg");
request.setProductKey(productKey);
//設置消息的內(nèi)容，一定要用Base64編碼，否則亂碼。
request.setMessageContent(Base64.encode("{\"accuracy\":0.001,\"time\":now}"));

實際業(yè)務場景中，您需修改調(diào)用接口的請求參數(shù)。詳細說明，請參見Pub。

發(fā)送消息。

try {
     PubResponse response = client.getAcsResponse(request);
     System.out.println("pub success?:" + response.getSuccess());
 } catch (Exception e) {
     System.out.println(e);
 }

設備端接收到的消息如下：

msg = [{"accuracy":0.001,"time":now}]

附錄：代碼示例

重要

實際業(yè)務場景中，請按照上文描述，修改相關(guān)代碼及相關(guān)參數(shù)的值。

下載Pub/Sub demo，包含本示例的云端SDK和設備端SDK配置代碼Demo。

AMQP客戶端接入物聯(lián)網(wǎng)平臺示例，請參見：

日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

使用自定義Topic進行通信

背景信息

準備開發(fā)環(huán)境

創(chuàng)建產(chǎn)品和設備

設備發(fā)送消息給服務器

服務器發(fā)送消息給設備

附錄：代碼示例