当前位置:  编程技术>.net/c#/asp.net

使用C#实现RTP数据包传输 参照RFC3550

    来源: 互联网  发布时间:2014-10-18

    本文导语:  闲暇时折腾IP网络视频监控系统,需要支持视频帧数据包在网络内的传输。未采用H.264或MPEG4等编码压缩方式,直接使用Bitmap图片。由于对帧的准确到达要求不好,所以采用UDP传输。如果发生网络丢包现象则直接将帧丢弃。为了...

闲暇时折腾IP网络视频监控系统,需要支持视频帧数据包在网络内的传输。
未采用H.264或MPEG4等编码压缩方式,直接使用Bitmap图片。
由于对帧的准确到达要求不好,所以采用UDP传输。如果发生网络丢包现象则直接将帧丢弃。
为了记录数据包的传输顺序和帧的时间戳,所以研究了下RFC3550协议,采用RTP包封装视频帧。
并未全面深究,所以未使用SSRC和CSRC,因为不确切了解其用意。不过目前的实现情况已经足够了。

代码如下:

///
   /// RTP(RFC3550)协议数据包
   ///
   ///
   /// The RTP header has the following format:
   ///  0                   1                   2                   3
   ///  0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
   /// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
   /// |V=2|P|X| CC    |M| PT          | sequence number               |
   /// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
   /// | timestamp                                                     |
   /// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
   /// | synchronization source (SSRC) identifier                      |
   /// +=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+
   /// | contributing source (CSRC) identifiers                        |
   /// | ....                                                          |
   /// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
   ///
   public class RtpPacket
   {
     ///
     /// version (V): 2 bits
     /// RTP版本标识,当前规范定义值为2.
     /// This field identifies the version of RTP. The version defined by this specification is two (2).
     /// (The value 1 is used by the first draft version of RTP and the value 0 is used by the protocol
     /// initially implemented in the vat" audio tool.)
     ///
     public int Version { get { return 2; } }

     ///
     /// padding (P):1 bit
     /// 如果设定padding,在报文的末端就会包含一个或者多个padding 字节,这不属于payload。
     /// 最后一个字节的padding 有一个计数器,标识需要忽略多少个padding 字节(包括自己)。
     /// 一些加密算法可能需要固定块长度的padding,或者是为了在更低层数据单元中携带一些RTP 报文。
     /// If the padding bit is set, the packet contains one or more additional padding octets at the
     /// end which are not part of the payload. The last octet of the padding contains a count of
     /// how many padding octets should be ignored, including itself. Padding may be needed by
     /// some encryption algorithms with fixed block sizes or for carrying several RTP packets in a
     /// lower-layer protocol data unit.
     ///
     public int Padding { get { return 0; } }

     ///
     /// extension (X):1 bit
     /// 如果设定了extension 位,定长头字段后面会有一个头扩展。
     /// If the extension bit is set, the fixed header must be followed by exactly one header extensio.
     ///
     public int Extension { get { return 0; } }

     ///
     /// CSRC count (CC):4 bits
     /// CSRC count 标识了定长头字段中包含的CSRC identifier 的数量。
     /// The CSRC count contains the number of CSRC identifiers that follow the fixed header.
     ///
     public int CC { get { return 0; } }

     ///
     /// marker (M):1 bit
     /// marker 是由一个profile 定义的。用来允许标识在像报文流中界定帧界等的事件。
     /// 一个profile 可能定义了附加的标识位或者通过修改payload type 域中的位数量来指定没有标识位.
     /// The interpretation of the marker is defined by a profile. It is intended to allow significant
     /// events such as frame boundaries to be marked in the packet stream. A profile may define
     /// additional marker bits or specify that there is no marker bit by changing the number of bits
     /// in the payload type field.
     ///
     public int Marker { get { return 0; } }

     ///
     /// payload type (PT):7 bits
     /// 这个字段定一个RTPpayload 的格式和在应用中定义解释。
     /// profile 可能指定一个从payload type 码字到payload format 的默认静态映射。
     /// 也可以通过non-RTP 方法来定义附加的payload type 码字(见第3 章)。
     /// 在 RFC 3551[1]中定义了一系列的默认音视频映射。
     /// 一个RTP 源有可能在会话中改变payload type,但是这个域在复用独立的媒体时是不同的。(见5.2 节)。
     /// 接收者必须忽略它不识别的payload type。
     /// This field identifies the format of the RTP payload and determines its interpretation by the
     /// application. A profile may specify a default static mapping of payload type codes to payload
     /// formats. Additional payload type codes may be defined dynamically through non-RTP means
     /// (see Section 3). A set of default mappings for audio and video is specified in the companion
     /// RFC 3551 [1]. An RTP source may change the payload type during a session, but this field
     /// should not be used for multiplexing separate media streams (see Section 5.2).
     /// A receiver must ignore packets with payload types that it does not understand.
     ///
     public RtpPayloadType PayloadType { get; private set; }

     ///
     /// sequence number:16 bits
     /// 每发送一个RTP 数据报文序列号值加一,接收者也可用来检测丢失的包或者重建报文序列。
     /// 初始的值是随机的,这样就使得known-plaintext 攻击更加困难, 即使源并没有加密(见9。1),
     /// 因为要通过的translator 会做这些事情。关于选择随机数方面的技术见[17]。
     /// The sequence number increments by one for each RTP data packet sent, and may be used
     /// by the receiver to detect packet loss and to restore packet sequence. The initial value of the
     /// sequence number should be random (unpredictable) to make known-plaintext attacks on
     /// encryption more dificult, even if the source itself does not encrypt according to the method
     /// in Section 9.1, because the packets may flow through a translator that does. Techniques for
     /// choosing unpredictable numbers are discussed in [17].
     ///
     public int SequenceNumber { get; private set; }

     ///
     /// timestamp:32 bits
     /// timestamp 反映的是RTP 数据报文中的第一个字段的采样时刻的时间瞬时值。
     /// 采样时间值必须是从恒定的和线性的时间中得到以便于同步和jitter 计算(见第6.4.1 节)。
     /// 必须保证同步和测量保温jitter 到来所需要的时间精度(一帧一个tick 一般情况下是不够的)。
     /// 时钟频率是与payload 所携带的数据格式有关的,在profile 中静态的定义或是在定义格式的payload format 中,
     /// 或通过non-RTP 方法所定义的payload format 中动态的定义。如果RTP 报文周期的生成,就采用虚拟的(nominal)
     /// 采样时钟而不是从系统时钟读数。例如,在固定比特率的音频中,timestamp 时钟会在每个采样周期时加一。
     /// 如果音频应用中从输入设备中读入160 个采样周期的块,the timestamp 就会每一块增加160,
     /// 而不管块是否传输了或是丢弃了。
     /// 对于序列号来说,timestamp 初始值是随机的。只要它们是同时(逻辑上)同时生成的,
     /// 这些连续的的 RTP 报文就会有相同的timestamp,
     /// 例如,同属一个视频帧。正像在MPEG 中内插视频帧一样,
     /// 连续的但不是按顺序发送的RTP 报文可能含有相同的timestamp。
     /// The timestamp reflects the sampling instant of the first octet in the RTP data packet. The
     /// sampling instant must be derived from a clock that increments monotonically and linearly
     /// in time to allow synchronization and jitter calculations (see Section 6.4.1). The resolution
     /// of the clock must be suficient for the desired synchronization accuracy and for measuring
     /// packet arrival jitter (one tick per video frame is typically not suficient). The clock frequency
     /// is dependent on the format of data carried as payload and is specified statically in the profile
     /// or payload format specification that defines the format, or may be specified dynamically for
     /// payload formats defined through non-RTP means. If RTP packets are generated periodically,
     /// the nominal sampling instant as determined from the sampling clock is to be used, not a
     /// reading of the system clock. As an example, for fixed-rate audio the timestamp clock would
     /// likely increment by one for each sampling period. If an audio application reads blocks covering
     /// 160 sampling periods from the input device, the timestamp would be increased by 160 for
     /// each such block, regardless of whether the block is transmitted in a packet or dropped as silent.
     ///
     public long Timestamp { get; private set; }

     ///
     /// SSRC:32 bits
     /// SSRC 域识别同步源。为了防止在一个会话中有相同的同步源有相同的SSRC identifier,
     /// 这个identifier 必须随机选取。
     /// 生成随机 identifier 的算法见目录A.6 。虽然选择相同的identifier 概率很小,
     /// 但是所有的RTP implementation 必须检测和解决冲突。
     /// 第8 章描述了冲突的概率和解决机制和RTP 级的检测机制,根据唯一的 SSRCidentifier 前向循环。
     /// 如果有源改变了它的源传输地址,
     /// 就必须为它选择一个新的SSRCidentifier 来避免被识别为循环过的源(见第8.2 节)。
     /// The SSRC field identifies the synchronization source. This identifier should be chosen
     /// randomly, with the intent that no two synchronization sources within the same RTP session
     /// will have the same SSRC identifier. An example algorithm for generating a random identifier
     /// is presented in Appendix A.6. Although the probability of multiple sources choosing the same
     /// identifier is low, all RTP implementations must be prepared to detect and resolve collisions.
     /// Section 8 describes the probability of collision along with a mechanism for resolving collisions
     /// and detecting RTP-level forwarding loops based on the uniqueness of the SSRC identifier. If
     /// a source changes its source transport address, it must also choose a new SSRC identifier to
     /// avoid being interpreted as a looped source (see Section 8.2).
     ///
     public int SSRC { get { return 0; } }

     ///
     /// 每一个RTP包中都有前12个字节定长的头字段
     /// The first twelve octets are present in every RTP packet
     ///
     public const int HeaderSize = 12;
     ///
     /// RTP消息头
     ///
     private byte[] _header;
     ///
     /// RTP消息头
     ///
     public byte[] Header { get { return _header; } }

     ///
     /// RTP有效载荷长度
     ///
     private int _payloadSize;
     ///
     /// RTP有效载荷长度
     ///
     public int PayloadSize { get { return _payloadSize; } }

     ///
     /// RTP有效载荷
     ///
     private byte[] _payload;
     ///
     /// RTP有效载荷
     ///
     public byte[] Payload { get { return _payload; } }

     ///
     /// RTP消息总长度,包括Header和Payload
     ///
     public int Length { get { return HeaderSize + PayloadSize; } }

     ///
     /// RTP(RFC3550)协议数据包
     ///
     /// 数据报文有效载荷类型
     /// 数据报文序列号值
     /// 数据报文采样时刻
     /// 数据
     /// 数据长度
     public RtpPacket(
       RtpPayloadType playloadType,
       int sequenceNumber,
       long timestamp,
       byte[] data,
       int dataSize)
     {
       // fill changing header fields
       SequenceNumber = sequenceNumber;
       Timestamp = timestamp;
       PayloadType = playloadType;

       // build the header bistream
       _header = new byte[HeaderSize];

       // fill the header array of byte with RTP header fields
       _header[0] = (byte)((Version (8 * i));
       }
       for (int i = 0; i < 4; i++)
       {
         _header[11 - i] = (byte)(SSRC >> (8 * i));
       }

       // fill the payload bitstream
       _payload = new byte[dataSize];
       _payloadSize = dataSize;

       // fill payload array of byte from data (given in parameter of the constructor)
       Array.Copy(data, 0, _payload, 0, dataSize);
     }

     ///
     /// RTP(RFC3550)协议数据包
     ///
     /// 数据报文有效载荷类型
     /// 数据报文序列号值
     /// 数据报文采样时刻
     /// 图片
     public RtpPacket(
       RtpPayloadType playloadType,
       int sequenceNumber,
       long timestamp,
       Image frame)
     {
       // fill changing header fields
       SequenceNumber = sequenceNumber;
       Timestamp = timestamp;
       PayloadType = playloadType;

       // build the header bistream
       _header = new byte[HeaderSize];

       // fill the header array of byte with RTP header fields
       _header[0] = (byte)((Version (8 * i));
       }
       for (int i = 0; i < 4; i++)
       {
         _header[11 - i] = (byte)(SSRC >> (8 * i));
       }

       // fill the payload bitstream
       using (MemoryStream ms = new MemoryStream())
       {
         frame.Save(ms, ImageFormat.Jpeg);
         _payload = ms.ToArray();
         _payloadSize = _payload.Length;
       }
     }

     ///
     /// RTP(RFC3550)协议数据包
     ///
     /// 数据包
     /// 数据包长度
     public RtpPacket(byte[] packet, int packetSize)
     {
       //check if total packet size is lower than the header size
       if (packetSize >= HeaderSize)
       {
         //get the header bitsream
         _header = new byte[HeaderSize];
         for (int i = 0; i < HeaderSize; i++)
         {
           _header[i] = packet[i];
         }

         //get the payload bitstream
         _payloadSize = packetSize - HeaderSize;
         _payload = new byte[_payloadSize];
         for (int i = HeaderSize; i < packetSize; i++)
         {
           _payload[i - HeaderSize] = packet[i];
         }

         //interpret the changing fields of the header
         PayloadType = (RtpPayloadType)(_header[1] & 127);
         SequenceNumber = UnsignedInt(_header[3]) + 256 * UnsignedInt(_header[2]);
         Timestamp = UnsignedInt(_header[7])
           + 256 * UnsignedInt(_header[6])
           + 65536 * UnsignedInt(_header[5])
           + 16777216 * UnsignedInt(_header[4]);
       }
     }

     ///
     /// 将消息转换成byte数组
     ///
     /// 消息byte数组
     public byte[] ToArray()
     {
       byte[] packet = new byte[Length];

       Array.Copy(_header, 0, packet, 0, HeaderSize);
       Array.Copy(_payload, 0, packet, HeaderSize, PayloadSize);

       return packet;
     }

     ///
     /// 将消息体转换成图片
     ///
     /// 图片
     public Bitmap ToBitmap()
     {
       return new Bitmap(new MemoryStream(_payload));
     }

     ///
     /// 将消息体转换成图片
     ///
     /// 图片
     public Image ToImage()
     {
       return Image.FromStream(new MemoryStream(_payload));
     }

     ///
     /// 将图片转换成消息
     ///
     /// 数据报文有效载荷类型
     /// 数据报文序列号值
     /// 数据报文采样时刻
     /// 图片帧
     ///
     /// RTP消息
     ///
     public static RtpPacket FromImage(
       RtpPayloadType playloadType,
       int sequenceNumber,
       long timestamp,
       Image frame)
     {
       return new RtpPacket(playloadType, sequenceNumber, timestamp, frame);
     }

     ///
     /// return the unsigned value of 8-bit integer nb
     ///
     ///
     ///
     private static int UnsignedInt(int nb)
     {
       if (nb >= 0)
         return (nb);
       else
         return (256 + nb);
     }
   }

    
 
 

您可能感兴趣的文章:

  • c#中SAPI使用总结——SpVoice的使用方法
  • c#友好显示日期 c#日期datetime使用方法
  • 请问在工作岗位的朋友!使用java开发的公司对c#的态度如何?
  • c#自带缓存使用方法 c#移除清理缓存
  • C#中的switch case使用介绍
  • c# 空合并运算符“??”的使用详解
  • 使用C#实现在屏幕上画图效果的代码实例
  • 深入C#中使用SqlDbType.Xml类型参数的使用详解
  • c#闭包使用方法示例
  • c# split分隔字符串使用方法
  • c#的params参数使用示例
  • c#使用资源文件的示例
  • 使用C# Winform应用程序获取网页源文件的解决方法
  • C#将时间转成文件名使用方法
  • C# 使用匿名函数解决EventHandler参数传递的难题
  • 使用C#获取系统特殊文件夹路径的解决方法
  • C#使用带like的sql语句时防sql注入的方法
  • C#可选参数的相关使用
  • C# 静态构造函数使用总结
  • C# WndProc的使用方法示例
  • 使用TCP传输文件,文件传输成功了,大小也一样,但无法打开
  • linux无线网络传输也可以直接使用socket接口编程吗?
  • 请教使用openobex库实现蓝牙传输的问题
  • 可不可以在程序中直接使用ftp客户端的函数实现文件传输?
  • DM9000如何使用100M模式传输?
  • 如何使用http协议实现流媒体的传输?
  • 使用TCP协议通讯,如果有很多种数据要传输,如:注册信息等,在C++中,我们可以使用结构,java中通常大家又是如何打包的呢?
  • JQuery中使用ajax传输超大数据的解决方法
  • 怎么样使用方式applet/servelet从客户端的某个位置将一个文件传输到服务器端
  • 如何在UNIX 和 WINDOWS 平台之间进行数据传输,使用TCP/IP 通信协议
  • unix支持ssh吗?能够使用sftp进行文件传输吗?
  •  
    本站(WWW.)旨在分享和传播互联网科技相关的资讯和技术,将尽最大努力为读者提供更好的信息聚合和浏览方式。
    本站(WWW.)站内文章除注明原创外,均为转载、整理或搜集自网络。欢迎任何形式的转载,转载请注明出处。












  • 相关文章推荐
  • sharepoint 2010 使用STSNavigate函数实现文件下载举例
  • 弱智问题:我们怎么才知道要使用的方法需要实现什么接口才能使用这个方法呢?
  • 使用java jdk中的LinkedHashMap实现简单的LRU算法
  • 请问谁能讲讲使用软件实现的mcu原理。
  • 在Python3中使用urllib实现http的get和post提交数据操作
  • 使用JavaScript实现的Flash运行环境 Gordon
  • 使用libpcap实现抓包程序的步骤及代码示例
  • 使用Applet能不能实现基于浏览器的打印呢???
  • juqery的python实现:pyquery学习使用教程
  • 请问使用或安装什么软件能够实现Win2000下访问Linux分区?
  • 急急!!!高分求助,关于实现LINUX软件的使用限制问题
  • 在ACC下不使用循环怎样实现,读取文件指定行的数据.
  • 如何使用shell文件实现linux环境下的挂载功能,具体代码!!
  • Linux下的Socket通信如何断开连接的端口从而实现重复使用该端口
  • 怎样在不使用offices产品开启WORD下实现将WORD内容转化为图片的格式
  • python使用循环实现批量创建文件夹示例
  • 使用实现状态栏?
  • 高分求救怎样使用libnet实现TCP的封堵技术!!!!
  • 使用mmap可以读写文件,这是怎么实现的?
  • 懂nginx,帮下忙,使用nginx实现大并发
  • Unix下System函数实现中为何要使用shell去调用执行程序?
  • C++ I/O 成员 tellg():使用输入流读取流指针
  • 在测试memset函数的执行效率时,分为使用Cash和不使用Cash辆种方式,该如何控制是否使用缓存?
  • C++ I/O 成员 tellp():使用输出流读取流指针
  • 求ibm6000的中文使用手册 !从来没用过服务器,现在急需使用它,不知如何使用! 急!!!!!
  • Python不使用print而直接输出二进制字符串
  • 请问:在使用oracle数据库作开发时,是使用pro*c作开发好些,还是使用库函数如oci等好一些啊?或者它们有什么区别或者优缺点啊?
  • Office 2010 Module模式下使用VBA Addressof
  • 急求结果!!假设一个有两个元素的信号量集S,表示了一个磁带驱动器系统,其中进程1使用磁带机A,进程2同时使用磁带机A和B,进程3使用磁带机B。
  • windows下tinyxml.dll下载安装使用(c++解析XML库)
  • 使用了QWidget的程序,如何使用后台程序启动它?


  • 站内导航:


    特别声明:169IT网站部分信息来自互联网,如果侵犯您的权利,请及时告知,本站将立即删除!

    ©2012-2021,,E-mail:www_#163.com(请将#改为@)

    浙ICP备11055608号-3