c#udp无法接收

Question

我已经在互联网上搜索了一两个星期，想找到一个UDP客户端程序，它可以同时发送和接收数据，但是对于c#来说，没有关于这个主题的内容。在过去的几天里，我尝试创建一个UDP客户端，其中包含一个接收数据的线程。

发送UDP数据包效果很好，但程序无法接收我发送到的服务器，我相信服务器正在将所有数据包发送到不同的端口。

我如何修复这个程序？

有没有一种更简单的方法来进行UDP编程，比如用于TCP的StreamReader和StreamWriter？

    static void CONNECTudp()
    {
        Console.WriteLine("Host:");
        IPAddress ipAddress = Dns.Resolve(Console.ReadLine()).AddressList[0];
        Console.WriteLine("Port:");
        int Port = int.Parse(Console.ReadLine());
        IPEndPoint ipEndPoint = new IPEndPoint(ipAddress, Port);
        Thread UDPthread = new Thread(() => CONNECTudpthread(ipEndPoint));
        UDPthread.Start();
        UdpClient udp = new UdpClient();
        do
        {
            Byte[] sendBytes = Encoding.ASCII.GetBytes(Console.ReadLine());
            udp.Send(sendBytes, sendBytes.Length, ipEndPoint);
        } while (true);
    }

    static void CONNECTudpthread(IPEndPoint ipEndPoint)
    {
        UdpClient udp = new UdpClient();
        do
        {
            try
            {
                Byte[] receiveBytes = udp.Receive(ref ipEndPoint);

                string returnData = Encoding.ASCII.GetString(receiveBytes);
                Console.WriteLine(returnData);
            }
            catch (Exception)
            {
            }
        } while (true);
    }

Answer 1

因为UDP是面向消息的，而不是面向流的，所以在UDP中使用StreamReader和StreamWriter并不是一种切实可行的方法。坚持使用示例中的面向消息的I/O是最好的。

代码中的问题是您正在使用两个不同的UdpClient实例来发送和接收。您没有显示UDP服务器代码，所以我也不能保证这是正确的。但是如果是这样，那么如果你把你的代码修复成更像下面这样的东西，它应该可以工作：

static void CONNECTudp()
{
    Console.WriteLine("Host:");
    IPAddress ipAddress = Dns.Resolve(Console.ReadLine()).AddressList[0];
    Console.WriteLine("Port:");
    int Port = int.Parse(Console.ReadLine());
    IPEndPoint ipEndPoint = new IPEndPoint(ipAddress, Port);

    // Bind port immediately
    UdpClient udp = new UdpClient(0);

    // Pass UdpClient instance to the thread
    Thread UDPthread = new Thread(() => CONNECTudpthread(udp));
    UDPthread.Start();
    do
    {
        Byte[] sendBytes = Encoding.ASCII.GetBytes(Console.ReadLine());
        udp.Send(sendBytes, sendBytes.Length, ipEndPoint);
    } while (true);
}

static void CONNECTudpthread(UdpClient udp)
{
    do
    {
        try
        {
            // Though it's a "ref", the "remoteEP" argument is really just
            // for returning the address of the sender.
            IPEndPoint ipEndPoint = new IPEndPoint(IPAddress.Any, 0);
            Byte[] receiveBytes = udp.Receive(ref ipEndPoint);

            string returnData = Encoding.ASCII.GetString(receiveBytes);
            Console.WriteLine(returnData);
        }
        catch (Exception)
        {
        }
    } while (true);
}