码迷，mamicode.com
首页 > 其他好文 > 详细

RTSP协议详解

时间：2017-03-15 12:38:56      阅读：217      评论：0      收藏：0      [点我收藏+]

标签：网上   gen   cancel   dir   streaming   reg   put   remote   lease   

RTSP简介
    RTSP（Real Time Streaming Protocol）是由Real Network和Netscape共同提出的如何有效地在IP网络上传输流媒体数据的应用层协议。RTSP对流媒体提供了诸如暂停，快进等控制，而它本身并不传输数据，RTSP的作用相当于流媒体服务器的远程控制。服务器端可以自行选择使用TCP或UDP来传送串流内容，它的语法和运作跟HTTP 1.1类似，但并不特别强调时间同步，所以比较能容忍网络延迟。而且允许同时多个串流需求控制（Multicast），除了可以降低服务器端的网络用量，还可以支持多方视频会议（Video  onference）。 因为与HTTP1.1的运作方式相似，所以代理服务器《Proxy》的快取功能《Cache》也同样适用于RTSP，并因RTSP具有重新导向功能，可视实际负载情况来转换提供服务的服务器，以避免过大的负载集中于同一服务器而造成延迟。
   
rtsp和http的区别和联系
    （1）联系：两者都用纯文本来发送消息，且rtsp协议的语法也和HTTP类似。Rtsp一开始这样设计，也是为了能够兼容使用以前写的HTTP协议分析代码 。
    （2）区别：rtsp是有状态的，不同的是RTSP的命令需要知道现在正处于一个什么状态，也就是说rtsp的命令总是按照顺序来发送，某个命令总在另外一个命令之前要发送。Rtsp不管处于什么状态都不会去断掉连接。，而http则不保存状态，协议在发送一个命令以后，连接就会断开，且命令之间是没有依赖性的。rtsp协议使用554端口，http使用80端口。
rtsp和sip的区别和联系
 
SIP（Session Initiation Protocol），是基于IP的一个应用层控制协议。由于SIP是基于纯文本的信令协议，可以管理不同接入网络上的会话等。会话可以是终端设备之间任何类型的通信，如视频会话、既时信息处理或协作会话。该协议不会定义或限制可使用的业务，传输、服务质量、计费、安全性等问题都由基本核心网络和其它协议处理。
 
    （1）联系：sip和rtsp都是应用层的控制协议，负责一次通信过程的建立和控制和结束，不负责中间的传输部分。他们都是基于纯文本的信令协议，穿墙性能良好。支持tcp、udp，支持多方通信。他们都需要服务器支持，都支持会话中重定向。sip和rtsp 都使用sdp协议来传送媒体参数，使用rtp（rtcp）协议来传输媒体流。
    （2）区别：rtsp是专门为流媒体制定的协议，在多个媒体流的时间同步方面比sip强大。rtsp还提供网络负载均衡的功能，减轻服务器压力和网络带宽要求。sip一般用来创建一次音频、视频通话（双向），而rtsp一般用来做视频点播、视频监控等（单向）。当然，从原理上讲，rtsp也可以做双向的视频通话。
 
RTSP和RTP（rtcp）的关系
技术分享
rtsp负责建立和控制会话，rtp负责多媒体的传输，rtcp配合rtp做控制和流量统计，他们是合作的关系。
RTSP的消息
       RTSP的消息有两大类，一是请求消息(request)，一是回应消息(response)，两种消息的格式不同。
 
请求消息格式：
       方法 URI RTSP版本 CR LF
       消息头 CR LF CR LF         
       消息体 CR LF

    其中方法包括OPTIONS、SETUP、PLAY、TEARDOWN等待，URI是接收方（服务端）的地址，例如：rtsp://192.168.22.136:5000/v0，每行后面的CR LF表示回车换行，需要接收端有相应的解析，最后一个消息头需要有两个CR LF。

回应消息格式：
       RTSP版本 状态码 解释 CR LF
       消息头 CR LF CR LF
       消息体 CR LF
    其中RTSP版本一般都是RTSP/1.0，状态码是一个数值，200表示成功，解释是与状态码对应的文本解释。

状态码由三位数组成，表示方法执行的结果，定义如下：

1XX：保留，将来使用；

2XX：成功，操作被接收、理解、接受（received,understand,accepted）；

3XX：重定向，要完成操作必须进行进一步操作；

4XX：客户端出错，请求有语法错误或无法实现；

5XX：服务器出错，服务器无法实现合法的请求。

 

RTSP的方法


 

rtsp中定义的方法有：OPTIONS, DESCRIBE, SETUP, TEARDOWN, PLAY, PAUSE, SCALE, GET_PARAMETER ，SET_PARAMETER 
 
 
1.OPTION
目的是得到服务器提供的可用方法:
OPTIONS rtsp://192.168.20.136:5000/xxx666 RTSP/1.0
CSeq: 1         //每个消息都有序号来标记，第一个包通常是option请求消息
User-Agent: VLC media player (LIVE555 Streaming Media v2005.11.10)
服务器的回应信息包括提供的一些方法,例如:
RTSP/1.0 200 OK
Server: UServer 0.9.7_rc1
Cseq: 1         //每个回应消息的cseq数值和请求消息的cseq相对应
Public: OPTIONS, DESCRIBE, SETUP, TEARDOWN, PLAY, PAUSE, SCALE, GET_PARAMETER //服务器提供的可用的方法
 
2.DESCRIBE
C向S发起DESCRIBE请求,为了得到会话描述信息(SDP):
DESCRIBE rtsp://192.168.20.136:5000/xxx666 RTSP/1.0
CSeq: 2
token:
Accept: application/sdp
User-Agent: VLC media player (LIVE555 Streaming Media v2005.11.10)
服务器回应一些对此会话的描述信息(sdp):
RTSP/1.0 200 OK
Server: UServer 0.9.7_rc1
Cseq: 2
x-prev-url: rtsp://192.168.20.136:5000
x-next-url: rtsp://192.168.20.136:5000
x-Accept-Retransmit: our-retransmit
x-Accept-Dynamic-Rate: 1
Cache-Control: must-revalidate
Last-Modified: Fri, 10 Nov 2006 12:34:38 GMT
Date: Fri, 10 Nov 2006 12:34:38 GMT
Expires: Fri, 10 Nov 2006 12:34:38 GMT
Content-Base: rtsp://192.168.20.136:5000/xxx666/
Content-Length: 344
Content-Type: application/sdp
v=0        //以下都是sdp信息
o=OnewaveUServerNG 1451516402 1025358037 IN IP4 192.168.20.136
s=/xxx666
u=http:///
e=admin@
c=IN IP4 0.0.0.0
t=0 0
a=isma-compliance:1,1.0,1
a=range:npt=0-
m=video 0 RTP/AVP 96    //m表示媒体描述，下面是对会话中视频通道的媒体描述
a=rtpmap:96 MP4V-ES/90000
a=fmtp:96 profile-level-id=245;config=000001B0F5000001B509000001000000012000C888B0E0E0FA62D089028307
a=control:trackID=0//trackID＝0表示视频流用的是通道0
 
3.SETUP
客户端提醒服务器建立会话,并确定传输模式:
SETUP rtsp://192.168.20.136:5000/xxx666/trackID=0 RTSP/1.0    
CSeq: 3
Transport: RTP/AVP/TCP;unicast;interleaved=0-1      
User-Agent: VLC media player (LIVE555 Streaming Media v2005.11.10)
//uri中带有trackID＝0，表示对该通道进行设置。Transport参数设置了传输模式，包的结构。接下来的数据包头部第二个字节位置就是interleaved，它的值是每个通道都不同的，trackID＝0的interleaved值有两个0或1，0表示rtp包，1表示rtcp包，接受端根据interleaved的值来区别是哪种数据包。
服务器回应信息:
RTSP/1.0 200 OK
Server: UServer 0.9.7_rc1
Cseq: 3
Session: 6310936469860791894     //服务器回应的会话标识符
Cache-Control: no-cache
Transport: RTP/AVP/TCP;unicast;interleaved=0-1;ssrc=6B8B4567
 
4.PLAY
客户端发送播放请求:
PLAY rtsp://192.168.20.136:5000/xxx666 RTSP/1.0
CSeq: 4
Session: 6310936469860791894
Range: npt=0.000-      //设置播放时间的范围
User-Agent: VLC media player (LIVE555 Streaming Media v2005.11.10)
服务器回应信息:
RTSP/1.0 200 OK
Server: UServer 0.9.7_rc1
Cseq: 4
Session: 6310936469860791894
Range: npt=0.000000-
RTP-Info: url=trackID=0;seq=17040;rtptime=1467265309     
//seq和rtptime都是rtp包中的信息
 
5.TEARDOWN
客户端发起关闭请求:
TEARDOWN rtsp://192.168.20.136:5000/xxx666 RTSP/1.0
CSeq: 5
Session: 6310936469860791894
User-Agent: VLC media player (LIVE555 Streaming Media v2005.11.10)
服务器回应:
RTSP/1.0 200 OK
Server: UServer 0.9.7_rc1
Cseq: 5
Session: 6310936469860791894
Connection: Close
以上方法都是交互过程中最为常用的,其它还有一些重要的方法如get/set_parameter,pause,redirect等等
 
ps:
sdp的格式
v=<version>
o=<username> <session id> <version> <network type> <address type> <address>
s=<session name>
i=<session description>
u=<URI>
e=<email address>
p=<phone number>
c=<network type> <address type> <connection address>
b=<modifier>:<bandwidth-value>
t=<start time> <stop time>
r=<repeat interval> <active duration> <list of offsets from start-time>
z=<adjustment time> <offset> <adjustment time> <offset> ....
k=<method>
k=<method>:<encryption key>
a=<attribute>
a=<attribute>:<value>
m=<media> <port> <transport> <fmt list>
v = （协议版本）
o = （所有者/创建者和会话标识符）
s = （会话名称）
i = * （会话信息）
u = * （URI 描述）
e = * （Email 地址）
p = * （电话号码）
c = * （连接信息）
b = * （带宽信息）
z = * （时间区域调整）
k = * （加密密钥）
a = * （0 个或多个会话属性行）
时间描述：
t = （会话活动时间）
r = * （0或多次重复次数）
媒体描述：
m = （媒体名称和传输地址）
i = * （媒体标题）
c = * （连接信息 — 如果包含在会话层则该字段可选）
b = * （带宽信息）
k = * （加密密钥）
a = * （0 个或多个媒体属性行）

 

RTSP客户端的JAVA实现


3.1  接口IEvent.java      

 接口IEvent.java的代码如下：

Java代码 
  1. package com.amigo.rtsp;  
  2.   
  3. import java.io.IOException;  
  4. import java.nio.channels.SelectionKey;  
  5.   
  6. /** *//** 
  7. * IEvent.java 网络事件处理器，当Selector可以进行操作时，调用这个接口中的方法. 
  8. * 2007-3-22 下午03:35:51 
  9. * @author sycheng 
  10. * @version 1.0 
  11. */  
  12. public interface IEvent {  
  13.     /** *//** 
  14.     * 当channel得到connect事件时调用这个方法. 
  15.     * @param key 
  16.     * @throws IOException 
  17.     */  
  18.     void connect(SelectionKey key) throws IOException;  
  19.   
  20.     /** *//** 
  21.     * 当channel可读时调用这个方法. 
  22.     * @param key 
  23.     * @throws IOException 
  24.     */  
  25.     void read(SelectionKey key) throws IOException;  
  26.   
  27.     /** *//** 
  28.     * 当channel可写时调用这个方法. 
  29.     * @throws IOException 
  30.     */  
  31.     void write() throws IOException;  
  32.   
  33.     /** *//** 
  34.     * 当channel发生错误时调用. 
  35.     * @param e 
  36.     */  
  37.     void error(Exception e);  
  38. }  

 3.2  RTSP的测试类：RTSPClient.java
        RTSP的测试类RTSPClient.java类的代码如下所示:

Java代码 
  1. package com.amigo.rtsp;  
  2.   
  3. import java.io.IOException;  
  4. import java.net.InetSocketAddress;  
  5. import java.nio.ByteBuffer;  
  6. import java.nio.channels.SelectionKey;  
  7. import java.nio.channels.Selector;  
  8. import java.nio.channels.SocketChannel;  
  9. import java.util.Iterator;  
  10. import java.util.concurrent.atomic.AtomicBoolean;  
  11.   
  12. public class RTSPClient extends Thread implements IEvent {  
  13.   
  14.     private static final String VERSION = " RTSP/1.0/r/n";  
  15.     private static final String RTSP_OK = "RTSP/1.0 200 OK";  
  16.   
  17.     /** *//** 远程地址 */  
  18.     private final InetSocketAddress remoteAddress;  
  19.   
  20.     /** *//** * 本地地址 */  
  21.     private final InetSocketAddress localAddress;  
  22.   
  23.     /** *//** * 连接通道 */  
  24.     private SocketChannel socketChannel;  
  25.   
  26.     /** *//** 发送缓冲区 */  
  27.     private final ByteBuffer sendBuf;  
  28.   
  29.     /** *//** 接收缓冲区 */  
  30.     private final ByteBuffer receiveBuf;  
  31.   
  32.     private static final int BUFFER_SIZE = 8192;  
  33.   
  34.     /** *//** 端口选择器 */  
  35.     private Selector selector;  
  36.   
  37.     private String address;  
  38.   
  39.     private Status sysStatus;  
  40.   
  41.     private String sessionid;  
  42.   
  43.     /** *//** 线程是否结束的标志 */  
  44.     private AtomicBoolean shutdown;  
  45.       
  46.     private int seq=1;  
  47.       
  48.     private boolean isSended;  
  49.       
  50.     private String trackInfo;  
  51.       
  52.   
  53.     private enum Status {  
  54.         init, options, describe, setup, play, pause, teardown  
  55.     }  
  56.   
  57.     public RTSPClient(InetSocketAddress remoteAddress,  
  58.             InetSocketAddress localAddress, String address) {  
  59.         this.remoteAddress = remoteAddress;  
  60.         this.localAddress = localAddress;  
  61.         this.address = address;  
  62.   
  63.         // 初始化缓冲区  
  64.         sendBuf = ByteBuffer.allocateDirect(BUFFER_SIZE);  
  65.         receiveBuf = ByteBuffer.allocateDirect(BUFFER_SIZE);  
  66.         if (selector == null) {  
  67.             // 创建新的Selector  
  68.             try {  
  69.                 selector = Selector.open();  
  70.             } catch (final IOException e) {  
  71.                 e.printStackTrace();  
  72.             }  
  73.         }  
  74.   
  75.         startup();  
  76.         sysStatus = Status.init;  
  77.         shutdown=new AtomicBoolean(false);  
  78.         isSended=false;  
  79.     }  
  80.   
  81.     public void startup() {  
  82.         try {  
  83.             // 打开通道  
  84.             socketChannel = SocketChannel.open();  
  85.             // 绑定到本地端口  
  86.             socketChannel.socket().setSoTimeout(30000);  
  87.             socketChannel.configureBlocking(false);  
  88.             socketChannel.socket().bind(localAddress);  
  89.             if (socketChannel.connect(remoteAddress)) {  
  90.                 System.out.println("开始建立连接:" + remoteAddress);  
  91.             }  
  92.             socketChannel.register(selector, SelectionKey.OP_CONNECT  
  93.                     | SelectionKey.OP_READ | SelectionKey.OP_WRITE, this);  
  94.             System.out.println("端口打开成功");  
  95.   
  96.         } catch (final IOException e1) {  
  97.             e1.printStackTrace();  
  98.         }  
  99.     }  
  100.   
  101.     public void send(byte[] out) {  
  102.         if (out == null || out.length < 1) {  
  103.             return;  
  104.         }  
  105.         synchronized (sendBuf) {  
  106.             sendBuf.clear();  
  107.             sendBuf.put(out);  
  108.             sendBuf.flip();  
  109.         }  
  110.   
  111.         // 发送出去  
  112.         try {  
  113.             write();  
  114.             isSended=true;  
  115.         } catch (final IOException e) {  
  116.             e.printStackTrace();  
  117.         }  
  118.     }  
  119.   
  120.     public void write() throws IOException {  
  121.         if (isConnected()) {  
  122.             try {  
  123.                 socketChannel.write(sendBuf);  
  124.             } catch (final IOException e) {  
  125.             }  
  126.         } else {  
  127.             System.out.println("通道为空或者没有连接上");  
  128.         }  
  129.     }  
  130.   
  131.     public byte[] recieve() {  
  132.         if (isConnected()) {  
  133.             try {  
  134.                 int len = 0;  
  135.                 int readBytes = 0;  
  136.   
  137.                 synchronized (receiveBuf) {  
  138.                     receiveBuf.clear();  
  139.                     try {  
  140.                         while ((len = socketChannel.read(receiveBuf)) > 0) {  
  141.                             readBytes += len;  
  142.                         }  
  143.                     } finally {  
  144.                         receiveBuf.flip();  
  145.                     }  
  146.                     if (readBytes > 0) {  
  147.                         final byte[] tmp = new byte[readBytes];  
  148.                         receiveBuf.get(tmp);  
  149.                         return tmp;  
  150.                     } else {  
  151.                         System.out.println("接收到数据为空,重新启动连接");  
  152.                         return null;  
  153.                     }  
  154.                 }  
  155.             } catch (final IOException e) {  
  156.                 System.out.println("接收消息错误:");  
  157.             }  
  158.         } else {  
  159.             System.out.println("端口没有连接");  
  160.         }  
  161.         return null;  
  162.     }  
  163.   
  164.     public boolean isConnected() {  
  165.         return socketChannel != null && socketChannel.isConnected();  
  166.     }  
  167.   
  168.     private void select() {  
  169.         int n = 0;  
  170.         try {  
  171.             if (selector == null) {  
  172.                 return;  
  173.             }  
  174.             n = selector.select(1000);  
  175.   
  176.         } catch (final Exception e) {  
  177.             e.printStackTrace();  
  178.         }  
  179.   
  180.         // 如果select返回大于0，处理事件  
  181.         if (n > 0) {  
  182.             for (final Iterator<SelectionKey> i = selector.selectedKeys()  
  183.                     .iterator(); i.hasNext();) {  
  184.                 // 得到下一个Key  
  185.                 final SelectionKey sk = i.next();  
  186.                 i.remove();  
  187.                 // 检查其是否还有效  
  188.                 if (!sk.isValid()) {  
  189.                     continue;  
  190.                 }  
  191.   
  192.                 // 处理事件  
  193.                 final IEvent handler = (IEvent) sk.attachment();  
  194.                 try {  
  195.                     if (sk.isConnectable()) {  
  196.                         handler.connect(sk);  
  197.                     } else if (sk.isReadable()) {  
  198.                         handler.read(sk);  
  199.                     } else {  
  200.                         // System.err.println("Ooops");  
  201.                     }  
  202.                 } catch (final Exception e) {  
  203.                     handler.error(e);  
  204.                     sk.cancel();  
  205.                 }  
  206.             }  
  207.         }  
  208.     }  
  209.   
  210.     public void shutdown() {  
  211.         if (isConnected()) {  
  212.             try {  
  213.                 socketChannel.close();  
  214.                 System.out.println("端口关闭成功");  
  215.             } catch (final IOException e) {  
  216.                 System.out.println("端口关闭错误:");  
  217.             } finally {  
  218.                 socketChannel = null;  
  219.             }  
  220.         } else {  
  221.             System.out.println("通道为空或者没有连接");  
  222.         }  
  223.     }  
  224.   
  225.     @Override  
  226.     public void run() {  
  227.         // 启动主循环流程  
  228.         while (!shutdown.get()) {  
  229.             try {  
  230.                 if (isConnected()&&(!isSended)) {  
  231.                     switch (sysStatus) {  
  232.                     case init:  
  233.                         doOption();  
  234.                         break;  
  235.                     case options:  
  236.                         doDescribe();  
  237.                         break;  
  238.                     case describe:  
  239.                         doSetup();  
  240.                         break;  
  241.                     case setup:  
  242.                         if(sessionid==null&&sessionid.length()>0){  
  243.                             System.out.println("setup还没有正常返回");  
  244.                         }else{  
  245.                             doPlay();  
  246.                         }  
  247.                         break;  
  248.                     case play:  
  249.                         doPause();  
  250.                         break;  
  251.                           
  252.                     case pause:  
  253.                         doTeardown();  
  254.                         break;  
  255.                     default:  
  256.                         break;  
  257.                     }  
  258.                 }  
  259.                 // do select  
  260.                 select();  
  261.                 try {  
  262.                     Thread.sleep(1000);  
  263.                 } catch (final Exception e) {  
  264.                 }  
  265.             } catch (final Exception e) {  
  266.                 e.printStackTrace();  
  267.             }  
  268.         }  
  269.           
  270.         shutdown();  
  271.     }  
  272.   
  273.     public void connect(SelectionKey key) throws IOException {  
  274.         if (isConnected()) {  
  275.             return;  
  276.         }  
  277.         // 完成SocketChannel的连接  
  278.         socketChannel.finishConnect();  
  279.         while (!socketChannel.isConnected()) {  
  280.             try {  
  281.                 Thread.sleep(300);  
  282.             } catch (final InterruptedException e) {  
  283.                 e.printStackTrace();  
  284.             }  
  285.             socketChannel.finishConnect();  
  286.         }  
  287.   
  288.     }  
  289.   
  290.     public void error(Exception e) {  
  291.         e.printStackTrace();  
  292.     }  
  293.   
  294.     public void read(SelectionKey key) throws IOException {  
  295.         // 接收消息  
  296.         final byte[] msg = recieve();  
  297.         if (msg != null) {  
  298.             handle(msg);  
  299.         } else {  
  300.             key.cancel();  
  301.         }  
  302.     }  
  303.   
  304.     private void handle(byte[] msg) {  
  305.         String tmp = new String(msg);  
  306.         System.out.println("返回内容：");  
  307.         System.out.println(tmp);  
  308.         if (tmp.startsWith(RTSP_OK)) {  
  309.             switch (sysStatus) {  
  310.             case init:  
  311.                 sysStatus = Status.options;  
  312.                 break;  
  313.             case options:  
  314.                 sysStatus = Status.describe;  
  315.                 trackInfo=tmp.substring(tmp.indexOf("trackID"));  
  316.                 break;  
  317.             case describe:  
  318.                 sessionid = tmp.substring(tmp.indexOf("Session: ") + 9, tmp  
  319.                         .indexOf("Date:"));  
  320.                 if(sessionid!=null&&sessionid.length()>0){  
  321.                     sysStatus = Status.setup;  
  322.                 }  
  323.                 break;  
  324.             case setup:  
  325.                 sysStatus = Status.play;  
  326.                 break;  
  327.             case play:  
  328.                 sysStatus = Status.pause;  
  329.                 break;  
  330.             case pause:  
  331.                 sysStatus = Status.teardown;  
  332.                 shutdown.set(true);  
  333.                 break;  
  334.             case teardown:  
  335.                 sysStatus = Status.init;  
  336.                 break;  
  337.             default:  
  338.                 break;  
  339.             }  
  340.             isSended=false;  
  341.         } else {  
  342.             System.out.println("返回错误：" + tmp);  
  343.         }  
  344.   
  345.     }  
  346.   
  347.     private void doTeardown() {  
  348.         StringBuilder sb = new StringBuilder();  
  349.         sb.append("TEARDOWN ");  
  350.         sb.append(this.address);  
  351.         sb.append("/");  
  352.         sb.append(VERSION);  
  353.         sb.append("Cseq: ");  
  354.         sb.append(seq++);  
  355.         sb.append("/r/n");  
  356.         sb.append("User-Agent: RealMedia Player HelixDNAClient/10.0.0.11279 (win32)/r/n");  
  357.         sb.append("Session: ");  
  358.         sb.append(sessionid);  
  359.         sb.append("/r/n");  
  360.         send(sb.toString().getBytes());  
  361.         System.out.println(sb.toString());  
  362.     }  
  363.   
  364.     private void doPlay() {  
  365.         StringBuilder sb = new StringBuilder();  
  366.         sb.append("PLAY ");  
  367.         sb.append(this.address);  
  368.         sb.append(VERSION);  
  369.         sb.append("Session: ");  
  370.         sb.append(sessionid);  
  371.         sb.append("Cseq: ");  
  372.         sb.append(seq++);  
  373.         sb.append("/r/n");  
  374.         sb.append("/r/n");  
  375.         System.out.println(sb.toString());  
  376.         send(sb.toString().getBytes());  
  377.   
  378.     }  
  379.   
  380.     private void doSetup() {  
  381.         StringBuilder sb = new StringBuilder();  
  382.         sb.append("SETUP ");  
  383.         sb.append(this.address);  
  384.         sb.append("/");  
  385.         sb.append(trackInfo);  
  386.         sb.append(VERSION);  
  387.         sb.append("Cseq: ");  
  388.         sb.append(seq++);  
  389.         sb.append("/r/n");  
  390.         sb.append("Transport: RTP/AVP;UNICAST;client_port=16264-16265;mode=play/r/n");  
  391.         sb.append("/r/n");  
  392.         System.out.println(sb.toString());  
  393.         send(sb.toString().getBytes());  
  394.     }  
  395.   
  396.     private void doOption() {  
  397.         StringBuilder sb = new StringBuilder();  
  398.         sb.append("OPTIONS ");  
  399.         sb.append(this.address.substring(0, address.lastIndexOf("/")));  
  400.         sb.append(VERSION);  
  401.         sb.append("Cseq: ");  
  402.         sb.append(seq++);  
  403.         sb.append("/r/n");  
  404.         sb.append("/r/n");  
  405.         System.out.println(sb.toString());  
  406.         send(sb.toString().getBytes());  
  407.     }  
  408.   
  409.     private void doDescribe() {  
  410.         StringBuilder sb = new StringBuilder();  
  411.         sb.append("DESCRIBE ");  
  412.         sb.append(this.address);  
  413.         sb.append(VERSION);  
  414.         sb.append("Cseq: ");  
  415.         sb.append(seq++);  
  416.         sb.append("/r/n");  
  417.         sb.append("/r/n");  
  418.         System.out.println(sb.toString());  
  419.         send(sb.toString().getBytes());  
  420.     }  
  421.       
  422.     private void doPause() {  
  423.         StringBuilder sb = new StringBuilder();  
  424.         sb.append("PAUSE ");  
  425.         sb.append(this.address);  
  426.         sb.append("/");  
  427.         sb.append(VERSION);  
  428.         sb.append("Cseq: ");  
  429.         sb.append(seq++);  
  430.         sb.append("/r/n");  
  431.         sb.append("Session: ");  
  432.         sb.append(sessionid);  
  433.         sb.append("/r/n");  
  434.         send(sb.toString().getBytes());  
  435.         System.out.println(sb.toString());  
  436.     }  
  437.       
  438.     public static void main(String[] args) {  
  439.         try {  
  440.             // RTSPClient(InetSocketAddress remoteAddress,  
  441.             // InetSocketAddress localAddress, String address)  
  442.             RTSPClient client = new RTSPClient(  
  443.                     new InetSocketAddress("218.207.101.236", 554),  
  444.                     new InetSocketAddress("192.168.2.28", 0),  
  445.                     "rtsp://218.207.101.236:554/mobile/3/67A451E937422331/8jH5QPU5GWS07Ugn.sdp");  
  446.             client.start();  
  447.         } catch (Exception e) {  
  448.             e.printStackTrace();  
  449.         }  
  450.     }  
  451. }  

 其中:rtsp://218.207.101.236:554/mobile/3/67A451E937422331/8jH5QPU5GWS07Ugn.sdp为我在网上找到的一个rtsp的sdp地址,读者可自行更换,RTSP的默认端口为554.
3.3  运行结果
       运行RTSPClient.java,运行结果如下所示:

Java代码 
  1. 端口打开成功  
  2. OPTIONS rtsp://218.207.101.236:554/mobile/3/67A451E937422331 RTSP/1.0  
  3. Cseq: 1  
  4.   
  5.   
  6. 返回内容：  
  7. RTSP/1.0 200 OK  
  8. Server: PVSS/1.4.8 (Build/20090111; Platform/Win32; Release/StarValley; )  
  9. Cseq: 1  
  10. Public: DESCRIBE, SETUP, TEARDOWN, PLAY, PAUSE, OPTIONS, ANNOUNCE, RECORD  
  11.   
  12.   
  13. DESCRIBE rtsp://218.207.101.236:554/mobile/3/67A451E937422331/8jH5QPU5GWS07Ugn.sdp RTSP/1.0  
  14. Cseq: 2  
  15.   
  16.   
  17. 返回内容：  
  18. RTSP/1.0 200 OK  
  19. Server: PVSS/1.4.8 (Build/20090111; Platform/Win32; Release/StarValley; )  
  20. Cseq: 2  
  21. Content-length: 421  
  22. Date: Mon, 03 Aug 2009 08:50:36 GMT  
  23. Expires: Mon, 03 Aug 2009 08:50:36 GMT  
  24. Content-Type: application/sdp  
  25. x-Accept-Retransmit: our-retransmit  
  26. x-Accept-Dynamic-Rate: 1  
  27. Content-Base: rtsp://218.207.101.236:554/mobile/3/67A451E937422331/8jH5QPU5GWS07Ugn.sdp/  
  28.   
  29. v=0  
  30. o=MediaBox 127992 137813 IN IP4 0.0.0.0  
  31. s=RTSP Session  
  32. i=Starv Box Live Cast  
  33. c=IN IP4 218.207.101.236  
  34. t=0 0  
  35. a=range:npt=now-  
  36. a=control:*  
  37. m=video 0 RTP/AVP 96  
  38. b=AS:20  
  39. a=rtpmap:96 MP4V-ES/1000  
  40. a=fmtp:96 profile-level-id=8; config=000001b008000001b5090000010000000120008440fa282c2090a31f; decode_buf=12586  
  41. a=range:npt=now-  
  42. a=framerate:5  
  43. a=framesize:96 176-144  
  44. a=cliprect:0,0,144,176  
  45. a=control:trackID=1  
  46.   
  47. SETUP rtsp://218.207.101.236:554/mobile/3/67A451E937422331/8jH5QPU5GWS07Ugn.sdp/trackID=1  
  48.  RTSP/1.0  
  49. Cseq: 3  
  50. Transport: RTP/AVP;UNICAST;client_port=16264-16265;mode=play  
  51.   
  52.   
  53. 返回内容：  
  54. RTSP/1.0 200 OK  
  55. Server: PVSS/1.4.8 (Build/20090111; Platform/Win32; Release/StarValley; )  
  56. Cseq: 3  
  57. Session: 15470472221769  
  58. Date: Mon, 03 Aug 2009 08:50:36 GMT  
  59. Expires: Mon, 03 Aug 2009 08:50:36 GMT  
  60. Transport: RTP/AVP;UNICAST;mode=play;client_port=16264-16265;server_port=20080-20081  
  61.   
  62.   
  63. PLAY rtsp://218.207.101.236:554/mobile/3/67A451E937422331/8jH5QPU5GWS07Ugn.sdp RTSP/1.0  
  64. Session: 15470472221769  
  65. Cseq: 4  
  66.   
  67.   
  68. 返回内容：  
  69. RTSP/1.0 200 OK  
  70. Server: PVSS/1.4.8 (Build/20090111; Platform/Win32; Release/StarValley; )  
  71. Cseq: 4  
  72. Session: 15470472221769  
  73. RTP-Info: url=rtsp://218.207.101.236:554/mobile/3/67A451E937422331/8jH5QPU5GWS07Ugn.sdp/trackID=1;seq=0;rtptime=0  
  74.   
  75.   
  76. PAUSE rtsp://218.207.101.236:554/mobile/3/67A451E937422331/8jH5QPU5GWS07Ugn.sdp/ RTSP/1.0  
  77. Cseq: 5  
  78. Session: 15470472221769  
  79.   
  80.   
  81. 返回内容：  
  82. RTSP/1.0 200 OK  
  83. Server: PVSS/1.4.8 (Build/20090111; Platform/Win32; Release/StarValley; )  
  84. Cseq: 5  
  85. Session: 15470472221769  
  86.   
  87.   
  88. TEARDOWN rtsp://218.207.101.236:554/mobile/3/67A451E937422331/8jH5QPU5GWS07Ugn.sdp/ RTSP/1.0  
  89. Cseq: 6  
  90. User-Agent: RealMedia Player HelixDNAClient/10.0.0.11279 (win32)  
  91. Session: 15470472221769  
  92.   
  93.   
  94. 返回内容：  
  95. RTSP/1.0 200 OK  
  96. Server: PVSS/1.4.8 (Build/20090111; Platform/Win32; Release/StarValley; )  
  97. Cseq: 6  
  98. Session: 15470472221769  
  99. Connection: Close  
  100.   
  101.   
  102. 端口关闭成功  

 对照运行结果,读者可以熟悉RTSP的常用命令.

RTSP协议详解

标签：网上   gen   cancel   dir   streaming   reg   put   remote   lease   

原文地址：http://www.cnblogs.com/lidabo/p/6553212.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！