服务支撑：FFmpeg + srs(流媒体服务器)
整个流程是 java 调用 FFmpeg 收流转码 并把流推 rtmp 到流媒体服务 ，流媒体服务再分发流到公网（如果使用得流媒体服务器支持转协议 可以分发 flv ,hls等）
搭建流媒体服务:
1.
SRS (Simple Realtime Server) | SRS
（
本例子使用的是SrS 安装使用docker
）
2.
GitHub - ZLMediaKit/ZLMediaKit: WebRTC/RTSP/RTMP/HTTP/HLS/HTTP-FLV/WebSocket-FLV/HTTP-TS/HTTP-fMP4/WebSocket-TS/WebSocket-fMP4/GB28181/SRT server and client framework based on C++11
3.nginx实现 （自己百度，他这个只实现了rtmp 要单独下载插件做支持）
4. 其他的还有收费的那种
2.服务器安装FFmpeg yum 可以安装
java 服务实现调用ffmpeg开始拉rtsp 转码推流
1.ProcessManager 用于执行指令以及 关闭这个流等操作
package io.renren.common.live;
import cn.hutool.core.thread.ThreadUtil;
import org.springframework.beans.factory.DisposableBean;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.lang.ref.WeakReference;
import java.util.HashMap;
import java.util.Map;
* @author chenkang
* @date 2023年8月3日09:43:21
public class ProcessManager implements DisposableBean {
private Map<String, WeakReference<Process>> processMap=new HashMap<>();
* 启动一个进程
* @param processName 进程名称key
* @param command 执行指令
public void startProcess(String processName, String command) {
ThreadUtil.execAsync(() -> {
try {
ProcessBuilder processBuilder = new ProcessBuilder(command.split(" "));
Process process = processBuilder.start();
processMap.put(processName, new WeakReference<>(process));
BufferedReader reader = new BufferedReader(new InputStreamReader(process.getErrorStream()));
String line;
while ((line = reader.readLine()) != null) {
System.out.println(processName + ": " + line);
int exitCode = process.waitFor();
System.out.println(processName + ": Process execution completed with exit code: " + exitCode);
} catch (IOException | InterruptedException e) {
e.printStackTrace();
* 销毁
* @param processName key
public void terminateProcess(String processName) {
WeakReference<Process> weakRef = processMap.get(processName);
if (weakRef != null) {
Process process = weakRef.get();
if (process != null) {
process.destroy();
processMap.remove(processName);
private void terminateAllProcesses() {
for (WeakReference<Process> weakRef : processMap.values()) {
Process process = weakRef.get();
if (process != null) {
process.destroy();
@Override
public void destroy() throws Exception {
this.terminateAllProcesses();
this.processMap.clear();
对接的是大华的摄像头
/**
* 开始推流
* 备注：现在客户的设备是NVR NVR 下大概有54个摄像头 公网映射rtsp 554 端口 根据channel 开区分是那个摄像头
* 必须条件：1.服务端要安装好 ffmpeg 2.要搭建一个流媒体服务器 这个使用的是 srs
* 流程：用户端想要查看某个摄像头->查询到设备信息获取到摄像头的channel 这个是提前维护好的
* ->拿到channel走如下方法 调用FFmpeg 执行转码推流指令（客户的摄像头是h265）-》rtsp流会被转码 重新设定分辨率 码率转h264 并把转码流推向流媒体服务器 srs
* ->客户想看的时候就 拉取 流媒体服务端的rtmp流 完成播放
*
* 其他：
* 1.用户再播放的时候 要先确定这个摄像头有没有别的人在观看 观看了就不在执行了 （1.可以调用srs 接口查询流是不是存在 这个比较稳妥 2.或者是 processManager 判断是否在推了）
* 2.有时候用户强制关闭客户端 无法感知用户不在观看了，这面还要 定时的去调用srs 接口查询闲置的流及时的给关闭 同时也要 把服务的process 给主动关闭不然一直推
* 这个要先去关闭process再调用接口关闭srs服务的流
*
*
* http://127.0.0.1:1985/api/v1/streams 查询服务端所有流
*{
* "code": 0,
* "server": "vid-f1gt8j3",
* "streams": [
* {
* "id": "vid-143p019",
* //streamName
* "name": "3",
* "vhost": "vid-5847096",
* "app": "live",
* "live_ms": 1691039306435,
* //客户端数量 这个要注意 默认就有1 个客户端是推流
* "clients": 1,
* "frames": 0,
* "send_bytes": 0,
* "recv_bytes": 1068,
* "kbps": {
* "recv_30s": 0,
* "send_30s": 0
* },
* "publish": {
* //是否正在推流 有时候服务端流停推了 但是还有客户端在看 这个流还能查到 但是 active 为false
* "active": false,
* "cid": ""
* },
* "video": null,
* "audio": null
* }
* ]
* }
*
*
*
* http://127.0.0.1:1985/api/v1/clients
*
*{
* "code": 0,
* "server": "vid-f1gt8j3",
* "clients": [
* {
* "id": "868249e9",
* "vhost": "vid-5847096",
* "stream": "vid-778ujy0",
* "ip": "172.17.0.1",
* "pageUrl": "",
* "swfUrl": "",
* "tcUrl": "rtmp://127.0.0.1:1935/live",
* "url": "/live/9",
* //类型是 fmle-publish 推流 删除掉这个推流就会停止
* //类型是 rtmp-play 拉流 删除掉这个拉流就会停止
* //剔除方法 Method DELETE api /api/v1/clients/{id} 停止推流/踢掉用户端
* "type": "fmle-publish",
* "publish": true,
* "alive": 16.18,
* "kbps": {
* "recv_30s": 0,
* "send_30s": 0
* }
* }
* ]
* }
*
*
* @param channel
*/
@GetMapping("/start")
@ResponseBody
public void start(@RequestParam(defaultValue = "1") String channel){
RtspUrlBuilder builder = new RtspUrlBuilder();
RtmpUrlBuilder rtmpUrlBuilder = new RtmpUrlBuilder();
//构建 rtsp 这个是客户的nvr rtsp 地址 只有channel 是灵活的 他们是64路 现在接了50多摄像头对应50 多路channel
String rstp = builder.setUsername("admin")
.setPassword("xx")
.setIpAddress("xx")
.setChannel(channel)
.build();
//这个是流媒体服务器的rtmp 推流地址
String rtmp = rtmpUrlBuilder.setApplication("live").setStreamName(channel).build();
final String vcodec="libx264";
String camera1=String.format(RTSP_RTMP, rstp,vcodec,rtmp);
//TODO 判断是否已经再推了 推就直接返回拉流地址
processManager.startProcess(channel,camera1);
//拉流地址和推流地址是一至的 除非 java 服务和srs 在一台服务器 那么 推流地址 rtmp ip为127.0.0.1 拉流 rtmp ip 为公网
// 就是java通过ffmpeg 收流转发到本地 rtmp srs分发流 到公网去
System.out.println("拉流地址："+rtmp);
@GetMapping("/end")
@ResponseBody
public void end(String channel){
processManager.terminateProcess(channel);
两个辅助类：
package io.renren.common.live;
* @author chenkang
* @date 2023-8-3 12:27
public class RtspUrlBuilder {
private String username;
private String password;
private String ipAddress;
private int port;
private String channel;
private int subtype;
public RtspUrlBuilder() {
// 默认端口为554
this.port = 554;
// 默认子类型为0
this.subtype = 0;
public RtspUrlBuilder setUsername(String username) {
this.username = username;
return this;
public RtspUrlBuilder setPassword(String password) {
this.password = password;
return this;
public RtspUrlBuilder setIpAddress(String ipAddress) {
this.ipAddress = ipAddress;
return this;
public RtspUrlBuilder setPort(int port) {
this.port = port;
return this;
public RtspUrlBuilder setChannel(String channel) {
this.channel = channel;
return this;
public RtspUrlBuilder setSubtype(int subtype) {
this.subtype = subtype;
return this;
public String build() {
return "rtsp://" + username + ":" + password + "@" + ipAddress + ":" + port +
"/cam/realmonitor?channel=" + channel + "&subtype=" + subtype;
package io.renren.common.live;
* @author chenkang
* @date 2023-8-3 12:30
public class RtmpUrlBuilder {
private String ipAddress;
private int port;
private String application;
private String streamName;
public RtmpUrlBuilder() {
// 默认IP地址为127.0.0.1
this.ipAddress = "127.0.0.1";
// 默认端口为1935
this.port = 1935;
public RtmpUrlBuilder setIpAddress(String ipAddress) {
this.ipAddress = ipAddress;
return this;
public RtmpUrlBuilder setPort(int port) {
this.port = port;
return this;
public RtmpUrlBuilder setApplication(String application) {
this.application = application;
return this;
public RtmpUrlBuilder setStreamName(String streamName) {
this.streamName = streamName;
return this;
public String build() {
return "rtmp://" + ipAddress + ":" + port + "/" + application + "/" + streamName;
访问得话应该是访问流媒体得ip
ffmpeg.exe能解析的格式：（asx，asf，mpg，wmv，3gp，mp4，mov，avi，flv等）
对ffmpeg.exe无法解析的文件格式(wmv9，rm，rmvb等),
可以先用别的工具（mencoder）转换为avi(ffmpeg能解析的)格式；
mencoder.exe;drv43260.dll;pncrt.dll这3个文件是为文件格式(wmv9，rm，rmvb等）
转换为avi(ffmpeg能解析的)格式准备的；再把转换好的avi文件再用ffmpeg.exe转换成flv格式的视频文件。。。
最近项目需要把监控摄像机的RTSP流在放在浏览器上播放，但由于目前浏览器并不支持RTSP，需要转码才行。之前试过nginx作为流媒体服务器，这次尝试使用ffmpeg将码流推送srs流媒体服务器，实现浏览器端播放，特此记录一下。
SRS 是一个简单高效的实时视频服务器，支持RTMP/WebRTC/HLS/HTTP-FLV/SRT
源码地址：
githup:https://github.com/ossrs/srs
gitee:https://gitee.com/ossrs/srs
1....
您好，您的问题是关于视频转码器的使用方法，如果您需要将H.265编码的16路监控摄像头的RTSP流转换为RTMP、HLS或FLV等常见的视频协议，您可以考虑使用一些专业的视频转码器软件，例如FFmpeg、Wowza Streaming Engine、Nimble Streamer等。
这些软件都提供了非常灵活的配置选项，可以满足不同的转码需求和网络环境。您可以根据自己的具体情况选择合适的软件，并参考相关的文档和教程进行配置和使用。另外，建议您在使用视频转码器时注意网络带宽和服务器性能等因素，以保证视频流的稳定和流畅。
