海康威视RTSP摄像头转RTMP推流前端方案(系统集成)

  前言:测试阶段验证了RTSP流转RTMP流并让前端拉流播放的可行性,但是用控制台实现功能有很多弊端,所以需要将其集成到web系统中。


  因为对视频推流等相关技术不甚了解,所以解决方案也是从相关博文中进行提取和优化,接下来说明下尝试的几种技术方案:

方案一: 用海康威视的web3.0包。当时测试时如大多数博客所说,只能在IE浏览器顺利运行,且要下载相应的插件,局限性实在太大,所以弃用。

方案二: 使用海康威视SDK调用摄像头的相关方法,并用FFmpegCommandHandler将RTSP流转RTMP流推到nginx流媒体服务器(使用nginx-rtmp-module插件)上,然后流媒体服务器通过前端使用videojs视频通过设置源推流地址播放。这里主要借鉴了这两篇博文中的方案和代码https://blog.csdn.net/lee_decimal/article/details/111215248

https://blog.csdn.net/qq_36720088/article/details/82893924

方案三: nginx插件换成nginx-http-flv-module,然后前端播放插件换成flvjs,其他都跟方案二一样。

  方案二过度到方案三的原因:H5的默认播放器video支持的视频格式有限,不能直接播放RTMP直播流,而市面上大多数的前端视频插件需要以flv格式播放RTMP流,且它们都需要flash插件的帮助才能播放,最纠结的地方在于chrome等大众浏览器都开始不再支持flash插件了。所以最好的替代方案就是flvjs(HTML5 Flash 视频播放器,可自行百度),而flvjs播放直播流的必要条件就是必须是http协议的流,所以在nginx中安装nginx-http-flv-module插件替换了原有插件。

  我先将博文中最普遍的方案二继续了实现,后一篇中再说改进方案。


系统集成

一. 下载需要的软件包和插件
  1. VLC media player。用于测试是否推流成功。
  2. FFmpeg。安装完后需要配置环境变量,项目中的FFmpegCommandHandler也需要配置相应的配置文件指定FFmpeg路径。
  3. nginx和nginx-rtmp-module插件。安装完后进行conf文件配置,测试阶段有相应配置代码。
  4. videojs。前端流媒体播放插件,下载5.xx.x版本(我用的是5.20.5)。
  5. 海康威视SDK,根据系统位数(32位和64位)下载,不然运行不了。


海康SDK

二. 代码编写
  后端代码的整体执行流程:首先调用海康的sdk工具连接摄像头设备,进行操作后获取操作结果或者需要的数据,再由后端条用FFmpegcommandHandler执行推流(将直播流推到nginx服务器上);浏览器用户浏览实时监控时,插件会从直播地址拉流到浏览器中进行播放。


  1. 工具类编写。HCNetUtil是主要负责和SDK直接操作,而MonitorUtil则负责直接调用HCNetUtil,并将返回结果和FFmpegcommandHandler操作一起封装成通用行为。其中HCNetUtil的主要行为是设备初始化,设备注册(其他接口可以查看SDK中的手册)

    /**
     * 初始化资源配置
     * @return
     */
    public boolean initDevice() {
        return hCNetSDK.NET_DVR_Init();
    }

    /**
     * 注册设备
     * @param userName
     * @param password
     * @param ipAddress
     * @param port
     * @return
     */
    public boolean registDevice(String userName, String password, String ipAddress, String port) {
        if (lUserID.longValue() > -1) {
            hCNetSDK.NET_DVR_Logout_V30(lUserID);
            lUserID = new NativeLong(-1);
        }
        
        // 开始注册
        // 获取设备参数数据结构
        deviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V30();
        lUserID = hCNetSDK.NET_DVR_Login_V30(ipAddress, (short)Integer.parseInt(port), userName, password, deviceInfo);
        long userID = lUserID.longValue();
        System.out.println("lUserID:" + lUserID + "***********************");
        if (-1 == userID) {
            deviceIP = "";
            return false;
        }
        deviceIP = ipAddress;
        System.out.println("注册设备成功***********************");
        return true;
    }

    /**
     * (注销并)释放SDK资源
     * @return
     */
    public boolean shutDownDev() {
        // 如果已经注册,则注销
        if (lUserID.longValue() > -1) {
            if (!hCNetSDK.NET_DVR_Logout_V30(lUserID)) {
                return false;
            }
        }
        // 释放SDK资源
        if (!hCNetSDK.NET_DVR_Cleanup()) {
            return false;
        }
        return true;
    }

  MinitorUtil中实现了推流,停止推流,推流并获取进程ID等方法。

/**
     * 开始推流并返回ffmpeg进程ID
     * @param monitor
     * @param prsName
     * @return
     */
    public Map<String, String> startTranscodeAndGetTask(String prsName, String userName, String password, String ipAddress, String port) {
        Map<String, String> result = new HashMap<>();
        int chanNum = -1;
        // 初始化设备并注册
        if(hCUtil.initDevice() && hCUtil.registDevice(userName, password, ipAddress, port)) {
            chanNum = hCUtil.getChannelNum();
            if(chanNum != -1) {
                result = MonitorUtil.startTranscode(prsName, userName, password, ipAddress, port, chanNum);
            }
        }
        result.put("errorMsg", hCUtil.getErrorMsg());
        if(!hCUtil.shutDownDev()) {
            System.err.println(hCUtil.getErrorMsg());
        }
        return result;
    }
    
    /**
     * 开始推流
     * @param prsName 进程名称
     * @param userName 设备用户名
     * @param password 密码
     * @param ipAddress ip地址
     * @param chanNum 通道号(针对这个ffmpeg工具jar包有点冗余,但还是加上这个参数,方便后期维护)
     * @return 成功返回进程ID(与设置的进程名称相同)
     */
    public static Map<String, String> startTranscode(String prsName, String userName, String password, String ipAddress, String port, int chanNum) {
        String chanNumStr = "ch" + chanNum;
        String taskID = "";
        String RTMPUrl = "";
        Map<String, String> map = new HashMap<>();
        Map<String, String> res = new HashMap<>();
        
        
        if(fManager == null) {
            fManager = new FFmpegManagerImpl();
        }
        // 如果进程存在,则直接返回
        if(MonitorUtil.taskIsRun(prsName)) {
            return res;
        }
        
        //进程名
        map.put("appName", prsName);
//        map.put("input", "rtsp://"+ userName +":" + password + "@" + ipAddress + ":554/Streaming/channels/001 -c:v libx264");
        map.put("input", "\"rtsp://" + userName + ":" + password + "@" + ipAddress + ":554" + "/h264/" + chanNumStr + "/main/av_stream\" -b:v 500k -bufsize 500k -maxrate 600k");
        map.put("output", RTMP_OUTPUT_URL); //rtmp流.live为nginx-rtmp的配置
        map.put("fps", "25");
        map.put("fmt", "flv");
        map.put("rtsp_transport", "tcp");
        map.put("twoPart", "1"); //只推元码流
        
        // 成功返回进程ID
        taskID = fManager.start(map);
        
        RTMPUrl = RTMP_OUTPUT_URL + taskID;
        res.put("taskID", (StringUtils.isNotEmpty(taskID)) ? taskID : "");
        res.put("RTMPUrl", RTMPUrl);
        return res;
    }
    
    /**
     * 关闭推流进程
     * @param taskID 进程ID号
     * @return
     */
    public static boolean stopTranscode(String taskID) {
        if(!taskIsRun(taskID)) {
            return true;
        }
        return fManager.stop(taskID);
    }

  2. 框架中对应的接口实现。中间的三层结构代码实现就不贴出来了,主要目的就是将rtmp推流地址传到前端并让前端动态加载视频。
  3. 前端显示。

<html>
<head>
<meta charset="UTF-8">
<title>Insert title here</title>
<link rel="stylesheet" type="text/css" href="../../../videojs/video-js.css" />
<script type="text/javascript" src="videojs/video.js"></script>
<script type="text/javascript" src="videojs/videojs-ie8.js"></script>
<script type="text/javascript" src="js/monitor.js"></script>
</head>
<body>
    <div id="monitorPreview"></div>
</body>
</html>
videojs.options.flash.swf = "videojs/video-js.swf"
monitorPreview("rtmp://localhost:1935/live/room")
function monitorPreview(targetPushAddress) {
    if (!targetPushAddress) {
        return
    }
    initMonitor(
        'monitorV', {
        controls: false, // 是否显示控制条
        poster: '', // 视频封面图地址
        preload: 'auto',
        width: 770,
        height: 550,
        language: 'zh-CN', // 设置语言
        muted: true, // 是否静音
        inactivityTimeout: false,
        sources: [ // 视频来源路径
            {
                src: targetPushAddress,
                type: 'rtmp/flv'
            }
        ]
    },
        function(player) {
            player.play()
        }
    )
}

function initMonitor(id, options, callback) {
    var mon = $('<video id="' + id + '" class="video-js" data-setup="{}"></video>')
    $('#monitorPreview').append(mon)
    // 挂到window上方便销毁
    this.monitor = videojs(id, options, function() {
        callback(this)
    })
}

  这里需要注意,如果直接在html页面中写对应的video控件并指定了视频流的源路径,当执行到js代码时,videojs控件就已经进行了初始化,而与jquery不同的是,videojs不允许对视频控件进行二次渲染(会报错Player “xxx“ is already initialised. Options will not be applied)所以这时就需要动态添加video控件了。
三. 问题和总结

  开发过程中主要碰到了以下几个问题:

  1. Unable to load library 'HCNetSDK': ÕҲ»µ½ָ¶¨。根本问题是找不到HCNetSDK.dll文件,分两种情况:
    • SDK版本和系统版本不对应,32位安装32位SDK,64对64。
    • 路径不对。一种场景是当动态获取路径时,因为某些系统中通过getResource("/").getPath()获取的路径如果包含" "则会把空格转成%20字符串,所以需要将对应字符替换回来;另一种场景就是粗心了,这时候需要查看日志修改代码。
  2. Player “xxx“ is already initialised. Options will not be applied。这个上面说过就不过多赘述。
  3. SDK报错码29(NET_DVR_DVROPRATEFAILED)、186(NET_SDK_ERR_FUNCTION_INVALID)。出现这写错误就需要查看SDK的dll文件是否导全了、SDK包和系统版本是否对应。
  4. FFmpegCommandHandler使用了已经弃用的stop()方法
    线程方法stop()

    拿到FFmpegCommandHandler源码,修改代码并重新打jar包。
    @SuppressWarnings("deprecation")
    @Override
    public boolean stop(Thread outHandler) {
         try {
             if (outHandler != null && outHandler.isAlive()) {
                 outHandler.sleep(200);
                 outHandler.interrupt();
                 outHandler.destroy();
             }
         } catch (InterruptedException e) {
             e.printStackTrace();
         } finally {
             return true;
         }
    }

  系统集成阶段总结:此方案极度依赖flash插件,现在最新版chrome已经不支持(连询问后加载的余地都没有),虽然有相应的解决方法,但是需要客户在浏览器令行安装插件,使用上并不友好。然后是安全问题,因为流媒体部署后,所有外网用户都能进行访问,这时需要对某些监控视频进行权限操作这个方案就不太行了,所以想出了对应的解决方案(方案三)。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,772评论 6 477
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,458评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,610评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,640评论 1 276
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,657评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,590评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,962评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,631评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,870评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,611评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,704评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,386评论 4 319
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,969评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,944评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,179评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 44,742评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,440评论 2 342

推荐阅读更多精彩内容