Python：engineio 库高级用法举例和应用详解

import engineio  # 导入engineio库

# 创建engineio服务器实例
eio = engineio.Server()  

# 定义一个连接事件的处理函数
@eio.on('connect')
def connect(sid, environ):  
    print(f'客户端 {sid} 已连接')  # 打印连接的客户端ID

# 定义一个断开连接事件的处理函数
@eio.on('disconnect')
def disconnect(sid):  
    print(f'客户端 {sid} 已断开连接')  # 打印断开的客户端ID

# 启动服务器
if __name__ == '__main__':
    import eventlet
    eventlet.wsgi.server(eventlet.listen(('0.0.0.0', 5000)), eio)  # 监听5000端口

import socketio  # 导入socketio库

# 创建Socket.IO客户端
sio = socketio.Client()

# 定义连接事件
@sio.event
def connect():
    print("成功连接到服务器")

# 定义断开事件
@sio.event
def disconnect():
    print("已断开与服务器的连接")

# 连接到server
sio.connect('http://localhost:5000')  # 连接到本地5000端口的server

# 在连接后可以发送消息
sio.send('你好，服务器！')  # 发送一条消息到服务器

import engineio  # 导入engineio库
import eventlet

eio = engineio.Server()  # 创建engineio服务器实例

# 连接时处理程序
@eio.on('message')
def handle_message(sid, data):
    print(f'收到来自 {sid} 的消息: {data}')  
    eio.send(sid, f'你说的是: {data}')  # 返回给发送者确认信息

# 广播消息给所有连接的客户端
def broadcast_message(message):
    eio.emit('message', message)  # 广播消息到所有客户端

if __name__ == '__main__':
    eventlet.wsgi.server(eventlet.listen(('0.0.0.0', 5000)), eio)  # 启动服务