解决Flask热重载中‘非套接字操作’错误：数据库连接管理与g对象的应用

Exception in thread Thread-2 (serve_forever):
Traceback (most recent call last):
  File "C:\Users\USER\AppData\Local\Programs\Python\Python310\lib\threading.py", line 1016, in _bootstrap_inner
    self.run()
  File "C:\Users\USER\AppData\Local\Programs\Python\Python310\lib\threading.py", line 953, in run
    self._target(*self._args, **self._kwargs)
  File "C:\Users\USER\AppData\Local\Programs\Python\Python310\lib\site-packages\werkzeug\serving.py", line 806, in serve_forever
    super().serve_forever(poll_interval=poll_interval)
  File "C:\Users\USER\AppData\Local\Programs\Python\Python310\lib\socketserver.py", line 232, in serve_forever
    ready = selector.select(poll_interval)
  File "C:\Users\USER\AppData\Local\Programs\Python\Python310\lib\selectors.py", line 324, in select
    r, w, _ = self._select(self._readers, self._writers, [], timeout)
  File "C:\Users\USER\AppData\Local\Programs\Python\Python310\lib\selectors.py", line 315, in _select
    r, w, x = select.select(r, w, w, timeout)
OSError: [WinError 10038] An operation was attempted on something that is not a socket

import logging
import threading
from flask import Flask, request

# 假设这是一个自定义的数据库连接类，内部可能启动了独立的线程来处理请求队列
class MyDBClass:
    def __init__(self):
        print("数据库实例已创建")
        # 假设这里启动了一个后台线程来管理连接或请求队列
        self._thread = threading.Thread(target=self._run_queue, daemon=True)
        self._thread.start()

    def _run_queue(self):
        # 模拟线程工作
        while True:
            # 处理数据库请求
            pass # 实际会包含数据库操作

    def close(self):
        print("数据库实例已关闭")
        # 优雅地停止线程和释放资源
        pass

# 全局初始化数据库实例
app = Flask(__name__)
db = MyDBClass() # <-- 问题根源：全局初始化

@app.route('/')
def index():
    # 正常使用db实例
    return "Hello, Flask!"

if __name__ == '__main__':
    app.run(host='0.0.0.0', port=5500, debug=True)

import logging
import threading
from flask import Flask, request, g # 导入g对象

# 假设这是一个自定义的数据库连接类，内部可能启动了独立的线程来处理请求队列
class MyDBClass:
    def __init__(self):
        print("数据库实例已创建")
        # 假设这里启动了一个后台线程来管理连接或请求队列
        self._thread = threading.Thread(target=self._run_queue, daemon=True)
        self._thread.start()

    def _run_queue(self):
        # 模拟线程工作
        while True:
            # 处理数据库请求
            pass # 实际会包含数据库操作

    def get_name(self, query):
        # 模拟数据库查询
        return "World"

    def close(self):
        print("数据库实例已关闭")
        # 优雅地停止线程和释放资源
        # 在这里实现线程的停止逻辑，例如设置一个标志位让_run_queue退出循环
        pass

def get_db():
    """
    将数据库实例插入到Flask的全局变量g中，其生命周期随应用上下文结束而终止。
    """
    if 'db' not in g:
        g.db = MyDBClass()  # 为当前请求创建一个新的数据库连接实例
    return g.db

def create_app():
    app = Flask(__name__)

    @app.before_request
    def before_request():
        """
        在每个请求开始前，确保g.db被初始化。
        """
        g.db = get_db()

    @app.route('/')
    def index():
        # 通过g.db访问数据库实例
        name = g.db.get_name({"id": 123})
        return f"Hello, {name}!"

    @app.teardown_appcontext
    def teardown_db(exception):
        """
        在应用上下文销毁时（通常是请求结束后），关闭数据库连接。
        """
        db_instance: MyDBClass | None = g.pop('db', None)
        if db_instance is not None:
            db_instance.close()

    return app

if __name__ == '__main__':
    app = create_app()
    app.run(host='0.0.0.0', port=5500, debug=True)