Dart中如何實(shí)現(xiàn)WebSocket通信

在Dart中實(shí)現(xiàn)WebSocket通信，可以使用dart:io庫中的WebSocket類來創(chuàng)建WebSocket服務(wù)器和客戶端。以下是一個(gè)簡單的示例代碼，展示如何在Dart中實(shí)現(xiàn)WebSocket通信：

1. 創(chuàng)建一個(gè)WebSocket服務(wù)器：

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. 創(chuàng)建一個(gè)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');
  });
}

以上代碼分別創(chuàng)建了一個(gè)WebSocket服務(wù)器和一個(gè)WebSocket客戶端，它們能夠進(jìn)行簡單的消息傳遞。在實(shí)際應(yīng)用中，可以根據(jù)具體需求來擴(kuò)展WebSocket通信功能。