Python实现推流直播

Python实现推流直播

首先给出展示结果，大体就是检测工业板子是否出现。采取检测的方法比较简单，用的OpenCV的模板检测。
在这里插入图片描述

大体思路

  • opencv读取视频
  • 将视频分割为帧
  • 对每一帧进行处理(opencv模板匹配)
  • 在将此帧写入pipe管道
  • 利用ffmpeg进行推流直播

中间遇到的问题

在处理本地视频时，并没有延时卡顿的情况。但对实时视频流的时候，出现了卡顿延时的效果。在一顿度娘操作之后，采取了多线程的方法。

opencv读取视频

def run_opencv_camera():video_stream_path = 0 # 当video_stream_path = 0 会开启计算机 默认摄像头  也可以为本地视频文件的路径cap = cv2.VideoCapture(video_stream_path)while cap.isOpened():is_opened, frame = cap.read()cv2.imshow('frame', frame)cv2.waitKey(1)cap.release()

OpenCV模板匹配

模板匹配就是在一幅图像中寻找一个特定目标的方法之一，这种方法的原理非常简单，遍历图像中每一个可能的位置，比较各处与模板是否相似，当相似度足够高时，就认为找到了目标。

def template_match(img_rgb):# 灰度转换img_gray = cv2.cvtColor(img_rgb, cv2.COLOR_BGR2GRAY)# 模板匹配res = cv2.matchTemplate(img_gray, template, cv2.TM_CCOEFF_NORMED)# 设置阈值threshold = 0.8loc = np.where(res >= threshold)if len(loc[0]):# 这里直接固定区域cv2.rectangle(img_rgb, (155, 515), (1810, 820), (0, 0, 255), 3)cv2.putText(img_rgb, category, (240, 600), cv2.FONT_HERSHEY_SIMPLEX, 1, (0, 255, 0), 2)cv2.putText(img_rgb, Confidence, (240, 640), cv2.FONT_HERSHEY_SIMPLEX, 1, (0, 255, 0), 2)cv2.putText(img_rgb, Precision, (240, 680), cv2.FONT_HERSHEY_SIMPLEX, 1, (0, 255, 0), 2)cv2.putText(img_rgb, product_yield, (240, 720), cv2.FONT_HERSHEY_SIMPLEX, 1, (0, 255, 0), 2)cv2.putText(img_rgb, result, (240, 780), cv2.FONT_HERSHEY_SIMPLEX, 2, (0, 255, 0), 5)return img_rgb

FFmpeg推流

  • 在Ubuntu 14 上安装 Nginx-RTMP 流媒体服务器
    https://www.cnblogs.com/cocoajin/p/4353767.html
import subprocess as sprtmpUrl = ""
camera_path = ""
cap = cv.VideoCapture(camera_path)# Get video information
fps = int(cap.get(cv.CAP_PROP_FPS))
width = int(cap.get(cv.CAP_PROP_FRAME_WIDTH))
height = int(cap.get(cv.CAP_PROP_FRAME_HEIGHT))# ffmpeg command
command = ['ffmpeg','-y','-f', 'rawvideo','-vcodec','rawvideo','-pix_fmt', 'bgr24','-s', "{}x{}".format(width, height),'-r', str(fps),'-i', '-','-c:v', 'libx264','-pix_fmt', 'yuv420p','-preset', 'ultrafast','-f', 'flv', rtmpUrl]# 管道配置
p = sp.Popen(command, stdin=sp.PIPE)# read webcamera
while(cap.isOpened()):ret, frame = cap.read()if not ret:print("Opening camera is failed")break# process frame# your code# process frame# write to pipep.stdin.write(frame.tostring())
  • 说明:rtmp是要接受视频的服务器，服务器按照上面所给连接地址即可。

多线程处理

  • python mutilprocessing多进程编程 https://blog.csdn.net/jeffery0207/article/details/82958520
def image_put(q):# 采取本地视频验证cap = cv2.VideoCapture("./new.mp4")# 采取视频流的方式# cap = cv2.VideoCapture(0)# cap.set(cv2.CAP_PROP_FRAME_WIDTH,1920)# cap.set(cv2.CAP_PROP_FRAME_HEIGHT,1080)if cap.isOpened():print('success')else:print('faild')while True:q.put(cap.read()[1])q.get() if q.qsize() > 1 else time.sleep(0.01)def image_get(q):while True:# start = time.time()#flag += 1frame = q.get()frame = template_match(frame)# end = time.time()# print("the time is", end-start)cv2.imshow("frame", frame)cv2.waitKey(0)# pipe.stdin.write(frame.tostring())#cv2.imwrite(save_path + "%d.jpg"%flag,frame)# 多线程执行一个摄像头
def run_single_camera():# 初始化mp.set_start_method(method='spawn')  # init# 队列queue = mp.Queue(maxsize=2)processes = [mp.Process(target=image_put, args=(queue, )),mp.Process(target=image_get, args=(queue, ))][process.start() for process in processes][process.join() for process in processes]def run():run_single_camera()  # quick, with 2 threadspass
  • 说明:使用Python3自带的多线程模块mutilprocessing模块，创建一个队列，线程A从通过rstp协议从视频流中读取出每一帧，并放入队列中，线程B从队列中将图片取出，处理后进行显示。线程A如果发现队列里有两张图片，即线程B的读取速度跟不上线程A，那么线程A主动将队列里面的旧图片删掉，换新图片。

全部代码展示

import time
import multiprocessing as mp
import numpy as np
import  random
import subprocess as sp
import cv2
import os
# 定义opencv所需的模板
template_path = "./high_img_template.jpg"# 定义矩形框所要展示的变量
category = "Category:      board"var_confidence = (np.random.randint(86, 98)) / 100
Confidence = "Confidence:     " + str(var_confidence)var_precision = round(random.uniform(98, 99), 2)
Precision = "Precision:    " + str(var_precision) + "%"product_yield = "Product Yield:  100%"result = "Result: perfect"# 读取模板并获取模板的高度和宽度
template = cv2.imread(template_path, 0)
h, w = template.shape[:2]
# 定义模板匹配函数
def template_match(img_rgb):# 灰度转换img_gray = cv2.cvtColor(img_rgb, cv2.COLOR_BGR2GRAY)# 模板匹配res = cv2.matchTemplate(img_gray, template, cv2.TM_CCOEFF_NORMED)# 设置阈值threshold = 0.8loc = np.where(res >= threshold)if len(loc[0]):# 这里直接固定区域cv2.rectangle(img_rgb, (155, 515), (1810, 820), (0, 0, 255), 3)cv2.putText(img_rgb, category, (240, 600), cv2.FONT_HERSHEY_SIMPLEX, 1, (0, 255, 0), 2)cv2.putText(img_rgb, Confidence, (240, 640), cv2.FONT_HERSHEY_SIMPLEX, 1, (0, 255, 0), 2)cv2.putText(img_rgb, Precision, (240, 680), cv2.FONT_HERSHEY_SIMPLEX, 1, (0, 255, 0), 2)cv2.putText(img_rgb, product_yield, (240, 720), cv2.FONT_HERSHEY_SIMPLEX, 1, (0, 255, 0), 2)cv2.putText(img_rgb, result, (240, 780), cv2.FONT_HERSHEY_SIMPLEX, 2, (0, 255, 0), 5)return img_rgb# 视频属性
size = (1920, 1080)
sizeStr = str(size[0]) + 'x' + str(size[1])
# fps = cap.get(cv2.CAP_PROP_FPS)  # 30p/self
# fps = int(fps)
fps = 11
hz = int(1000.0 / fps)
print ('size:'+ sizeStr + ' fps:' + str(fps) + ' hz:' + str(hz))rtmpUrl = 'rtmp://localhost/hls/test'
# 直播管道输出
# ffmpeg推送rtmp 重点 ： 通过管道 共享数据的方式
command = ['ffmpeg','-y','-f', 'rawvideo','-vcodec','rawvideo','-pix_fmt', 'bgr24','-s', sizeStr,'-r', str(fps),'-i', '-','-c:v', 'libx264','-pix_fmt', 'yuv420p','-preset', 'ultrafast','-f', 'flv',rtmpUrl]
#管道特性配置
# pipe = sp.Popen(command, stdout = sp.PIPE, bufsize=10**8)
pipe = sp.Popen(command, stdin=sp.PIPE) #,shell=False
# pipe.stdin.write(frame.tostring())def image_put(q):# 采取本地视频验证cap = cv2.VideoCapture("./new.mp4")# 采取视频流的方式# cap = cv2.VideoCapture(0)# cap.set(cv2.CAP_PROP_FRAME_WIDTH,1920)# cap.set(cv2.CAP_PROP_FRAME_HEIGHT,1080)if cap.isOpened():print('success')else:print('faild')while True:q.put(cap.read()[1])q.get() if q.qsize() > 1 else time.sleep(0.01)# 采取本地视频的方式保存图片
save_path = "./res_imgs"
if os.path.exists(save_path):os.makedir(save_path)def image_get(q):while True:# start = time.time()#flag += 1frame = q.get()frame = template_match(frame)# end = time.time()# print("the time is", end-start)cv2.imshow("frame", frame)cv2.waitKey(0)# pipe.stdin.write(frame.tostring())#cv2.imwrite(save_path + "%d.jpg"%flag,frame)# 多线程执行一个摄像头
def run_single_camera():# 初始化mp.set_start_method(method='spawn')  # init# 队列queue = mp.Queue(maxsize=2)processes = [mp.Process(target=image_put, args=(queue, )),mp.Process(target=image_get, args=(queue, ))][process.start() for process in processes][process.join() for process in processes]def run():run_single_camera()  # quick, with 2 threadspassif __name__ == '__main__':run()

参考文章

    1. 在Ubuntu 14 上安装 Nginx-RTMP 流媒体服务器:https://www.cnblogs.com/cocoajin/p/4353767.html
    1. python mutilprocessing多进程编程:https://blog.csdn.net/jeffery0207/article/details/82958520
    1. ffmpeg 将视频和图片互转化:https://blog.csdn.net/TingiBanDeQu/article/details/53896944
    1. 基于python2.7的opencv3.3-ffmpeg-rtmp视频处理并推送流直播:https://blog.csdn.net/u014303844/article/details/80394101
    1. 读取多个(海康\大华)网络摄像头的视频流 (使用opencv-python)，解决实时读取延迟问题:https://zhuanlan.zhihu.com/p/38136322
    1. python利用ffmpeg进行rtmp推流直播:https://zhuanlan.zhihu.com/p/74260950

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

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

相关文章

直播-拉流和推流概述

直播-拉流和推流概述

拉流（播放） 根据协议类型（如RTMP、RTP、RTSP、HTTP等），与服务器建立连接并接收数据； 解析二进制数据，从中找到相关流信息；根据不同的封装格式（如FLV、TS）解…
阅读更多...
网红直播辅助推流设备（可同时多平台推流直播）

网红直播辅助推流设备（可同时多平台推流直播）

1. 多平台推流需求 许多刚入行的小主播，不知道哪个平台适合自己，也不知道哪个平台的流量最好，因此都很希望能同时在多个平台尝试，鸡蛋分开放到多个篮子是最安全的。这就催生了多平台推流的需求。 2. 软件方案 在百度上搜索多平…
阅读更多...
微信直播如何引流获客？

微信直播如何引流获客？

微信作为国内最大的社交平台，拥有巨大的流量，很多商家因此想通过微信直播进行引流获客。但是对于不同的行业，不同的领域的商家来说，直播引流获客的方式也不同，如创客匠人平台打通微信直播渠道，通过多种工具…
阅读更多...
H5直播之从推流服务搭建到视频直播

H5直播之从推流服务搭建到视频直播

最近视频直播比较火，发现目前 WEB 上主流的视频直播方案有 HLS 和 RTMP，移动 WEB 端目前以 HLS 为主，PC端则以 RTMP 为主实时性较好，接下来将围绕这两种视频流协议来展开H5直播主题分享，下面通过本文给大家分享HTML5视…
阅读更多...
chatgpt赋能python：Python中连接函数的使用

chatgpt赋能python：Python中连接函数的使用

Python中连接函数的使用 在Python编程中，连接函数是一个非常重要的部分。连接函数主要是用来连接字符串和序列。它可以把多个字符串或序列合并成一个字符串或序列。本篇文章将介绍Python中连接函数的基本用法。 连接字符串 使用加号（）可以…
阅读更多...
chatgpt赋能python：Python内连接介绍

chatgpt赋能python：Python内连接介绍

Python内连接介绍 Python是一种高级编程语言，因其简单易懂、易于学习、高效易用而备受欢迎。内连接是Python编程中的一个重要概念，其可以用于连接两个或更多数据集，极大地方便了数据的处理和分析。 Python内连接是指通过相同的列将两个或更…
阅读更多...
chatgpt赋能python：Python连接Hive：深度剖析

chatgpt赋能python：Python连接Hive：深度剖析

Python连接Hive：深度剖析 简介 近年来，数据分析和处理在企业中扮演着越来越重要的角色。因此，数据仓库系统（如Hive）的需求也越来越迫切。对于数据分析工程师和开发人员而言，Hive提供了一种基于Hadoop的SQ…
阅读更多...
chatgpt赋能python：Python如何连接数据库？

chatgpt赋能python：Python如何连接数据库？

Python如何连接数据库？ Python作为一种高级编程语言，已经被广泛应用于数据科学和Web开发。连接数据库是Python的一项重要功能，可以使我们的代码访问各种数据源来收集、分析和存储数据。在这篇文章中，我们将介绍Python如何连接各种…
阅读更多...
【VMware workstation】虚拟机/主机互相ping不通的问题排查

【VMware workstation】虚拟机/主机互相ping不通的问题排查

环境：主机 Windows10 VMware workstation pro; 虚拟机 Windows XP 参考：VMware虚拟机和主机互相ping不通排查以及解决 workstation下载：感谢原作者！截止到目前是可用的 问题描述 虚拟机无法上网，主机与虚拟机互相pi…
阅读更多...
免费主机 虚拟主机 香港虚拟主机

免费主机 虚拟主机 香港虚拟主机

免费主机 虚拟主机 香港虚拟主机http://zhuji.zzhinan.com/
阅读更多...
虚拟呼叫中心运营管理平台压力测试

虚拟呼叫中心运营管理平台压力测试

今次将以实际的案例来说明，asterisk 的并发量，通过对比发现asterisk 1.8 性能比asterisk1.4 版本高了很多。 普通4线程的CPU，2G 内存，Asterisk 1.8 运行100路并发，系统负载最大负载也只有到1，但是Asterisk …
阅读更多...
host-only模式,主机能ping通虚拟机，虚拟机无法ping通主机解决办法

host-only模式,主机能ping通虚拟机，虚拟机无法ping通主机解决办法

一、问题描述 今天配环境发现VMware下的虚拟机处于host-only模式时：主机能ping通虚拟机，虚拟机无法ping通主机。 二、解决办法 1、打开控制面板—->Windows防火墙——>允许应用或功能xxx 2.勾选“文件和打印机共享” 然后点确定。
阅读更多...
为什么VM虚拟机ping得通主机，但主机ping不通虚拟机？

为什么VM虚拟机ping得通主机，但主机ping不通虚拟机？

云计算这门课程要搭建hadoop集群环境，我就按着老师得要求，在我win 10里的VMware中安装了Ubuntu。 确认安装Hadoop，然后两台机子还要互ping。之前的步骤顺风顺水，到这一步就出现问题了。我主机ping不通虚拟机，但是Ubun…
阅读更多...
VMware 主机与虚拟机ping不通问题

VMware 主机与虚拟机ping不通问题

VMnet1：是host-only，也就是说，选择用VMnet1就相当于VMware提供了一台虚拟机，仅虚拟机和真实系统连接，虚拟机可用与真实系统共享文件，但是虚拟机无法访问外网 VMnet8：是网络地址转换&#xff08…
阅读更多...
为什么选择香港虚拟主机？

为什么选择香港虚拟主机？

虚拟主机的工作原理是在单个物理服务器托管多个站点——在这台共享的服务器上，各种用户以非常低的成本来享受资源配置，适合不需要高级配置或流量不高的小型网站。而位于香港数据中心的虚拟主机通常拥有免备案、高稳定性的特点，尤其适合拓宽国…
阅读更多...
对于主机ping不通vmware虚拟机，虚拟机能ping通主机的一种解决方案

对于主机ping不通vmware虚拟机，虚拟机能ping通主机的一种解决方案

如果都在vmware的网络适配器的参数和主机中VMnet8网络配置好了都不能解决的话，可以试试重启VMnet8网络 先禁用再启动
阅读更多...
Callnovo全球联络中心云通讯CRM平台系列(一)

Callnovo全球联络中心云通讯CRM平台系列(一)

技术赋能语音电话组件为全球来电顾客打造优质体验 为了实现全球客服中心优质运营管理，给客服中心一线客服人员和全球来电顾客打造优质体验，每一家进军全球市场的出海企业都一定会通过自建或者外包，部署一套专业且完善的全球客诉解决方案。其…
阅读更多...
关于虚拟机能ping通主机，而主机不能ping通虚拟机的问题

关于虚拟机能ping通主机，而主机不能ping通虚拟机的问题

Ping不通虚拟机或者主机这个问题恐怕让很多同学头疼吧？如果你是关于标题的问题，可以参考一下，如果是其他问题请移步其他博客。当然也欢迎大家前来阅读指正！第一次写，写的不好的地方大家多包涵！ 这个问题是我…
阅读更多...
经济回暖、兴趣电商升级，品牌在竞争白热化的市场中如何突围？| D3大会圆桌回顾

经济回暖、兴趣电商升级，品牌在竞争白热化的市场中如何突围？| D3大会圆桌回顾

冬去春来，消费市场韧性回弹，消费趋势正处于“转折”和“跃升”的阶段。新的机遇和挑战也将伴随着新的思维、方法和模式，呈现出更多元的变化和创新：渠道虚实融合，内容为王，社会化媒体成为主战场等消费场景不…
阅读更多...
计算机的负面影响英语作文,关于电脑的坏处英语作文

计算机的负面影响英语作文,关于电脑的坏处英语作文

电脑，大家并不陌生，电脑能带给我们什么呢? 我觉得电脑是我们学习中的好伙伴，电脑可以用来查资料，电脑可以用来看你最想了解的新闻，电脑可以用来写博文，发表你自己的文章，发表你... 这学期&…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023