Flask-SocketIO每次请求返回不同SID 无法存储实现私有消息功能

问题根源 #

sid是SocketIO连接的会话标识，仅在同一条稳定连接的生命周期内保持固定，出现频繁变动的常见原因如下：

• 传输协议降级/重连：Flask-SocketIO默认优先使用WebSocket协议，若握手失败会自动降级为长轮询模式，每一次轮询请求都会生成全新的sid
• 前端重复实例化：如果前端每次发送事件都重新执行io()创建新的Socket连接，每一条新连接都会生成独立的sid
• 连接意外断开重连：客户端配置了自动重连逻辑时，连接中断后重新建立的连接会生成新的sid
• 多worker部署无共享存储：使用gunicorn等多worker部署时，没有配置公共消息队列的话，不同worker之间的会话不互通，请求打到不同worker时也会出现sid变动

修复方案 #

1. 配置稳定的连接规则 #

首先避免传输协议降级导致的sid变动，服务端初始化时指定传输方式，同时前端全局复用同一个Socket实例：
服务端配置：

app = Flask(__name__)
app.secret_key = "Secret_Key"
# 新增transports参数指定允许的传输协议
socket_ = SocketIO(app, cors_allowed_origins="*", transports=['websocket', 'polling'])

前端配置（以JS客户端为例）：

// 全局仅初始化一次，不要每次发消息都重新执行这段代码
const socket = io('/check', {
  transports: ['websocket', 'polling']
});

如果使用Nginx等反向代理，需要额外配置支持WebSocket转发，否则会出现WebSocket握手失败的问题

2. 绑定用户标识与sid实现稳定的私有消息投递 #

不要直接用sid作为用户的唯一标识，建议在连接建立时将用户自身的唯一ID（如登录态user_id）与当前sid绑定，断开连接时删除对应关联：

# 生产环境建议用Redis作为共享存储，适配多节点部署
user_sid_mapping = {}

@socket_.on('connect', namespace='/check')
def handle_connect():
    # 可从连接参数、session中获取当前用户的唯一标识
    user_id = request.args.get('user_id')
    if user_id:
        user_sid_mapping[user_id] = request.sid

@socket_.on('disconnect', namespace='/check')
def handle_disconnect():
    user_id = request.args.get('user_id')
    if user_id in user_sid_mapping:
        del user_sid_mapping[user_id]

# 私有消息发送示例
def send_private_message(user_id, msg_content):
    if user_id in user_sid_mapping:
        socket_.emit('private_message', msg_content, to=user_sid_mapping[user_id])

3. 多worker部署适配 #

如果使用多worker部署，必须配置公共消息队列实现会话共享，以Redis为例：

# 新增message_queue参数，指定Redis地址
socket_ = SocketIO(
    app, 
    cors_allowed_origins="*", 
    transports=['websocket', 'polling'],
    message_queue='redis://localhost:6379/0'
)

需要额外安装Redis依赖：pip install redis

内容的提问来源于stack exchange，提问作者Sid Nutthi