Flask-Websocket实现服务端即时推送信息到web前端

本文转载自查看原文 2020-04-06 13:46 1168 flask

 1 from flask import Flask, request,render_template
 2 from geventwebsocket.websocket import WebSocket
 3 from gevent.pywsgi import WSGIServer
 4 from geventwebsocket.handler import WebSocketHandler
 5 
 6 
 7 user_socket_list = []
 8 app = Flask(__name__)
 9 
10 @app.route('/')
11 def index():
12     return render_template('index.html')
13 
14 @app.route('/ws')
15 def ws():
16     user_socket = request.environ.get('wsgi.websocket') # type:WebSocket  
17     # 建立连接
18     if user_socket:
19         user_socket_list.append(user_socket) # 将建立的连接添加进一个列表
20         print(len(user_socket_list))
21     else:
22         print('请用websocket链接')
23         return render_template('index.html',message='请用websocket链接')
24     while True:
25         msg = user_socket.receive()
26         print(msg)
27         for socket in user_socket_list:
28                 socket.send(msg)
29                 
30 if __name__ == '__main__':
31     http_serv = WSGIServer(('0.0.0.0',5000),app,handler_class=WebSocketHandler)
32     http_serv.serve_forever()

APP.PY

 1 <!DOCTYPE html>
 2 <html lang="en">
 3 
 4 <head>
 5     <meta charset="UTF-8">
 6     <title>Title</title>
 7 </head>
 8 
 9 <body>
10     <h1>
11         <dvi id='idMsg'>群聊</dvi>
12     </h1>
13     <input type='button' value='Test' onclick='test()'>
14 
15     <script src="https://cdn.staticfile.org/jquery/1.10.2/jquery.min.js"></script>
16     <script>
17         var ws = new WebSocket('ws://127.0.0.1:5000/ws');
18         ws.onmessage = function(data) {
19             var jdata = JSON.parse(data.data);
20             $('#idMsg').html(jdata.user + ': ' + jdata.text);
21         }
22 
23         function test() {
24             mydict = {
25                 'user': 'myname',
26                 'text': 'mytext',
27             };
28             jdata = JSON.stringify(mydict);
29             ws.send(jdata)
30         }
31     </script>
32 </body>
33 
34 </html>

index.html

免责声明！

本站转载的文章为个人学习借鉴使用，本站对版权不负任何法律责任。如果侵犯了您的隐私权益，请联系本站邮箱yoyou2525@163.com删除。

猜您在找 springboot使用websocket进行实时传送信息实战(包含服务端和客户端) 利用控制台承载SignalR作为服务端、及第三方推送信息 SpringBoot2.0集成WebSocket，实现后台向前端推送信息 SpringBoot2.0集成WebSocket，实现后台向前端推送信息 SpringBoot2.0集成WebSocket，实现后台向前端推送信息 WebSocket 实现服务端给客户端推送消息 Flask-websocket实现聊天功能 Springboot整合WebSocket，实现向指定页面推送信息 [WebSocket长连接]SpringBoot2.0集成WebSocket，实现后台向前端推送信息如何实现服务端主动给客户端推送消息，websocket详解，以及django如何使用websocket问题