如何在 C# (IGMPv3) 中加入源特定的多播组答案

【问题标题】：How to join source specific multicast group in C# (IGMPv3)如何在 C# (IGMPv3) 中加入源特定的多播组
【发布时间】：2011-02-28 18:10:21
【问题描述】：

我们有一个可以加入多播组并从多播组接收数据的 C# 应用程序。这很好用。我们现在希望支持 IGMPv3 并能够在加入多播组时指定源的 IP。从 MSDN 文档中，我看不到如何执行此操作。我发现以下链接似乎可以回答我的问题。

http://social.msdn.microsoft.com/Forums/en/netfxnetcom/thread/e8063f6d-22f5-445e-a00c-bf46b46c1561

我是这样实现的：

byte[] membershipAddresses = new byte[12]; // 3 IPs * 4 bytes (IPv4)
Buffer.BlockCopy(multicastIp.GetAddressBytes(), 0, membershipAddresses, 0, 4);
Buffer.BlockCopy(sourceIp.GetAddressBytes(), 0, membershipAddresses, 4, 4);
Buffer.BlockCopy(localIp.GetAddressBytes(), 0, membershipAddresses, 8, 4);
socket.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership, membershipAddresses);

但是在调用 SetSocketOption() 时出现 SocketException 错误：The requested address is not valid in its context。

有人可以指出我在这里做错了什么吗？谢谢！

【问题讨论】：

正如 Steve-O 所指出的，SocketOptionName 应该是 AddSourceMembership 而不是 AddMembership。

标签： c# sockets multicast igmp

【解决方案1】：

链接显示SocketOptionName.AddSourceMembership，您使用的是AddMembership。

【讨论】：

Doh...你是对的。使用AddSourceMembership 而不是AddMembership，代码可以工作。谢谢！

【解决方案2】：

对于任何在源多播方面苦苦挣扎的人

static void StartListner(IPAddress sourceIp, IPAddress multicastGroupIp, IPAddress localIp, int port)
{
    Task.Run(() =>
    {
        try
        {
            Console.WriteLine("Starting: "  + sourceIp + " - " + multicastGroupIp + " - " + localIp + " / " + port);

            Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);

            IPEndPoint localEndpoint = new IPEndPoint(localIp, port);
            socket.Bind(localEndpoint);

            byte[] membershipAddresses = new byte[12]; // 3 IPs * 4 bytes (IPv4)
            Buffer.BlockCopy(multicastGroupIp.GetAddressBytes(), 0, membershipAddresses, 0, 4);
            Buffer.BlockCopy(sourceIp.GetAddressBytes(), 0, membershipAddresses, 4, 4);
            Buffer.BlockCopy(localIp.GetAddressBytes(), 0, membershipAddresses, 8, 4);
            socket.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddSourceMembership, membershipAddresses);

            while (true)
            {
                byte[] b = new byte[1024];
                int length = socket.Receive(b);

                Console.WriteLine("PORT: " + port + " : " + Encoding.ASCII.GetString(b, 0, length));
            }
        }
        catch (Exception e)
        {
            Console.WriteLine(e.Message);
        }
    });
}

【讨论】：