C# UDPClient 接受任何 IP 地址

Question

我正在尝试用 C# 编写一个 3 路 UDP 打孔应用程序。根据我的阅读，步骤如下。

1. Peer 1 连接到服务器
2. 服务器备注 IP 地址和端口
3. Peer 2 连接到服务器并获取 Peer 1 详细信息
4. Peer 2 连接到 Peer 1

我现在拥有的是 Peer 1 正在连接到端口 8924 上的服务器，服务器将远程 IP 地址和端口详细信息写入 SQL 数据库。 Peer 2 连接到服务器并请求详细信息，然后 Peer 2 使用获得的详细信息创建一个新的 UDPClient 和 IPEndpoint。到目前为止一切似乎都正常，但是当 Peer 2 向 Peer 1 发送数据时，什么都没有到达。

连接 Peer 1 -> Server, Server -> Peer 1, Peer 2 -> Server, Server -> Peer 2 没有问题。

在我看来，Peer 1 似乎不会接受来自另一个 IP 地址的消息，而不是服务器。

下面的代码相当基本，但可能会告诉我哪里出错了。如果有人能帮忙，我将不胜感激。

同行 1

static void Main(string[] args)
    {
        int command = 0;
        Random r = new Random();
        while (true)
        {
            UdpClient client = new UdpClient();
            IPEndPoint serverEndpoint = new IPEndPoint(IPAddress.Parse("xxx.xxx.xxx.xxx"), 8924);
            client.Connect(serverEndpoint);
            client.Send(BitConverter.GetBytes(command), 1);
            Task.Run(() => {
                byte[] data = client.Receive(ref serverEndpoint);
                Console.WriteLine(ASCIIEncoding.ASCII.GetString(data));
                Console.ReadLine();
            });
            Console.WriteLine("sleep");
            Thread.Sleep(30000);
            Console.WriteLine("resume");

        }

    }

同行 2

static void Main(string[] args)
    {
        while (true)
        {
            Console.WriteLine("press enter to start");
            Console.ReadLine();
            UdpClient getDetailsClient = new UdpClient();
            IPEndPoint getDetailsEndpoint = new IPEndPoint(IPAddress.Parse("xxx.xxx.xxx.xxx"), 8924);
            getDetailsClient.Connect(getDetailsEndpoint);
            getDetailsClient.Send(BitConverter.GetBytes(1), 1);
            byte[] details = getDetailsClient.Receive(ref getDetailsEndpoint);
            byte[] bIp = new byte[15];
            int port = BitConverter.ToInt32(details, 0);
            Array.Copy(details, 4, bIp, 0, 15);
            string Ip = ASCIIEncoding.ASCII.GetString(bIp).Trim();
            Console.WriteLine($"Address: {Ip} \tPort: {port}");
            UdpClient peerClient = new UdpClient();
            IPEndPoint endpointClient = new IPEndPoint(IPAddress.Parse(Ip), port);
            peerClient.Connect(endpointClient);
            peerClient.Send(ASCIIEncoding.ASCII.GetBytes("test"), 4);
            Console.ReadLine();
        }

    }

服务器

static void Main(string[] args)
    {
        int port =  8924;
        IPEndPoint remote = new IPEndPoint(IPAddress.Any, port);
        byte command;

        UdpClient server = new UdpClient(port);
        while(true)
        {
            //Wait on connection from client                
            var data = server.Receive(ref remote);
            //get command
            command = data[0];
            switch(command)
            {
                case (byte)0:
                    updateDatabase(ref server, ref remote);
                    break;
                case (byte)1:
                    readDatabase(ref server, ref remote);
                    break;
                default:
                    break;
            }

        }

    }

    private static void updateDatabase(ref UdpClient server, ref IPEndPoint remote)
    {
        Console.WriteLine("Write Command");
        using (dbDataContext db = new dbDataContext())
        {
            ConnectionTB tb = db.ConnectionTBs
                .Where(t => t.UniqueIdentifier.Trim().Equals("123456789"))
                .Select(t => t)
                .FirstOrDefault();
            tb.Port = remote.Port;
            tb.IPAddress = remote.Address.ToString();
            tb.LastPing = DateTime.Now;
            db.SubmitChanges();
            server.Send(ASCIIEncoding.ASCII.GetBytes(remote.Address.ToString().PadRight(15)),15,remote);
        }
    }

    private static void readDatabase(ref UdpClient server, ref IPEndPoint remote)
    {
        Console.WriteLine("Read Command");
        using (dbDataContext db = new dbDataContext())
        {
            ConnectionTB  p = db.ConnectionTBs
                .Where(c => c.UniqueIdentifier.Trim().Equals("123456789"))
                .Select(c => c)
                .FirstOrDefault();

            int port = p.Port.Value;
            string ip = p.IPAddress.Trim();
            byte[] data = new byte[19];
            byte[] bPort = BitConverter.GetBytes(port);
            byte[] bIp = ASCIIEncoding.ASCII.GetBytes(p.IPAddress.PadRight(15));

            Array.Copy(bPort, 0, data, 0, 4);
            Array.Copy(bIp, 0, data, 4, 15);
            server.Send(data, 19, remote);
        }
    }

Answer 1

@user_ABCD - 事实证明你是对的。如果我使用 Sockets 而不是 UDPCLient，我可以“SendTo(EndPoint)”而不进行绑定，这使我可以更改下一次发送的 IP 地址/端口，并且一切正常。

谢谢。