Reply to thread

Message

<blockquote data-quote="KayDiefenthal" data-source="post: 1067331" data-attributes="member: 22825">mm1352000 i use this for receiving of RtpDataInitialize the RtpSession(localaddress, localPort)&nbsp; in RtspSetup Responseand Invoke&nbsp; Connect in RtspPlay[CODE]public class RtpSession&nbsp; &nbsp; {&nbsp;&nbsp; &nbsp;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; private Thread _listenerThread;&nbsp;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; private EndPoint _endPoint;&nbsp; &nbsp; &nbsp; &nbsp; private MemoryStream _stream;&nbsp; &nbsp; &nbsp; &nbsp; public MemoryStream Stream&nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; get { return _stream; }&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; set { _stream = value; }&nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; private bool _listening;&nbsp; &nbsp; &nbsp; &nbsp; private Socket _socket;&nbsp; &nbsp; &nbsp; &nbsp; private int _rcvd;&nbsp; &nbsp; &nbsp; &nbsp; /// &lt;summary&gt;&nbsp; &nbsp; &nbsp; &nbsp; /// Initialize a new Instance of&lt;see cref=&quot;RtpSession&quot;/&gt; Class.&nbsp; &nbsp; &nbsp; &nbsp; /// &lt;/summary&gt;&nbsp; &nbsp; &nbsp; &nbsp; public RtpSession(string address,int port )&nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; _stream = new MemoryStream();&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; Connect(address, port);&nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; private void Connect(string address,int port )&nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; var rtpEndPoint = new IPEndPoint(IPAddress.Parse(address), port);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; var endPoint = (EndPoint)rtpEndPoint;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; _socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; _socket.SetSocketOption(SocketOptionLevel.Socket,SocketOptionName.ReuseAddress, 1);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; _socket.Bind(endPoint);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; var sender = new IPEndPoint(IPAddress.Parse(address), port);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; _endPoint = (EndPoint)sender;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; _listenerThread = new Thread(ReceiveCallback);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; _listenerThread.Start();&nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; private void ReceiveCallback()&nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; _listening = true;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; while (_listening)&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; // Receive RTP packet&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; byte[] packet = new byte[1370];&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; _rcvd = _socket.ReceiveFrom( packet ,ref _endPoint);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; // Decode the header of the packet.&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; // Each piece of information has a start bit and an end bit.&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; // The GetRTPHeaderValue takes the packet, the start bit index and the&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; // end bit index and determines what the header value is. The header values&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; // are all in Big Endian, which makes things more complicated.&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; int version = GetRTPHeaderValue(packet, 0, 1);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; int padding = GetRTPHeaderValue(packet, 2, 2);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; int extension = GetRTPHeaderValue(packet, 3, 3);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; int csrcCount = GetRTPHeaderValue(packet, 4, 7);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; int marker = GetRTPHeaderValue(packet, 8, 8);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; int payloadType = GetRTPHeaderValue(packet, 9, 15);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; int sequenceNum = GetRTPHeaderValue(packet, 16, 31);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; int timestamp = GetRTPHeaderValue(packet, 32, 63);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; int ssrcId = GetRTPHeaderValue(packet, 64, 95);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; int csrcid = GetRTPHeaderValue(packet, 96,96);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; StringBuilder sb = new StringBuilder();&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; sb.Append(string.Format(&quot; RtpPacket V:{0}, P:{1}, EX:{2}, CSRC:{3}, M:{4}, PT:{5}, SQ:{6}, TS:{7}, SSRC:{8}, CSRC:{9} \r\n&quot;, version, padding, extension, csrcCount, marker, payloadType, sequenceNum, timestamp, ssrcId,csrcid));&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; Debug.Write(sb.ToString());//the packet payload starts at Offset 12 and the Payload lenght is packet.lenght without headersize&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; _stream.Write(packet, 12, packet.Length - 12);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; private&nbsp; int GetRTPHeaderValue(byte[] packet, int startBit, int endBit)&nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; int result = 0;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; // Number of bits in value&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; int length = endBit - startBit + 1;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; // Values in RTP header are big endian, so need to do these conversions&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; for (int i = startBit; i &lt;= endBit; i++)&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; int byteIndex = i / 8;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; int bitShift = 7 - (i % 8);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; result += ((packet[byteIndex] &gt;&gt; bitShift) &amp; 1) * (int)Math.Pow(2, length - i + startBit - 1);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; return result;&nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; public void StopClient()&nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; // Tell listener thread that we are done listening.&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; _listening = false;&nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; }[/CODE]</blockquote>

[QUOTE="KayDiefenthal, post: 1067331, member: 22825"] mm1352000 i use this for receiving of RtpData Initialize the RtpSession(localaddress, localPort) in RtspSetup Response and Invoke Connect in RtspPlay [CODE]public class RtpSession { private Thread _listenerThread; private EndPoint _endPoint; private MemoryStream _stream; public MemoryStream Stream { get { return _stream; } set { _stream = value; } } private bool _listening; private Socket _socket; private int _rcvd; /// <summary> /// Initialize a new Instance of<see cref="RtpSession"/> Class. /// </summary> public RtpSession(string address,int port ) { _stream = new MemoryStream(); Connect(address, port); } private void Connect(string address,int port ) { var rtpEndPoint = new IPEndPoint(IPAddress.Parse(address), port); var endPoint = (EndPoint)rtpEndPoint; _socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); _socket.SetSocketOption(SocketOptionLevel.Socket,SocketOptionName.ReuseAddress, 1); _socket.Bind(endPoint); var sender = new IPEndPoint(IPAddress.Parse(address), port); _endPoint = (EndPoint)sender; _listenerThread = new Thread(ReceiveCallback); _listenerThread.Start(); } private void ReceiveCallback() { _listening = true; while (_listening) { // Receive RTP packet byte[] packet = new byte[1370]; _rcvd = _socket.ReceiveFrom( packet ,ref _endPoint); // Decode the header of the packet. // Each piece of information has a start bit and an end bit. // The GetRTPHeaderValue takes the packet, the start bit index and the // end bit index and determines what the header value is. The header values // are all in Big Endian, which makes things more complicated. int version = GetRTPHeaderValue(packet, 0, 1); int padding = GetRTPHeaderValue(packet, 2, 2); int extension = GetRTPHeaderValue(packet, 3, 3); int csrcCount = GetRTPHeaderValue(packet, 4, 7); int marker = GetRTPHeaderValue(packet, 8, 8); int payloadType = GetRTPHeaderValue(packet, 9, 15); int sequenceNum = GetRTPHeaderValue(packet, 16, 31); int timestamp = GetRTPHeaderValue(packet, 32, 63); int ssrcId = GetRTPHeaderValue(packet, 64, 95); int csrcid = GetRTPHeaderValue(packet, 96,96); StringBuilder sb = new StringBuilder(); sb.Append(string.Format(" RtpPacket V:{0}, P:{1}, EX:{2}, CSRC:{3}, M:{4}, PT:{5}, SQ:{6}, TS:{7}, SSRC:{8}, CSRC:{9} \r\n", version, padding, extension, csrcCount, marker, payloadType, sequenceNum, timestamp, ssrcId,csrcid)); Debug.Write(sb.ToString()); //the packet payload starts at Offset 12 and the Payload lenght is packet.lenght without headersize _stream.Write(packet, 12, packet.Length - 12); } } private int GetRTPHeaderValue(byte[] packet, int startBit, int endBit) { int result = 0; // Number of bits in value int length = endBit - startBit + 1; // Values in RTP header are big endian, so need to do these conversions for (int i = startBit; i <= endBit; i++) { int byteIndex = i / 8; int bitShift = 7 - (i % 8); result += ((packet[byteIndex] >> bitShift) & 1) * (int)Math.Pow(2, length - i + startBit - 1); } return result; } public void StopClient() { // Tell listener thread that we are done listening. _listening = false; } }[/CODE] [/QUOTE]

Verification