Dart 网络 I/O 源码剖析

2023-11-19 05:17:36

Dart 网络 I/O 源码剖析

在 [上篇](Dart IO 源码剖析（上）) 中，我们详细剖析了 Dart 的文件 I/O。这一章，我们将剖析 Dart 网络 I/O。

网络 I/O 基于上篇的基础，我们已经大概知道 Dart VM 的一些知识，那么这篇文

章我们就直接从 Dart 网络 I/O 的核心——Socket 开始。

Socket

Socket 是网络 I/O 的基础，它表示一个网络连接的端点。在 Dart 中，Socket 类位于 dart:io 库中。

Socket 的构造函数需要两个参数：一个 address 和一个 port。address 是一个 InternetAddress 对象，表示要连接的远程主机的 IP 地址。port 是一个整数，表示要连接的远程主机的端口号。

import 'dart:io';

main() async {
  // 创建一个 IPv4 的 Socket。
  Socket socket = await Socket.connect('127.0.0.1', 8080);

  // 写入一些数据到 Socket 中。
  socket.write('Hello, world!');

  // 从 Socket 中读取数据。
  socket.listen((data) {
    print('收到数据: $data');
  });

  // 关闭 Socket。
  socket.close();
}

这段代码创建一个连接到本地主机 8080 端口的 IPv4 Socket。然后，它向 Socket 写入一些数据，并监听来自 Socket 的数据。最后，它关闭 Socket。

HTTP

HTTP（超文本传输协议）是一种用于在万维网上传输数据的协议。在 Dart 中，HTTP 支持位于 dart:io 库中。

HTTP 类表示一个 HTTP 连接。它可以用来发送和接收 HTTP 请求和响应。

import 'dart:io';

main() async {
  // 创建一个 HTTP 连接。
  HttpClient client = HttpClient();

  // 发送一个 GET 请求。
  HttpClientRequest request = await client.getUrl(Uri.parse('https://www.google.com'));

  // 监听来自服务器的响应。
  HttpClientResponse response = await request.close();

  // 打印响应状态码。
  print('状态码: ${response.statusCode}');

  // 打印响应正文。
  response.transform(utf8.decoder).listen((data) {
    print('响应正文: $data');
  });

  // 关闭 HTTP 连接。
  client.close();
}

这段代码创建一个 HTTP 连接并发送一个 GET 请求到 Google 的主页。然后，它监听来自服务器的响应，并打印响应状态码和响应正文。最后，它关闭 HTTP 连接。

WebSocket

WebSocket 是一种在单个 TCP 连接上进行全双工通信的协议。在 Dart 中，WebSocket 支持位于 dart:io 库中。

WebSocket 类表示一个 WebSocket 连接。它可以用来发送和接收 WebSocket 消息。

import 'dart:io';

main() async {
  // 创建一个 WebSocket 连接。
  WebSocket webSocket = await WebSocket.connect('ws://localhost:8080/websocket');

  // 发送一个消息到 WebSocket。
  websocket.add('Hello, world!');

  // 监听来自 WebSocket 的消息。
  websocket.listen((data) {
    print('收到消息: $data');
  });

  // 关闭 WebSocket 连接。
  websocket.close();
}