Java 实现Rtsp 转rtmp,hls,flv

服务支撑:FFmpeg  + srs(流媒体服务器)  

整个流程是 FFmpeg 收流转码 推 rtmp 到流媒体服务 流媒体服务再 分发流到公网

搭建流媒体服务:

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实现 (自己百度)

4. 其他的还有收费的那种 

2.服务器安装FFmpeg  yum 可以安装

java 服务实现调用ffmpeg

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();}}}@Overridepublic 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")@ResponseBodypublic void start(@RequestParam(defaultValue = "1") String channel){RtspUrlBuilder builder = new RtspUrlBuilder();RtmpUrlBuilder rtmpUrlBuilder = new RtmpUrlBuilder();//构建 rtsp 这个是客户的nvr rtsp 地址 只有channel 是灵活的 他们是64路 现在接了50多摄像头对应50 多路channelString 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")@ResponseBodypublic 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() {// 默认端口为554this.port = 554;// 默认子类型为0this.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.1this.ipAddress = "127.0.0.1";// 默认端口为1935this.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;}
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/36050.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

python菱形问题

Python类分为两种&#xff0c;一种叫经典类&#xff0c;一种叫新式类。都支持多继承&#xff0c;但继承顺序不同。 新式类&#xff1a;从object继承来的类。&#xff08;如:class A(object)&#xff09;&#xff0c;采用广度优先搜索的方式继承&#xff08;即先水平搜索&#…

【二分答案】CF803 D

感觉之前的*1900好简单 Problem - D - Codeforces 题意&#xff1a; 思路&#xff1a; 注意到宽度具有单调性&#xff0c;考虑二分宽度 然后限制了最大宽度&#xff0c;要使行数 < k 那么在check里贪心&#xff0c;每行选的尽可能多 考虑双指针&#xff0c;每次选长度…

Spring MVC相关知识点

1.Spring MVC的理解&#xff1f; 首先&#xff0c;MVC模型是模型&#xff0c;视图&#xff0c;控制器的简写&#xff0c;其思想核心是通过将请求处理控制&#xff0c;业务逻辑&#xff0c;数据封装&#xff0c;数据显示等流程节点分离的思想来组织代码。 所以&#xff0c;MVC…

SpringBoot复习:(47)ConfigFileApplicationListener

它监听ApplicationEnvironmentPreparedEvent和ApplicationPreparedEvent。 它会把配置文件中配置的内容注入到环境中去&#xff0c;配置文件也就生效了

融云荣获「2023 中国数字生态通信领军企业」奖

融云北极星如何协助开发者排查问题和预警风险&#xff1f; 8月17日直播课&#xff0c;点击上方报名~ 由 B.P 商业伙伴主办的“2023 数字生态大会”于 8 月 4 日在京举行&#xff0c;融云携数智办公解决方案受邀参展&#xff0c;并获“2023 中国数字生态通信领军企业”奖。关注【…

详解VCC、VDD、VEE、VSS

VCC、 VDD、VEE、VSS 版本一&#xff1a; 简单说来&#xff0c;可以这样理解&#xff1a; 一、解释 VCC&#xff1a;Ccircuit 表示电路的意思, 即接入电路的电压&#xff1b; VDD&#xff1a;Ddevice 表示器件的意思, 即器件内部的工作电压&#xff1b; VSS&#xff1a;Sser…

vue3+element-plus组件下拉列表,数组数据转成树形数据

引入组件 可以直接在项目中引入element-plus表格组件&#xff0c;如果需要变成下拉列表样式需要添加以下属性&#xff1a; row-key 必填 最好给数字或唯一属性 &#xff0c; 给每个节点设置id 不填的话 没有办法实现展开效果 load 这个是动态添加数据的 前提&#xff08;开启…

使用MyEclipse如何部署Descriptor (XML)编辑器?

Descriptor (XML) Editor编辑器包含了高级的XML编辑功能&#xff0c;在本文中您将了解到这些编辑功能、Web XML编辑等&#xff0c;此功能包含在MyEclipse中可用。 MyEclipse v2023.1.2离线版下载 1. Web XML 编辑器 MyEclipse Web XML编辑器包括高级XML编辑功能&#xff0c;…

最新AI创作系统ChatGPT程序源码+详细搭建部署教程+微信公众号版+H5源码/支持GPT4.0+GPT联网提问/支持ai绘画+MJ以图生图+思维导图生成!

使用Nestjs和Vue3框架技术&#xff0c;持续集成AI能力到系统&#xff01; 新增 MJ 官方图片重新生成指令功能同步官方 Vary 指令 单张图片对比加强 Vary(Strong) | Vary(Subtle)同步官方 Zoom 指令 单张图片无限缩放 Zoom out 2x | Zoom out 1.5x新增GPT联网提问功能、手机号注…

深入了解 Postman Test 校验的使用方法

Postman 是一个广泛使用的 API 开发工具&#xff0c;它允许开发人员测试 API 的各个方面&#xff0c;包括请求、响应、身份验证等等&#xff0c;其中最常用的功能之一就是 Test 校验。那今天就一起来看看 Postman 的 Test 校验该如何使用。 Test 校验是什么&#xff1f; Test…

【Spring】浅谈spring为什么推荐使用构造器注入

目录 一、前言 二、常见的三种注入方式 2.1 field注入 2.2 构造器注入 2.3 setter注入 三、构造器注入的好处 四、答疑 五、总结 一、前言 ​ Spring框架对Java开发的重要性不言而喻&#xff0c;其核心特性就是IOC&#xff08;Inversion of Control&#xff0c; 控制反转&…

RunLoop

1.CFRunLoopModeRef特征代表RunLoop对象内的运行模式(每个RunLoop对象内存中存在很多种运行模式,每个Mode运行模式下必然包含若干个有效的Source0/Source1/Timer/Observer数据序组) 2.RunLoop对象活跃(操作)启动时能且仅能选择某个Mode匹配currentMode(暗示Loop对象的操作运行必…

分类预测 | MATLAB实现BO-BiGRU贝叶斯优化双向门控循环单元多输入分类预测

分类预测 | MATLAB实现BO-BiGRU贝叶斯优化双向门控循环单元多输入分类预测 目录 分类预测 | MATLAB实现BO-BiGRU贝叶斯优化双向门控循环单元多输入分类预测预测效果基本介绍模型描述程序设计参考资料 预测效果 基本介绍 1.Matlab实现BO-BiGRU贝叶斯优化双向门控循环单元多特征分…

2.1.2 VisionOS——VisionOS 中的窗口化应用程序

在visionOS中&#xff0c;用户可以使用窗口来呈现2D或3D内容&#xff0c;或者使用体积来呈现3D内容和对象。Unity 将这些窗口中的应用程序描述为“窗口应用程序”。 默认情况下&#xff0c;如果您构建针对visionOS 平台的Unity 应用程序而未通过XR 插件管理器启用PolySpatial …

React - useEffect函数的理解和使用

文章目录 一&#xff0c;useEffect描述二&#xff0c;它的执行时机三&#xff0c;useEffect分情况使用1&#xff0c;不写第二个参数 说明监测所有state&#xff0c;其中一个变化就会触发此函数2&#xff0c;第二个参数如果是[]空数组&#xff0c;说明谁也不监测3&#xff0c;第…

gRPC vs REST:创建API的方法比较

本文对gRPC和REST的特征和区别进行了介绍&#xff0c;这可能是当今创建API最常用的两种方法。 文章目录 一、gRPC的介绍 二、什么是REST&#xff1f; 三、什么是gRPC? 四、gRPC和REST的比较 &#xff08;1&#xff09;底层HTTP协议 &#xff08;2&#xff09;支持的数据…

平替 Docker - 玩转容器新利器 Podman Desktop (视频)

《OpenShift 4.x HOL教程汇总》 在 podman-desktop 1.2.1 podman 4.4 环境中验证。 文章目录 什么是 podman 和 podman-desktop安装 podman 和 podman-desktop 基本环境Image、Container 和 Pod 的基本操作拉取 Image运行 Container 将 Pod 部署到 Kubernetes安装 Kind 扩展插…

Python爬虫——selenium_元素定位

元素定位&#xff1a;自动化要做的就是模拟鼠标和键盘来操作这些元素&#xff0c;点击&#xff0c;输入等等。操作这些元素前首先要找到它们&#xff0c;WebDriver提供很多定位元素的方法 from selenium import webdriver# 创建浏览器对象 path files/chromedriver.exe brows…

【安全】浅谈信息安全

信息安全 理解信息安全&#xff0c;要从“信息”、“安全”两个角度入手。 信息 信息是对客观世界的反映&#xff0c;表现客观事物的运动状态和变化的实质内容。 信息具有可识别、可传载、可共享、可度量的基本特征。 信息系统 信息系统是获取&#xff08;收集&#xff0…

中心对称链表

文章目录 1 题目2 思路2.1 思路一2.2 思路二2.3 考点2.4 扩展 3 实现3.1 思路13.2 思路23.3 完整例子 1 题目 已知长度为n&#xff08;n>1&#xff09;的单链表&#xff0c;表头指针为L&#xff0c;结点结构由data和next两个域构成&#xff0c;其中data域为字符型&#xff…