客戶端只在發送訊息時監聽服務器

我正在實作套接字。兩個客戶端連接到服務器沒有問題，當客戶端 1 向服務器發送訊息時，服務器將其發布給所有其他客戶端（在這種情況下是客戶端 2）。但是 client2 除非發送訊息，否則不會收到訊息。客戶端的監聽器似乎不起作用。顯然，我希望 client2 立即從 client1 獲取訊息。

這是我的服務器代碼：

import 'dart:io';
import 'dart:typed_data';

void main() async {
  // bind the socket server to an address and port
  MySocket mySocket = MySocket();
  await mySocket.init();
}

class MySocket {
  ServerSocket? server;
  List<Socket> clients = [];

  //initialize the socket
  init() async {
    server = await ServerSocket.bind("192.168.0.112", 4000);
    // listen for client connections to the server
    server!.listen((client) {
      handleConnection(client);
      addClient(client);
    });
  }

  void handleConnection(Socket client) async {
    print('Connection from'
        ' ${client.remoteAddress.address}:${client.remotePort}');

    // listen for events from the client
    client.listen(
      // handle data from the client
      (Uint8List data) async {
        await Future.delayed(Duration(seconds: 1));
        final message = String.fromCharCodes(data);
        print(message);
        publish(message, client);
      },

      // handle errors
      one rror: (error) {
        print(error);
        client.close();
      },

      // handle the client closing the connection
      onDone: () {
        print('Client left');
        client.close();
      },
    );
  }

  void addClient(Socket client) {
    //if client doesn't already exist add it to the list of clients
    if (!clients.any((element) =>
        '${client.remoteAddress.address}:${client.remotePort}' ==
        '${element.remoteAddress.address}:${element.remotePort}')) {
      clients.add(client);
    }
  }

  void publish(String message, Socket client) {
    //write the message to every client except the author of it
    clients.forEach((element) async {
      if ('${client.remoteAddress.address}:${client.remotePort}' !=
          '${element.remoteAddress.address}:${element.remotePort}') {
        element.write(message);
      }
    });
  }
}

這是我的客戶端代碼：

import 'dart:io';
import 'dart:typed_data';

void main() async {
  //gets the username
  String name = '';
  while (name.isEmpty) {
    print('Enter your name: ');
    name = stdin.readLineSync() ?? '';
  }

  // connect to the socket server
  final socket = await Socket.connect("192.168.0.112", 4000);
  print('Connected to: ${socket.remoteAddress.address}:${socket.remotePort}');


  // listen for responses from the server
  socket.listen(
    // handle data from the server
    (Uint8List data) {
      final serverResponse = String.fromCharCodes(data);
      print('$serverResponse');
    },

    // handle errors
    one rror: (error) {
      print(error);
      socket.destroy();
    },

    // handle server ending connection
    onDone: () {
      print('Left server.');
      socket.destroy();
    },
  );


  // sending messages to the server
  String message = "";
  while (message != "exit") {
    message = stdin.readLineSync() ?? '';
    await sendMessage(socket, name, message);
  }
  socket.close();
}


Future<void> sendMessage(Socket socket, String name, String message) async {
  socket.write('$name: $message');
  await Future.delayed(Duration(seconds: 2));
}

先感謝您。

uj5u.com熱心網友回復：

問題是因為stdin.readLineSync()在您的客戶端中阻止了當前執行緒。您可以通過生成一個隔離來處理該部分代碼來解決這個問題，這樣它就不會阻止socket.listen從服務器列印出回應。

請參閱下面的更新客戶端代碼：

import 'dart:io';
import 'dart:isolate';
import 'dart:typed_data';

void main() async {
  //gets the username
  String name = '';
  while (name.isEmpty) {
    print('Enter your name: ');
    name = stdin.readLineSync() ?? '';
  }

  // connect to the socket server
  final socket = await Socket.connect("192.168.0.112", 4000);
  print('Connected to: ${socket.remoteAddress.address}:${socket.remotePort}');

  // listen for responses from the server
  socket.listen(
    // handle data from the server
    (Uint8List data) {
      final serverResponse = String.fromCharCodes(data);
      print('$serverResponse');
    },

    // handle errors
    one rror: (dynamic error) {
      print(error);
      socket.destroy();
    },

    // handle server ending connection
    onDone: () {
      print('Left server.');
      socket.destroy();
    },
  );

  final receive = ReceivePort();
  final isolate = await Isolate.spawn(readMessages, receive.sendPort);
  await for (final message in receive) {
    if (message == 'exit') break;
    await sendMessage(socket, name, message as String);
  }

  socket.close();
}

void readMessages(SendPort port) {
  String message = '';
  while (message != 'exit') {
    message = stdin.readLineSync() ?? '';
    port.send(message);
  }
  Isolate.exit(port);
}

Future<void> sendMessage(Socket socket, String name, String message) async {
  socket.write('$name: $message');
  await Future<void>.delayed(Duration(seconds: 2));
}

標籤：扑 插座 镖

上一篇：在Python中使用socket.connect()之前查找作業系統生成的埠

下一篇：如何將請求從服務器斷開連接發送到所有客戶端并且服務器仍然存在（python套接字）