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

AI 助理
備案控制臺
文檔
輸入文檔關鍵字查找
首頁 物聯網平臺 開發參考 設備端開發指南 C Link SDK 文件上傳 示例二：MQTT數據流模式文件上傳

示例二：MQTT數據流模式文件上傳

更新時間：
產品詳情
我的收藏

MQTT數據流模式適用于未知文件大小的上傳，例如邊采集邊上傳的錄音文件，無法確定停止時文件的具體大小，可以通過MQTT數據流模式來上傳文件。

操作步驟

  1. 初始化MQTT模塊。

  2. 初始化MQTT Upload模塊，在mqtt_upload_stream_send_demo.c文件中設置需要上傳文件的信息。

        /* 增加MQTT UPLOAD 組件的初始化，創建upload會話實例 */
    void *up_handle = aiot_mqtt_upload_init();
 /* 把Upload會話和MQTT會話關聯起來 */
    aiot_mqtt_upload_setopt(up_handle, AIOT_MQTT_UPLOADOPT_MQTT_HANDLE, mqtt_handle);
 /* (可選)設置每包數據超時重發的超時時間，默認是5s超時重試 */
    uint32_t rsp_timeout = 10000;
    aiot_mqtt_upload_setopt(up_handle, AIOT_MQTT_UPLOADOPT_RSP_TIMEOUT_MS, &rsp_timeout);
 /* (可選)設置每包數據超時重試的次數，默認是超時重試次數是10次 */
    uint32_t rety_count = 5;
    aiot_mqtt_upload_setopt(up_handle, AIOT_MQTT_UPLOADOPT_RETRY_COUNT, &rety_count);
 /* (可選)設置每包數據發送的大小，默認是2KB，最小不能小于256Byte，最大不能大于128KB */
    uint32_t block_size = 256;
    aiot_mqtt_upload_setopt(up_handle, AIOT_MQTT_UPLOADOPT_DEFAULT_BLOCK_SIZE, &block_size);

    /* 配置MQTT需要上傳的文件信息，未知文件大小，文件長度設置為-1，回調函數read_data_handler設置為NULL，
       使用aiot_mqtt_upload_send_data接口進行數據發送 */
 /* 當MQTT上傳的文件長度為-1時，您可以上傳任意大小不超過16M的文件，上傳過程中您可以隨時將is_commplete參數設置為1，結束并完成文件上傳 */
    uint32_t file_size = -1;
    aiot_mqtt_upload_file_opt_t file_option = {
        .file_name = MQTT_UPLOAD_SINGLE_FILE_NAME,
        .file_size = file_size,
        .mode = AIOT_MQTT_UPLOAD_FILE_MODE_OVERWRITE,
        .digest = NULL,
        .read_data_handler = NULL,
        .userdata = NULL
    };
    aiot_mqtt_upload_setopt(up_handle, AIOT_MQTT_UPLOADOPT_FILE_OPTION, &file_option);

  3. 請求文件上傳。

    請求文件上傳aiot_mqtt_upload_open_stream接口是同步接口，您需要等待應答信息后才能開始進行上傳。

        aiot_mqtt_upload_recv_t recv_packet = {0};
    res = aiot_mqtt_upload_open_stream(up_handle, MQTT_UPLOAD_SINGLE_FILE_NAME, &recv_packet);
    if (res < STATE_SUCCESS) {
        goto exit;
    }

  4. 上傳分片文件。

    您主動調用aiot_mqtt_upload_send_data接口，進行分片數據的上傳。

    is_commplete參數是通知物聯網平臺是否為文件上傳的最后一包數據，所以在上傳的過程中該參數需要設置為0，上傳最后一包數據時is_commplete參數需設置為1。

    if ((upload_file_len + data_len) < MQTT_UPLOAD_SINGLE_FILE_SIZE) {
    /* 發送分包數據 */
    data_len = block_size;
    is_commplete = 0;
} else {
    /* 發送最后一包文件內容 */
    data_len = MQTT_UPLOAD_SINGLE_FILE_SIZE - upload_file_len;
    is_commplete = 1;
}

res = aiot_mqtt_upload_send_data(up_handle, MQTT_UPLOAD_SINGLE_FILE_NAME,            &g_upload_single_file_buf[upload_file_len], data_len, is_commplete);
if (res == STATE_SUCCESS) {
    upload_file_len += data_len;
    printf("upload_file_len:%d\r\n", upload_file_len);
}

  5. 結束所有上傳文件后銷毀會話句柄。

    /* 等待所有文件上傳完成后，才可銷毀MQTT UPload 會話實例 */
aiot_mqtt_upload_deinit(&up_handle);

日志說明

  1. MQTT連接成功。

    [1637138922.457][LK-0313] MQTT user calls aiot_mqtt_connect api, connect
[1637138922.457][LK-032A] mqtt host: iot-*******.iot-as-mqtt.unify.aliyuncs.com
[1637138922.457][LK-0317] user name: mqtt*******************Dih
[1637138922.457][LK-0318] password: 2AE57DEEAADE00***********44BA8F5622507D1EFD6CB7687
success to establish tcp, fd=5
local port: 57**9
[1637138922.488][LK-1000] establish mbedtls connection with server(host='io***********t-as-mqtt.unify.aliyuncs.com', port=[1883])
[1637138922.507][LK-1000] success to establish mbedtls connection, (cost 45247 bytes in total, max used 47983 bytes)
[1637138922.654][LK-0313] MQTT connect success in 197 ms
AIOT_MQTTEVT_CONNECT

  2. MQTT UPLOAD創建會話并進行subtopic訂閱。

    [1637138922.654][LK-2013] aiot_mqtt_upload_init init
[1637138922.654][LK-0309] sub: /sys/a1*****bDih/mqttupload0001/thing/file/upload/mqtt/init_reply
[1637138922.654][LK-0309] sub: /sys/a1*****bDih/mqttupload0001/thing/file/upload/mqtt/send_reply
[1637138922.654][LK-0309] sub: /sys/a1*****bDih/mqttupload0001/thing/file/upload/mqtt/cancel_reply

  3. 請求物聯網平臺進行文件上傳。

    Demo演示請求上傳文件，文件長度：-1，文件名：mqttuploadfile.txt，上傳模式覆蓋模式：overwrite。

    [LK-030A] > 7B 22 69 64 22 3A 22 31  22 2C 22 70 61 72 61 6D | {"id":"1","param
[LK-030A] > 73 22 3A 7B 22 66 69 6C  65 4E 61 6D 65 22 3A 22 | s":{"fileName":"
[LK-030A] > 6D 71 74 74 75 70 6C 6F  61 64 66 69 6C 65 2E 74 | mqttuploadfile.t
[LK-030A] > 78 74 22 2C 22 66 69 6C  65 53 69 7A 65 22 3A 2D | xt","fileSize":-
[LK-030A] > 31 2C 22 63 6F 6E 66 6C  69 63 74 53 74 72 61 74 | 1,"conflictStart
[LK-030A] > 65 67 79 22 3A 22 6F 76  65 72 77 72 69 74 65 22 | egy":"overwrite"
[LK-030A] > 2C 22 69 6E 69 74 55 69  64 22 3A 22 31 36 34 34 | ,"initUid":"1644
[LK-030A] > 32 31 39 33 37 33 33 33  39 37 35 22 7D 7D       | 2193********5"}}

heartbeat response

  4. 收到物聯網平臺應答消息。

    [1644219373.441][LK-0309] pub: /sys/a1P*****Dih/mqttupload0002/thing/file/upload/mqtt/init_reply

[LK-030A] < 7B 22 63 6F 64 65 22 3A  32 30 30 2C 22 64 61 74 | {"code":200,"dat
[LK-030A] < 61 22 3A 7B 22 66 69 6C  65 4E 61 6D 65 22 3A 22 | a":{"fileName":"
[LK-030A] < 6D 71 74 74 75 70 6C 6F  61 64 66 69 6C 65 2E 74 | mqttuploadfile.t
[LK-030A] < 78 74 22 2C 22 75 70 6C  6F 61 64 49 64 22 3A 22 | xt","uploadId":"
[LK-030A] < 64 4E 48 79 33 35 4F 55  4A 66 64 4A 49 31 6B 31 | dNH*********dJI1k1
[LK-030A] < 6D 31 62 55 30 31 30 32  30 30 22 2C 22 6F 66 66 | m1bU010200","off
[LK-030A] < 73 65 74 22 3A 30 2C 22  66 69 6C 65 53 69 7A 65 | set":0,"fileSize
[LK-030A] < 22 3A 2D 31 2C 22 63 6F  6E 66 6C 69 63 74 53 74 | ":-1,"conflictSt
[LK-030A] < 72 61 74 65 67 79 22 3A  22 6F 76 65 72 77 72 69 | rategy":"overwri
[LK-030A] < 74 65 22 7D 2C 22 69 64  22 3A 22 31 22 2C 22 6D | te"},"id":"1","m
[LK-030A] < 65 73 73 61 67 65 22 3A  22 73 75 63 63 65 73 73 | essage":"success
[LK-030A] < 22 7D                                            | "}

[1644219373.441][LK-210B] Recv file name:mqttuploadfile.txt

  5. 分送分片文件。

    循環調用aiot_mqtt_upload_send_data函數進行數據上傳，該函數是同步發送接口，等待應答STATE_SUCCESS后才能發起上傳新的一包數據。

    [1644219373.462][LK-0309] pub: /sys/a1*****Dih/mqttupload0002/thing/file/upload/mqtt/send

[LK-030A] > 00 67 7B 22 69 64 22 3A  22 32 22 2C 22 70 61 72 | .g{"id":"2","par
[LK-030A] > 61 6D 73 22 3A 7B 22 75  70 6C 6F 61 64 49 64 22 | ams":{"uploadId"
[LK-030A] > 3A 22 64 4E 48 79 33 35  4F 55 4A 66 64 4A 49 31 | :"dN*****（fdJI1
[LK-030A] > 6B 31 6D 31 62 55 30 31  30 32 30 30 22 2C 22 6F | k1m1bU010200","o
[LK-030A] > 66 66 73 65 74 22 3A 30  2C 22 62 53 69 7A 65 22 | ffset":0,"bSize"
[LK-030A] > 3A 32 35 36 2C 22 69 73  43 6F 6D 70 6C 65 74 65 | :256,"isComplete
[LK-030A] > 22 3A 66 61 6C 73 65 7D  7D 00 00 00 00 00 00 00 | ":false}}.......
[LK-030A] > 00 00 00 00 00 00 00 00  00 00 00 00 00 00 00 00 | ................
[LK-030A] > 00 00 00 00 00 00 00 00  00 00 00 00 00 00 00 00 | ................
[LK-030A] > 00 00 00 00 00 00 00 00  00 00 00 00 00 00 00 00 | ................
[LK-030A] > 00 00 00 00 00 00 00 00  00 00 00 00 00 00 00 00 | ................
......
......
......

  6. 結束文件上傳。

    上傳最后一包數據時，您需要將isComplete字段設置為1，通知物聯網平臺這是最后一包上傳數據，完成文件上傳。

    [1644219373.734][LK-0309] pub: /sys/a1*****Dih/mqttupload0002/thing/file/upload/mqtt/send

[LK-030A] > 00 68 7B 22 69 64 22 3A  22 35 22 2C 22 70 61 72 | .h{"id":"5","par
[LK-030A] > 61 6D 73 22 3A 7B 22 75  70 6C 6F 61 64 49 64 22 | ams":{"uploadId"
[LK-030A] > 3A 22 64 4E 48 79 33 35  4F 55 4A 66 64 4A 49 31 | :"dN*******dJI1
[LK-030A] > 6B 31 6D 31 62 55 30 31  30 32 30 30 22 2C 22 6F | k1m1bU010200","o
[LK-030A] > 66 66 73 65 74 22 3A 37  36 38 2C 22 62 53 69 7A | ffset":768,"bSiz
[LK-030A] > 65 22 3A 32 35 36 2C 22  69 73 43 6F 6D 70 6C 65 | e":256,"isComple
[LK-030A] > 74 65 22 3A 74 72 75 65  7D 7D 00 00 00 00 00 00 | te":true}}......
[LK-030A] > 00 00 00 00 00 00 00 00  00 00 00 00 00 00 00 00 | ................
......
......
......

[1644219373.822][LK-0309] pub: /sys/a1*******Dih/mqttupload0002/thing/file/upload/mqtt/send_reply

[LK-030A] < 7B 22 63 6F 64 65 22 3A  32 30 30 2C 22 64 61 74 | {"code":200,"dat
[LK-030A] < 61 22 3A 7B 22 66 69 63  4D 6F 64 65 22 3A 22 63 | a":{"ficMode":"c
[LK-030A] < 72 63 36 34 22 2C 22 75  70 6C 6F 61 64 49 64 22 | rc64","uploadId"
[LK-030A] < 3A 22 64 4E 48 79 33 35  4F 55 4A 66 64 4A 49 31 | :"dNHy*******JI1
[LK-030A] < 6B 31 6D 31 62 55 30 31  30 32 30 30 22 2C 22 6F | k1m1bU010200","o
[LK-030A] < 66 66 73 65 74 22 3A 37  36 38 2C 22 63 6F 6D 70 | ffset":768,"comp
[LK-030A] < 6C 65 74 65 22 3A 74 72  75 65 2C 22 66 69 63 56 | lete":true,"ficV
[LK-030A] < 61 6C 75 65 53 65 72 76  65 72 22 3A 22 63 33 37 | alueServer":"c37
[LK-030A] < 38 36 33 39 37 32 30 36  39 32 37 30 63 22 2C 22 | 863972069270c","
[LK-030A] < 62 53 69 7A 65 22 3A 32  35 36 7D 2C 22 69 64 22 | bSize":256},"id"
[LK-030A] < 3A 22 35 22 2C 22 6D 65  73 73 61 67 65 22 3A 22 | :"5","message":"
[LK-030A] < 73 75 63 63 65 73 73 22  7D                      | success"}

[1644219373.822][LK-2125] Complete upload total size:1024
upload_file_len:1024
[1644219373.830][LK-2100] Finish upload,Deleted upload task.MQTT Upload file(mqttuploadfile.txt) uploadid(dNHy35OU*********1bU010200) success.

  7. 上傳完成后銷毀句柄釋放資源。

    [1644219378.827][LK-210F] aiot_mqtt_upload_deinit
[1644219378.827][LK-0309] unsub: /sys/a1P8*****ih/mqttupload0002/thing/file/upload/mqtt/init_reply
[1644219378.827][LK-0309] unsub: /sys/a1P8*****ih/mqttupload0002/thing/file/upload/mqtt/send_reply
[1644219378.827][LK-0309] unsub: /sys/a1P8*****ih/mqttupload0002/thing/file/upload/mqtt/cancel_reply
[1644219378.827][LK-1000] adapter_network_deinit