161 lines
6.1 KiB
Python
161 lines
6.1 KiB
Python
import eventlet
|
||
import logging
|
||
|
||
# 配置 eventlet 日志，抑制 IOClosed 等错误日志
|
||
logging.getLogger('eventlet.hubs').setLevel(logging.CRITICAL)
|
||
logging.getLogger('eventlet.greenio').setLevel(logging.CRITICAL)
|
||
|
||
# 进行猴子补丁操作
|
||
eventlet.monkey_patch()
|
||
|
||
# 配置 eventlet hub 以更优雅地处理所有错误
|
||
try:
|
||
from eventlet import hubs
|
||
import eventlet
|
||
import traceback
|
||
|
||
# 获取当前的 hub 实例
|
||
current_hub = hubs.get_hub()
|
||
|
||
# 保存原始的方法
|
||
original_handle_error = hubs.handle_error
|
||
original_trampoline = hubs.trampoline
|
||
|
||
def custom_handle_error(context, type, value, tb):
|
||
# 捕获并打印所有 eventlet.hubs 相关错误，不再往外raise
|
||
print(f"[Eventlet Hub Error] Type: {type.__name__}, Value: {value}")
|
||
print(f"[Context] {context}")
|
||
print("[Traceback]")
|
||
traceback.print_tb(tb)
|
||
# 不再调用原始方法，直接返回，不往外传播错误
|
||
|
||
def custom_trampoline(fd, read=False, write=False, timeout=None, timeout_exc=None):
|
||
try:
|
||
return original_trampoline(fd, read, write, timeout, timeout_exc)
|
||
except Exception as e:
|
||
# 捕获 trampoline 方法中所有异常
|
||
print(f"[Eventlet Trampoline Error] {type(e).__name__}: {e}")
|
||
print(f"[Params] fd: {fd}, read: {read}, write: {write}, timeout: {timeout}")
|
||
print("[Traceback]")
|
||
traceback.print_exc()
|
||
# 返回 None 继续运行，不往外传播错误
|
||
return None
|
||
|
||
# 替换原始方法
|
||
hubs.handle_error = custom_handle_error
|
||
hubs.trampoline = custom_trampoline
|
||
|
||
# 同样处理 greenio 模块的所有相关方法，捕获所有异常
|
||
from eventlet import greenio
|
||
|
||
# 保存原始的 greenio 方法
|
||
original_recv_loop = greenio.base.GreenSocket._recv_loop
|
||
original_recv_into = greenio.base.GreenSocket.recv_into
|
||
original_send_loop = greenio.base.GreenSocket._send_loop
|
||
original_send = greenio.base.GreenSocket.send
|
||
|
||
def safe_io_operation(io_func, *args, **kwargs):
|
||
"""安全执行 IO 操作，捕获所有异常"""
|
||
try:
|
||
return io_func(*args, **kwargs)
|
||
except Exception as e:
|
||
# 捕获所有 IO 操作异常
|
||
print(f"[Eventlet IO Error] {io_func.__name__}: {type(e).__name__}: {e}")
|
||
print("[Traceback]")
|
||
traceback.print_exc()
|
||
# 根据操作类型返回适当的默认值
|
||
if 'recv' in io_func.__name__ or 'read' in io_func.__name__:
|
||
return b'' if 'recv' in io_func.__name__ else ''
|
||
elif 'send' in io_func.__name__ or 'write' in io_func.__name__:
|
||
return 0
|
||
return None
|
||
|
||
def custom_recv_loop(self, recv_func, recv_args, *args, **kwargs):
|
||
return safe_io_operation(original_recv_loop, self, recv_func, recv_args, *args, **kwargs)
|
||
|
||
def custom_recv_into(self, buffer, nbytes=0, flags=0):
|
||
return safe_io_operation(original_recv_into, self, buffer, nbytes, flags)
|
||
|
||
def custom_send_loop(self, send_func, data, *args, **kwargs):
|
||
return safe_io_operation(original_send_loop, self, send_func, data, *args, **kwargs)
|
||
|
||
def custom_send(self, data, flags=0):
|
||
return safe_io_operation(original_send, self, data, flags)
|
||
|
||
# 替换 greenio 方法
|
||
greenio.base.GreenSocket._recv_loop = custom_recv_loop
|
||
greenio.base.GreenSocket.recv_into = custom_recv_into
|
||
greenio.base.GreenSocket._send_loop = custom_send_loop
|
||
greenio.base.GreenSocket.send = custom_send
|
||
|
||
# 处理 WSGI 中的所有错误
|
||
try:
|
||
import eventlet.wsgi
|
||
original_wsgi_handle_one_request = eventlet.wsgi.HttpProtocol.handle_one_request
|
||
original_wsgi_handle_one_response = eventlet.wsgi.HttpProtocol.handle_one_response
|
||
|
||
def custom_wsgi_handle_one_request(self):
|
||
try:
|
||
return original_wsgi_handle_one_request(self)
|
||
except Exception as e:
|
||
# 捕获 WSGI 请求处理中的所有异常
|
||
print(f"[Eventlet WSGI Request Error] {type(e).__name__}: {e}")
|
||
print("[Traceback]")
|
||
traceback.print_exc()
|
||
# 清理连接状态并返回，不往外传播错误
|
||
try:
|
||
self.finish()
|
||
except Exception:
|
||
pass
|
||
return
|
||
|
||
def custom_wsgi_handle_one_response(self):
|
||
try:
|
||
return original_wsgi_handle_one_response(self)
|
||
except Exception as e:
|
||
# 捕获 WSGI 响应处理中的所有异常
|
||
print(f"[Eventlet WSGI Response Error] {type(e).__name__}: {e}")
|
||
print("[Traceback]")
|
||
traceback.print_exc()
|
||
# 清理连接状态并返回，不往外传播错误
|
||
try:
|
||
self.finish()
|
||
except Exception:
|
||
pass
|
||
return
|
||
|
||
eventlet.wsgi.HttpProtocol.handle_one_request = custom_wsgi_handle_one_request
|
||
eventlet.wsgi.HttpProtocol.handle_one_response = custom_wsgi_handle_one_response
|
||
except Exception as e:
|
||
# 如果修改失败，忽略错误
|
||
print(f"[WSGI Patch Error] {e}")
|
||
|
||
print("[Eventlet Error Handling] All eventlet.hubs errors will be caught and printed, not raised")
|
||
except Exception as e:
|
||
# 如果修改失败，打印错误但继续运行
|
||
print(f"[Eventlet Patch Initialization Error] {e}")
|
||
traceback.print_exc()
|
||
|
||
from flask import Flask
|
||
from .views.routes import main_bp
|
||
from .views.file import file_bp
|
||
from .config import Config
|
||
from .extensions import init_extensions,register_namespaces
|
||
|
||
def create_app():
|
||
app = Flask(__name__, template_folder="../templates", static_folder="../static",static_url_path="/vsc-like/static")
|
||
app.config.from_object(Config)
|
||
@app.route('/')
|
||
def hello():
|
||
return 'Hello, World!'
|
||
|
||
# 注册蓝图
|
||
app.register_blueprint(main_bp)
|
||
app.register_blueprint(file_bp)
|
||
# 初始化SocketIO
|
||
init_extensions(app)
|
||
|
||
register_namespaces(app)
|
||
|
||
return app
|