实战踩坑：用Java+SpringBoot处理GB28181的RTP PS流，转RTMP推流（附完整代码）

GB28181流媒体实战：Java+SpringBoot实现RTP PS流转RTMP推流全解析

在视频监控与智能安防领域，GB28181协议作为国家标准协议，已经成为设备互联互通的重要技术规范。本文将深入探讨如何基于Java+SpringBoot技术栈，实现GB28181协议中RTP PS流的接收、解析与RTMP推流的完整技术方案，并分享实际开发中的关键问题与优化经验。

1. GB28181协议栈与RTP PS流解析基础

GB28181协议定义了视频监控系统中的设备发现、媒体传输、控制信令等核心功能。其中媒体传输主要采用RTP/RTCP协议承载PS（Program Stream）封装格式的视频数据。

RTP PS流的核心特征：

• 基于UDP传输，存在丢包和乱序问题
• 每个RTP包包含12字节头部+PS负载
• PS流以00 00 01 BA开头标识系统头
• I帧以00 00 01 BB标识，P帧以00 00 01 E0标识

// RTP头部解析示例 public class BitUtils { public static int byte2ToInt(byte b1, byte b2) { return ((b1 & 0xff) << 8) + (b2 & 0xff); } public static int byte4ToInt(byte b1, byte b2, byte b3, byte b4) { return ((b1 & 0xff) << 24) + ((b2 & 0xff) << 16) + ((b3 & 0xff) << 8) + (b4 & 0xff); } }

PS流解析关键步骤：

1. 识别RTP序列号处理乱序问题
2. 解析PS系统头获取时间基准信息
3. 提取PES包中的视频/音频数据
4. 处理时间戳(PTS/DTS)同步问题

2. SpringBoot集成GB28181协议栈

2.1 网络层实现方案

针对GB28181的两种传输模式，我们需要分别实现TCP和UDP处理器：

// UDP处理器核心逻辑 public class SsrcUdpHandler { private Map<Integer, Packet> mPacketMap = new HashMap<>(60); private ConcurrentLinkedDeque<Integer> mSeqMap = new ConcurrentLinkedDeque<>(); public void read(byte[] copyData) { int seq = BitUtils.byte2ToInt(copyData[2], copyData[3]); // 识别关键帧类型 if (copyData.length > 16 && copyData[12] == 0 && copyData[13] == 0 && copyData[14] == 1 && (copyData[15] & 0xff) == 0xba) { int stuffingLength = copyData[25] & 7; int startIndex = 25 + stuffingLength + 1; // I帧识别 if (copyData[startIndex] == 0 && copyData[startIndex+1] == 0 && copyData[startIndex+2] == 1 && (copyData[startIndex+3] & 0xff) == 0xbb) { packet = new Packet(seq, copyData, Packet.I); } // P帧处理 else { packet = new Packet(seq, copyData, Packet.P); } mSeqMap.add(seq); mPacketMap.put(seq, packet); } } }

2.2 流媒体处理架构设计

核心组件交互流程：

1. Netty网络层接收原始RTP数据包
2. 序列化处理器处理乱序和丢包
3. PS解析器提取ES基本流
4. RTMP推流器封装FLV格式

[网络层] → [缓存排序] → [PS解析] → [RTMP封装] (UDP/TCP) (I/P帧处理) (JavaCV)

3. RTP PS流转RTMP关键技术实现

3.1 PS流解析优化策略

针对海康等厂商设备的兼容性问题，需要特别注意：

1. 时间基准处理：部分设备使用90000时间基准，需转换为毫秒
2. 缓存机制：设置5帧缓存缓解UDP乱序问题
3. 首帧丢弃：非I帧数据直接丢弃直到首个I帧

// 时间戳处理逻辑 public void onPts(long pts, boolean isAudio) { if (isAudio) return; // 识别时间基准(90000或1000) if (mLastPts == 0 && pts != 0) { mIs90000TimeBase = (pts >= 3000); } // 时间基准转换 if (mIs90000TimeBase) { pts = pts / 90; } // 防止时间戳回退 if (mLastPts != 0 && pts < mLastPts) { pts = mLastPts + 40; } mPtsQueue.add(pts); mLastPts = pts; }

3.2 JavaCV推流实战

基于JavaCV的推流器需要解决的关键问题：

1. 管道阻塞控制：设置合理的缓冲区大小(建议1024字节)
2. 时间戳同步：手动维护视频PTS队列
3. 异常恢复：实现超时检测机制

推流器核心配置：

public class RtmpPusher implements Runnable { private FFmpegFrameGrabber grabber; private CustomFFmpegFrameRecorder recorder; public void startRemux() { grabber = new FFmpegFrameGrabber(pis, 1024); // 关键：控制缓冲区大小 grabber.start(); recorder = new CustomFFmpegFrameRecorder(address, width, height, 0); recorder.setVideoCodec(AV_CODEC_ID_H264); recorder.setFormat("flv"); recorder.start(grabber.getFormatContext()); // 超时检测线程 SsrcLiveCheck.rtmps.add(this); } public void run() { while (mRunning) { AVPacket avPacket = grabber.grabPacket(); if (avPacket != null) { Long pts = mPtsQueue.poll(); recorder.recordPacket(avPacket, pts, pts); } } } }

4. 性能优化与异常处理

4.1 内存管理最佳实践

1. 对象池技术：复用Packet对象减少GC压力
2. 及时释放资源：AVPacket必须调用av_packet_unref
3. 缓冲区控制：限制队列最大长度防止OOM

// 内存释放示例 try { recorder.recordPacket(avPacket, pts, pts); } finally { av_packet_unref(avPacket); }

4.2 常见问题解决方案

问题现象：推流延迟逐渐增大
解决方案：

• 调整JavaCV的grabber缓冲区大小
• 优化PTS处理逻辑，避免时间戳堆积

问题现象：长时间运行后内存泄漏
排查方法：

1. 检查Packet对象是否及时移除
2. 确认AVFrame/AVPacket是否规范释放
3. 监控JVM内存使用情况

稳定性优化配置：

5. 完整实现与部署方案

5.1 系统依赖配置

Maven关键依赖：

<dependency> <groupId>org.bytedeco</groupId> <artifactId>javacv</artifactId> <version>1.5.6</version> </dependency> <dependency> <groupId>org.bytedeco</groupId> <artifactId>ffmpeg-platform</artifactId> <version>4.3.2-1.5.6</version> </dependency>

5.2 SpringBoot集成示例

@Configuration public class GB28181Config { @Bean public CommonParser commonParser() { return new CommonParser(); } @Bean public SsrcLiveCheck ssrcLiveCheck() { return new SsrcLiveCheck(); } @Bean(destroyMethod = "stop") public MediaUdpHandler mediaUdpHandler(CommonParser parser) { return new MediaUdpHandler(parser); } }

5.3 监控与运维建议

1. 指标监控：

   • 推流帧率与延迟
   • 内存使用情况
   • 网络丢包率

2. 日志配置：

logging.level.com.yourpackage.media=DEBUG logging.file.name=gb28181.log

3. 健康检查API：

@RestController @RequestMapping("/monitor") public class MonitorController { @GetMapping("/streams") public List<StreamStats> getActiveStreams() { return SsrcLiveCheck.getStats(); } }

在实际项目部署中，我们发现海康摄像头的PS流封装存在一些特殊情况，特别是在时间戳处理上需要额外注意。通过引入动态时间基准检测机制，成功解决了不同厂商设备的兼容性问题。对于高并发场景，建议采用线程隔离策略，每个视频流独立处理线程，避免相互影响。