python开发视频播放器_基于Flask的在线视频播放器

项目描述

使用 Flask 实现的简单网页视频播放器。

开发准备：Python3

功能简介

在线视频播放

视频列表浏览

上传共享视频

基于socket的多人弹幕评论

功能演示

项目结构

Vision

—— blueprints （注册蓝图）

—— sockets （内嵌 socket ，用于实现在线评论等功能）

—— static （静态资源目录）

———— css （ css 文件）

———— js （ Javascript 文件）

———— img （静态图片资源）

———— image （视频缩略图）

———— video （视频源文件）

———— upload （保存视频格式文件）

—— templates （网页模板文件）

—— utils （功能文件夹）

—— app.py （系统启动文件）

1. 上传视频

定义/play/upload接口，用于提供上传视频页面。

定义/play/music/upload接口，用于网页通过POST请求上传视频到后台。

bp = Blueprint(&＃39;play&＃39;,__name__,url_prefix="/play")

@bp.route(&＃39;/upload&＃39;, methods=[&＃39;GET&＃39;])

def upload():

return render_template(&＃39;play/upload.html&＃39;)

@bp.route(&＃39;/music/upload&＃39;, methods=[&＃39;POST&＃39;])

def doupload():

id = random_name()

# 下载视频

video = request.files[&＃39;video&＃39;]

video.save(&＃39;static/video/&＃39; + id + file_extension(video.filename))

# 下载视频缩略图

image = &＃39;static/image/&＃39; + id + &＃39;.jpg&＃39;

capture(&＃39;static/video/&＃39; + id + file_extension(video.filename), image)

data = {

"author": request.form["author"],

"date": now(),

"image": "/" + image,

"video": "/static/video/" + id + file_extension(video.filename),

"title": request.form["title"]

"description": request.form["description"]

}

# 保存视频格式化文件

with open("static/upload/" + id + ".json", "w") as f:

json.dump(data, f)

return redirect(url_for(&＃39;play.index&＃39;))

default.json（视频保存格式）：

{

"author": "管理员",

"date": "2019-03-21 15:33",

"image": "/static/image/wsl.png",

"video": "/static/video/wsl.mp4",

"title": "一笑倾城",

"description": "我想和你唱 汪苏泷"

}

提示：所有格式化文件均保存在upload文件夹中。

上传视频表单：

返回

分享人：

长度1~5个字符

标题：

长度1~20个字符

视频：

请使用mp4格式

2. 滚动弹幕评论

服务端

基于flask_socketio；

监听用户登录（connect）、登出（disconnect）状态；

一旦监听到用户评论信息（imessage），就向客户端广播 message 信息。

from flask_socketio import emit

namespace = "/comment"

@socketio.on(&＃39;imessage&＃39;, namespace=namespace)

def test_message(message):

emit(&＃39;message&＃39;, {&＃39;data&＃39;: message[&＃39;data&＃39;]}, broadcast=True, namespace=namespace)

@socketio.on(&＃39;connect&＃39;, namespace=namespace)

def connected_msg():

"""socket client event - connected"""

socketio.emit(&＃39;message&＃39;, {&＃39;data&＃39;: &＃39;系统消息：欢迎进入！！！&＃39;}, namespace=namespace)

print(&＃39;client connected!&＃39;)

@socketio.on(&＃39;disconnect&＃39;, namespace=namespace)

def disconnect_msg():

"""socket client event - disconnected"""

socketio.emit(&＃39;message&＃39;, {&＃39;data&＃39;: &＃39;系统消息：有人离开了！！！&＃39;}, broadcast=True, namespace=namespace)

print(&＃39;client disconnected!&＃39;)

客户端

基于socket.io.min.js ；

监听所有 message 信息，并提取内容产生滚动弹幕；

获取用户评论信息，并以 imessage 消息形式发送给服务端。

var namespace = &＃39;/comment&＃39;;

var socket = io.connect(location.protocol + &＃39;//&＃39; + document.domain + &＃39;:&＃39; + location.port + namespace);

socket.on(&＃39;message&＃39;, function (msg) {

$(&＃39;body&＃39;).barrager({&＃39;href&＃39;: &＃39;#&＃39;, &＃39;info&＃39;: $(&＃39;

});

$("#comment").keypress(function (e) {

if (e.which == 13) {

socket.emit(&＃39;imessage&＃39;, {data: encodeURI($(&＃39;#comment&＃39;).val())});

$(&＃39;#comment&＃39;).val(&＃39;&＃39;);

}

});

3. 项目启动入口

app.py：

from flask import *

from flask_socketio import SocketIO

from blueprints import play

from sockets import comment

app = Flask(__name__)

app.config[&＃39;SECRET_KEY&＃39;] = &＃39;123456&＃39;

@app.route(&＃39;/&＃39;)

def index():

return redirect(url_for("play.index"))

app.register_blueprint(play.bp)

socketio = SocketIO(app)

comment.register_comment(socketio)

if __name__ == &＃39;__main__&＃39;:

socketio.run(app, host=&＃39;0.0.0.0&＃39;, port=80, debug=True)

在命令行中执行python app.py，启动系统，如果提示有工具包未安装，使用pip install即可 。默认运行在80端口，你可以在浏览器中访问localhost或者电脑的局域网IP地址。启动成功后，赶紧把你的服务IP地址告诉小伙伴，一起交流分享视频资源吧！

完整项目代码可以在微信公众号【四元群】，后台回复「播放器」获取。