知识点
- 基于 Server-Sent Event 工作方式，Web 即时通信
- Redis 包 发布订阅功能的使用
- flask 快速入门，常用对象实例方法函数
- Vuejs 列表页面自动渲染
效果图
代码段
- app.py 主文件
import datetime
from flask import Flask, session, redirect, Response, request, render_template, url_for, flash
from redis import StrictRedis
app = Flask(__name__)
# session cookie密钥
app.secret_key = 'pardon110'
# 连接redis数据库,默认是零号库,可随便更改
rds = StrictRedis(db=3)
# 消息生成器
def event_stream():
# 从数据库连接上获取发布订阅管理对象实例
pub = rds.pubsub()
# 在管理订阅(建立通道)频道
pub.subscribe('chat')
# 监听频道信息
for message in pub.listen():
print(type(message['data']), type(message), message)
# 只响应有消息的（字节），首次无消息返回的为int状态码对象，直接忽略
if isinstance(message['data'], bytes):
# 转为utf8字符串，发送 SSE（Server Send Event）协议格式的数据
yield 'data: %s\\n\\n' % message['data'].decode()
# 首次访问需要登录
@app.route('/login', methods=['GET', 'POST'])
def login():
if request.method == 'POST':
session['username'] = request.form['user']
# 重定向到home处理器
flash('您已经成功登录！')
return redirect(url_for('home'))
return '登录
分享到:
閱讀更多 呆萌胖頭魚 的文章
