Flutter网络通信插件client_server_sockets的使用

Flutter网络通信插件client_server_sockets的使用

这是一个简单的客户端-服务器套接字包，它使用了Socket和ServerSocket类。

使用方法

启动服务器：

// 启动服务器实例
Server.instance.start();

通过地址连接客户端到服务器：

// 连接到指定IP地址的服务器
Client.instance.connect("192.168.1.10");

发送消息到服务器：

// 从客户端发送消息到服务器
Client.instance.send("Hello World!");

广播消息给所有客户端：

// 服务器向所有客户端广播消息
Server.instance.broadcast("Broadcasted message");

为了从一个客户端发送消息到另一个客户端，可以使用Payload类配合服务器上的sendTo()函数。更多详细信息请查看示例代码。

示例代码

以下是完整的示例代码，展示了如何使用这个插件来实现基本的客户端-服务器通信。

import 'dart:io';

import 'package:client_server_sockets/client_server_sockets.dart';

void main(List<String> args) {
  // 检查是否传入参数
  if (args.isEmpty) {
    print("No args passed");
    print("Usage:");
    print("Server: dart example/main.dart s");
    print("Client: dart example/main.dart c");
    print("Client with prompt: dart example/main.dart cp");
    return;
  }
  
  // 根据传入参数选择运行模式
  if (args.first == "s") _server();
  if (args.first == "c") _client();
  if (args.first == "cp") _client(true);
}

// 服务器端逻辑
void _server() async {
  final started = await Server.instance.start(
    onServerError: (error) {
      // 处理服务器错误
      print("Server error: $error");
    },
    onNewClient: (client) {
      // 新客户端连接时触发
      print("New client: ${client.remotePort}");
    },
    onClientData: (client, data) {
      // 接收到客户端数据时触发
      Payload payload = Payload.fromJson(data);
      print("Message from client ${client.remotePort}: $payload");
      // 将消息转发到指定端口的客户端
      Server.instance.sendTo(payload.port, payload.data);
    },
    onClientError: (client, error) {
      // 处理客户端错误
      print("Error from client ${client.remotePort}: $error");
    },
    onClientLeft: (client) {
      // 客户端离开时触发
      print("Client ${client.remotePort} left");
    },
  );

  if (!started) {
    print("Couldn't start server");
    return;
  }

  print("server running on ${Server.instance.port}");

  // 延迟30秒后广播消息
  Future.delayed(Duration(seconds: 30), () {
    String? message;
    do {
      print("Enter message to broadcast:");
      message = stdin.readLineSync();
    } while (message == null || message.isEmpty);

    Server.instance.broadcast(message);
  });
}

// 客户端逻辑
void _client([bool prompt = false]) async {
  final connected = await Client.instance.connect(
    "192.168.1.10", // 替换为你的服务器IP地址
    onClientError: (error) {
      // 处理客户端错误
      print("Client error: $error");
    },
    onServerData: (data) {
      // 接收到服务器数据时触发
      print("Message from sever: $data");
    },
    onServerError: (error) {
      // 处理服务器错误
      print("Error from server: $error");
    },
    onServerStopped: () {
      // 服务器停止时触发
      print("Server stopped");
    },
  );

  if (!connected) {
    print("Couldn't connect to server");
    return;
  }

  print("Connected to ${Client.instance.remotePort} from ${Client.instance.port}");

  if (prompt) _prompts();
}

// 客户端提示输入
void _prompts() {
  Future.delayed(Duration(seconds: 10), () {
    String? port;
    do {
      print("Enter client port you wish to send a message to:");
      port = stdin.readLineSync();
    } while (port == null || port.isEmpty);

    String? message;
    do {
      print("Enter message to send to client 2:");
      message = stdin.readLineSync();
    } while (message == null || message.isEmpty);

    // 创建Payload对象并发送消息
    Payload payload = Payload(port: int.parse(port), data: message);

    Client.instance.send(payload.toJson());
  });
}