产品解决方案文档与社区权益中心定价云市场合作伙伴支持与服务了解阿里云
联系我们
4008013260
售前咨询售后服务
其他服务
我要建议我要投诉
备案控制台
探索云世界
开发者社区 开发与运维 文章 正文

RTSP协议详解

2017-03-15 3456
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： RTSP简介     RTSP（Real Time Streaming Protocol）是由Real Network和Netscape共同提出的如何有效地在IP网络上传输流媒体数据的应用层协议。
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的常用命令.

文章标签：
Java
移动开发
流计算
网络协议
double2li
目录
相关文章
须尽欢~~
|
15天前
|
存储 网络协议 网络安全
RTSP协议抓包及讲解（三）
RTSP协议抓包及讲解
须尽欢~~
16 1
长征2号
|
网络性能优化 网络架构 网络协议
rtp协议详解/rtcp协议详解
长征2号
4419 0
须尽欢~~
|
15天前
|
存储 编解码 移动开发
RTSP协议抓包及讲解（一）
RTSP协议抓包及讲解
须尽欢~~
24 0
须尽欢~~
|
15天前
|
移动开发 网络协议 Windows
RTSP协议抓包及讲解（二）
RTSP协议抓包及讲解
须尽欢~~
27 1
No8g攻城狮
|
6月前
|
网络协议 网络安全 流计算
【流媒体】RTMP、RTSP、HLS、HTTP协议的介绍与对比
【流媒体】RTMP、RTSP、HLS、HTTP协议的介绍与对比
No8g攻城狮
158 0
稀风
|
3月前
|
编解码 网络协议 流计算
RTSP协议介绍
RTSP协议介绍
稀风
73 0
稀风
|
3月前
|
Linux C语言
RTSP协议的实现
RTSP协议的实现
稀风
30 0
音视频牛哥
|
7月前
|
监控 网络协议
RTSP、RTMP、HTTP协议区别
HTTP将数据作为文件处理，所以HTTP不是流媒体协议，RTMP和RTSP是流媒体协议。 RTMP是Adobe的私有协议，未完全公开，RTSP和HTTP是共有协议。 RTMP一般传输flv,f4v格式流，RTSP传输ts，MP4格式流，HTTP没有特定的流。 RTSP一般需要2-3个通道，数据和命令通道分开，RTMP和HTTP在一个通道上传输命令和数据。
音视频牛哥
66 0
龙哥手记
|
缓存 网络协议 算法
认识下RTMP协议是什么
系列
龙哥手记
194 1
Tinywan.
|
网络协议 网络性能优化 流计算
RTSP协议、RTMP协议、HTTP协议的区别
理论上RTSP RTMPHTTP都可以做直播和点播，但一般做直播用RTSP RTMP，做点播用HTTP。做视频会议的时候原来用SIP协议，现在基本上被RTMP协议取代了。 RTSP、 RTMP、HTTP的共同点、区别 共同点： 1：RTSP RTMP HTTP都是在应用应用层。
Tinywan.
3063 0
为什么选择阿里云什么是云计算全球基础设施技术领先稳定可靠安全合规分析师报告
产品和定价全部产品免费试用产品动态产品定价价格计算器云上成本管理
解决方案技术解决方案
文档与社区文档开发者社区天池大赛培训与认证
权益中心免费试用高校计划企业扶持计划推荐返现计划
支持与服务基础服务企业增值服务迁云服务官网公告健康看板信任中心
关注阿里云
关注阿里云公众号或下载阿里云APP，关注云资讯，随时随地运维管控云服务
阿里云APP阿里云微信
联系我们：4008013260
法律声明Cookies政策廉正举报安全举报联系我们加入我们
阿里巴巴集团淘宝网天猫全球速卖通阿里巴巴国际交易市场1688阿里妈妈飞猪阿里云计算AliOS万网高德UC友盟优酷钉钉支付宝达摩院淘宝海外阿里云盘饿了么
© 2009-2024 Aliyun.com 版权所有 增值电信业务经营许可证： 浙B2-20080101 域名注册服务机构许可： 浙D3-20210002 京D3-20220015
浙公网安备 33010602009975号浙B2-20080101-4