简介
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'); });
复制代码
评论