通过预建连接提升HTTP传输性能

import { rcp } from '@kit.RemoteCommunicationKit';

export async function startConnectionOnlyByRequest() {
  const session = rcp.createSession();
  const request = new rcp.Request('https://example.com', 'GET');
  request.connectOnly = true;

  const response = await session.fetch(request);
  console.info(`Request succeeded, statusCode is ${response.statusCode}`);

  // 此session可用于发起后续请求
}

#include "RemoteCommunicationKit/rcp.h"
#include <stdio.h>
#include <thread>

void DataRequestCallback(void *userContext, Rcp_Response *response, uint32_t errCode) {
    printf("DataRequest callback, errCode: %u\n", errCode);
    if (response != nullptr) {
        printf("Data request succeeded, status code: %d\n", response->statusCode);
        response->destroyResponse(response);
    }
}

void dataTransRequest() {
    uint32_t errCode = 0;
    // 创建session
    Rcp_Session *session = HMS_Rcp_CreateSession(nullptr, &errCode);
    printf("create session end: %d\n", errCode);
    const char *kHttpServerAddress = "https://example.com";
    Rcp_Request *dataRequest = HMS_Rcp_CreateRequest(kHttpServerAddress);
    dataRequest->method = RCP_METHOD_GET;

    // 设置本次请求仅建立连接。
    errCode = HMS_Rcp_SetRequestConnectOnly(dataRequest, true);

    Rcp_ResponseCallbackObject callback = {DataRequestCallback, nullptr};

    errCode = HMS_Rcp_Fetch(session, dataRequest, &callback);
    printf("session fetch end: %d\n", errCode);

    // 等待结果，仅是等待异步调用完成，开发者可根据自己实际场景处理回调。
    std::this_thread::sleep_for(std::chrono::milliseconds(1000 * 1000 * 3));

    // 请求完成后，清理request
    HMS_Rcp_DestroyRequest(dataRequest);

    // 此session在被close前可用于发起后续请求
    errCode = HMS_Rcp_CloseSession(&session);
    printf("HMS_Rcp_CloseSession end errCode: %d\n", errCode);
}

import { rcp } from '@kit.RemoteCommunicationKit';

export async function startConnectionOnlyByRequest() {
  const defaultSession = rcp.getDefaultSession();
  const request = new rcp.Request('https://example.com', 'GET');
  request.connectOnly = true;

  const response = await defaultSession.fetch(request);
  console.info(`Request succeeded, statusCode is ${response.statusCode}`);

  // 可以在默认session上发起后续请求
}

#include <stdio.h>
#include <thread>
#include "RemoteCommunicationKit/rcp.h"

Rcp_Session *defaultSession = nullptr;

void DataRequestCallback(void *userContext, Rcp_Response *response, uint32_t errCode) {
    printf("DataRequest callback, errCode: %u\n", errCode);
    if (response != nullptr) {
        printf("Data request succeeded, status code: %d\n", response->statusCode);
        response->destroyResponse(response);
    }
}

void dataTransRequest() {
    uint32_t errCode = 0;
    // 获得默认session
    errCode = HMS_Rcp_GetDefaultSession(&defaultSession);

    printf("create session end: %d\n", errCode);
    const char *kHttpServerAddress = "https://example.com";
    Rcp_Request *dataRequest = HMS_Rcp_CreateRequest(kHttpServerAddress);
    dataRequest->method = RCP_METHOD_GET;
  
    Rcp_ResponseCallbackObject callback = {DataRequestCallback, nullptr};
    errCode = HMS_Rcp_Fetch(defaultSession, dataRequest, &callback);
    printf("defaultSession fetch end: %d\n", errCode);
    // 等待结果，仅是等待异步调用完成，开发者可根据自己实际场景处理回调。
    std::this_thread::sleep_for(std::chrono::milliseconds(1000 * 1000 * 3));
    // 清理request
    HMS_Rcp_DestroyRequest(dataRequest);

    // 可以在默认session上发起后续请求

    // 当不再需要默认session时，使用HMS_Rcp_CloseSession释放对默认session的强引用
    errCode = HMS_Rcp_CloseSession(&defaultSession);
    printf("HMS_Rcp_CloseSession end errCode: %d\n", errCode);
}