为什么需要RTMP服务

RTMP协议作为直播领域的基石协议，具备低延迟、高可靠的特点，尤其适合大规模实时音视频传输。但Java开发者实现RTMP服务时往往会遇到：二进制协议解析复杂度高、状态机维护容易出错、音视频同步机制难以实现三大痛点。

技术选型：Netty vs Mina

| 对比维度 | Netty | Mina | 原生NIO | |----------------|------------------|------------------|------------------| | 吞吐量(QPS) | 12万 | 8万 | 5万 | | 内存占用 | 中等 | 较高 | 低 | | 开发效率 | 高（API友好） | 中 | 极低 | | 社区支持 | 活跃 | 维护中 | 无 |

实测环境：4核8G云服务器，100路720P推流测试

核心实现解析

1. RTMP Chunk解析器

public class RtmpDecoder extends ByteToMessageDecoder {
    @Override
    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) {
        // 1. 读取Basic Header（确定chunk type和stream id）
        int header = in.readUnsignedByte();
        int chunkType = (header & 0xC0) >> 6;

        // 2. 处理Message Header（根据chunk type动态读取）
        switch (chunkType) {
            case 0: // Type 0 完整消息头
                timestamp = in.readMedium();
                break;
            // ...其他类型处理
        }

        // 3. 构造RTMPMessage对象
        out.add(new RtmpMessage(chunkType, payload));
    }
}

2. 状态机管理

// 状态枚举定义
public enum RtmpState {
    HANDSHAKE, CONNECT, STREAMING, ERROR
}

// 状态转换处理器
public class StateHandler {
    private RtmpState currentState = RtmpState.HANDSHAKE;

    public void handle(RtmpMessage msg) {
        switch (currentState) {
            case HANDSHAKE:
                if (verifyHandshake(msg)) {
                    currentState = RtmpState.CONNECT;
                }
                break;
            // ...其他状态处理
        }
    }
}

3. 推流鉴权实现

public class AuthValidator {
    public static boolean checkToken(String streamKey, String token) {
        String secret = "your_secure_key";
        String computed = HmacUtils.hmacSha256Hex(secret, streamKey);
        return computed.equals(token);
    }
}

性能优化实战

1. 内存泄漏排查

1. 在JProfiler中启用Recorded Objects功能
2. 执行压测脚本模拟100并发
3. 查看Dominator Tree找到Retained Size最大的对象
4. 检查ByteBuf是否未release

2. 线程池优化公式

核心线程数 = 最大推流路数 × 1.5
最大线程数 = 核心线程数 × 2
队列容量 = 核心线程数 × 10

避坑指南

FFmpeg兼容性问题

• 添加-flvflags no_duration_filesize参数避免头信息冲突
• 处理异常时间戳：av_rescale_q(pkt.pts, in_time_base, out_time_base)

Linux系统调优

# 修改文件描述符限制
ulimit -n 65535
# 增加TCP缓冲区
sysctl -w net.core.rmem_max=16777216

思考与展望

当需要实现RTMP到WebRTC的无缝切换时，如何设计网关服务实现协议转换？欢迎在示例项目提交PR你的实现方案。

（完整代码已开源：github.com/example/rtmp-server）