UDP在同一进程中的两个套接字之间的组播

Question

我正在为处理UDP多播通信的类写入一些测试。 我设计了测试，使用回送接口（127.0.0.1）进行测试，因为我不希望它们干扰网络上的其他程序/设备。

以我“的单元测试”我有一个测试插座销连接给定多播组并结合到127.0.0.1和发送 套接字还加入了相同的多播组并结合到127.0.0.1，二者当然在相同的过程。

为了确保消息已发送，我有另一个测试程序（也是另一个进程），它也加入了多播组并输出发送给它的所有内容。

问题是我的测试套接字永远不会收到发送者发送的内容，但测试程序（所以另一个进程）收到它。

组合多个套接字/多播/本地主机是否存在一些限制？

新的信息：

我的错误是考虑到UDP在localhost上可能是可靠的。下面的测试程序显示，第一个UDP数据包从来没有被我的侦听套接字（至少在我的计算机上）接收（但其他进程仍然收到它）。

在我的单元测试中，我正在发送一个数据包，并希望得到具体的答案：我无法负担发送消息两次并只接收一次答案。

如果我在发送第一个数据包之前等待第一个接收超时，它似乎可以可靠地工作。

有没有人有一个想法，为什么第一个UDP数据包永远不会到达？

下面是我在试验中使用的代码：

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 
using System.Net; 
using System.Net.Sockets; 
using System.Threading; 
using NUnit.Framework; 

namespace MulticastTest 
{ 
    [TestFixture] 
    public class Program 
    { 
     static void Main(string[] args) 
     { 
      new Program().Run(); 
      Console.WriteLine("Press any key to exit..."); 
      Console.ReadKey(); 
     } 

    [Test] 
    public void Run() 
    { 
     _waitFirstReadTiemout = new AutoResetEvent(false); 
     IPAddress lMulticastAddress = new IPAddress(0xFAFFFFEF); 
     IPEndPoint lRemoteEndPoint = new IPEndPoint(lMulticastAddress, 1900); 

     // Create sender socket 
     Socket lSendSocket = new Socket(AddressFamily.InterNetwork, 
          SocketType.Dgram, 
          ProtocolType.Udp); 

     // Allow to share the port 1900 with other applications 
     lSendSocket.SetSocketOption(SocketOptionLevel.Socket, 
           SocketOptionName.ReuseAddress, 
           true); 

     // Set TTL for multicast packets: socket needs to be bounded to do this 
     lSendSocket.SetSocketOption(SocketOptionLevel.IP, 
           SocketOptionName.MulticastTimeToLive, 
           2); 

     // Bind the socket to the local end point: this MUST be done before joining the multicast group 
     lSendSocket.Bind(new IPEndPoint(IPAddress.Loopback, 55236)); 

     // Join the multicast group 
     lSendSocket.SetSocketOption(SocketOptionLevel.IP, 
         SocketOptionName.MulticastLoopback, 
         true); 

     lSendSocket.SetSocketOption(SocketOptionLevel.IP, 
           SocketOptionName.AddMembership, 
           new MulticastOption(lMulticastAddress)); 

     // Create receiver and start its thread 
     Thread lReceiveThread = new Thread(ReceiveThread); 
     lReceiveThread.Start(); 

     int i = 0; 
     while (!fStop) 
     { 
      if (i == 0) 
       _waitFirstReadTiemout.WaitOne(10000); 

      byte[] lToSend = Encoding.ASCII.GetBytes(DateTime.Now.ToString("yyyyMMdd HHmmss")); 
      lSendSocket.SendTo(lToSend, lRemoteEndPoint); 
      Console.WriteLine("Sent #" + (i + 1) + ": " + DateTime.Now.ToString("yyyyMMdd HHmmss")); 
      Thread.Sleep(1000); 
      try 
      { 
       if (Console.KeyAvailable || i >= 10) 
        fStop = true; 
      } 
      catch (InvalidOperationException) 
      { 
       fStop = i >= 10; 
      } 
      finally 
      { 
       ++i; 
      } 
     } 
    } 

    private AutoResetEvent _waitFirstReadTiemout; 

    private bool fStop; 

    private void ReceiveThread() 
    { 
     Socket lSocket = new Socket(AddressFamily.InterNetwork, 
            SocketType.Dgram, 
            ProtocolType.Udp); 

     // Allow to share the port 1900 with other applications 
     lSocket.SetSocketOption(SocketOptionLevel.Socket, 
           SocketOptionName.ReuseAddress, 
           true); 

     // TTL not required here: we will only LISTEN on the multicast socket 
     // Bind the socket to the local end point: this MUST be done before joining the multicast group 
     lSocket.Bind(new IPEndPoint(IPAddress.Loopback, 1900)); 

     // Join the multicast group 

     // If the local IP is a loopback one, enable multicast loopback 
     lSocket.SetSocketOption(SocketOptionLevel.IP, 
        SocketOptionName.MulticastLoopback, 
        true); 

     lSocket.SetSocketOption(SocketOptionLevel.IP, 
           SocketOptionName.AddMembership, 
           new MulticastOption(
             new IPAddress(0xFAFFFFEF))); 

     lSocket.ReceiveTimeout = 1000; 

     byte[] lBuffer = new byte[65000]; 
     int i = 0; 
     while (!fStop) 
     { 
      try 
      { 
       int lReceived = lSocket.Receive(lBuffer); 
       ++i; 
       Console.WriteLine("Received #" + i + ": " + Encoding.ASCII.GetString(lBuffer, 0, lReceived)); 
      } 
      catch (SocketException se) 
      { 
       _waitFirstReadTiemout.Set(); 
       Console.WriteLine(se.ToString()); 
      } 
     } 
    } 
} 

}

Answer 1

这很可能是您的发送和接收线程之间的竞赛 - 您在接收方加入组之前发送第一个数据包。这解释了为什么它在超时时间内工作。

Answer 2

您可能需要启用插槽上的环回模式。