HarmonyOS网络管理开发—Socket连接

简介

socket连接主要是通过socket进行数据传输，支持tcp/udp/tls协议。

基本概念

​ ● socket：套接字，就是对网络中不同主机上的应用进程之间进行双向通信的端点的抽象。

​ ● tcp：传输控制协议(transmission control protocol)。是一种面向连接的、可靠的、基于字节流的传输层通信协议。

​ ● udp：用户数据报协议协议(user datagram protocol)。是一个简单的面向消息的传输层，不需要连接。

​ ● tls：安全传输层协议(transport layer security)。用于在两个通信应用程序之间提供保密性和数据完整性。

场景介绍

应用通过socket进行数据传输，支持tcp/udp/tls协议。主要场景有：

​ ● 应用通过tcp/udp socket进行数据传输

​ ● 应用通过tls socket进行加密数据传输

接口说明

完整的js api说明以及实例代码请参考：socket连接。

socket连接主要由socket模块提供。具体接口说明如下表。

tls socket连接主要由tls_socket模块提供。具体接口说明如下表。

应用tcp/udp协议进行通信

udp与tcp流程大体类似，下面以tcp为例：

​ 1. import需要的socket模块。

​ 2. 创建一个tcpsocket连接，返回一个tcpsocket对象。

​ 3. （可选）订阅tcpsocket相关的订阅事件。

​ 4. 绑定ip地址和端口，端口可以指定或由系统随机分配。

​ 5. 连接到指定的ip地址和端口。

​ 6. 发送数据。

​ 7. socket连接使用完毕后，主动关闭。

import socket from '@ohos.net.socket'

// 创建一个tcpsocket连接，返回一个tcpsocket对象。
let tcp = socket.constructtcpsocketinstance();

// 订阅tcpsocket相关的订阅事件
tcp.on('message', value => {
  console.log("on message")
  let buffer = value.message
  let dataview = new dataview(buffer)
  let str = ""
  for (let i = 0; i < dataview.bytelength; ++i) {
    str += string.fromcharcode(dataview.getuint8(i))
  }
  console.log("on connect received:" + str)
});
tcp.on('connect', () => {
  console.log("on connect")
});
tcp.on('close', () => {
  console.log("on close")
});

// 绑定ip地址和端口。
let bindaddress = {
  address: '192.168.xx.xx',
  port: 1234, // 绑定端口，如1234
  family: 1
};
tcp.bind(bindaddress, err => {
  if (err) {
    console.log('bind fail');
    return;
  }
  console.log('bind success');
  // 连接到指定的ip地址和端口。
  let connectaddress = {
    address: '192.168.xx.xx',
    port: 5678, // 连接端口，如5678
    family: 1
  };
  tcp.connect({
    address: connectaddress, timeout: 6000
  }, err => {
    if (err) {
      console.log('connect fail');
      return;
    }
    console.log('connect success');
    // 发送数据
    tcp.send({
      data: 'hello, server!'
    }, err => {
      if (err) {
        console.log('send fail');
        return;
      }
      console.log('send success');
    })
  });
});
// 连接使用完毕后，主动关闭。取消相关事件的订阅。
settimeout(() => {
  tcp.close((err) => {
    console.log('close socket.')
  });
  tcp.off('message');
  tcp.off('connect');
  tcp.off('close');
}, 30 * 1000);

应用通过tls socket进行加密数据传输

开发步骤

客户端tls socket流程：

​ 1. import需要的socket模块。

​ 2. 绑定服务器ip和端口号。

​ 3. 双向认证上传客户端ca证书及数字证书；单向认证上传客户端ca证书。

​ 4. 创建一个tlssocket连接，返回一个tlssocket对象。

​ 5. （可选）订阅tlssocket相关的订阅事件。

​ 6. 发送数据。

​ 7. tlssocket连接使用完毕后，主动关闭。

 import socket from '@ohos.net.socket'

   // 创建一个（双向认证）tls socket连接，返回一个tls socket对象。
   let tlstwoway = socket.constructtlssocketinstance();

   // 订阅tls socket相关的订阅事件
   tlstwoway.on('message', value => {
       console.log("on message")
       let buffer = value.message
       let dataview = new dataview(buffer)
       let str = ""
       for (let i = 0; i < dataview.bytelength; ++i) {
           str += string.fromcharcode(dataview.getuint8(i))
       }
       console.log("on connect received:" + str)
   });
   tlstwoway.on('connect', () => {
       console.log("on connect")
   });
   tlstwoway.on('close', () => {
       console.log("on close")
   });

   // 绑定本地ip地址和端口。
   tlstwoway.bind({ address: '192.168.xxx.xxx', port: xxxx, family: 1 }, err => {
       if (err) {
           console.log('bind fail');
           return;
       }
       console.log('bind success');
   });

   // 设置通信过程中使用参数
   let options = {
       alpnprotocols: ["spdy/1", "http/1.1"],

       // 连接到指定的ip地址和端口。
       address: {
           address: "192.168.xx.xxx",
           port: xxxx, // 端口
           family: 1,
       },

       // 设置用于通信过程中完成校验的参数。
       secureoptions: {
           key: "xxxx",                            // 密钥
           cert: "xxxx",                           // 数字证书
           ca: ["xxxx"],                           // ca证书
           passwd: "xxxx",                         // 生成密钥时的密码
           protocols: [socket.protocol.tlsv12],    // 通信协议
           useremotecipherprefer: true,            // 是否优先使用对端密码套件
           signaturealgorithms: "rsa_pss_rsae_sha256:ecdsa+sha256",    // 签名算法
           ciphersuite: "aes256-sha256",           // 密码套件
       },
   };

   // 建立连接
   tlstwoway.connect(options, (err, data) => {
       console.error(err);
       console.log(data);
   });

   // 连接使用完毕后，主动关闭。取消相关事件的订阅。
   tlstwoway.close((err) => {
       if (err) {
           console.log("close callback error = " + err);
       } else {
           console.log("close success");
       }
       tlstwoway.off('message');
       tlstwoway.off('connect');
       tlstwoway.off('close');
   });

   // 创建一个（单向认证）tls socket连接，返回一个tls socket对象。
   let tlsoneway = socket.constructtlssocketinstance(); // one way authentication

   // 订阅tls socket相关的订阅事件
   tlstwoway.on('message', value => {
       console.log("on message")
       let buffer = value.message
       let dataview = new dataview(buffer)
       let str = ""
       for (let i = 0;i < dataview.bytelength; ++i) {
           str += string.fromcharcode(dataview.getuint8(i))
       }
       console.log("on connect received:" + str)
   });
   tlstwoway.on('connect', () => {
       console.log("on connect")
   });
   tlstwoway.on('close', () => {
       console.log("on close")
   });

   // 绑定本地ip地址和端口。
   tlsoneway.bind({ address: '192.168.xxx.xxx', port: xxxx, family: 1 }, err => {
       if (err) {
           console.log('bind fail');
           return;
       }
       console.log('bind success');
   });

   // 设置通信过程中使用参数
   let onewayoptions = {
       address: {
           address: "192.168.xxx.xxx",
           port: xxxx,
           family: 1,
       },
       secureoptions: {
           ca: ["xxxx","xxxx"],            // ca证书
           ciphersuite: "aes256-sha256",   // 密码套件
       },
   };

   // 建立连接
   tlsoneway.connect(onewayoptions, (err, data) => {
       console.error(err);
       console.log(data);
   });

   // 连接使用完毕后，主动关闭。取消相关事件的订阅。
   tlstwoway.close((err) => {
       if (err) {
           console.log("close callback error = " + err);
       } else {
           console.log("close success");
       }
       tlstwoway.off('message');
       tlstwoway.off('connect');
       tlstwoway.off('close');
   });