热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

使用Flask搭建一个流媒体服务器

摘要收到前不久订阅的PythonWeekly发过来的一个邮件通知,由Miguel写的一篇介绍如何使用Flask搭建一个流媒体服务器的文章,思路很新颖也很有意思。你可以点击这里阅读英

摘要

收到前不久订阅的PythonWeekly发过来的一个邮件通知,由Miguel写的一篇介绍如何使用Flask搭建一个流媒体服务器的文章,思路很新颖也很有意思。你可以点击这里阅读英文原文。或者跟随本文跟我一起体验一把搭建一个流媒体服务器的过程吧。

理论基础

流媒体有两大特点,一是数据量大。二是有实时性要求。针对这两个特点,我们必须把应答数据分块传输给客户端来实现流媒体服务器。这里我们用到了两个关键技术来实现流媒体服务器,我们使用生成器函数来把数据分块传送,Flask的Response类本身对生成器函数有良好的支持。接着,我们使用Multipart来组装一个HTTP应答。

生成器函数

生成器函数是可被打断和恢复的函数。其关键字是yield,来看一个例子:

**def** gen():
    **yield** 1
    **yield** 2
    **yield** 3

上面的代码我们就定义了一个生成器函数,当生成器函数被调用时,它返回一个生成器迭代器,或直接叫生成器。通过不断地调用生成器的next()方法来执行生成器函数体的代码,直到遇到异常为止。

>>>> g = gen()
>>> g

>>> g.next()
1
>>> g.next()
2
>>> g.next()
3
>>> g.next()
Traceback (most recent call last):
  File "", line 1, **in** 
**StopIteration**

从上面的例子可以看到一个生成器函数可以返回多个结果。每当程序执行到yield语句时,函数现场会被保留,同时返回一个值。Flask就是利用这个特性把应答数据通过生成器分块发送给客户端。

Multipart应答

Multipart应答包含一个multipart媒体类型,后面跟着多块独立的数据,每块数据有自己的Content-Type,每块数据之间通过boundary分隔。下面是一个例子:

HTTP/1.1 200 OK
Content-Type: multipart/x-mixed-replace; boundary=frame

--frame
Content-Type: image/jpeg


--frame
Content-Type: image/jpeg


...

Multipart有多种不同的类型,针对流媒体,我们使用multipart/x-mixed-replace。浏览器处理这种Multipart类型时,会使用当前的块数据替换之前的块数据。这刚好就是我们想要的流媒体的效果。我们可以把媒体的一帧数据打包为一个数据块,每块数据有自己的Content-Type和可选的Content-Length。浏览器逐帧替换,就实现了视频的播放功能。RFC1341对Multipart媒体类型进行了详细的描述,有兴趣的朋友可移步参考。

实现流媒体服务器

上面介绍了实现流媒体服务器的理论知识。接下来我们使用这些知识来用Flask搭建一个流媒体服务器。

有多种方法可以在浏览器里实现流媒体播放,和Flask配合较好的是使用Motion JPEG的方法。简单地讲,就是把视频画面通过JPEG图片的方式,一帧一帧地发送给浏览器。这也是很多IP Camera使用的流媒体播放方式,它实时性很好,但视频效果不是很理想。因为Motion JPEG对视频的压缩效率太低了。

#!/usr/bin/env python
from flask import Flask, render_template, Response
from camera import Camera

app = Flask(__name__)

@app.route('/')
def index():
    return render_template('index.html')

def gen(camera):
    while True:
        frame = camera.get_frame()
        yield (b'--frame\r\n'
               b'Content-Type: image/jpeg\r\n\r\n' + frame + b'\r\n')

@app.route('/video_feed')
def video_feed():
    return Response(gen(Camera()),
                    mimetype='multipart/x-mixed-replace; boundary=frame')

if __name__ == '__main__':
    app.run(host='0.0.0.0', debug=True)

这个Flask应用程序导入了一个Camera类,这个类是为了持续不断地提供视频的帧数据的类。这个程序提供了两个服务路径,/路径由index.html模板提供服务,下面是它的内容:


  
    
  
  
    Video Streaming Demonstration
    
  

这是一个非常简单的HTML网页。其中关键的是img这个标签,它定义了一张图片元素,其URL是/video_feed。从Flask应用程序代码的Line17-20可以知道,/video_feed是由一个video_feed()方法提供服务的,它返回的是一个multipart应答。这个应答的内容是由生成器函数gen()提供的。而gen()函数就是不停地从camera里获取一帧一帧的图片,并通过生成器返回给客户端。客户端浏览器在收到这个流媒体时,会在img标签定义的图片里,逐帧地显示图片,这样一个视频就播放出来的。目前市面上绝大部分浏览器都支持这个功能。

模拟视频帧数据

现在只要实现Camera类,并提供源源不断的视频帧数据即可运行上面的程序了。由于连接摄像头涉及到硬件,我们使用一个简单的模拟器来源源不断地返回数据:

#!/usr/bin/env python
from time import time

class Camera(object):
    def __init__(self):
        self.frames = [open(f + '.jpg', 'rb').read() for f in ['1', '2', '3']]

    def get_frame(self):
        return self.frames[int(time()) % 3]

这个代码很简单,它从本地读取三个图片,并根据当前时间,每秒返回不同的图片来模拟提供源源不断的视频帧数据。

大家可以从原作者的GitHub上下载程序的代码来运行。

`$ git clonehttps://github.com/miguelgrinberg/flask-video-streaming.git

或者直接下载ZIP包来运行。

下载完代码,进入代码根目录,执行python app.py。然后在浏览器里打开http://localhost:5000即可以看到模拟的视频了。

安装Flask

要运行上述代码,需要先安装Flask。官网上有教程,简单易懂。

连接硬件摄像头

下载代码的同学应该可以看到代码里还有一个camera_pi.py的文件,这个是用来实现真正的连接硬件摄像头的代码。原文作者使用的摄像头是Raspberry Pi,这是个类似Arduino的开源的硬件项目。

一些限制

当客户端浏览器打开上述流媒体服务的网址时,它就独占了这个线程。在把Flask应用Deploy到Nginx+uwsgi服务器上时,它能服务的最大客户端数目为应用程序的线程数,一般就是几个到几十个。而如果是在本机使用python app.py运行的测试服务器,则只能服务一个客户端。

针对这个问题,原文作者提供了一个解决方案。使用gevent来解决。

gevent is a coroutine-based Python networking library that uses greenlet to provide a high-level synchronous API on top of the libev event loop.

有兴趣的同学可以在原代码的基础上,引入gevent来支持多客户端。


推荐阅读
  • 本文介绍了Java并发库中的阻塞队列(BlockingQueue)及其典型应用场景。通过具体实例,展示了如何利用LinkedBlockingQueue实现线程间高效、安全的数据传递,并结合线程池和原子类优化性能。 ... [详细]
  • 本文探讨了如何优化和正确配置Kafka Streams应用程序以确保准确的状态存储查询。通过调整配置参数和代码逻辑,可以有效解决数据不一致的问题。 ... [详细]
  • 优化ListView性能
    本文深入探讨了如何通过多种技术手段优化ListView的性能,包括视图复用、ViewHolder模式、分批加载数据、图片优化及内存管理等。这些方法能够显著提升应用的响应速度和用户体验。 ... [详细]
  • 本文将介绍如何编写一些有趣的VBScript脚本,这些脚本可以在朋友之间进行无害的恶作剧。通过简单的代码示例,帮助您了解VBScript的基本语法和功能。 ... [详细]
  • 本文介绍如何使用Objective-C结合dispatch库进行并发编程,以提高素数计数任务的效率。通过对比纯C代码与引入并发机制后的代码,展示dispatch库的强大功能。 ... [详细]
  • 本文详细介绍如何使用Python进行配置文件的读写操作,涵盖常见的配置文件格式(如INI、JSON、TOML和YAML),并提供具体的代码示例。 ... [详细]
  • 1:有如下一段程序:packagea.b.c;publicclassTest{privatestaticinti0;publicintgetNext(){return ... [详细]
  • 本文详细介绍了如何在Linux系统上安装和配置Smokeping,以实现对网络链路质量的实时监控。通过详细的步骤和必要的依赖包安装,确保用户能够顺利完成部署并优化其网络性能监控。 ... [详细]
  • 使用 Azure Service Principal 和 Microsoft Graph API 获取 AAD 用户列表
    本文介绍了一段通用代码示例,该代码不仅能够操作 Azure Active Directory (AAD),还可以通过 Azure Service Principal 的授权访问和管理 Azure 订阅资源。Azure 的架构可以分为两个层级:AAD 和 Subscription。 ... [详细]
  • 本文详细介绍了Java编程语言中的核心概念和常见面试问题,包括集合类、数据结构、线程处理、Java虚拟机(JVM)、HTTP协议以及Git操作等方面的内容。通过深入分析每个主题,帮助读者更好地理解Java的关键特性和最佳实践。 ... [详细]
  • Python自动化处理:从Word文档提取内容并生成带水印的PDF
    本文介绍如何利用Python实现从特定网站下载Word文档,去除水印并添加自定义水印,最终将文档转换为PDF格式。该方法适用于批量处理和自动化需求。 ... [详细]
  • MQTT技术周报:硬件连接与协议解析
    本周开发笔记重点介绍了在新项目中使用MQTT协议进行硬件连接的技术细节,涵盖其特性、原理及实现步骤。 ... [详细]
  • 掌握远程执行Linux脚本和命令的技巧
    本文将详细介绍如何利用Python的Paramiko库实现远程执行Linux脚本和命令,帮助读者快速掌握这一实用技能。通过具体的示例和详尽的解释,让初学者也能轻松上手。 ... [详细]
  • 本文详细分析了Hive在启动过程中遇到的权限拒绝错误,并提供了多种解决方案,包括调整文件权限、用户组设置以及环境变量配置等。 ... [详细]
  • 使用Vultr云服务器和Namesilo域名搭建个人网站
    本文详细介绍了如何通过Vultr云服务器和Namesilo域名搭建一个功能齐全的个人网站,包括购买、配置服务器以及绑定域名的具体步骤。文章还提供了详细的命令行操作指南,帮助读者顺利完成建站过程。 ... [详细]
author-avatar
丿车荣璇
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有