提交

fix(stream reader FFmpegFrameGrabber timeout parameter): stream reader "FFmpegFrameGrabber" timeout parameter setting fix

.gitignore

@@ -1,33 +0,0 @@
-README.md
-target/
-!.mvn/wrapper/maven-wrapper.jar
-!**/src/main/**/target/
-!**/src/test/**/target/
-
-### STS ###
-.apt_generated
-.classpath
-.factorypath
-.project
-.settings
-.springBeans
-.sts4-cache
-
-### IntelliJ IDEA ###
-.idea
-*.iws
-*.iml
-*.ipr
-
-### NetBeans ###
-/nbproject/private/
-/nbbuild/
-/dist/
-/nbdist/
-/.nb-gradle/
-build/
-!**/src/main/**/build/
-!**/src/test/**/build/
-
-### VS Code ###
-.vscode/

LICENSE

@@ -1,201 +0,0 @@
-                                 Apache License
-                           Version 2.0, January 2004
-                        http://www.apache.org/licenses/
-
-   TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
-
-   1. Definitions.
-
-      "License" shall mean the terms and conditions for use, reproduction,
-      and distribution as defined by Sections 1 through 9 of this document.
-
-      "Licensor" shall mean the copyright owner or entity authorized by
-      the copyright owner that is granting the License.
-
-      "Legal Entity" shall mean the union of the acting entity and all
-      other entities that control, are controlled by, or are under common
-      control with that entity. For the purposes of this definition,
-      "control" means (i) the power, direct or indirect, to cause the
-      direction or management of such entity, whether by contract or
-      otherwise, or (ii) ownership of fifty percent (50%) or more of the
-      outstanding shares, or (iii) beneficial ownership of such entity.
-
-      "You" (or "Your") shall mean an individual or Legal Entity
-      exercising permissions granted by this License.
-
-      "Source" form shall mean the preferred form for making modifications,
-      including but not limited to software source code, documentation
-      source, and configuration files.
-
-      "Object" form shall mean any form resulting from mechanical
-      transformation or translation of a Source form, including but
-      not limited to compiled object code, generated documentation,
-      and conversions to other media types.
-
-      "Work" shall mean the work of authorship, whether in Source or
-      Object form, made available under the License, as indicated by a
-      copyright notice that is included in or attached to the work
-      (an example is provided in the Appendix below).
-
-      "Derivative Works" shall mean any work, whether in Source or Object
-      form, that is based on (or derived from) the Work and for which the
-      editorial revisions, annotations, elaborations, or other modifications
-      represent, as a whole, an original work of authorship. For the purposes
-      of this License, Derivative Works shall not include works that remain
-      separable from, or merely link (or bind by name) to the interfaces of,
-      the Work and Derivative Works thereof.
-
-      "Contribution" shall mean any work of authorship, including
-      the original version of the Work and any modifications or additions
-      to that Work or Derivative Works thereof, that is intentionally
-      submitted to Licensor for inclusion in the Work by the copyright owner
-      or by an individual or Legal Entity authorized to submit on behalf of
-      the copyright owner. For the purposes of this definition, "submitted"
-      means any form of electronic, verbal, or written communication sent
-      to the Licensor or its representatives, including but not limited to
-      communication on electronic mailing lists, source code control systems,
-      and issue tracking systems that are managed by, or on behalf of, the
-      Licensor for the purpose of discussing and improving the Work, but
-      excluding communication that is conspicuously marked or otherwise
-      designated in writing by the copyright owner as "Not a Contribution."
-
-      "Contributor" shall mean Licensor and any individual or Legal Entity
-      on behalf of whom a Contribution has been received by Licensor and
-      subsequently incorporated within the Work.
-
-   2. Grant of Copyright License. Subject to the terms and conditions of
-      this License, each Contributor hereby grants to You a perpetual,
-      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
-      copyright license to reproduce, prepare Derivative Works of,
-      publicly display, publicly perform, sublicense, and distribute the
-      Work and such Derivative Works in Source or Object form.
-
-   3. Grant of Patent License. Subject to the terms and conditions of
-      this License, each Contributor hereby grants to You a perpetual,
-      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
-      (except as stated in this section) patent license to make, have made,
-      use, offer to sell, sell, import, and otherwise transfer the Work,
-      where such license applies only to those patent claims licensable
-      by such Contributor that are necessarily infringed by their
-      Contribution(s) alone or by combination of their Contribution(s)
-      with the Work to which such Contribution(s) was submitted. If You
-      institute patent litigation against any entity (including a
-      cross-claim or counterclaim in a lawsuit) alleging that the Work
-      or a Contribution incorporated within the Work constitutes direct
-      or contributory patent infringement, then any patent licenses
-      granted to You under this License for that Work shall terminate
-      as of the date such litigation is filed.
-
-   4. Redistribution. You may reproduce and distribute copies of the
-      Work or Derivative Works thereof in any medium, with or without
-      modifications, and in Source or Object form, provided that You
-      meet the following conditions:
-
-      (a) You must give any other recipients of the Work or
-          Derivative Works a copy of this License; and
-
-      (b) You must cause any modified files to carry prominent notices
-          stating that You changed the files; and
-
-      (c) You must retain, in the Source form of any Derivative Works
-          that You distribute, all copyright, patent, trademark, and
-          attribution notices from the Source form of the Work,
-          excluding those notices that do not pertain to any part of
-          the Derivative Works; and
-
-      (d) If the Work includes a "NOTICE" text file as part of its
-          distribution, then any Derivative Works that You distribute must
-          include a readable copy of the attribution notices contained
-          within such NOTICE file, excluding those notices that do not
-          pertain to any part of the Derivative Works, in at least one
-          of the following places: within a NOTICE text file distributed
-          as part of the Derivative Works; within the Source form or
-          documentation, if provided along with the Derivative Works; or,
-          within a display generated by the Derivative Works, if and
-          wherever such third-party notices normally appear. The contents
-          of the NOTICE file are for informational purposes only and
-          do not modify the License. You may add Your own attribution
-          notices within Derivative Works that You distribute, alongside
-          or as an addendum to the NOTICE text from the Work, provided
-          that such additional attribution notices cannot be construed
-          as modifying the License.
-
-      You may add Your own copyright statement to Your modifications and
-      may provide additional or different license terms and conditions
-      for use, reproduction, or distribution of Your modifications, or
-      for any such Derivative Works as a whole, provided Your use,
-      reproduction, and distribution of the Work otherwise complies with
-      the conditions stated in this License.
-
-   5. Submission of Contributions. Unless You explicitly state otherwise,
-      any Contribution intentionally submitted for inclusion in the Work
-      by You to the Licensor shall be under the terms and conditions of
-      this License, without any additional terms or conditions.
-      Notwithstanding the above, nothing herein shall supersede or modify
-      the terms of any separate license agreement you may have executed
-      with Licensor regarding such Contributions.
-
-   6. Trademarks. This License does not grant permission to use the trade
-      names, trademarks, service marks, or product names of the Licensor,
-      except as required for reasonable and customary use in describing the
-      origin of the Work and reproducing the content of the NOTICE file.
-
-   7. Disclaimer of Warranty. Unless required by applicable law or
-      agreed to in writing, Licensor provides the Work (and each
-      Contributor provides its Contributions) on an "AS IS" BASIS,
-      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
-      implied, including, without limitation, any warranties or conditions
-      of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
-      PARTICULAR PURPOSE. You are solely responsible for determining the
-      appropriateness of using or redistributing the Work and assume any
-      risks associated with Your exercise of permissions under this License.
-
-   8. Limitation of Liability. In no event and under no legal theory,
-      whether in tort (including negligence), contract, or otherwise,
-      unless required by applicable law (such as deliberate and grossly
-      negligent acts) or agreed to in writing, shall any Contributor be
-      liable to You for damages, including any direct, indirect, special,
-      incidental, or consequential damages of any character arising as a
-      result of this License or out of the use or inability to use the
-      Work (including but not limited to damages for loss of goodwill,
-      work stoppage, computer failure or malfunction, or any and all
-      other commercial damages or losses), even if such Contributor
-      has been advised of the possibility of such damages.
-
-   9. Accepting Warranty or Additional Liability. While redistributing
-      the Work or Derivative Works thereof, You may choose to offer,
-      and charge a fee for, acceptance of support, warranty, indemnity,
-      or other liability obligations and/or rights consistent with this
-      License. However, in accepting such obligations, You may act only
-      on Your own behalf and on Your sole responsibility, not on behalf
-      of any other Contributor, and only if You agree to indemnify,
-      defend, and hold each Contributor harmless for any liability
-      incurred by, or claims asserted against, such Contributor by reason
-      of your accepting any such warranty or additional liability.
-
-   END OF TERMS AND CONDITIONS
-
-   APPENDIX: How to apply the Apache License to your work.
-
-      To apply the Apache License to your work, attach the following
-      boilerplate notice, with the fields enclosed by brackets "[]"
-      replaced with your own identifying information. (Don't include
-      the brackets!)  The text should be enclosed in the appropriate
-      comment syntax for the file format. We also recommend that a
-      file or class name and description of purpose be included on the
-      same "printed page" as the copyright notice for easier
-      identification within third-party archives.
-
-   Copyright [yyyy] [name of copyright owner]
-
-   Licensed under the Apache License, Version 2.0 (the "License");
-   you may not use this file except in compliance with the License.
-   You may obtain a copy of the License at
-
-       http://www.apache.org/licenses/LICENSE-2.0
-
-   Unless required by applicable law or agreed to in writing, software
-   distributed under the License is distributed on an "AS IS" BASIS,
-   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-   See the License for the specific language governing permissions and
-   limitations under the License.

README.cn.md

@@ -1,11 +1,6 @@
 <!-- Easy-FLV: Java RTSP/RTMP to FLV Converter -->
 # 📺 Easy-FLV: Java 实现的 RTSP/RTMP 到 FLV 转换器
 
-[![GitHub stars](https://img.shields.io/github/stars/javpower/easy-flv.svg)](https://github.com/javpower/easy-flv)
-[![GitHub issues](https://img.shields.io/github/issues/javpower/easy-flv.svg)](https://github.com/javpower/easy-flv/issues)
-[![Apache License 2.0](https://img.shields.io/badge/license-Apache%202.0-blue.svg)](https://opensource.org/licenses/Apache-2.0)
-[![Java Version](https://img.shields.io/badge/java-1.8+-orange.svg)](https://adoptopenjdk.net/)
-[![Spring Boot](https://img.shields.io/badge/spring--boot-2.7.+-blue.svg)](https://spring.io/projects/spring-boot)
 
 ## 🌟 关于 Easy-FLV
 Easy-FLV 是一个用 Java 实现的库，它能够将 RTSP 或 RTMP 视频流转换为 FLV 格式，以便在浏览器中播放。它为实时视频监控、直播和视频流处理提供了一个高效、稳定且易于集成的解决方案。
@@ -16,11 +11,6 @@ Easy-FLV 是一个用 Java 实现的库，它能够将 RTSP 或 RTMP 视频流
 - **现代浏览器支持**：支持所有主流浏览器，无需额外插件。
 - **实时流处理**：适用于实时视频流的转换，如安防监控和直播。
 
-## 📄 效果图
-以下是 Easy-FLV 在行动的效果图：
-
-![img_1.png](img_1.png)
-![img.png](img.png)
 
 ## 🚀 快速开始
 
@@ -29,9 +19,9 @@ Easy-FLV 是一个用 Java 实现的库，它能够将 RTSP 或 RTMP 视频流
 
 ```xml
 <dependency>
-    <groupId>io.github.javpower</groupId>
+    <groupId>me.zhengjie</groupId>
-    <artifactId>rtsp-converter-flv-spring-boot-starter</artifactId>
+    <artifactId>eladmin-flv</artifactId>
-    <version>1.5.9.1</version>
+    <version>1.1</version>
 </dependency>
 ```
 
@@ -45,7 +35,7 @@ public class RtspDataService implements IOpenFLVService {
     @Override
     public String getUrl(Integer channel) {
         // 根据 channel 获取 RTSP 视频流地址
-        return "rtsp://10.11.9.251:554/openUrl/16HV8mA";
+        return "rtsp://xx.xx.xx.xx/openUrl/16HV8mA";
     }
 }
 ```
@@ -84,8 +74,3 @@ public static void main(String[] args) throws UnsupportedEncodingException {
 
 ## 📄 许可证
 Easy-FLV 根据 [Apache License 2.0](LICENSE) 发布。
-
-## 📧 联系
-- Email: [javpower@163.com](mailto:your-email@example.com)
-- GitHub: [https://github.com/javpower/easy-flv](https://github.com/javpower/easy-flv)
-- Gitee: [https://gitee.com/giteeClass/easy-flv](https://gitee.com/giteeClass/easy-flv)

pom.xml

@@ -2,12 +2,12 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
-    <groupId>io.github.javpower</groupId>
+    <groupId>me.zhengjie</groupId>
-    <artifactId>rtsp-converter-flv-spring-boot-starter</artifactId>
+    <artifactId>eladmin-flv</artifactId>
-    <version>1.5.9.1</version>
+    <version>1.1</version>
-    <name>rtsp-converter-flv-spring-boot-starter</name>
+    <name>视频模块</name>
-    <description>a tool about easy rtsp-converter-flv</description>
+    <description>视频流转换 rtsp/rtmp 转flv</description>
-    <url>https://github.com/javpower/easy-flv</url>
+
     <licenses>
         <license>
             <name> The Apache Software License, Version 2.0 </name>
@@ -38,6 +38,11 @@
     </properties>
 
     <dependencies>
+        <dependency>
+            <groupId>me.zhengjie</groupId>
+            <artifactId>eladmin-logging</artifactId>
+            <version>1.1</version>
+        </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter</artifactId>

src/main/java/com/gc/easy/flv/controller/FLVController.java

@@ -2,10 +2,16 @@ package com.gc.easy.flv.controller;
 
 import com.gc.easy.flv.service.IFLVService;
 import com.gc.easy.flv.service.IOpenFLVService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import me.zhengjie.annotation.Log;
+import me.zhengjie.annotation.rest.AnonymousGetMapping;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.util.StringUtils;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.servlet.http.HttpServletRequest;
@@ -17,28 +23,25 @@ import java.io.UnsupportedEncodingException;
  *
  * @author gc.x
  */
-@RestController
+@Slf4j
+@RestController("api/front/flv")
+@Api(tags = "微信：拉流播放")
 public class FLVController {
 
     @Autowired
     private IFLVService service;
+
     @Autowired(required = false)
     private IOpenFLVService openFLVService;
 
-	@GetMapping(value = "/get/flv/hls/stream_{channel}.flv")
+    @Log("拉流播放")
-	public void open(@PathVariable(value = "channel") Integer channel, HttpServletResponse response,
+    @ApiOperation(value = "打开视频流")
-					  HttpServletRequest request) {
+    // @GetMapping(value = "/get/stream")
-		String url = openFLVService.getUrl(channel);
+    @AnonymousGetMapping(value = "/get/stream")
-		if(!StringUtils.isEmpty(url)){
+    public void open(String url, HttpServletResponse response, HttpServletRequest request) throws UnsupportedEncodingException {
-			service.open(channel,url, response, request);
-		}
-	}
-	@GetMapping(value = "/get/flv/hls/stream")
-	public void open1(String url, HttpServletResponse response,
-					 HttpServletRequest request) throws UnsupportedEncodingException {
         if (!StringUtils.isEmpty(url)) {
             String decodedUrl = java.net.URLDecoder.decode(url, "UTF-8");
-			service.open(decodedUrl, response, request);
+            service.open(decodedUrl, response, request, openFLVService);
         }
     }
 }

src/main/java/com/gc/easy/flv/controller/FLVPlayController.java

@@ -1,39 +1,30 @@
-package com.gc.easy.flv.controller;
+//package com.gc.easy.flv.controller;
-
+//
-import com.gc.easy.flv.config.FlvConfig;
+//import com.gc.easy.flv.config.FlvConfig;
-import org.springframework.beans.factory.annotation.Autowired;
+//import me.zhengjie.annotation.rest.AnonymousGetMapping;
-import org.springframework.stereotype.Controller;
+//import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.ui.Model;
+//import org.springframework.stereotype.Controller;
-import org.springframework.web.bind.annotation.GetMapping;
+//import org.springframework.ui.Model;
-import org.springframework.web.bind.annotation.PathVariable;
+//
-
+//import java.io.UnsupportedEncodingException;
-import java.io.UnsupportedEncodingException;
+//
-
+///**
-/**
+// * FLV流转换
- * FLV流转换
+// *
- * 
+// * @author gc.x
- * @author gc.x
+// */
- */
+//@Controller
-@Controller
+//public class FLVPlayController {
-public class FLVPlayController {
+//	@Autowired
-	@Autowired
+//	private FlvConfig flvConfig;
-	private FlvConfig flvConfig;
+//
-
+//	@AnonymousGetMapping(value = "/flv/hls/stream")
-	@GetMapping(value = "/flv/hls/stream_{channel}.flv")
+//	public String getAppHtml1(String url, Model model) throws UnsupportedEncodingException {
-	public String getAppHtml(@PathVariable(value = "channel") Integer channel, Model model)  {
+//		String decodedUrl = java.net.URLDecoder.decode(url, "UTF-8");
-		String videoPath=flvConfig.getHost()+"/get/flv/hls/stream_"+channel+".flv";
+//		String videoPath="/api/front/flv/get/stream?url="+decodedUrl;
-		model.addAttribute("videoPath", videoPath);
+//		model.addAttribute("videoPath", videoPath);
-		model.addAttribute("wight", flvConfig.getWight());
+//		model.addAttribute("wight", flvConfig.getWight());
-		model.addAttribute("height", flvConfig.getHeight());
+//		model.addAttribute("height", flvConfig.getHeight());
-		return "video";
+//		return "video";
-	}
+//	}
-	@GetMapping(value = "/flv/hls/stream")
+//}
-	public String getAppHtml1(String url, Model model) throws UnsupportedEncodingException {
-		String decodedUrl = java.net.URLDecoder.decode(url, "UTF-8");
-		String videoPath=flvConfig.getHost()+"/get/flv/hls/stream?url="+decodedUrl;
-		model.addAttribute("videoPath", videoPath);
-		model.addAttribute("wight", flvConfig.getWight());
-		model.addAttribute("height", flvConfig.getHeight());
-		return "video";
-	}
-}

src/main/java/com/gc/easy/flv/factories/ConverterFactories.java

@@ -1,6 +1,7 @@
 package com.gc.easy.flv.factories;
 
 import com.alibaba.fastjson.util.IOUtils;
+import com.gc.easy.flv.service.IOpenFLVService;
 import lombok.extern.slf4j.Slf4j;
 import org.bytedeco.ffmpeg.avcodec.AVPacket;
 import org.bytedeco.ffmpeg.global.avcodec;
@@ -29,7 +30,7 @@ public class ConverterFactories extends Thread implements Converter {
      */
     private FFmpegFrameGrabber grabber;
     /**
-	 * 转码器
+     * 转码器1
      */
     private FFmpegFrameRecorder recorder;
     /**
@@ -60,12 +61,15 @@ public class ConverterFactories extends Thread implements Converter {
      */
     private Map<String, Converter> factories;
 
+    private IOpenFLVService openFLVService;
 
-	public ConverterFactories(String url, String key, Map<String, Converter> factories, List<AsyncContext> outEntitys) {
+
+    public ConverterFactories(String url, String key, Map<String, Converter> factories, List<AsyncContext> outEntitys, IOpenFLVService openFLVService) {
         this.url = url;
         this.key = key;
         this.factories = factories;
         this.outEntitys = outEntitys;
+        this.openFLVService = openFLVService;
     }
 
     @Override
@@ -75,11 +79,11 @@ public class ConverterFactories extends Thread implements Converter {
             grabber = new FFmpegFrameGrabber(url);
             if ("rtsp".equals(url.substring(0, 4))) {
                 grabber.setOption("rtsp_transport", "tcp");
-				grabber.setOption("stimeout", "5000000");
+                grabber.setOption("timeout", "5000000");
             }
             grabber.start();
             if (avcodec.AV_CODEC_ID_H264 == grabber.getVideoCodec()
-					&& (grabber.getAudioChannels() == 0 || avcodec.AV_CODEC_ID_AAC == grabber.getAudioCodec())) {
+                    && (grabber.getAudioChannels() == 0 || avcodec.AV_CODEC_ID_AAC == grabber.getAudioCodec()) && (openFLVService == null || !openFLVService.openPreview())) {
                 log.info("this url:{} converterFactories start", url);
                 // 来源视频H264格式,音频AAC格式
                 // 无须转码，更低的资源消耗，更低的延迟
@@ -135,7 +139,7 @@ public class ConverterFactories extends Thread implements Converter {
             } else {
                 isCloseGrabberAndResponse = false;
                 // 需要转码为视频H264格式,音频AAC格式
-				ConverterTranFactories c = new ConverterTranFactories(url, key, factories, outEntitys, grabber);
+                ConverterTranFactories c = new ConverterTranFactories(url, key, factories, outEntitys, grabber, openFLVService);
                 factories.put(key, c);
                 c.start();
             }

src/main/java/com/gc/easy/flv/factories/ConverterTranFactories.java

@@ -1,11 +1,14 @@
 package com.gc.easy.flv.factories;
 
 import com.alibaba.fastjson.util.IOUtils;
+import com.gc.easy.flv.service.IOpenFLVService;
 import lombok.extern.slf4j.Slf4j;
 import org.bytedeco.ffmpeg.global.avcodec;
 import org.bytedeco.javacv.FFmpegFrameGrabber;
 import org.bytedeco.javacv.FFmpegFrameRecorder;
 import org.bytedeco.javacv.Frame;
+import org.bytedeco.javacv.OpenCVFrameConverter;
+import org.bytedeco.opencv.opencv_core.IplImage;
 
 import javax.servlet.AsyncContext;
 import java.io.ByteArrayOutputStream;
@@ -59,13 +62,18 @@ public class ConverterTranFactories extends Thread implements Converter {
 	 */
 	private Map<String, Converter> factories;
 
+	private OpenCVFrameConverter.ToIplImage converter;
+	private IOpenFLVService openFLVService;
+
+
 	public ConverterTranFactories(String url, String key, Map<String, Converter> factories,
-			List<AsyncContext> outEntitys, FFmpegFrameGrabber grabber) {
+								  List<AsyncContext> outEntitys, FFmpegFrameGrabber grabber, IOpenFLVService openFLVService) {
 		this.url = url;
 		this.key = key;
 		this.factories = factories;
 		this.outEntitys = outEntitys;
 		this.grabber = grabber;
+		this.openFLVService=openFLVService;
 	}
 
 	@Override
@@ -82,6 +90,8 @@ public class ConverterTranFactories extends Thread implements Converter {
 			stream = new ByteArrayOutputStream();
 			recorder = new FFmpegFrameRecorder(stream, grabber.getImageWidth(), grabber.getImageHeight(),
 					grabber.getAudioChannels());
+			converter = new OpenCVFrameConverter.ToIplImage();
+
 			recorder.setInterleaved(true);
 			recorder.setVideoOption("preset", "ultrafast");
 			recorder.setVideoOption("tune", "zerolatency");
@@ -107,6 +117,14 @@ public class ConverterTranFactories extends Thread implements Converter {
 			while (runing) {
 				// 抓取一帧
 				Frame f = grabber.grab();
+  				if(openFLVService!=null&&openFLVService.openPreview()){
+					  //预处理
+					IplImage iplImage = converter.convert(f);//抓取一帧视频并将其转换为图像，至于用这个图像用来做什么？加水印，人脸识别等等自行添加
+					if (iplImage != null) {
+						openFLVService.preview(iplImage);
+						f = converter.convert(iplImage);
+					}
+				}
 				if (f != null) {
 					try {
 						// 转码

src/main/java/com/gc/easy/flv/service/IFLVService.java

@@ -11,7 +11,7 @@ public interface IFLVService {
 	 * @param url
 	 * @param response
 	 */
-	public void open(Integer channel,String url, HttpServletResponse response, HttpServletRequest request);
+	public void open(Integer channel,String url, HttpServletResponse response, HttpServletRequest request,IOpenFLVService openFLVService);
-	public void open(String url, HttpServletResponse response, HttpServletRequest request);
+	public void open(String url, HttpServletResponse response, HttpServletRequest request,IOpenFLVService openFLVService);
 
 }

src/main/java/com/gc/easy/flv/service/IOpenFLVService.java

@@ -1,5 +1,7 @@
 package com.gc.easy.flv.service;
 
+import org.bytedeco.opencv.opencv_core.IplImage;
+
 public interface IOpenFLVService {
 
 
@@ -8,5 +10,17 @@ public interface IOpenFLVService {
      * @param channel
      * @return
      */
-    public String  getUrl(Integer channel);
+    String getUrl(Integer channel);
+
+    /**
+     * 抓取一帧视频并将其转换为图像预处理
+     * @param iplImage
+     */
+    void preview(IplImage iplImage);
+
+    /**
+     * 开启预处理
+     * @return
+     */
+    boolean openPreview();
 }

src/main/java/com/gc/easy/flv/service/impl/FLVService.java

@@ -4,6 +4,7 @@ package com.gc.easy.flv.service.impl;
 import com.gc.easy.flv.factories.Converter;
 import com.gc.easy.flv.factories.ConverterFactories;
 import com.gc.easy.flv.service.IFLVService;
+import com.gc.easy.flv.service.IOpenFLVService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
@@ -27,12 +28,14 @@ import java.util.concurrent.ConcurrentHashMap;
 public class FLVService implements IFLVService {
 
     private ConcurrentHashMap<String, Converter> converters = new ConcurrentHashMap<>();
+
     @Override
-	public void open(String url, HttpServletResponse response, HttpServletRequest request) {
+    public void open(String url, HttpServletResponse response, HttpServletRequest request, IOpenFLVService openFLVService) {
-		open(null,url,response,request);
+        open(null, url, response, request, openFLVService);
     }
+
     @Override
-	public void open(Integer channel,String url, HttpServletResponse response, HttpServletRequest request) {
+    public void open(Integer channel, String url, HttpServletResponse response, HttpServletRequest request, IOpenFLVService openFLVService) {
         String key = md5(url);
         AsyncContext async = request.startAsync();
         async.setTimeout(0);
@@ -47,7 +50,7 @@ public class FLVService implements IFLVService {
         } else {
             List<AsyncContext> outs = new ArrayList<>();
             outs.add(async);
-			ConverterFactories c = new ConverterFactories(url, key, converters, outs);
+            ConverterFactories c = new ConverterFactories(url, key, converters, outs, openFLVService);
             c.start();
             converters.put(key, c);
         }

src/main/java/com/gc/easy/flv/service/impl/OpenFLVService.java

@@ -0,0 +1,33 @@
+package com.gc.easy.flv.service.impl;
+
+
+import com.gc.easy.flv.service.IOpenFLVService;
+import lombok.extern.slf4j.Slf4j;
+import org.bytedeco.opencv.opencv_core.IplImage;
+import org.springframework.stereotype.Service;
+
+/**
+ * FLV流转换
+ *
+ * @author gc.x
+ */
+@Slf4j
+@Service
+public class OpenFLVService implements IOpenFLVService {
+
+
+	@Override
+	public String getUrl(Integer channel) {
+		return "";
+	}
+
+	@Override
+	public void preview(IplImage iplImage) {
+
+	}
+
+	@Override
+	public boolean openPreview() {
+		return false;
+	}
+}

src/main/resources/templates/video.html

@@ -5,12 +5,12 @@
     <title>FLV Video Player</title>
 
     <!-- 引入flv.js库 -->
-    <script src="https://cdn.jsdelivr.net/npm/flv.js@1.5.0/dist/flv.min.js"></script>
+    <script type="text/javascript" src="https://cdnjs.cloudflare.com/ajax/libs/flv.js/1.5.0/flv.min.js"></script>
 </head>
 <body>
 
 
-<video id="videoPlayer" th:style="'width:' + ${width} + 'px; height:' + ${height} + 'px;'" controls></video>
+<video id="videoPlayer" th:style="'width:500px; height:500px;'" controls></video>
 
 <script th:inline="javascript">
     (function () {
@@ -20,7 +20,7 @@
             var videoElement = document.getElementById('videoPlayer');
             var flvPlayer = flvjs.createPlayer({
                 type: 'flv',
-                    url: videoPath
+                url: 'http://localhost:8000' + videoPath
             });
 
             flvPlayer.attachMediaElement(videoElement);

target/classes/templates/video.html

@@ -0,0 +1,37 @@
+<!DOCTYPE html>
+<html xmlns:th="http://www.thymeleaf.org">
+<head>
+    <meta charset="UTF-8">
+    <title>FLV Video Player</title>
+
+    <!-- 引入flv.js库 -->
+    <script type="text/javascript" src="https://cdnjs.cloudflare.com/ajax/libs/flv.js/1.5.0/flv.min.js"></script>
+</head>
+<body>
+
+
+<video id="videoPlayer" th:style="'width:500px; height:500px;'" controls></video>
+
+<script th:inline="javascript">
+    (function () {
+        var videoPath = /*[[${videoPath}]]*/ '';
+
+        if (flvjs.isSupported()) {
+            var videoElement = document.getElementById('videoPlayer');
+            var flvPlayer = flvjs.createPlayer({
+                type: 'flv',
+                url: 'http://localhost:8000' + videoPath
+            });
+
+            flvPlayer.attachMediaElement(videoElement);
+            flvPlayer.load();
+
+            // 播放视频
+            videoElement.play();
+        } else {
+            console.error('FLV not supported');
+        }
+    })();
+</script>
+</body>
+</html>