基于SpringBoot+FFmpeg+ZLMediaKit實現(xiàn)本地視頻推流
更新時間：2025年11月03日 09:07:11 作者：皮皮林551
文章介紹了如何在服務器上安裝和配置ZLMediaKit和FFmpeg,以及如何使用SpringBoot實現(xiàn)視頻推流和播放功能,包括環(huán)境準備、后端實現(xiàn)和使用說明,涵蓋了推流和播放的完整流程,需要的朋友可以參考下
1. 環(huán)境準備
1.1 ZLMediaKit 安裝配置
下載安裝
# 拉取鏡像 docker pull zlmediakit/zlmediakit:master # 啟動 docker run -d \ --name zlm-server \ -p 1935:1935 \ -p 8099:80 \ -p 8554:554 \ -p 10000:10000 \ -p 10000:10000/udp \ -p 8000:8000/udp \ -v /docker-volumes/zlmediakit/conf/config.ini:/opt/media/conf/config.ini \ zlmediakit/zlmediakit:master
配置文件 (config.ini)
[hls] broadcastRecordTs=0 deleteDelaySec=300 # 推流的視頻保存多久(5分鐘) fileBufSize=65536 filePath=./www # 保存路徑 segDur=2 # 單個.ts 切片時長（秒）。 segNum=1000 # 直播時.m3u8 里最多同時保留多少個切片。 segRetain=9999 # 磁盤上實際保留多少個歷史切片
啟動服務
# 查看啟動狀態(tài) docker logs -f zlm-server
1.2 FFmpeg 安裝
# 下載路徑 https://www.gyan.dev/ffmpeg/builds/
這兩個都可以選
配置環(huán)境變量
C:\ffmpeg\ffmpeg-7.0.2-essentials_build\bin
找到 bin 目錄，將其配到 path 環(huán)境變量中。
出來版本就成功了。
2. Spring Boot 后端實現(xiàn)
2.1 添加依賴
<dependencies>
<!-- 進程管理 -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-exec</artifactId>
<version>1.3</version>
</dependency>
</dependencies>
2.2 推流配置類
package com.lyk.plugflow.config;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
@Data
@Component
@ConfigurationProperties(prefix = "stream")
public class StreamConfig {
/**
* ZLMediaKit服務地址
*/
private String zlmHost;
/**
* RTMP推流端口
*/
private Integer rtmpPort;
/**
* HTTP-FLV拉流端口
*/
private Integer httpPort;
/**
* FFmpeg可執(zhí)行文件路徑
*/
private String ffmpegPath;
/**
* 視頻存儲路徑
*/
private String videoPath;
}
2.3 推流服務類
package com.lyk.plugflow.service;
import com.lyk.plugflow.config.StreamConfig;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.exec.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
@Slf4j
@Service
public class StreamService {
@Autowired
private StreamConfig streamConfig;
// 存儲推流進程
private final Map<String, DefaultExecutor> streamProcesses = new ConcurrentHashMap<>();
// 添加手動停止標記
private final Map<String, Boolean> manualStopFlags = new ConcurrentHashMap<>();
/**
* 開始推流
*/
public boolean startStream(String videoPath, String streamKey) {
try {
// 檢查視頻文件是否存在
File videoFile = new File(videoPath);
if (!videoFile.exists()) {
log.error("視頻文件不存在: {}", videoPath);
returnfalse;
}
// 構建RTMP推流地址
String rtmpUrl = String.format("rtmp://%s:%d/live/%s",
streamConfig.getZlmHost(), streamConfig.getRtmpPort(), streamKey);
// 構建FFmpeg命令
CommandLine cmdLine = getCommandLine(videoPath, rtmpUrl);
// 創(chuàng)建執(zhí)行器
DefaultExecutor executor = new DefaultExecutor();
executor.setExitValue(0);
// 設置watchdog用于進程管理
ExecuteWatchdog watchdog = new ExecuteWatchdog(ExecuteWatchdog.INFINITE_TIMEOUT);
executor.setWatchdog(watchdog);
// 設置輸出流
ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
PumpStreamHandler streamHandler = new PumpStreamHandler(outputStream);
executor.setStreamHandler(streamHandler);
// 異步執(zhí)行
executor.execute(cmdLine, new ExecuteResultHandler() {
@Override
public void onProcessComplete(int exitValue) {
log.info("推流完成, streamKey: {}, exitValue: {}", streamKey, exitValue);
streamProcesses.remove(streamKey);
}
@Override
public void onProcessFailed(ExecuteException e) {
boolean isManualStop = manualStopFlags.remove(streamKey);
if (isManualStop) {
log.info("推流已手動停止, streamKey: {}", streamKey);
} else {
log.error("推流失敗, streamKey: {}, error: {}", streamKey, e.getMessage());
}
streamProcesses.remove(streamKey);
}
});
// 保存進程引用
streamProcesses.put(streamKey, executor);
log.info("開始推流, streamKey: {}, rtmpUrl: {}", streamKey, rtmpUrl);
returntrue;
} catch (Exception e) {
log.error("推流啟動失敗", e);
returnfalse;
}
}
private CommandLine getCommandLine(String videoPath, String rtmpUrl) {
CommandLine cmdLine = new CommandLine(streamConfig.getFfmpegPath());
cmdLine.addArgument("-re"); // 按原始幀率讀取
cmdLine.addArgument("-i");
cmdLine.addArgument(videoPath);
cmdLine.addArgument("-c:v");
cmdLine.addArgument("libx264"); // 視頻編碼
cmdLine.addArgument("-c:a");
cmdLine.addArgument("aac"); // 音頻編碼
cmdLine.addArgument("-f");
cmdLine.addArgument("flv"); // 輸出格式
cmdLine.addArgument("-flvflags");
cmdLine.addArgument("no_duration_filesize");
cmdLine.addArgument(rtmpUrl);
return cmdLine;
}
/**
* 停止推流
*/
public boolean stopStream(String streamKey) {
try {
DefaultExecutor executor = streamProcesses.get(streamKey);
if (executor != null) {
// 設置手動停止標記
manualStopFlags.put(streamKey, true);
ExecuteWatchdog watchdog = executor.getWatchdog();
if (watchdog != null) {
watchdog.destroyProcess();
} else {
log.warn("進程沒有watchdog，無法強制終止, streamKey: {}", streamKey);
}
streamProcesses.remove(streamKey);
log.info("停止推流成功, streamKey: {}", streamKey);
returntrue;
}
returnfalse;
} catch (Exception e) {
log.error("停止推流失敗", e);
returnfalse;
}
}
/**
* 獲取拉流地址
*/
public String getPlayUrl(String streamKey, String protocol) {
return switch (protocol.toLowerCase()) {
case"flv" -> String.format("http://%s:%d/live/%s.live.flv",
streamConfig.getZlmHost(), streamConfig.getHttpPort(), streamKey);
case"hls" -> String.format("http://%s:%d/live/%s/hls.m3u8",
streamConfig.getZlmHost(), streamConfig.getHttpPort(), streamKey);
default -> null;
};
}
/**
* 檢查推流狀態(tài)
*/
public boolean isStreaming(String streamKey) {
return streamProcesses.containsKey(streamKey);
}
}
2.4 配置文件
stream:
zlm-host: 192.168.159.129
rtmp-port: 1935
http-port: 8099
ffmpeg-path: ffmpeg
video-path: \videos\
# 文件上傳配置
spring:
servlet:
multipart:
max-file-size: 1GB
max-request-size: 1GB
3. 使用說明
3.1 推流流程
- • 啟動 ZLMediaKit 服務
- • 上傳視頻文件到服務器
- • 調(diào)用推流接口，指定視頻路徑和推流密鑰
- • Spring Boot 執(zhí)行 FFmpeg 命令推流到 ZLMediaKit
3.2 播放流程
- • 獲取推流地址（HTTP-FLV 或 HLS）
- • 支持實時播放和回放
ffmpeg -re -i "C:\Users\lyk19\Videos\8月9日.mp4" -c:v libx264 -preset ultrafast -tune zerolatency -c:a aac -ar 44100 -b:a 128k -f flv rtmp://192.168.159.129:1935/live/stream
- • 前端播放
<!DOCTYPE html>
<html lang="zh-CN">
<head>
<meta charset="UTF-8">
<meta name="viewport" content="width=device-width, initial-scale=1.0">
<title>FLV直播播放器</title>
<style>
body {
margin: 0;
padding: 20px;
font-family: Arial, sans-serif;
background-color: #f0f0f0;
}
.player-container {
max-width: 800px;
margin: 0 auto;
background: white;
border-radius: 8px;
padding: 20px;
box-shadow: 0 2px 10px rgba(0, 0, 0, 0.1);
}
#videoElement {
width: 100%;
height: 450px;
background-color: #000;
border-radius: 4px;
}
.controls {
margin-top: 15px;
text-align: center;
}
button {
padding: 10px 20px;
margin: 0 5px;
border: none;
border-radius: 4px;
background-color: #007bff;
color: white;
cursor: pointer;
font-size: 14px;
}
button:hover {
background-color: #0056b3;
}
button:disabled {
background-color: #ccc;
cursor: not-allowed;
}
.status {
margin-top: 10px;
padding: 10px;
border-radius: 4px;
text-align: center;
}
.status.success {
background-color: #d4edda;
color: #155724;
}
.status.error {
background-color: #f8d7da;
color: #721c24;
}
.status.info {
background-color: #d1ecf1;
color: #0c5460;
}
</style>
</head>
<body>
<div class="player-container">
<h1>FLV直播播放器</h1>
<video id="videoElement" controls muted>
您的瀏覽器不支持視頻播放
</video>
<div class="controls">
<button id="playBtn">播放</button>
<button id="pauseBtn" disabled>暫停</button>
<button id="stopBtn" disabled>停止</button>
<button id="muteBtn">靜音</button>
</div>
<div id="status" class="status info">
準備就緒，點擊播放開始觀看直播
</div>
</div>
<!-- 使用flv.js庫 -->
<script src="https://cdn.jsdelivr.net/npm/flv.js@1.6.2/dist/flv.min.js"></script>
<script>
let flvPlayer = null;
const videoElement = document.getElementById('videoElement');
const playBtn = document.getElementById('playBtn');
const pauseBtn = document.getElementById('pauseBtn');
const stopBtn = document.getElementById('stopBtn');
const muteBtn = document.getElementById('muteBtn');
const statusDiv = document.getElementById('status');
// 你的流地址
const streamUrl = 'http://192.168.159.129:8099/live/stream.live.flv';
function updateStatus(message, type) {
statusDiv.textContent = message;
statusDiv.className = `status ${type}`;
console.log(`[${type.toUpperCase()}] ${message}`);
}
function updateButtons(playEnabled, pauseEnabled, stopEnabled) {
playBtn.disabled = !playEnabled;
pauseBtn.disabled = !pauseEnabled;
stopBtn.disabled = !stopEnabled;
}
// 檢查瀏覽器支持
if (!flvjs.isSupported()) {
updateStatus('您的瀏覽器不支持FLV播放，請使用Chrome、Firefox或Edge瀏覽器', 'error');
playBtn.disabled = true;
}
// 播放功能
playBtn.addEventListener('click', function () {
try {
if (flvPlayer) {
flvPlayer.destroy();
}
// 創(chuàng)建FLV播放器
flvPlayer = flvjs.createPlayer({
type: 'flv',
url: streamUrl,
isLive: true
}, {
enableWorker: false,
lazyLoad: true,
lazyLoadMaxDuration: 3 * 60,
deferLoadAfterSourceOpen: false,
autoCleanupSourceBuffer: true,
enableStashBuffer: false
});
flvPlayer.attachMediaElement(videoElement);
flvPlayer.load();
// 監(jiān)聽事件
flvPlayer.on(flvjs.Events.ERROR, function (errorType, errorDetail, errorInfo) {
console.error('FLV播放器錯誤:', errorType, errorDetail, errorInfo);
updateStatus(`播放錯誤: ${errorDetail}`, 'error');
});
flvPlayer.on(flvjs.Events.LOADING_COMPLETE, function () {
updateStatus('流加載完成', 'success');
});
flvPlayer.on(flvjs.Events.RECOVERED_EARLY_EOF, function () {
updateStatus('從早期EOF恢復', 'info');
});
// 開始播放
videoElement.play().then(() => {
updateStatus('正在播放直播流', 'success');
updateButtons(false, true, true);
}).catch(error => {
console.error('播放失敗:', error);
updateStatus('播放失敗: ' + error.message, 'error');
});
} catch (error) {
console.error('創(chuàng)建播放器失敗:', error);
updateStatus('創(chuàng)建播放器失敗: ' + error.message, 'error');
}
});
// 暫停功能
pauseBtn.addEventListener('click', function () {
if (videoElement && !videoElement.paused) {
videoElement.pause();
updateStatus('播放已暫停', 'info');
updateButtons(true, false, true);
}
});
// 停止功能
stopBtn.addEventListener('click', function () {
if (flvPlayer) {
flvPlayer.pause();
flvPlayer.unload();
flvPlayer.destroy();
flvPlayer = null;
}
videoElement.src = '';
videoElement.load();
updateStatus('播放已停止', 'info');
updateButtons(true, false, false);
});
// 靜音功能
muteBtn.addEventListener('click', function () {
videoElement.muted = !videoElement.muted;
muteBtn.textContent = videoElement.muted ? '取消靜音' : '靜音';
updateStatus(videoElement.muted ? '已靜音' : '已取消靜音', 'info');
});
// 視頻事件監(jiān)聽
videoElement.addEventListener('loadstart', function () {
updateStatus('開始加載視頻流...', 'info');
});
videoElement.addEventListener('canplay', function () {
updateStatus('視頻流已準備就緒', 'success');
});
videoElement.addEventListener('playing', function () {
updateStatus('正在播放直播流', 'success');
updateButtons(false, true, true);
});
videoElement.addEventListener('pause', function () {
updateStatus('播放已暫停', 'info');
updateButtons(true, false, true);
});
videoElement.addEventListener('error', function (e) {
updateStatus('視頻播放出錯', 'error');
updateButtons(true, false, false);
});
</script>
</body>
</html>
以上就是基于SpringBoot+FFmpeg+ZLMediaKit實現(xiàn)本地視頻推流的詳細內(nèi)容，更多關于SpringBoot FFmpeg本地視頻推流的資料請關注腳本之家其它相關文章！
相關文章
Springboot+Shiro+Jwt實現(xiàn)權限控制的項目實踐
如今的互聯(lián)網(wǎng)已經(jīng)成為前后端分離的時代,所以本文在使用SpringBoot整合Shiro框架的時候會聯(lián)合JWT一起搭配使用,具有一定的參考價值,感興趣的可以了解一下2023-09-09
Java實現(xiàn)整合文件上傳到FastDFS的方法詳細
FastDFS是一個開源的輕量級分布式文件系統(tǒng)，對文件進行管理，功能包括：文件存儲、文件同步、文件上傳、文件下載等，解決了大容量存儲和負載均衡的問題。本文將提供Java將文件上傳至FastDFS的示例代碼，需要的參考一下2022-02-02
java連接hdfs ha和調(diào)用mapreduce jar示例
這篇文章主要介紹了Java API連接HDFS HA和調(diào)用MapReduce jar包,需要的朋友可以參考下2014-03-03
這篇文章主要介紹了maven工程如何讀取，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-11-11
今天小編就為大家分享一篇關于JAVA JDK8 List分組獲取第一個元素的方法，小編覺得內(nèi)容挺不錯的，現(xiàn)在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧2018-12-12
抽幀（frame extraction）是指從視頻流中提取一些特定的幀，通常是關鍵幀或者隨機幀，以供后續(xù)處理。這篇文章主要為大家介紹了如何用Java實現(xiàn)對m3u8直播流抽幀，需要的可以參考一下2023-03-03
IDEA修改idea.vmoptions后,IDEA無法打開的解決方案
文章介紹了在IDEA中因錯誤修改啟動參數(shù)導致無法啟動的問題,指出正確的修改文件位置應在破解插件目錄下的idea.vmoptions,并分享了個人經(jīng)驗供參考2025-10-10
Mybatis注解開發(fā)@Select執(zhí)行參數(shù)和執(zhí)行sql語句的方式(最新詳解)
@Select 是 Mybatis 框架中的一個注解，用于執(zhí)行 SQL 查詢語句，并把查詢結果映射到指定的 Java 對象中，這篇文章主要介紹了Mybatis注解開發(fā)@Select執(zhí)行參數(shù)和執(zhí)行sql語句的方式,需要的朋友可以參考下2023-07-07
這篇文章主要介紹了Java中生成唯一ID的方法示例，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-02-02
為了數(shù)據(jù)安全問題,有時候需要將部分敏感字段加密后再入庫，本文主要介紹了MyBatis實現(xiàn)字段加解密的實踐，具有一定的參考價值，感興趣的可以了解一下2023-11-11