-
-
Save teocci/7212e17883fa401e8a961c60b851397d to your computer and use it in GitHub Desktop.
rtsp TCP Client for DarwinStreamingServer(python)
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#! /usr/bin/python | |
import socket,time,string,random,thread | |
m_Vars = { | |
"bufLen" : 1024 * 10, | |
"defaultServerIp" : "192.168.1.100", | |
"defaultServerPort" : 554, | |
"defaultTestUrl" : "rtsp://192.168.1.100/test1.mp4", | |
"defaultUserAgent" : "LibVLC/2.0.3 (LIVE555 Streaming Media v2011.12.23)" | |
} | |
def genmsg_OPTIONS(url,seq,userAgent): | |
msgRet = "OPTIONS " + url + " RTSP/1.0\r\n" | |
msgRet += "CSeq: " + str(seq) + "\r\n" | |
msgRet += "User-Agent: " + userAgent + "\r\n" | |
msgRet += "\r\n" | |
return msgRet | |
def genmsg_DESCRIBE(url,seq,userAgent): | |
msgRet = "DESCRIBE " + url + " RTSP/1.0\r\n" | |
msgRet += "CSeq: " + str(seq) + "\r\n" | |
msgRet += "User-Agent: " + userAgent + "\r\n" | |
msgRet += "Accept: application/sdp\r\n" | |
msgRet += "\r\n" | |
return msgRet | |
def genmsg_SETUP(url,seq,userAgent): | |
msgRet = "SETUP " + url + " RTSP/1.0\r\n" | |
msgRet += "CSeq: " + str(seq) + "\r\n" | |
msgRet += "User-Agent: " + userAgent + "\r\n" | |
msgRet += "Transport: RTP/AVP/TCP;unicast;interleaved=0-1\r\n" | |
msgRet += "\r\n" | |
return msgRet | |
def genmsg_SETUP2(url,seq,userAgent,sessionId): | |
msgRet = "SETUP " + url + " RTSP/1.0\r\n" | |
msgRet += "CSeq: " + str(seq) + "\r\n" | |
msgRet += "User-Agent: " + userAgent + "\r\n" | |
msgRet += "Transport: RTP/AVP/TCP;unicast;interleaved=2-3\r\n" | |
msgRet += "Session: " + sessionId + "\r\n" | |
msgRet += "\r\n" | |
return msgRet | |
def genmsg_PLAY(url,seq,userAgent,sessionId): | |
msgRet = "PLAY " + url + " RTSP/1.0\r\n" | |
msgRet += "CSeq: " + str(seq) + "\r\n" | |
msgRet += "User-Agent: " + userAgent + "\r\n" | |
msgRet += "Session: " + sessionId + "\r\n" | |
msgRet += "\r\n" | |
return msgRet | |
def genmsg_TEARDOWN(url,seq,userAgent,sessionId): | |
msgRet = "TEARDOWN " + url + " RTSP/1.0\r\n" | |
msgRet += "CSeq: " + str(seq) + "\r\n" | |
msgRet += "User-Agent: " + userAgent + "\r\n" | |
msgRet += "Session: " + sessionId + "\r\n" | |
msgRet += "\r\n" | |
return msgRet | |
def decodeMsg(strContent): | |
mapRetInf = {} | |
for str in [elem for elem in strContent.split("\n") if len(elem) > 1][2:-1]: | |
#print str | |
tmp2 = str.split(":") | |
mapRetInf[tmp2[0]]=tmp2[1][:-1] | |
#print mapRetInf | |
return mapRetInf | |
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM) | |
s.connect((m_Vars["defaultServerIp"],m_Vars["defaultServerPort"])) | |
seq = 1 | |
print genmsg_OPTIONS(m_Vars["defaultTestUrl"],seq,m_Vars["defaultUserAgent"]) | |
s.send(genmsg_OPTIONS(m_Vars["defaultTestUrl"],seq,m_Vars["defaultUserAgent"])) | |
print s.recv(m_Vars["bufLen"]) | |
seq = seq + 1 | |
s.send(genmsg_DESCRIBE(m_Vars["defaultTestUrl"],seq,m_Vars["defaultUserAgent"])) | |
msg1 = s.recv(m_Vars["bufLen"]) | |
print msg1 | |
seq = seq + 1 | |
s.send(genmsg_SETUP(m_Vars["defaultTestUrl"] + "/trackID=3",seq,m_Vars["defaultUserAgent"])) | |
msg1 = s.recv(m_Vars["bufLen"]) | |
print msg1 | |
seq = seq + 1 | |
sessionId = decodeMsg(msg1)['Session'] | |
s.send(genmsg_SETUP2(m_Vars["defaultTestUrl"] + "/trackID=4",seq,m_Vars["defaultUserAgent"],sessionId)) | |
msg1 = s.recv(m_Vars["bufLen"]) | |
print msg1 | |
seq = seq + 1 | |
s.send(genmsg_PLAY(m_Vars["defaultTestUrl"] + "/",seq,m_Vars["defaultUserAgent"],sessionId)) | |
msg1 = s.recv(m_Vars["bufLen"]) | |
print msg1 | |
seq = seq + 1 | |
while True : | |
#s.send(genmsg_ANNOUNCE(m_Vars["defaultServerIp"])) | |
msgRcv = s.recv(m_Vars["bufLen"]) | |
if 0 == len(msgRcv) : break | |
print len(msgRcv) | |
#time.sleep(5) | |
s.send(genmsg_TEARDOWN(m_Vars["defaultTestUrl"] + "/",seq,m_Vars["defaultUserAgent"],sessionId)) | |
msg1 = s.recv(m_Vars["bufLen"]) | |
print msg1 | |
s.close() |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment