说明

UDP组播。

组播使用

组播使用非常简单，

  1. 配置中启用广播UseBroadcast重要
  2. 在UdpSession启动后。调用JoinMulticastGroup即可加入组播。调用DropMulticastGroup，退出组播。

下列示例使用的是UdpPackageAdapter适配器，如果是普通udp接受端，请使用NormalUdpDataHandlingAdapter适配器。

  1. private static void TestUdpMulticastGroup()
  2. {
  3.     IPEndPoint multicast = new IPEndPoint(IPAddress.Parse("224.5.6.7"), 7788);
  5.     UdpSession mainUdpSession = new UdpSession();
  6.     mainUdpSession.SetDataHandlingAdapter(new UdpPackageAdapter());
  7.     //udpSession.SetDataHandlingAdapter(new NormalUdpDataHandlingAdapter());
  9.     mainUdpSession.Setup(new RRQMConfig()
  10.         .SetBindIPHost(new IPHost(7789))
  11.         .SetThreadCount(1)
  12.         .UseBroadcast()                
  13.         .SetBufferLength(1024 * 64))
  14.         .Start();
  16.     mainUdpSession.JoinMulticastGroup(IPAddress.Parse("224.5.6.7"));
  19.     UdpSession multicastUdpSession = new UdpSession();
  20.     multicastUdpSession.SetDataHandlingAdapter(new UdpPackageAdapter());
  21.     //udpSession.SetDataHandlingAdapter(new NormalUdpDataHandlingAdapter());
  23.     int count = 0;
  24.     multicastUdpSession.Received += (remote, byteBlock, requestInfo) =>
  25.     {
  26.         Console.WriteLine(byteBlock.ToString());
  27.         count++;
  28.         if (count==5)
  29.         {
  30.             multicastUdpSession.DropMulticastGroup(IPAddress.Parse("224.5.6.7"));
  31.         }
  32.     };
  34.     multicastUdpSession.Setup(new RRQMConfig()
  35.         .SetBindIPHost(new IPHost(7788))
  36.         .SetThreadCount(1)
  37.         .SetBufferLength(1024 * 64))
  38.         .Start();
  40.     multicastUdpSession.JoinMulticastGroup(IPAddress.Parse("224.5.6.7"));
  42.     while (true)
  43.     {
  44.         mainUdpSession.Send(multicast,Encoding.UTF8.GetBytes("RRQM"));
  45.         Thread.Sleep(1000);
  46.     }
  47. }

广播

广播的使用也非常简单，仅仅需要将发送的目的地址设置为255.255.255.255即可。此处可通过IPEndPoint实现，也可以通过IPHost实现。