Python构建可插拔中间件框架教程

Python可插拔中间件框架核心是解耦、约定与运行时注册：以函数为插件单元，统一接口（context, next_handler）、配置驱动链式调度、支持条件启用与热重载，错误通过context["error"]传播。

Python构建可插拔的业务中间件框架，核心在于解耦、约定和运行时注册——不是靠继承或硬编码，而是用函数/类作为插件单元，通过统一接口 + 配置驱动 + 执行链调度实现灵活扩展。

定义清晰的中间件协议

所有中间件必须遵守同一调用签名和生命周期约定。推荐使用“处理器函数”模式：

• 每个中间件是一个接受 context: dict 和 next_handler: callable 的函数
• 必须显式调用 next_handler(context) 向下传递（支持短路或改写 context）
• 返回值统一为 dict（含 result / error / metadata 等标准字段）

示例：

def auth_middleware(context, next_handler):
    if not context.get("token"):
        return {"error": "Unauthorized", "status": 401}
    context["user_id"] = validate_token(context["token"])
    return next_handler(context)

def logging_middleware(context, next_handler):
    print(f"[LOG] Start: {context.get('request_id')}")
    result = next_handler(context)
    print(f"[LOG] Done: {result.get('status', 200)}")
    return result

用配置驱动中间件加载与顺序

避免在代码里写死执行链。把中间件列表声明在配置中（YAML/JSON/Python dict），按序加载并组装成链：

• 配置示例：["logging_middleware", "auth_middleware", "db_transaction_middleware"]
• 运行时用 importlib.import_module 动态导入函数，或维护一个注册表（如 MIDDLEWARES = {"auth": auth_middleware}）
• 用闭包或 functools.reduce 从右到左组合成单个入口函数

这样增删中间件只需改配置，不碰主流程代码。

提供运行时插拔与条件启用能力

真实业务常需按场景开关中间件（如仅对 API 路由启用鉴权，对静态资源跳过）：

• 中间件函数接收额外 **kwargs，支持传入路由名、请求类型等上下文标签
• 封装一个 ConditionalMiddleware 包装器：只在满足 if_fn(context) 时才执行原中间件
• 支持热重载：监听配置文件变更，自动重建中间件链（适合开发环境）

内置标准上下文与错误传播机制

统一 context 结构是插拔可靠的前提：

• 预设字段：{"request_id", "method", "path", "params", "headers", "user_id", "trace_id"}
• 中间件可自由添加字段（如 context["db_conn"]），但不得覆盖关键字段
• 错误不抛异常，而是写入 context["error"] 并由顶层统一处理（如转 HTTP 响应）
• 提供 context.pop("error", None) 让下游中间件主动“消化”错误（例如降级处理）

基本上就这些。不复杂但容易忽略的是：协议比工具重要，先写好接口文档和两个示例中间件，再搭框架；后面加新模块时，90% 的工作就是写一个符合协议的函数 + 配置里加一行名字。