python gevent 每个socket 的消息接收是否有使用事件监听回调的方法_百 ...

发布网友发布时间：2022-05-09 16:59

共1个回答

热心网友时间：2022-04-18 07:47

gevent 比起其他框架（比如tornado，twisted）的一个巨大优势就是：用同步的方法（自然没有回调函数）写异步应用，因为同步的方式更接近开发人员的编程思维。
gevent可以用一句话向pythoner阐述：使用多路IO复用对文件描述符的事件监听，从而撬动协程的“透明”切换。这句话说起来容易，但是阐述起来就复杂些：
底层（或者说主协程）自然有一个多路IO复用循环（linux上是epoll，unix是kqueue，以下统一用epoll代替描述）
当处理一个socket链接时，就创建一个协程greenlet去处理。
当socket遇到阻塞的时候，比如等待数据的返回或者发送，此时gevent做了很关键的两步：
为这个socket的fd在epoll上添加可读或者可写事件回调，而这个回调函数便是 gevent.getcurrent().switch
通过 get_hub().switch() 切换到主协程。切换回主协程，去干其他事情了。但是当该socket可读或者可写，epoll自然会调用上述添加的回调函数，从而切换回socket的处理协程，从上次悬挂点接着往下执行。
之所以做到透明，是因为python socket上打了patch。所谓打patch，就是自己实现了一个socket模块替换了python的标准socket模块。

python gevent 每个socket 的消息接收是否有使用事件监听回调的方法_百 ...

pyhton协程-gevent

在python的标准库里socket默认是阻塞模式，这种模式下它的许多函数都是阻塞的，其中就包括recv()，接收对端发送的数据。转了一堆弯找到最终调用的是hub.wait()，首先声明一个Waiter对象，将waiter.switch函数传入到绑定了当前socket读事件的io watcher，当watcher监听到有数据到来时，就执行回调函数waiter.sw...

Flask-SocketIO 简单使用指南

接收消息在客户端通过JavaScript回调实现，Flask-SocketIO中，服务器端需为事件注册处理程序。未命名事件使用字符串消息，JSON数据事件使用JSON格式。自定义事件支持多种数据类型，并允许多个参数。命名空间允许客户端在同一物理套接字上复用多个独立连接。使用on_event方法处理自定义命名空间的事件，客户端请求确...