网络编程 - 无论我做什么，C# UdpClient.Receive() 都无法使用多播

本文关键字：多播 Receive 什么 网络编程 UdpClient | 更新日期: 2023-09-27 17:56:35

过去试图单独解决这个问题，我什至不知道，但谷歌搜索在这里对我有帮助，我需要一些建议。我每 10 秒从本地网络上的另一台 PC 接收一次 UDP 数据包，可以在 wireshark 中看到它们，但应用程序卡在 udpClient.Receive（） 行上。组播组和端口是正确的值，在 main（） n+1 中检查。如果您有任何可能有帮助的想法，请提出解决方案。谢谢。

（我正在尝试接收服务器的信息，以便应用程序可以自动开始通过TCP进行通信）

class MulticastListener {
    private UdpClient udpClient;
    private IPEndPoint remoteEndPoint;
    IPAddress multicastIP;
    private int port;
    public MulticastListener(ref IPAddress multicastIP, int port) {
        remoteEndPoint = new IPEndPoint(IPAddress.Any, port);
        this.multicastIP = multicastIP;
        this.port = port;
        udpClient = new UdpClient();
        udpClient.Client.Bind(remoteEndPoint);
    }
    public IPEndPoint GetServer() {
        try {
            udpClient.JoinMulticastGroup(multicastIP);
        } catch (ObjectDisposedException e) {
            Console.WriteLine("ERROR: The underlying socket has been closed!");
        } catch (SocketException e) {
            Console.WriteLine("ERROR: An error occurred when accessing the socket!");
        } catch (ArgumentException e) {
            Console.WriteLine("ERROR: The IP address is not compatible with the AddressFamily value that defines the addressing scheme of the socket!");
        }
        Byte[] serverInfoBytes = udpClient.Receive(ref remoteEndPoint);
        Stream stream = new MemoryStream(serverInfoBytes); //receives a serialised IPEndpoint object
        BinaryFormatter formatter = new BinaryFormatter();
        udpClient.Close();
        return (IPEndPoint)formatter.Deserialize(stream);
    }
}

网络编程 - 无论我做什么，C# UdpClient.Receive() 都无法使用多播

正如我评论的那样，您的代码对我来说 100% 按原样工作正常。我会检查您是否在接收的同一子网上发送。也许您的发件人未配置正确的界面？

也许尝试不同的发件人会有所帮助，这是我用来测试的：

    static void Main(string[] args)
    {
        //Configuration
        var interfaceIp = IPAddress.Parse("192.168.9.121");
        var interfaceEndPoint = new IPEndPoint(interfaceIp, 60001);
        var multicastIp = IPAddress.Parse("230.230.230.230");
        var multicastEndPoint = new IPEndPoint(multicastIp, 60001);
        //initialize the socket
        var socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
        socket.ExclusiveAddressUse = false;
        socket.MulticastLoopback = false;
        socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, 1);
        MulticastOption option = new MulticastOption(multicastEndPoint.Address, interfaceIp);
        socket.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership, option);
        //bind on a network interface
        socket.Bind(interfaceEndPoint);
        //initialize args for sending packet on the multicast channel
        var sockArgs = new SocketAsyncEventArgs();
        sockArgs.RemoteEndPoint = multicastEndPoint;
        sockArgs.SetBuffer(new byte[1234], 0, 1234);
        //send an empty packet of size 1234 every 3 seconds
        while (true)
        {
            socket.SendToAsync(sockArgs);
            Thread.Sleep(3000);
        }
    }
相关文章：