.NET 6下UDP Multicast数据无法被客户端接收的技术问询

问题描述 #

客户端无法接收UDP组播数据，Wireshark、windump等工具可捕获到组播包，端口已开放且防火墙已禁用。原.NET 4下正常运行的代码迁移至.NET 6后完全失效，即便照搬旧代码也无法工作，推测是.NET版本变更导致组播机制变化。

运行环境 #

各版本Windows系统

相关代码 #

using System;
using System.Net.Sockets;
using System.Net;
using Easy.Logger.Interfaces;
using Easy.Logger;
using MktSrvcAPI.Sockets;
using RBClients.SprdClient;

namespace SpreadFeedPubSub.DAL
{
    public class MulticastEndpoint
    {
        private static readonly IEasyLogger log = Log4NetService.Instance.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);

        public int AssociatedFilterId { get; private set; }
        public string AssociatedFilterName { get; private set; }
        public IPAddress Address { get; private set; }
        public int Port { get; private set; }
        private IPEndPoint _remoteEndpoint;
        public Socket MulticastClient { get; private set; }
        public ByteBuffer Buffer { get; private set; }
        public string Protocol { get; private set; }

        private int _maxBufferSize;

        public MulticastEndpoint(string ip, int port, int associatedFilter = -1, int bufferSize = 2048)
        {
            Address = IPAddress.Parse(ip);
            Port = port;
            _remoteEndpoint = new IPEndPoint(Address, Port);
            _maxBufferSize = Math.Min(bufferSize, 2048);
            Buffer = new ByteBuffer(_maxBufferSize);
            AssociatedFilterId = associatedFilter;
        }

        public void SendData(Message data)
        {
            if (data == null)
            {
                return;
            }
            lock (Buffer)
            {
                if (Buffer.UnusedLength < data.Length)
                {
                    SendBuffer();
                }
                Buffer.Append(data.Bytes, 0, data.Length);
            }
        }

        public void SendBuffer()
        {
            if (Buffer.SIZE == Buffer.UnusedLength)
            {
                return;
            }
            MulticastClient.SendTo(Buffer.DATA, _remoteEndpoint);
            Buffer.Clear();
        }

        public void Close()
        {
            try
            {
                MulticastClient.Close();
                MulticastClient.Dispose();
            }
            catch (Exception ex)
            {
                //log.Error($"StartConnection {IP}:{Port} - " + ex.ToString());
            }
        }

        public void Create()
        {
            try
            {
                MulticastClient = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
                MulticastClient.ExclusiveAddressUse = false;
                MulticastClient.EnableBroadcast = true;
                MulticastClient.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership, new MulticastOption(Address, Program.IFACE_HOST));
                MulticastClient.Bind(new IPEndPoint(Program.IFACE_HOST, Port));
            }
            catch (SocketException se)
            {
                //log.Error($"StartConnection {IP}:{Port} - " + se.ToString());
                if (se.ErrorCode == 10048)
                {
                    log.Error("Socket already being used.");
                }
                throw (se);
            }
            catch (Exception ex)
            {
                //log.Error($"StartConnection {IP}:{Port} - " + ex.ToString());
                throw (ex);
            }
        }
    }
}

已尝试方案 #

• 使用UdpClient，配置JoinMulticast、ExclusiveAddressUse=false、EnableBroadcast=true，向目标端点发送数据
• 使用Socket，尝试开关ExclusiveAddressUse、EnableBroadcast选项，尝试绑定/不绑定端口

解决思路与修正方案 #

.NET 6对Socket组播配置的顺序要求更严格，原代码先添加组播成员再绑定端口的逻辑在新版本下会失效，正确的流程是先绑定端口，再加入组播组。同时需要确保绑定地址和组播选项的配置匹配网卡。

修正后的Create方法 #

public void Create()
{
    try
    {
        MulticastClient = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
        // 禁用独占地址，允许多进程绑定同一端口
        MulticastClient.ExclusiveAddressUse = false;
        // 先绑定端口：绑定0.0.0.0监听所有网卡，也可指定Program.IFACE_HOST
        MulticastClient.Bind(new IPEndPoint(IPAddress.Any, Port));
        // 再加入组播组，指定本地网卡地址
        MulticastClient.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership, 
            new MulticastOption(Address, Program.IFACE_HOST));
        // 可选：设置组播超时与回环，避免残留组播条目
        MulticastClient.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.MulticastTimeToLive, 1);
        MulticastClient.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.MulticastLoopback, false);
    }
    catch (SocketException se)
    {
        log.Error($"创建组播端点失败 {Address}:{Port} - {se.ToString()}");
        if (se.ErrorCode == 10048)
        {
            log.Error("端口已被占用");
        }
        throw;
    }
    catch (Exception ex)
    {
        log.Error($"创建组播端点失败 {Address}:{Port} - {ex.ToString()}");
        throw;
    }
}

额外注意事项 #

1. 接收逻辑验证：确保存在完整的接收逻辑（原代码仅展示发送部分），可使用ReceiveFrom或异步方法接收数据，且缓冲区大小足够容纳组播包
2. UdpClient的正确用法：若使用UdpClient，同样需先绑定再加入组播组

   using var udpClient = new UdpClient();
   udpClient.ExclusiveAddressUse = false;
   udpClient.Client.Bind(new IPEndPoint(IPAddress.Any, Port));
   udpClient.JoinMulticastGroup(Address, Program.IFACE_HOST);
   // 接收数据
   var result = await udpClient.ReceiveAsync();
   

3. 网卡地址正确性：确认Program.IFACE_HOST是有效本地网卡IPv4地址，避免使用回环地址（127.0.0.1）接收跨网卡组播

内容的提问来源于stack exchange，提问作者Mike