flask上使用websocket的方法示例

更新時間：2022年06月08日 10:05:06 作者：王大拿

本文主要介紹了flask上使用websocket的方法示例，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧

Flask-Sockets和Flask-SocketIO之間的主要區(qū)別在于前者僅僅將WebSocket協(xié)議（通過使用gevent-websocket項目）進行包裝，因此它只適用于原生支持WebSocket協(xié)議的瀏覽器，對于那些不支持WebSocket協(xié)議的較老的瀏覽器，就無法使用它了。 Flask-SocketIO則不同，通過前面的介紹，讀者應該已經(jīng)知道了它不僅實現(xiàn)了WebSocket協(xié)議，并且對于那些不支持WebSocket協(xié)議的舊版瀏覽器，使用它也能夠實現(xiàn)相同的效果。新版舊版的瀏覽器都能使用他

另一個區(qū)別是Flask-SocketIO實現(xiàn)了SocketIO Javascript庫公開的消息傳遞協(xié)議。 Flask-Sockets只是實現(xiàn)通信通道，發(fā)送的是完全取決于應用程序。
Flask-SocketIO還為事件處理程序創(chuàng)建了一個類似flask的常規(guī)視圖函數(shù)的環(huán)境，包括創(chuàng)建應用程序和請求上下文。然而，在文檔中會介紹一些重要的例外情形。

Flask-SocketIO服務器端程序

如下是一個使用了Flask-SocketIO的Flask應用程序。

from flask import Flask, render_template
from flask_socketio import SocketIO, emit

app = Flask(__name__)
app.config['SECRET_KEY'] = 'secret!'
socketio = SocketIO(app)

@app.route('/')
def index():
? ? return render_template('index.html')

@socketio.on('my event', namespace='/test')
def test_message(message):
? ? emit('my response', {'data': message['data']})

@socketio.on('my broadcast event', namespace='/test')
def test_message(message):
? ? emit('my response', {'data': message['data']}, broadcast=True)

@socketio.on('connect', namespace='/test')
def test_connect():
? ? emit('my response', {'data': 'Connected'})

@socketio.on('disconnect', namespace='/test')
def test_disconnect():
? ? print('Client disconnected')

if __name__ == '__main__':
? ? socketio.run(app)

SocketIO客戶端程序

$(document).ready(function(){
? ? var socket = io.connect('http://' + document.domain + ':' + location.port + '/test');
? ? socket.on('my response', function(msg) {
? ? ? ? $('#log').append('<p>Received: ' + msg.data + '</p>');
? ? });
? ? $('form#emit').submit(function(event) {
? ? ? ? socket.emit('my event', {data: $('#emit_data').val()});
? ? ? ? return false;
? ? });
? ? $('form#broadcast').submit(function(event) {
? ? ? ? socket.emit('my broadcast event', {data: $('#broadcast_data').val()});
? ? ? ? return false;
? ? });
});

使用Flask-Sockets

sever端：

from flask import Flask
from flask_sockets import Sockets
import datetime
import time
import random

app = Flask(__name__)
sockets = Sockets(app)


@sockets.route('/echo')
def echo_socket(ws):
? ? while not ws.closed:

? ? ? ? now = datetime.datetime.now().isoformat() + 'Z'
? ? ? ? ws.send(now) ?#發(fā)送數(shù)據(jù)
? ? ? ? time.sleep(1)

@app.route('/')
def hello():
? ? return 'Hello World!'

if __name__ == "__main__":
? ? from gevent import pywsgi
? ? from geventwebsocket.handler import WebSocketHandler
? ? server = pywsgi.WSGIServer(('', 5000), app, handler_class=WebSocketHandler)
? ? print('server start')
? ? server.serve_forever()

client端：

<!DOCTYPE html>
<html lang="en">
<head>
? ? <meta charset="UTF-8">
? ? <title>Title</title>
? ? <script src="https://cdn.bootcss.com/jquery/3.2.0/jquery.js"></script>
</head>
<body>
? ? <div id="time" style="width: 300px;height: 50px;background-color: #0C0C0C;
? ? color: white;text-align: center;line-height: 50px;margin-left: 40%;font-size: 20px"></div>

? ? <script>
? ? ? ? ? ? var ws = new WebSocket("ws://127.0.0.1:5000/echo"); ?#連接server

? ? ? ? ? ? ws.onmessage = function (event) {
? ? ? ? ? ? ? ? content = document.createTextNode(event.data); # 接收數(shù)據(jù)
? ? ? ? ? ? ? ? $("#time").html(content);

? ? ? ? ? ? };

? ? </script>
? ? </body>
</html>

到此這篇關于flask上使用websocket的方法示例的文章就介紹到這了,更多相關flask使用websocket內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: