背景与痛点

现在很多监控摄像头、直播推流设备使用的是RTSP或RTMP协议，但现代浏览器已经不再支持这些协议的直接播放。前端开发同学经常会遇到这样的需求：如何让网页直接播放这些流媒体？这时候就需要通过后端将RTSP/RTMP流转码为浏览器支持的FLV格式。

技术选型

在Java生态中，我们有几种方案可以实现这个转换：

1. FFmpeg：功能强大，支持几乎所有音视频格式转换，社区活跃
2. GStreamer：跨平台多媒体框架，但Java集成较复杂
3. 商业SDK：如Wowza等，但成本较高

综合考虑开发成本和技术成熟度，FFmpeg是最佳选择。它可以通过Java直接调用命令行工具，或者使用Java封装库如FFmpeg-Java。

核心实现

FFmpeg转码部分

1. 首先需要安装FFmpeg并确保它在系统PATH中
2. 构建转码命令，将RTSP转为FLV

ffmpeg -i rtsp://your_stream_url -c copy -f flv rtmp://localhost/live/streamkey

Java调用FFmpeg

ProcessBuilder pb = new ProcessBuilder(
    "ffmpeg",
    "-i", "rtsp://your_stream_url",
    "-c", "copy",
    "-f", "flv",
    "rtmp://localhost/live/streamkey"
);
Process process = pb.start();

WebSocket传输实现

1. 创建Spring Boot WebSocket服务
2. 客户端通过WebSocket接收FLV流

@ServerEndpoint("/stream/{streamId}")
public class StreamWebSocket {
    @OnOpen
    public void onOpen(Session session, @PathParam("streamId") String streamId) {
        // 初始化流连接
    }

    @OnMessage
    public void onMessage(String message, Session session) {
        // 处理客户端消息
    }
}

完整代码示例

// FFmpeg命令构建工具类
public class FFmpegUtil {
    public static Process startStreamConversion(String inputUrl, String outputUrl) {
        try {
            ProcessBuilder pb = new ProcessBuilder(
                "ffmpeg",
                "-i", inputUrl,
                "-c", "copy",
                "-f", "flv",
                outputUrl
            );
            return pb.start();
        } catch (IOException e) {
            throw new RuntimeException("启动FFmpeg失败", e);
        }
    }
}

// WebSocket处理器
@ServerEndpoint("/live/{streamId}")
public class LiveStreamEndpoint {
    private static final Map<String, Session> sessions = new ConcurrentHashMap<>();

    @OnOpen
    public void onOpen(Session session, @PathParam("streamId") String streamId) {
        sessions.put(streamId, session);
    }

    // 其他WebSocket事件处理方法...
}

性能优化与安全

性能优化

1. 使用硬件加速：添加-hwaccel参数
2. 调整缓冲区大小：-bufsize参数
3. 多线程处理：-threads参数

安全防护

1. 流地址鉴权：在WebSocket连接时验证token
2. IP白名单限制
3. 流访问频率控制

常见问题解决方案

1. 内存泄漏：确保及时关闭FFmpeg进程
2. 高并发处理：使用连接池管理FFmpeg进程
3. 流中断重连：实现自动重连机制

总结与思考

通过这套方案，我们成功实现了浏览器播放RTSP/RTMP流的功能。实际应用中还可以考虑：

1. 如何进一步降低延迟？
2. 是否支持HLS等其他格式？
3. 如何实现动态码率调整？

这些优化方向留给大家思考和实践。如果你有更好的解决方案，欢迎在评论区分享！