Java RTSP 拉流实现指南 - 示例代码与解析

以下是使用 Java 实现 RTSP 拉流的示例代码：

import java.net.*;
import java.io.*;

public class RTSPClient {
    
    private String serverAddress;
    private int serverPort;
    private String streamName;

    private Socket socket;
    private BufferedReader reader;
    private PrintWriter writer;

    public RTSPClient(String serverAddress, int serverPort, String streamName) {
        this.serverAddress = serverAddress;
        this.serverPort = serverPort;
        this.streamName = streamName;
    }

    public void connect() throws IOException {
        socket = new Socket(serverAddress, serverPort);
        reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        writer = new PrintWriter(socket.getOutputStream(), true);
    }

    public void setup() throws IOException {
        String request = 'SETUP rtsp://' + serverAddress + ':' + serverPort + '/' + streamName + ' RTSP/1.0\r\n';
        request += 'CSeq: 1\r\n';
        request += 'Transport: RTP/AVP;unicast;client_port=8000-8001\r\n';
        request += '\r\n';
        writer.print(request);
        writer.flush();

        String response = reader.readLine();
        if (!response.startsWith('RTSP/1.0 200 OK')) {
            throw new IOException('Invalid response: ' + response);
        }
    }

    public void play() throws IOException {
        String request = 'PLAY rtsp://' + serverAddress + ':' + serverPort + '/' + streamName + ' RTSP/1.0\r\n';
        request += 'CSeq: 2\r\n';
        request += '\r\n';
        writer.print(request);
        writer.flush();

        String response = reader.readLine();
        if (!response.startsWith('RTSP/1.0 200 OK')) {
            throw new IOException('Invalid response: ' + response);
        }
    }

    public void receive() throws IOException {
        DatagramSocket socket = new DatagramSocket(8000);
        byte[] buffer = new byte[4096];
        DatagramPacket packet = new DatagramPacket(buffer, buffer.length);

        while (true) {
            socket.receive(packet);
            byte[] data = packet.getData();
            // 处理数据...
        }
    }

    public void teardown() throws IOException {
        String request = 'TEARDOWN rtsp://' + serverAddress + ':' + serverPort + '/' + streamName + ' RTSP/1.0\r\n';
        request += 'CSeq: 3\r\n';
        request += '\r\n';
        writer.print(request);
        writer.flush();

        String response = reader.readLine();
        if (!response.startsWith('RTSP/1.0 200 OK')) {
            throw new IOException('Invalid response: ' + response);
        }
    }

    public void disconnect() throws IOException {
        reader.close();
        writer.close();
        socket.close();
    }

    public static void main(String[] args) {
        try {
            RTSPClient client = new RTSPClient('192.168.1.100', 554, 'test');
            client.connect();
            client.setup();
            client.play();
            client.receive();
            client.teardown();
            client.disconnect();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

在上面的示例中，RTSPClient类代表了一个RTSP客户端，包含了连接、建立会话、拉流、断开连接等方法。在main方法中创建实例并调用这些方法即可。具体实现如下：

1. 首先创建一个RTSPClient对象，传入服务器地址、端口号和流名。
2. 调用connect方法连接服务器。
3. 调用setup方法建立会话。其中，请求头中的Transport字段指定了RTP流的传输方式和客户端端口号范围。
4. 调用play方法开始拉流。
5. 调用receive方法接收RTP数据包。这里使用一个DatagramSocket对象来接收数据包，一旦接收到数据包，就可以进行处理了。这里的处理方式因具体需求而异。
6. 调用teardown方法结束会话。
7. 调用disconnect方法断开连接。

需要注意的是，在建立会话和结束会话时都需要发送RTSP请求，并接收服务器的响应。这里使用了BufferedReader和PrintWriter对象来分别读取和写入数据。另外，receive方法中使用了一个无限循环来接收数据包，需要手动停止。