chat

其实楼主留下了两个不是坑的坑，需要开启redis服务端，开启flask的多线程（最新的flask已默认开启），主要是文档没有提示，也没有说。如果后来的同学想依靠文档，一步步下来是不可能测试成功。另外补充一下，需要中文交互，则要对消息生成器作一些改动，目的在于从redis数据库中得到的字节对象转为字符串发送给客户端就ok了。效果及代码如下 ![图片描述](https://dn-simplecloud.shiyanlou.com/courses/uid458321-20190629-1561780569676) ``` import datetime import flask import redis app = flask.Flask('sse-chat') # session cookie密钥 app.secret_key = 'pardon110' # 连接redis数据库,默认是零号库,可随便更改 rds = redis.StrictRedis(host='127.0.0.1', port=6379, db=1) # 消息生成器 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 flask.request.method == 'POST': flask.session['user'] = flask.request.form['user'] return flask.redirect('/') return '

user: ' # 接收js发送过来的消息 @app.route('/post', methods=['POST']) def post(): # 获取表单提交内容 message = flask.request.form['message'] user = flask.session.get('user', 'anonymous') now = datetime.datetime.now().replace(microsecond=0).time() # 通过频道发布消息 rds.publish('chat', u'[%s] %s: %s' % (now.isoformat(), user, message)) return flask.Response(status=204) # 定义事件流接口，返回一个response @app.route('/stream') def stream(): return flask.Response(event_stream(), mimetype="text/event-stream") @app.route('/') def home(): # 强制用户登录 if 'user' not in flask.session: return flask.redirect('/login') return u""" chat

hi, %s!

Message:

""" % flask.session['user'] if __name__ == '__main__': app.debug = True # falsk1.0.2默认多线程开启，默认端口是5000 app.run(host='0.0.0.0', port=8080) ```

“Flask 实现简单聊天室”实验报告