flask-SocketIO

本文来源：https://www.jianshu.com/p/d81397edd2b1

 

 

websocket是html5中实现了服务端和客户端进行双向文本或二进制数据通讯的一种新协议，其实已经低于HTTP协议自己和HTTP本质上没有什么关系了。不过形式上二者仍是有想象之处。所以websocket的链接地址是长这样的：ws://localhost:8080。能够看到，协议修饰符不是http了。

　　另外，websocket在链接创建阶段是经过HTTP的握手方式进行的，这能够看作是为了兼容浏览器或者使用一些现成的功能来实现，这样一种捷径。当链接创建以后，客户端和服务端之间就再也不进行HTTP通讯了，全部信息交互都由websocket接管。

　　从资源占用的角度上来讲，其实websocket比ajax占用的资源更多，但它真正实现了全双工通讯这一点仍是很理想的，意味着不管是前端仍是后台的信息交互程序编写都会变得更加方便。因为采用了新的协议，因此咱们也须要适当地改造下先后台的程序

对app进行一些路由设置
对socketio进行一些监听设置
socketio的监听设置，这才是真正关系到先后端websocket通讯过程的。

 

 

@socketio.on('request_for_response',namespace='/testnamespace')
def give_response(data):
    value = data.get('param')

    #进行一些对value的处理或者其余操做,在此期间能够随时会调用emit方法向前台发送消息
    emit('response',{'code':'200','msg':'start to process...'})

    time.sleep(5)
    emit('response',{'code':'200','msg':'processed'})

socketio也用了和app.route相似的装饰器的形式进行监听设置。主要参数中有namespace这一项，也就是这项指定了这个监听的范围。

在前端，只有注册在testnamespace上的socket，emit向request_for_response的消息才会被这个函数接受并处理。

处理函数自带一个参数用来接收前端emit来消息中的那个object，在处理函数中能够对其解析处理。随后后端向前端发送了start to process的消息。也使用了emit这个方法，而后指明了监听是response。也就是说前端on在response上的监听处理函数会处理这个消息（固然仍是在testnamespace的框架内）。发出消息后后端不会被阻塞而是继续向下执行，在处理了5秒钟以后发出告终束处理的消息，前端天然隔了五秒以后就获得了这个消息了。

socket监听响应函数自己不须要返回什么值，只须要在处理过程当中适当的位置emit出消息便可。

关于send和emit方法：

网上其余一些教程中会提到send方法来取代emit方法的位置（不管是前端仍是后端），其实send方法就是把上文中的'request_for_response','response'这两个标识都默认成'message'。如此在写的时候就不用写事件名，直接写要传递的参数便可。反过来看，用emit方法其实是作了一个自定义事件的工做，能够说更加灵活多变一点

flask-socketio

为flask应用提供了一个客户端与服务器之间低延迟的双向通讯。客户端应用能够用Javascript,C++,Java,Swift或者其它任意的编程语言的socketio官方库的客户端去和服务端建立一个永久的链接。

 

1.flask-socketio的依赖

这个异步的服务的包的依赖能够有三个选择：

• eventlet：这是最好的选择，支持长链接(long-polling)和websocket传输。

• gevent: 支持许多不一样的配置，长链接传输是彻底支持的，可是不一样于eventlet，gevent并无原生支持websocket。添加websocket（功能）有两种方法：gevent-websocket包为gevent添加了websocket支持，可是不幸的是，这个包只能用于python2；至于另一个选择，是用uWSGI网络服务器，这个可以在功能上支持websocket。gevent依然是可操做的选择，可是优先级略微地低于eventlet。

• 基于Werkzeug开发的flask服务器也是可行的，使用缺少可操做性的caveat，它仅能够被用于简化workflow的开发。这个方案仅支持长链接方式传输。

这个扩展自动寻找已安装的异步框架来使用。最优先的是eventlet，其次是gevent。在gevent中，对于websocket的支持，uWSGI是优先考虑的，其次是gevent-websocket。若是eventlet和gevent都没有被安装，那么就使用flask-development将会被启用。

若是使用多进程，一个消息队列服务将会被进程用来协调操做，例如广播。支持这个队列的有Redis,RabbitMQ,还有其余由Kombu支持的包。

在客户端，Javascript官方的SOcket.IO能够用来建立一个与服务端通讯的链接。这里有许多用Swift,Java,C++编写的官方客户端。非官方的客户端也是能够工做的，只要他们支持了Socket.IO协议。

2.Flask-SocketIO引入到Flask应用

from flask import Flask, render_template
from flask_socketio import SocketIO

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

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

init_app()风格的初始化也是支持的。

注意网络服务器的启动。

函数socketio.run()封装了网络服务器的启动部分，而且代替了flask开发服务器的标准启动语句app.run()。当应用在debug模式下，Werkzeug开发服务器也是在socketio.run()中被合理地应用和配置。若是可用的话，在生产模式下eventlet网络服务器也是被应用的，不然，gevent网络服务器将会被启用。若是eventlet和gevent都没有被安装，那么将会使用Werkzeug开发网络服务器。

 

在flask 0.11中被引入的可点击命令行界面也是被支持的。这个扩展提供了一个新版的flask run命令，适合启动一个Socket.IO服务器。用法示例：

FLASK_APP = my_app flask run

 

这个应用只能为那种链接到客户端的页面服务，而且客户端还需引用Socket.IO库而且创建一个链接：

<script type="text/javascript" scr="//cdn.cloudflare.com/ajax/libs/socket.io/1.3.6/socket.io.min.js"></script>

<script type="text/javascript" charset="utf-8">
var socket = io.connect(location.protocol + '//' + document.domain + ':' + location.port);
socket.on('connect', function() {
socket.emit('my event', {data: 'I\'m connected!'});
});
</script>

 

3.如何接收消息

在使用SocketIO的时候，消息将被做为活动(event)的两端接收。

在客户端使用JavaScript回叫信号。

使用Flask-SocketIO服务器，须要为这些活动注册处理器(handler)，相似于视图函数怎样处理路由。

 

4.未命名的活动

建立了一个服务端的活动处理器(event handler)：使用了字符串消息/json。

@socketio.on('message')
def handle_message(message):
　　print('received message:　' + message)

@socketio.on('json')

def handle_json(json):

　　print('received json:　'+ str(json))

5.自定义的活动名称

这些活动的消息数据类型能够是字符串，字节，整型，或者JSON：

@socketio.on('my event')
def handle_my_custom_event(json):
　　print('received json: ' + str(json))
自定义名称的活动能够支持多参数：

@socketio.on('my event')
def handle_my_sustom_event(arg1, arg2, arg3):

　　print('received args: ' + arg1 + arg2 + arg3)

命名活动是极度复杂的，在其消除了额外的元数据(metadata)来描述消息类型的时候。

6.命名空间

Flask-SocketIO一样支持命名空间(namespace)，这个功能容许客户端在一个相同的物理socket上多路复用几个独立的链接：

@scoketio.on('my event', namespace='/test')
def handle_my_custom_namespace_event(json):
　　print('received json: ' + str(json))
当一个命名空间没有具体指出，一个全局的命名空间'/'将会被启用

 

有时，装饰器的语法并不方便，on_event()方法能够做为替代

def my_function_handler(data):
　　pass
socketio.on_event('my event', my_function_handler, namespace='/test')

 

7.返回值

客户端要求一个确认回复，来确认消息的接收。任何一个从处理函数(handler function)中返回的值都会在回调函数中做为一个参数返回给客户端。

@socketio.on('my event')
def handle_my_custom_event(json):
　　print('received json:　'　+ str(json))
　　return('one', 2)
在上面的例子中，客户端回调函数将会回调两个参数，one和2。若是处理函数没有返回值，这个客户端回调函数将以没有参数的状况返回。

 

 

8.发送消息

以前章节定义的SocketIO活动处理函数，能够凭借send()函数和emit()函数来主动链接客户端。

9.未命名的活动

from flask_socketio import send, emit

@socketio.on('message')
def handle_message(message):
　　send(message)

@socketio.on('json')
def handle_json(json):
　　send(json, json=True)

@socket.on('my event')
def handle_my_custom_event(json):
　　emit('my response', json)

有命名空间的活动

send()和emit()默认用在接下来的消息中。不一样的命名空间能够被具体化到可选择的可选择的命名空间参数上

@socketio.on('message')
def handle_message(message):
　　send(message, namespace='/chat')

@socketio.on('message')
def handle_my_sustom_event(json):
　　emit('my response', json, namespace='/chat')
为了实现发送一个多参数的活动，发送一个元组：

 

使用回调时，JavaScript客户端使用回调函数在接收到的信息时回调。在客户端应用启用回调函数时，服务器会启用服务端相匹配的函数去响应。若是客户端没有回调任何值，这些将会做为服务端的响应被提供。

也就是说不管客户端是否接收到，服务端必定会执行回调函数

def ack():
　　print('message was received!')

@socketio.on('my event')
def handle_my_custom_event(json):
　　emit('my response', json, callback=ack)

 

 

客户端的应用一样要求一个来自服务端的确认信息。若是服务端想为一次响应提供一个参数，它必需要在活动处理函数中被返回。

@socketio.on('my event')
def handle_my_custom_event(json):
　　# ... handle the event
　　return 'foo', 'bar', 123 # client callback will receive these 3 arguments

 

10.广播

SocketIO另一个很是有用的特性就是广播消息。Flask-SocketIO中，只要将broadcast = True这个可选参数加到send()和emit()中便可：

@socketio.on('my event')
def handle_my_custom_event(data):
　　emit('my response', data, broadcast=True)
当一个消息以广播选项被开启的状况下被发出的时候，链接到这个命名空间的全部客户端都会收到这个消息。注意：广播的消息将不会被回调。

全部的例子代表，直到这个节点服务器才回复客户端发出的这个活动。可是另外的应用中，服务器须要成为消息的发起者。对于起源于服务器的活动而言，这个有利于发送通知到客户端，好比在后台线程中。socketio.send()和socketio.emit()方法能够用来对全部的链接进行广播。

 

 

def some_function():
　　socketio.emit('some event', {'data': 42})

注意：经过对send()和emit()的上下文的感知，socketio.send()和socketio.emit()不是相同的函数。一样须要注意的是：以上的用法是没有客户端内容，因此假定broadcast=True，而且须要被具体化。