2. 异常处理机制：try-except-finally 结构、异常链、自定义异常类

在缓存一致性闭环集成测试与安全权限设计中，异常处理机制是保障系统健壮性的最后一道防线。Python 的异常处理体系以 try-except-finally 为核心，配合异常链与自定义异常类，能够精确捕获、传递并记录分布式缓存场景下的各类故障。

2.1 try-except-finally 结构

标准异常处理块由三个子句构成，执行顺序遵循“尝试 → 捕获 → 收尾”的严格路径。下表总结了各子句的触发条件与典型用途：

子句	触发条件	典型缓存场景用途
try	始终执行，直到出现异常或正常结束	执行缓存读取、写入、失效操作
except	匹配到指定异常类型时执行	捕获连接超时、数据反序列化失败、权限拒绝
else	try 块未抛出任何异常时执行	记录缓存命中成功日志、更新统计计数器
finally	无论是否异常，始终执行	释放连接池、关闭游标、重置上下文变量

import redis
from cache_connection import get_redis_pool

def read_cache_with_cleanup(key: str) -> str | None:
    """带连接清理的缓存读取示例"""
    conn = None
    try:
        conn = get_redis_pool().get_connection()
        value = conn.get(key)
        if value is None:
            raise KeyNotFoundError(f"缓存键 {key} 不存在")
        return value.decode("utf-8")
    except redis.TimeoutError:
        # 捕获连接超时，降级返回 None
        return None
    except KeyNotFoundError as e:
        # 捕获自定义异常，记录日志后返回 None
        log_warning(str(e))
        return None
    else:
        # 无异常时记录命中
        increment_cache_hit_counter(key)
    finally:
        # 无论成功或失败，释放连接
        if conn:
            conn.close()

2.2 异常链：保留故障传播路径

在多层缓存架构中，底层异常（如 Redis 连接失败）往往需要被上层业务逻辑重新包装为领域异常。异常链机制通过 raise ... from ... 语法保留原始异常的完整上下文，避免调试时丢失根因。

class CacheServiceError(Exception):
    """缓存服务通用异常基类"""
    pass

def get_user_profile(user_id: str) -> dict:
    """从缓存获取用户信息，底层异常包装为领域异常"""
    try:
        raw_data = cache_client.get(f"user:{user_id}")
        if raw_data is None:
            raise CacheMissError(f"用户 {user_id} 缓存未命中")
        return json.loads(raw_data)
    except redis.ConnectionError as e:
        # 保留原始异常链
        raise CacheServiceError("缓存服务不可用，无法获取用户信息") from e
    except json.JSONDecodeError as e:
        raise CacheServiceError("缓存数据格式损坏") from e

异常链在日志系统中的呈现效果：

CacheServiceError: 缓存服务不可用，无法获取用户信息
    └── caused by: redis.ConnectionError: 连接 10.0.1.5:6379 超时
        └── caused by: socket.timeout: 连接超时 (30s)

下表对比了三种异常传播方式的差异：

传播方式	语法	是否保留原始异常	调试价值
直接抛出	raise NewException	否	低，丢失根因
隐式链	raise NewException（在 except 块中）	自动附加 __context__	中，可能被覆盖
显式链	raise NewException from e	是，设置 __cause__	高，明确因果关系

2.3 自定义异常类：构建领域异常体系

为缓存一致性闭环设计一套层次化的自定义异常体系，能够精确区分故障类型，便于集成测试断言与安全审计。推荐采用“基类 → 分类子类 → 具体异常”的三层结构。

class CacheConsistencyError(Exception):
    """缓存一致性异常基类"""
    def __init__(self, message: str, error_code: str = "CACHE-000", details: dict = None):
        self.error_code = error_code
        self.details = details or {}
        super().__init__(message)

class CacheConnectionError(CacheConsistencyError):
    """缓存连接相关异常"""
    def __init__(self, message: str, host: str = None, port: int = None):
        details = {"host": host, "port": port}
        super().__init__(message, error_code="CACHE-001", details=details)

class CacheDataError(CacheConsistencyError):
    """缓存数据异常"""
    pass

class CacheMissError(CacheDataError):
    """缓存未命中"""
    def __init__(self, key: str):
        super().__init__(f"缓存键 {key} 不存在", error_code="CACHE-010", details={"key": key})

class CacheStaleDataError(CacheDataError):
    """缓存数据过期"""
    def __init__(self, key: str, expected_version: int, actual_version: int):
        details = {"key": key, "expected_version": expected_version, "actual_version": actual_version}
        super().__init__(f"缓存数据版本不一致", error_code="CACHE-011", details=details)

class CachePermissionError(CacheConsistencyError):
    """缓存权限异常"""
    def __init__(self, operation: str, role: str):
        details = {"operation": operation, "role": role}
        super().__init__(f"角色 {role} 无权限执行 {operation}", error_code="CACHE-020", details=details)

2.4 异常处理流程总览

下图展示了从缓存操作触发到底层异常被包装为领域异常的完整流程，包含异常链的传递路径：

2.5 异常处理在集成测试中的验证要点

在缓存一致性闭环的集成测试中，异常处理机制需要覆盖以下验证维度：

• 异常类型匹配： 测试用例应断言抛出的异常类型与预期一致，例如 CacheStaleDataError 而非泛化的 Exception。
• 异常链完整性： 验证 __cause__ 属性不为 None，且原始异常类型正确。
• 资源释放验证： 在 finally 块中设置标记变量，测试结束后断言资源已被释放（如连接池计数归零）。
• 错误码唯一性： 自定义异常类的 error_code 应在整个系统中唯一，避免监控告警混淆。
• 安全权限异常： 模拟未授权角色访问缓存接口，验证 CachePermissionError 被正确抛出且不泄露敏感信息。

2.6 异常处理与缓存一致性的闭环关系

异常处理机制与缓存一致性闭环之间存在双向影响：异常处理不当可能导致缓存数据不一致（例如 finally 中误提交了脏数据），而缓存一致性校验失败又需要通过异常链向上层报告精确的故障位置。下图展示了这种闭环关系：