zoukankan      html  css  js  c++  java
  • SRS流媒体服务器搭建及拉取摄像头视频流经opencv处理后再推流至SRS

    OSSRS流媒体服务器

    官方文档:https://github.com/ossrs/srs/wiki
    
    SRS定位是运营级的互联网直播服务器集群,追求更好的概念完整性和最简单实现的代码。SRS提供了丰富的接入方案将RTMP流接入SRS,包括推送RTMP到SRS、推送RTSP/UDP/FLV到SRS、拉取流到SRS。 SRS还支持将接入的RTMP流进行各种变换,譬如将RTMP流转码、流截图、转发给其他服务器、转封装成HTTP-FLV流、转封装成HLS、 转封装成HDS、转封装成DASH、录制成FLV/MP4。SRS包含支大规模集群如CDN业务的关键特性,譬如RTMP多级集群、源站集群、VHOST虚拟服务器 、 无中断服务Reload、HTTP-FLV集群。此外,SRS还提供丰富的应用接口,包括HTTP回调、安全策略Security、HTTP API接口、 RTMP测速。SRS在源站和CDN集群中都得到了广泛的应用Applications。
    

      

    安装及启动
    # 拉代码
    git clone -b 4.0release https://gitee.com/ossrs/srs.git
        
    # 启动程序
    cd srs/trunk                 # 主目录
    ./configure && make          # 编译
    ./objs/srs -c conf/srs.conf  # 启动srs流媒体服务器
    # 配置推流服务器
    vim conf/rtmp.conf
    """
    # conf/rtmp.conf
    listen              1935;
    max_connections     1000;
    vhost __defaultVhost__ {
    }
    """
    ./objs/srs -c conf/rtmp.conf # 启动推流服务
    
    

    拉取视频流,经过opencv处理后再推流至SRS( Linux环境 )

    import cv2
    import subprocess
    ​
    rtsp = ""  # 拉取摄像头流地址
    rtmp = "rtmp://{{ip}}:1935/live/livestream"   # 推流地址
    ​
    """
    观看处理后的流地址为
    rtmp://{{ip}}/live/livestream
    也可以去SRS服务器后台
    http://{{ip}}:8080
    """
    ​
    # 读取视频并获取属性
    cap = cv2.VideoCapture(rtsp)
    size = (int(cap.get(cv2.CAP_PROP_FRAME_WIDTH)), int(cap.get(cv2.CAP_PROP_FRAME_HEIGHT)))
    sizeStr = str(size[0]) + 'x' + str(size[1])
    ​
    command = ['ffmpeg',
               '-y', '-an',
               '-f', 'rawvideo',
               '-vcodec', 'rawvideo',
               '-pix_fmt', 'bgr24',
               '-s', sizeStr,
               '-r', '25',
               '-i', '-',
               '-c:v', 'libx264',
               '-pix_fmt', 'yuv420p',
               '-preset', 'ultrafast',
               '-f', 'flv',
               rtmp]
    ​
    pipe = subprocess.Popen(command, shell=False, stdin=subprocess.PIPE)
    ​
    while cap.isOpened():
        success, frame = cap.read()
        if success:
            '''
            对frame进行识别处理
            '''
            if cv2.waitKey(1) & 0xFF == ord('q'):
                break
            pipe.stdin.write(frame.tostring())
    ​
    cap.release()
    pipe.terminate()
     
    

    感谢官网及 https://zhuanlan.zhihu.com/p/74260950 提供参考

  • 相关阅读:
    javascript 原型世界浅析
    zookeeper
    Message Queue
    js给对象onclick事件赋值
    什么是堡垒机
    什么是数据库实例
    动态规划解决矩阵路径问题
    0-1背包问题
    回溯算法
    Python列表的复制
  • 原文地址:https://www.cnblogs.com/zhoulangshunxinyangfan/p/14788934.html
Copyright © 2011-2022 走看看