HarmonyOS 鸿蒙Next网络ping时延怎么实现

可以通过C++层用ICMP去实现。
std::string TestPing::ping(const char *ip) {
OH_LOG_DEBUG(LOG_APP, "Start ping");

struct sockaddr_in addr;
bzero(&addr, sizeof(addr));
std::string strip = ip;

addr.sin_family = AF_INET;
addr.sin_port = 0;
if (inet_aton(ip, (struct in_addr *)&addr.sin_addr.s_addr) == 0) {
OH_LOG_DEBUG(LOG_APP, "bad ip address: %s\n", ip);

struct hostent* hptr = gethostbyname(ip);
if (hptr == nullptr) {
return "Ping " + strip + ": Name does not resolve\n";
}
memcpy(&addr.sin_addr, hptr->h_addr, sizeof(hptr->h_addr));
}

// 创建一个可以发送和接收ICMP消息的套接字
int sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_ICMP);
if (sock == -1) {
  OH_LOG_DEBUG(LOG_APP, "create icmp socket error");
  return "create icmp socket error";
}

// 设置接收socket消息的超时时间
struct timeval tv;
tv.tv_sec = 0;
tv.tv_usec = RECV_TIMEOUT_USEC;
int ret = setsockopt(sock, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv));
if (ret == -1) {
  OH_LOG_DEBUG(LOG_APP, "setsockopt option error");
  return "setsockopt option error";
}

double next_ts = get_timestamp();
int ident = getpid();
int seq = 1;

double current_ts = get_timestamp();
if (current_ts >= next_ts) {
  // 发送回显请求
  ret = send_echo_request(sock, &addr, ident, seq);
  if (ret == -1) {
    OH_LOG_DEBUG(LOG_APP, "Send failed");

    return "Send failed";
  }

  next_ts = current_ts + 1;
  seq += 1;
}

// 接收ICMP回显应答报文
std::string recv_ping_echo_reply = recv_echo_reply(sock, ident, strip);
if (recv_ping_echo_reply == "") {
  OH_LOG_DEBUG(LOG_APP, "Receive failed");
  return "Receive failed";
}

return recv_ping_echo_reply;
}

std::string TestPing::recv_echo_reply(int sock, int ident, const std::string& strip) {

OH_LOG_DEBUG(LOG_APP, "Start recv_echo_reply");
// 定义缓冲区
unsigned char buffer[IP_BUFFER_SIZE];
struct sockaddr_in peer_addr;

// 接收一个新报文
socklen_t addr_len = sizeof(peer_addr);
int bytes = recvfrom(sock, buffer, sizeof(buffer), 0, (struct sockaddr *)&peer_addr, &addr_len);
if (bytes == -1) {
// 接收报文超时
if (errno == EAGAIN || errno == EWOULDBLOCK) {
OH_LOG_DEBUG(LOG_APP, "errno == EAGAIN || errno == EWOULDBLOCK, timeout, return\n");
return "";
}
OH_LOG_DEBUG(LOG_APP, "recvfrom bytes is -1, return\n");
return "";
}

// IP头部长度
int ip_header_len = (buffer[0] & 0xf) << 2;
// 从IP报文中取出ICMP报文
struct icmp_echo *icmp = (struct icmp_echo *)(buffer + ip_header_len);

// 检查ICMP报文类型
if (icmp->type != 0 || icmp->code != 0) {
  OH_LOG_DEBUG(LOG_APP, "check type failed\n");
  return "";
}

// IP头部
struct ip *iphdr = (struct ip *)buffer;

std::ostringstream stream;
stream << "Ping " << strip << "(" << inet_ntoa(peer_addr.sin_addr) << "):\n"
  << inet_ntoa(peer_addr.sin_addr) << " seq=" << ntohs(icmp->seq)
  << " ttl=" << static_cast<unsigned int>(iphdr->ip_ttl) << " time=" << std::fixed << std::setprecision(2)
  << (get_timestamp() - icmp->sending_ts) * 1000 << "ms\n";

OH_LOG_DEBUG(LOG_APP, "stream.str(): %s\n", stream.str().c_str());

return stream.str();
}