Dart中如何实现WebSocket通信

在Dart中实现WebSocket通信，可以使用dart:io库中的WebSocket类来创建WebSocket服务器和客户端。以下是一个简单的示例代码，展示如何在Dart中实现WebSocket通信：

1. 创建一个WebSocket服务器：

import 'dart:io';

void main() {
  runWebSocketServer();
}

void runWebSocketServer() async {
  var server = await HttpServer.bind(InternetAddress.loopbackIPv4, 8080);
  print('WebSocket server listening on ws://${server.address.address}:${server.port}');

  var webSocket = await server.transform(WebSocketTransformer()).listen((webSocket) {
    print('WebSocket connected');

    webSocket.listen((data) {
      print('Received data: $data');
      webSocket.add('Received: $data');
    }, onDone: () {
      print('WebSocket disconnected');
    });
  });
}

2. 创建一个WebSocket客户端：

import 'dart:io';
import 'dart:async';

void main() {
  runWebSocketClient();
}

void runWebSocketClient() {
  WebSocket.connect('ws://localhost:8080').then((webSocket) {
    print('Connected to WebSocket server');

    webSocket.listen((data) {
      print('Received data: $data');
    });

    webSocket.add('Hello, WebSocket server');
  });
}

以上代码分别创建了一个WebSocket服务器和一个WebSocket客户端，它们能够进行简单的消息传递。在实际应用中，可以根据具体需求来扩展WebSocket通信功能。