当RTSP客户端向RTSP服务端发送DESCRIBE命令时,服务端理应当回复一条SDP报文。
该SDP报文中包含RTSP服务端的基本信息、所能提供的音视频媒体类型以及相应的负载能力,以下是一段SDP示例:
RTSP/1.0 200 OK
Server: VLC/2.1.6
Date: Sun, 06 Dec 2015 11:51:38 GMT
Content-Type: application/sdp
Content-Base: rtsp://127.0.0.1:554/ansersion
Content-Length: 572
Cache-Control: no-cache
Cseq: 2
v=0
o=- 15712671843665285047 15712671843665285047 IN IP4 localhost.localdomain
s=Unnamed
i=N/A
c=IN IP4 0.0.0.0
t=0 0
a=tool:vlc 2.1.6
a=recvonly
a=type:broadcast
a=charset:UTF-8
a=control:rtsp://127.0.0.1:554/ansersion
m=audio 0 RTP/AVP 14
b=AS:128
b=RR:0
a=rtpmap:14 MPA/90000
a=control:rtsp://127.0.0.1:554/ansersion/trackID=0
m=video 0 RTP/AVP 96
b=RR:0
a=rtpmap:96 H264/90000
a=fmtp:96 packetization-mode=1;profile-level-id=64000c;sprop-parameter-sets=Z2QADKzZQUH7ARAAAGewAA/DqPFCmWA=,aOvjyyLA;
a=control:rtsp://127.0.0.1:554/ansersion/trackID=1
对于myRTSPClient,所有的SDP报文均在“int RtspClient::ParseSDP(string SDP)”中被处理,并将这些信息记录进MediaSessionMap中,以便后续建立媒体流连接时使用。截至myRtspClient-1.2.3,该函数仅处理了关于SDP报文中关于音视频的部分信息(即以上示例中红色字体部分)。有关SDP的更多意义,可参见RFC4566。
一、int RtspClient::ParseSDP(string SDP)实现流程
SDP报文有个特点,即每行均为“x=yyy”的形式,我们称x为Key, “yyy”为Value。Key为SDP中的关键字,有着特定意义(可参见RFC4566)。Value则为Key的具体参数。
所以本函数的实现策略就是逐行提取报文中的Key和Value,并将其对应保存至MediaSessionMap中,逐行提取使用的是Regex.RegexLine正则表达式接口。有些Value比较复杂,需要进一步提取数据,则使用Regex.Regex正则表达式接口。
本函数主要提取
(1) m=***
(2) a=***
m指明了媒体流(media)的类型(audio/video)等参数;
a指明了媒体流的属性(attribute),如编码格式(比如H264)等。
解析完SDP后,再检查一下各媒体流基本信息是否有效(MediaInfoCheck)。
代码如下
int RtspClient::ParseSDP(string SDP)
{
MyRegex Regex;
string Response("");
int Result = ; // don't have meaning yet if(SDP.length() != ) Response.assign(SDP);
else if(RtspResponse.length() != ) Response.assign(SDPStr);
else return Result; string Pattern = "([a-zA-Z])=(.*)";
list<string> Group;
bool CollectMediaInfo = false;
string CurrentMediaSession("");
while(Regex.RegexLine(&Response, &Pattern, &Group)) {
string Key(""), Value("");
if(!Group.empty()) {
Group.pop_front(); // pop the line
Group.pop_front(); // pop the matched part
Key.assign(Group.front()); Group.pop_front();
Value.assign(Group.front()); Group.pop_front();
// SDPInfo->insert(pair<string, string>(Key, Value));
}
if(Key == "m") CollectMediaInfo = true;
if(Key == "s") CollectMediaInfo = false;
if(!CollectMediaInfo) continue; if(Key == "m") {
/* Pattern: (MediaType) +(Ports) +(Protocol) +(PayloadType)"
Example: "(audio) (0) (RTP/AVP) (14)"
*/
// string PatternTmp("([a-zA-Z]+) +.+ +(.+) +.*");
string PatternTmp("([a-zA-Z]+) +([0-9/]+) +([A-Za-z/]+) +\\b([0-9]+)\\b");
if(!Regex.Regex(Value.c_str(), PatternTmp.c_str(), &Group)) {
continue;
}
Group.pop_front();
CurrentMediaSession.assign(Group.front());
Group.pop_front();
Group.pop_front(); // FIXME: Ports are ignored
string Protocol(Group.front());
Group.pop_front();
int PayloadTypeTmp = -;
stringstream ssPayloadType;
ssPayloadType << Group.front();
ssPayloadType >> PayloadTypeTmp; MediaSession NewMediaSession;
NewMediaSession.MediaType.assign(CurrentMediaSession);
NewMediaSession.Protocol.assign(Protocol);
NewMediaSession.PayloadType.push_back(PayloadTypeTmp);
(*MediaSessionMap)[CurrentMediaSession] = NewMediaSession; }
if("a" == Key) {
string PatternRtpmap("rtpmap:.* +([0-9A-Za-z]+)/([0-9]+)");
string PatternFmtp_H264("fmtp:.*sprop-parameter-sets=([A-Za-z0-9+/=]+),([A-Za-z0-9+/=]+)");
string PatternFmtp_H265("fmtp:.*sprop-vps=([A-Za-z0-9+/=]+);.*sprop-sps=([A-Za-z0-9+/=]+);.*sprop-pps=([A-Za-z0-9+/=]+)");
string PatternControl("control:(.+)");
if(CurrentMediaSession.length() == ) {
continue;
}
if(Regex.Regex(Value.c_str(), PatternRtpmap.c_str(), &Group)) {
Group.pop_front();
(*MediaSessionMap)[CurrentMediaSession].EncodeType = Group.front();;
Group.pop_front();
stringstream TimeRate;
TimeRate << Group.front();
TimeRate >> (*MediaSessionMap)[CurrentMediaSession].TimeRate;
} else if(Regex.Regex(Value.c_str(), PatternControl.c_str(), &Group)) {
Group.pop_front();
string ControlURITmp("");
/* 'Value' could be
* 1: "rtsp://127.0.0.1/ansersion/track=1"
* 2: "track=1"
* If is the '2', it should be prefixed with the URI. */
if(!Regex.Regex(Value.c_str(), "rtsp://")) {
ControlURITmp += RtspURI;
ControlURITmp += "/";
}
ControlURITmp += Group.front();
printf("Control: %s\n", ControlURITmp.c_str());
(*MediaSessionMap)[CurrentMediaSession].ControlURI.assign(ControlURITmp);
} else if(Regex.Regex(Value.c_str(), PatternFmtp_H264.c_str(), &Group)) {
Group.pop_front();
SPS.assign(Group.front());
Group.pop_front();
PPS.assign(Group.front()); if(Regex.Regex(Value.c_str(), "packetization-mode=([0-2])", &Group)) {
Group.pop_front();
stringstream PacketizationMode;
PacketizationMode << Group.front();
PacketizationMode >> (*MediaSessionMap)[CurrentMediaSession].Packetization;
}
} else if(Regex.Regex(Value.c_str(), PatternFmtp_H265.c_str(), &Group)) {
Group.pop_front();
VPS.assign(Group.front());
Group.pop_front();
SPS.assign(Group.front());
Group.pop_front();
PPS.assign(Group.front());
}
}
} for(map<string, MediaSession>::iterator it = MediaSessionMap->begin(); it != MediaSessionMap->end(); it++) {
it->second.MediaInfoCheck();
} return Result;
}
二、提取媒体流信息
while(Regex.RegexLine(&Response, &Pattern, &Group))
其中Response为SDP字符串,Pattern为正则表达式模板"([a-zA-Z])=(.*)",Group为空的string的list。
RegexLine会进行正则匹配Response的第1行,如果匹配成功,则将匹配内容放入Group这个list中,list的第1项是整行字符串,第2项是匹配上模板的字符串,第3项为Key,第4项为Value,然后将匹配指针指向下一行(下次匹配时就会匹配下一行),并且返回true。如果匹配失败,则返回false。
if(!Group.empty()) {
Group.pop_front(); // pop the line
Group.pop_front(); // pop the matched part
Key.assign(Group.front()); Group.pop_front();
Value.assign(Group.front()); Group.pop_front();
}
if(Key == "m") CollectMediaInfo = true;
保存Key和Value,如果Key为“m”,则将CollectMediaInfo标志置为true,表示可以提取媒体流信息,以及相关属性。
if(Key == "m") {
/* Pattern: (MediaType) +(Ports) +(Protocol) +(PayloadType)"
Example: "(audio) (0) (RTP/AVP) (14)"
*/
string PatternTmp("([a-zA-Z]+) +([0-9/]+) +([A-Za-z/]+) +\\b([0-9]+)\\b");
if(!Regex.Regex(Value.c_str(), PatternTmp.c_str(), &Group)) {
continue;
}
Group.pop_front();
CurrentMediaSession.assign(Group.front());
Group.pop_front();
Group.pop_front(); // FIXME: Ports are ignored
string Protocol(Group.front());
Group.pop_front();
int PayloadTypeTmp = -1;
stringstream ssPayloadType;
ssPayloadType << Group.front();
ssPayloadType >> PayloadTypeTmp;
MediaSession NewMediaSession;
NewMediaSession.MediaType.assign(CurrentMediaSession);
NewMediaSession.Protocol.assign(Protocol);
NewMediaSession.PayloadType.push_back(PayloadTypeTmp);
(*MediaSessionMap)[CurrentMediaSession] = NewMediaSession;
}
提取媒体流的类型、端口、协议类型和Payload,并添加进MediaSessionMap中,索引为媒体流类型(audio/video)
注:截至myRtspClient-1.2.3,单个myRtspClient实例仅支持单一的audio和video媒体会话,即当RTSP服务器提供多种video(或audio)——比如不同码率——媒体流时,myRtspClient仅适用SDP中标识的最后一个。
还有一些提取属性(a=***)的代码,形式与上述雷同,不再赘述。
注:Regex.Regex不同于Regex.RegexLine,匹配成功后,string的list中的第1项为匹配上模板的字符串,第2项为第1个匹配上括号的字符串,以此类推。
三、检查媒体信息
for(map<string, MediaSession>::iterator it = MediaSessionMap->begin(); it != MediaSessionMap->end(); it++) {
it->second.MediaInfoCheck();
}
检查媒体流信息,并打印错误。