package module;

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

public class RTSPServer {
    public static void main(String[] args) {
        try {
            // 创建ServerSocket来监听客户端连接
            int port =554;
            ServerSocket serverSocket = new ServerSocket(port);

            System.out.println("RTSP Server is running...");

            while (true) {
                // 等待客户端连接
                Socket clientSocket = serverSocket.accept();
                System.out.println("Client connected: " + clientSocket.getInetAddress());

                // 获取输入和输出流
                BufferedReader inputStream = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
                BufferedWriter outputStream = new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream()));

                // 读取客户端的RTSP请求
                String request = inputStream.readLine();
                System.out.println("Client Request: " + request);

                // 发送RTSP响应
                String response = "RTSP/1.0 200 OK\r\n";
                response += "Content-Type: application/sdp\r\n";
                response += "Content-Length: 123\r\n";
                response += "\r\n";
                response += "SDP data goes here..."; // 此处应该包含SDP描述信息
                outputStream.write(response);
                outputStream.flush();

                // 关闭连接
                clientSocket.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}