flask 使用 gevent-websocket + gunicorn 部署

超、凢脫俗 2021-09-30 08:24 467阅读 0赞

参考：[https://segmentfault.com/q/1010000009284816?\_ea=1883181][https_segmentfault.com_q_1010000009284816_ea_1883181]

[gunicorn 的官方配置文档：http://docs.gunicorn.org/en/stable/settings.html][gunicorn _http_docs.gunicorn.org_en_stable_settings.html]

### ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzM0MzE0NA_size_16_color_FFFFFF_t_70][] ###

### **使用框架[Flask-Sockets][]的代码【说明：[Flask-SocketIO是Flask-Sockets][Flask-Sockets]框架使用gunicorn服务器和gevent-websocket都是可以运行websocket的】 ** ###

from flask import Flask
    from flask_sockets import Sockets
    
    
    app = Flask(__name__)
    sockets = Sockets(app)
    
    
    @sockets.route('/')
    def echo_socket(ws):
        while not ws.closed:
            # 服务器端没关闭之前必须有接收阻塞，否则服务器和客户端都会死循环而崩溃
            # websocket的原理：客户端发送消息请求,服务器端回复数据【客户端不发消息,循环不会阻塞就是死循环】
            message = ws.receive()
            print("监听成功")
            ws.send(message)
    
    
    @app.route('/')
    def hello():
        return 'Hello World!'
    
    
    if __name__ == "__main__":
        from gevent import pywsgi
        from geventwebsocket.handler import WebSocketHandler
        server = pywsgi.WSGIServer(('0.0.0.0', 9099), app, handler_class=WebSocketHandler)
        server.serve_forever()

### **执行命令：【务必先安装pip install gevent-websocket】 ** ###

gunicorn -k geventwebsocket.gunicorn.workers.GeventWebSocketWorker -b 0.0.0.0:9099 testSockets:app

[https_segmentfault.com_q_1010000009284816_ea_1883181]: https://segmentfault.com/q/1010000009284816?_ea=1883181
[gunicorn _http_docs.gunicorn.org_en_stable_settings.html]: http://docs.gunicorn.org/en/stable/settings.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzM0MzE0NA_size_16_color_FFFFFF_t_70]: /images/20210812/d92bc181b46e4922a8c862ffbc75ca29.png
[Flask-Sockets]: https://mp.csdn.net/postedit/92801617