欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

如何應(yīng)用C#實(shí)現(xiàn)UDP的分包組包

 更新時(shí)間:2013年04月18日 11:10:37   作者:  
本篇文章小編將為大家介紹,如何應(yīng)用C#實(shí)現(xiàn)UDP的分包組包。需要的朋友參考下

場景介紹
如果需要使用UDP傳輸較大數(shù)據(jù),例如傳輸10M的圖片,這突破了UDP的設(shè)計(jì)原則。UDP的設(shè)計(jì)是基于"datagram",也就是它假設(shè)你發(fā)送的每個數(shù)據(jù)包都能包含在單一的包內(nèi)。并且設(shè)定UDP數(shù)據(jù)包的最大長度受基礎(chǔ)網(wǎng)絡(luò)協(xié)議的限制。

UDP數(shù)據(jù)包的理論最大長度限制是 65535 bytes,這包含 8 bytes 數(shù)據(jù)包頭和 65527 bytes 數(shù)據(jù)。但如果基于IPv4網(wǎng)絡(luò)傳輸,則還需減去 20 bytes 的IP數(shù)據(jù)包頭。
則單一的UDP數(shù)據(jù)包可傳輸?shù)臄?shù)據(jù)最大長度為:

則單一的UDP數(shù)據(jù)包可傳輸?shù)臄?shù)據(jù)最大長度為:

MaxUdpDataLength = 65535 - 8 - 20 = 65507 bytes

這就需要實(shí)現(xiàn)UDP包的分包傳輸和接收組包功能。

分包功能

復(fù)制代碼 代碼如下:

/// <summary>
   /// UDP數(shù)據(jù)包分割器
   /// </summary>
   public static class UdpPacketSplitter
   {
     /// <summary>
     /// 分割UDP數(shù)據(jù)包
     /// </summary>
     /// <param name="sequence">UDP數(shù)據(jù)包所持有的序號</param>
     /// <param name="datagram">被分割的UDP數(shù)據(jù)包</param>
     /// <param name="chunkLength">分割塊的長度</param>
     /// <returns>
     /// 分割后的UDP數(shù)據(jù)包列表
     /// </returns>
     public static ICollection<UdpPacket> Split(long sequence, byte[] datagram, int chunkLength)
     {
       if (datagram == null)
         throw new ArgumentNullException("datagram");

       List<UdpPacket> packets = new List<UdpPacket>();

       int chunks = datagram.Length / chunkLength;
       int remainder = datagram.Length % chunkLength;
       int total = chunks;
       if (remainder > 0) total++;

       for (int i = 1; i <= chunks; i++)
       {
         byte[] chunk = new byte[chunkLength];
         Buffer.BlockCopy(datagram, (i - 1) * chunkLength, chunk, 0, chunkLength);
         packets.Add(new UdpPacket(sequence, total, i, chunk, chunkLength));
       }
       if (remainder > 0)
       {
         int length = datagram.Length - (chunkLength * chunks);
         byte[] chunk = new byte[length];
         Buffer.BlockCopy(datagram, chunkLength * chunks, chunk, 0, length);
         packets.Add(new UdpPacket(sequence, total, total, chunk, length));
       }

       return packets;
     }
   }

發(fā)送分包
復(fù)制代碼 代碼如下:

private void WorkThread()
 {
   while (IsRunning)
   {
     waiter.WaitOne();
     waiter.Reset();

     while (queue.Count > 0)
     {
       StreamPacket packet = null;
       if (queue.TryDequeue(out packet))
       {
         RtpPacket rtpPacket = RtpPacket.FromImage(
           RtpPayloadType.JPEG,
           packet.SequenceNumber,
           (long)Epoch.GetDateTimeTotalMillisecondsByYesterday(packet.Timestamp),
           packet.Frame);

         // max UDP packet length limited to 65,535 bytes
         byte[] datagram = rtpPacket.ToArray();
         packet.Frame.Dispose();

         // split udp packet to many packets
         // to reduce the size to 65507 limit by underlying IPv4 protocol
         ICollection<UdpPacket> udpPackets
           = UdpPacketSplitter.Split(
             packet.SequenceNumber,
             datagram,
             65507 - UdpPacket.HeaderSize);
         foreach (var udpPacket in udpPackets)
         {
           byte[] udpPacketDatagram = udpPacket.ToArray();
           // async sending
           udpClient.BeginSend(
             udpPacketDatagram, udpPacketDatagram.Length,
             packet.Destination.Address,
             packet.Destination.Port,
             SendCompleted, udpClient);
         }
       }
     }
   }
 }

接收組包功能
復(fù)制代碼 代碼如下:

private void OnDatagramReceived(object sender, UdpDatagramReceivedEventArgs<byte[]> e)
     {
       try
       {
         UdpPacket udpPacket = UdpPacket.FromArray(e.Datagram);

         if (udpPacket.Total == 1)
         {
           RtpPacket packet = new RtpPacket(udpPacket.Payload, udpPacket.PayloadSize);
           Bitmap bitmap = packet.ToBitmap();
           RaiseNewFrameEvent(
             bitmap, Epoch.GetDateTimeByYesterdayTotalMilliseconds(packet.Timestamp));
         }
         else
         {
           // rearrange packets to one packet
           if (packetCache.ContainsKey(udpPacket.Sequence))
           {
             List<UdpPacket> udpPackets = null;
             if (packetCache.TryGetValue(udpPacket.Sequence, out udpPackets))
             {
               udpPackets.Add(udpPacket);

               if (udpPackets.Count == udpPacket.Total)
               {
                 packetCache.TryRemove(udpPacket.Sequence, out udpPackets);

                 udpPackets = udpPackets.OrderBy(u => u.Order).ToList();
                 int rtpPacketLength = udpPackets.Sum(u => u.PayloadSize);
                 int maxPacketLength = udpPackets.Select(u => u.PayloadSize).Max();

                 byte[] rtpPacket = new byte[rtpPacketLength];
                 foreach (var item in udpPackets)
                 {
                   Buffer.BlockCopy(
                     item.Payload, 0, rtpPacket,
                     (item.Order - 1) * maxPacketLength, item.PayloadSize);
                 }

                 RtpPacket packet = new RtpPacket(rtpPacket, rtpPacket.Length);
                 Bitmap bitmap = packet.ToBitmap();
                 RaiseNewFrameEvent(
                   bitmap,
                   Epoch.GetDateTimeByYesterdayTotalMilliseconds(packet.Timestamp));

                 packetCache.Clear();
               }
             }
           }
           else
           {
             List<UdpPacket> udpPackets = new List<UdpPacket>();
             udpPackets.Add(udpPacket);
             packetCache.AddOrUpdate(
               udpPacket.Sequence,
               udpPackets, (k, v) => { return udpPackets; });
           }
         }
       }
       catch (Exception ex)
       {
         RaiseVideoSourceExceptionEvent(ex.Message);
       }
     }

相關(guān)文章

  • Unity實(shí)現(xiàn)虛擬鍵盤

    Unity實(shí)現(xiàn)虛擬鍵盤

    這篇文章主要為大家詳細(xì)介紹了Unity實(shí)現(xiàn)虛擬鍵盤,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2021-03-03
  • C#中的Task.WaitAll和Task.WaitAny方法介紹

    C#中的Task.WaitAll和Task.WaitAny方法介紹

    這篇文章介紹了C#中的Task.WaitAll和Task.WaitAny方法,文中通過示例代碼介紹的非常詳細(xì)。對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2022-04-04
  • C#使用文件流FileStream和內(nèi)存流MemoryStream操作底層字節(jié)數(shù)組byte[]

    C#使用文件流FileStream和內(nèi)存流MemoryStream操作底層字節(jié)數(shù)組byte[]

    這篇文章介紹了C#使用文件流FileStream和內(nèi)存流MemoryStream操作底層字節(jié)數(shù)組byte[]的方法,文中通過示例代碼介紹的非常詳細(xì)。對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2022-05-05
  • c#語言使用Unity粒子系統(tǒng)制作手雷爆炸

    c#語言使用Unity粒子系統(tǒng)制作手雷爆炸

    這篇文章主要為大家介紹了Unity的粒子系統(tǒng)由粒子發(fā)射器、粒子動畫器、粒子渲染器組成,通過使用一或兩個紋理多次繪制,創(chuàng)造一個混沌的效果,通過復(fù)習(xí)粒子系統(tǒng)做一個手雷和實(shí)彈投擲現(xiàn)場
    2022-04-04
  • 詳解WPF中的對象資源

    詳解WPF中的對象資源

    這篇文章主要介紹了WPF中對象資源的相關(guān)資料,幫助大家更好的理解和學(xué)習(xí)使用WPF,感興趣的朋友可以了解下
    2021-04-04
  • Unity3D舊電視濾鏡shader的實(shí)現(xiàn)示例

    Unity3D舊電視濾鏡shader的實(shí)現(xiàn)示例

    這篇文章主要介紹了Unity3D舊電視濾鏡shader的實(shí)現(xiàn)示例,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2021-04-04
  • c# Process.Start()找不到系統(tǒng)文件的解決方法

    c# Process.Start()找不到系統(tǒng)文件的解決方法

    vs1027在X64應(yīng)用程序下執(zhí)行process.start()時(shí),OK;但是在X86應(yīng)用程序下執(zhí)行process.start(),報(bào)錯:找不到系統(tǒng)文件,本文就詳細(xì)的介紹一下解決方法,感興趣的可以了解一下
    2023-09-09
  • C#的Socket實(shí)現(xiàn)UDP協(xié)議通信示例代碼

    C#的Socket實(shí)現(xiàn)UDP協(xié)議通信示例代碼

    本篇文章主要介紹了C#的Socket實(shí)現(xiàn)UDP協(xié)議通信示例代碼,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-01-01
  • 基于params,ref,out的參數(shù)問題詳解

    基于params,ref,out的參數(shù)問題詳解

    本篇文章是對params,ref,out的參數(shù)問題進(jìn)行了詳細(xì)的分析介紹,需要的朋友參考下
    2013-06-06
  • C#實(shí)現(xiàn)Excel合并單元格數(shù)據(jù)導(dǎo)入數(shù)據(jù)集詳解

    C#實(shí)現(xiàn)Excel合并單元格數(shù)據(jù)導(dǎo)入數(shù)據(jù)集詳解

    這篇文章主要為大家詳細(xì)介紹了C#如何實(shí)現(xiàn)Excel合并單元格數(shù)據(jù)導(dǎo)入數(shù)據(jù)集,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下
    2024-01-01

最新評論