web_synchronization_tool/lib/windows/socket_tool.dart

import 'dart:async';
import 'dart:convert';
import 'dart:io';
import 'dart:typed_data';
import 'package:web_synchronization_tool/windows/synchronization_web_tool.dart';

import 'little_extension.dart';
import 'code.dart';
import 'number_tool.dart';

class SocketUtils extends SyncSocket{
  // 私有构造函数
  SocketUtils._();
  // 私有静态变量，保存类的唯一实例
  static SocketUtils? _instance;

  // 公开的静态方法，返回类的唯一实例
  static SocketUtils getInstance() {
    _instance ??= SocketUtils._();
    return _instance!;
  }

}

class SyncSocket {

  String url = '127.0.0.1';
  static int port = 12345;

  RawDatagramSocket? socket;

  // IC 0主机 1 从机
  int ic = 0;

  /// 从机ip
  List<String> childrenIp = [];

  connect() async {
    socket?.close();
    socket = await RawDatagramSocket.bind(InternetAddress.anyIPv4, 0);

    // 发送身份包
    Map data = {
      "op": 0,
      "IC": ic
    };
    socket?.send(dataMake(data), InternetAddress(url), port);

    // 监听来自网络的数据包
    socket?.listen((RawSocketEvent e) {
      Datagram? d = socket?.receive();
      if (d == null) return;

      Map data = dataCute(d.data);

      // 收到消息
      if (data['op'] == 2){

        print(data);

        //点击
        if (data['click'] != null){
          Map click = data['click'];
          int x = click['x'] as int;
          int y = click['y'] as int;

          SynchronizationWebTool.getInstance().clickSynchronization(x, y);
        }
        //输入
        if (data['input'] != null){
          int input = data['input'];
          List<int> nums = NumberTool().randomNum(input);
          SynchronizationWebTool.getInstance().input(nums);
        }

      }

      // 心跳
      if (data['op'] == 11){

      }
      // 服务器 已连接的ip
      if (data['Arr'] != null){
        List arr = data['Arr'];
        List<String> ips = [];
        arr.forEach((clientMap) {
          String ip = clientMap['Client'];
          ips.add(ip);
        });
        childrenIp = ips;
      }

    });

  }

  /// 发送消息
  sendClickMessage(Map data){
    Map messageMap = {
      "op": 2,
      "click": data
    };
    socket?.send(dataMake(messageMap), InternetAddress(url), port);
  }

  /// 发送获取从机 消息
  sendGetChilds(){
    Map messageMap = {
      "op": 3,
    };
    socket?.send(dataMake(messageMap), InternetAddress(url), port);
  }


  /// 发送输入喜消息
  sendInpuMessage(int num){
    Map messageMap = {
      "op": 2,
      "input": num
    };
    socket?.send(dataMake(messageMap), InternetAddress(url), port);
  }

  /// 心跳
  heartbeat(){
    Timer timer = Timer(const Duration(seconds: 10), () async {

      if (socket == null){
        // 重连
        await connect();
      }

      Map data =   {
        "op": 1,
        "IC": ic
      };
      socket?.send(dataMake(data), InternetAddress(url), port);

      heartbeat();
    });
  }

  /// 发送数据的处理
  List<int> dataMake(Map map){
    // 将Map对象转换为JSON字符串
    String json = jsonEncode(map);
    // 加密
    String ps = makecode(json, skey);
    // 转成无符号整数数组
    Uint8List uinData = Uint8List.fromList(ps.codeUnits);
    // 在前面添加 4位 表示长度的小端序
    uinData = uinData.toLittle(value: uinData.length);
    return uinData.toList();
  }

  /// 接收数据处理
  Map dataCute(Uint8List data){

    if (data.length <= 4) return {};

    Uint8List pData = data.sublist(4,data.length);

    String str = cutecode(pData);

    Map map = json.decode(str);

    return map;
  }

}