遗留Java单体系统事务迁移至Spring的连接处理方案咨询

1. OncePerRequestFilter 方案完全可行，且是最优选择 #

这个方案和你原系统的Servlet拦截器逻辑高度对齐，能做到最小改造：

• 它是Spring Web专门为单次请求拦截设计的过滤器，天然覆盖所有HTTP请求，和原系统拦截器的作用范围一致
• 可以直接获取HttpSession，完美适配“数据库会话与用户会话绑定”的核心逻辑，不需要额外修改会话关联代码
• 支持前置/后置全流程处理：请求进入Controller前设置数据库连接，请求完成后（包括异常场景）执行收尾逻辑

给个极简实现示例：

@Component
public class DbConnectionBindingFilter extends OncePerRequestFilter {

    @Override
    protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException {
        // 前置逻辑：从用户会话取出绑定的数据库连接，设置到应用底层
        HttpSession session = request.getSession(false);
        if (session != null) {
            CorbaDbSession dbSession = (CorbaDbSession) session.getAttribute("USER_DB_SESSION");
            if (dbSession != null) {
                // 调用原系统的底层设置方法
                LegacyDbConnectionManager.setCurrentConnection(dbSession.getConnection());
            }
        }

        try {
            // 执行后续请求链（包含REST Controller的业务逻辑）
            filterChain.doFilter(request, response);
        } finally {
            // 后置逻辑：请求完成后的清理或自定义操作
            // 注意：严格保留原逻辑，仅在显式保存时提交事务，这里不要主动提交
            LegacyDbConnectionManager.clearCurrentConnection();
        }
    }
}

只需把这个过滤器注册到Spring容器（比如加@Component），就能自动生效，不需要修改现有REST Controller代码。

2. AOP方案的局限性 #

你对AOP的顾虑是对的，这个方案并不适合你的场景：

• AOP是方法层面的拦截，需要精确定义切点覆盖所有REST方法，后续新增Controller时容易遗漏，维护成本高
• 无法覆盖请求进入Spring MVC前的场景（比如静态资源请求、其他前置过滤器），而原系统的拦截器是覆盖所有请求的
• 异常处理有盲区：如果请求在进入Controller前就抛出异常，AOP无法拦截，而过滤器的finally块能保证后置逻辑必执行
• 存在Spring AOP代理陷阱：如果Controller内部调用自身方法，切面不会触发，可能导致数据库连接未正确设置

3. REST操作后拦截逻辑的实现方式 #

在OncePerRequestFilter中，通过try-finally块就能实现可靠的后置拦截：

• try块中执行filterChain.doFilter(request, response)，触发后续的请求处理流程
• finally块中编写后置逻辑，不管请求成功、失败还是抛出异常，finally都会执行，确保收尾逻辑不遗漏
• 如果需要区分请求成功/失败的场景，可以通过response.getStatus()判断状态码，或者在try块中捕获异常做针对性处理，但finally依然要保留基础清理逻辑

如果需要读取REST接口的响应内容（比如根据返回结果执行特定操作），可以用Spring提供的ContentCachingResponseWrapper包装响应对象，示例如下：

@Override
protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException {
    ContentCachingResponseWrapper wrappedResponse = new ContentCachingResponseWrapper(response);
    
    // 前置逻辑...

    try {
        filterChain.doFilter(request, wrappedResponse);
        // 这里可以读取响应内容
        byte[] responseBody = wrappedResponse.getContentAsByteArray();
        String responseStr = new String(responseBody, wrappedResponse.getCharacterEncoding());
        // 根据响应内容执行自定义逻辑
    } finally {
        // 必须把缓存的响应内容写回原response
        wrappedResponse.copyBodyToResponse();
        // 后置清理逻辑...
    }
}

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