如何使所有的设备在网络内部统一？

Question

现在已经有大约8个小时了，我正试图找到一种方法，这样我就可以接收与我在同一个网络中的所有设备。我已经找到了一些方法来做到这一点，但它们都归结为对网络中的所有in进行ping。如果联合允许多线程，那就不是什么大问题了。由于它不/基本上只允许IEnumerator，所以我不得不一个接一个地执行每个ping，这需要大量的时间，您甚至不能使用GUI。

我目前的代码如下：

public class AddressFinder {

    private List<Ping> pingers = new List<Ping>();
    private List<IPAddress> addresses = new List<IPAddress>();

    private int timeOut = 250;
    private int ttl = 5;
    private int instances;
    private MonoBehaviour m;

    public void Scan(MonoBehaviour mono, IPSegment ips, Action<List<IPAddress>> callback) {
        this.m = mono;
        m.StartCoroutine(ScanAsync(ips, callback)); // New Coroutine so the UI should not freeze
    }

    private IEnumerator ScanAsync(IPSegment ips, Action<List<IPAddress>> callback) {
        PingOptions po = new PingOptions(ttl, true);
        byte[] data = new System.Text.ASCIIEncoding().GetBytes("abababababababababababababababab");
        instances = 0;
        foreach(uint host in ips.Hosts()) {  // Itterate through all IPs in that network
            m.StartCoroutine(Send(IPHelper.ToIpString(host) // IP as String, data, po));
        }
        WaitForSeconds wait = new WaitForSeconds(0.05f);
        while(instances > 0) {
            yield return wait;
        }
        callback(addresses);
    }

    private IEnumerator Send(string ip, byte[] data, PingOptions po) {
        instances++;
        Ping p = new Ping();
        PingReply rep = p.Send(ip, timeOut, data, po);
        p.Dispose();
        if(rep.Status == IPStatus.Success)
            addresses.Add(IPAddress.Parse(ip));
        instances--;
        yield return new WaitForSeconds(0);
    }
}

这个wcode将实际工作，但需要像4分钟来测试所有253个in在我的网络。此外，UI冻结在这段时间。

我也试着用团结平，它看上去很不一致，也没有那么好用，因为它也需要254平的时间。

有没有人知道问题是什么，或者有另一个想法让所有的设备都进入网络？

Answer 1

我找到了一条解决问题的方法。实际上，我认为不应该在Unity中使用线程，但它似乎只是不使用主线程之外的Unity，这意味着其他线程是允许的。总之，这是我的密码：

using Ping = System.Net.NetworkInformation.Ping;

public class AddressFinder {

    public List<string> addresses = new List<string>();
    private MonoBehaviour m;

    Thread myThread = null;
    public int instances = 0;

    public AddressFinder(MonoBehaviour mono) {
        m = mono;
    }

    public void Scan(List<IPSegment> iPSegments, Action<List<string>> addresses) {
        myThread = new Thread(() => ScanThreads(iPSegments, addresses));
        myThread.Start();
    }

    private void ScanThreads(List<IPSegment> iPSegments, Action<List<string>> callback) {
        Ping myPing;
        PingReply reply;
        instances = 0;

        foreach(IPSegment ips in iPSegments) {
            foreach(uint hosta in ips.Hosts()) {
                string ip = IPHelper.ToIpString(hosta);
                Task.Factory.StartNew(() => {
                    myPing = new Ping();
                    instances++;
                    reply = myPing.Send(ip, 250);

                    if(reply.Status == IPStatus.Success) {
                        addresses.Add(ip);
                    }
                    instances--;
                }, TaskCreationOptions.PreferFairness | TaskCreationOptions.LongRunning);
            }
        }
        int i = 0;
        while(instances > 0) {
            if(i > 100)
                break;
            i++;
            Thread.Sleep(10);
        }
        callback(addresses);
    }
}

public class LobbyManager : MonoBehaviour {

    public UnityEngine.Object[] Games;
    private List<string> localAddresses = new List<string>();
    private List<string> hostAddresses = new List<string>();
    private Ping p;
    AddressFinder af;

    public void Start() {
        List<IPSegment> iPSegments = GetInterfaces(true);
        af = new AddressFinder(this);
        af.Scan(
            iPSegments,
            (addresses) => {
                localAddresses = addresses;
                foreach(string address in localAddresses) {
                    Debug.Log(address.ToString());
                }
            }
        );
    }

    public void Update() {

    }

    public List<IPSegment> GetInterfaces(bool showVPN) {
        List<IPSegment> ipsList = new List<IPSegment>();
        foreach(NetworkInterface ni in NetworkInterface.GetAllNetworkInterfaces()) {
            if(ni.Name.Contains("VM") || ni.Name.Contains("Loopback"))
                continue;
            if(!showVPN && ni.Name.Contains("VPN"))
                continue;
            foreach(UnicastIPAddressInformation ip in ni.GetIPProperties().UnicastAddresses) {
                if(ip.Address.AddressFamily == AddressFamily.InterNetwork) {
                    IPSegment ips = new IPSegment(ip.Address.ToString(), ip.IPv4Mask.ToString());
                    ipsList.Add(ips);
                }
            }
        }
        return ipsList;
    }
}

IPSegment是根据子网掩码将此段中的所有is保存在其中的类。

这段代码工作得很好，但并不是那种穿孔，这意味着不应该有比255.255.255.0更高的子网掩码，否则它将需要时间。