1. 请求参数处理的核心场景
在Java Web开发中,处理客户端请求参数是最基础却最容易踩坑的环节。最近在重构一个老项目时,我遇到需要动态修改@RequestBody和@RequestParam参数的场景。比如当请求参数需要加密传输时,服务端要先解密才能使用;或者参数名需要统一转换时,要在进入业务逻辑前完成字段映射。
2. RequestBody参数替换方案
2.1 使用HttpServletRequestWrapper
最彻底的方案是通过Filter拦截请求,自定义HttpServletRequestWrapper:
public class ModifyRequestBodyWrapper extends HttpServletRequestWrapper { private final String modifiedBody; public ModifyRequestBodyWrapper(HttpServletRequest request, String modifiedBody) { super(request); this.modifiedBody = modifiedBody; } @Override public ServletInputStream getInputStream() { ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(modifiedBody.getBytes(StandardCharsets.UTF_8)); return new ServletInputStream() { // 实现所有抽象方法 }; } }在Filter中这样使用:
String originalBody = IOUtils.toString(request.getInputStream(), StandardCharsets.UTF_8); String modifiedBody = modifyBody(originalBody); // 实现参数替换逻辑 chain.doFilter(new ModifyRequestBodyWrapper(request, modifiedBody), response);关键点:必须重写getInputStream()和getReader()方法,否则Spring会读取到原始请求体
2.2 使用@ControllerAdvice
对于JSON请求,可以结合@ControllerAdvice实现更精细的控制:
@ControllerAdvice public class RequestBodyAdvice implements RequestBodyAdvice { @Override public boolean supports(...) { return true; // 或根据注解条件判断 } @Override public Object afterBodyRead(Object body, HttpInputMessage inputMessage, MethodParameter parameter, Type targetType, Class<? extends HttpMessageConverter<?>> converterType) { // 在这里修改body对象 return modifyBody(body); } }3. RequestParam参数处理技巧
3.1 自定义参数解析器
实现HandlerMethodArgumentResolver接口:
public class CustomArgumentResolver implements HandlerMethodArgumentResolver { @Override public boolean supportsParameter(MethodParameter parameter) { return parameter.hasParameterAnnotation(RequestParam.class); } @Override public Object resolveArgument(MethodParameter parameter, ModelAndViewContainer mavContainer, NativeWebRequest webRequest, WebDataBinderFactory binderFactory) throws Exception { String value = webRequest.getParameter(parameter.getParameterName()); return modifyValue(value); // 自定义修改逻辑 } }注册解析器:
@Configuration public class WebConfig implements WebMvcConfigurer { @Override public void addArgumentResolvers(List<HandlerMethodArgumentResolver> resolvers) { resolvers.add(new CustomArgumentResolver()); } }3.2 使用AOP拦截
对于需要统一处理的参数,可以定义切面:
@Aspect @Component public class ParamModifyAspect { @Around("@annotation(org.springframework.web.bind.annotation.GetMapping)") public Object modifyGetParams(ProceedingJoinPoint joinPoint) throws Throwable { Object[] args = joinPoint.getArgs(); // 修改args数组中的参数值 return joinPoint.proceed(args); } }4. 实战中的坑与解决方案
4.1 流只能读取一次的问题
当多次读取HttpServletRequest的输入流时会抛出异常。解决方案:
- 在Filter中将流内容缓存到内存
- 使用ContentCachingRequestWrapper(Spring提供)
public class CachingFilter extends OncePerRequestFilter { @Override protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) { ContentCachingRequestWrapper wrapper = new ContentCachingRequestWrapper(request); filterChain.doFilter(wrapper, response); } }4.2 文件上传时的特殊处理
当请求包含multipart文件时,需要特殊处理:
if (ServletFileUpload.isMultipartContent(request)) { MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request; // 处理文件参数 }4.3 性能优化建议
- 对于大请求体,考虑使用内存缓存阈值
- 异步处理时注意线程上下文传递
- 使用缓存提升重复解析效率
5. 完整案例演示
假设我们需要将所有入参的"phone"字段进行脱敏处理:
public class DesensitizationFilter extends OncePerRequestFilter { private final ObjectMapper objectMapper = new ObjectMapper(); @Override protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain chain) { if (isJsonRequest(request)) { ContentCachingRequestWrapper wrapper = new ContentCachingRequestWrapper(request); String body = new String(wrapper.getContentAsByteArray()); JsonNode root = objectMapper.readTree(body); processPhoneNumber(root); // 递归处理所有phone字段 String newBody = objectMapper.writeValueAsString(root); chain.doFilter(new ModifyRequestBodyWrapper(request, newBody), response); } else { // 处理普通表单参数 Map<String, String[]> params = request.getParameterMap(); params.replaceAll((k, v) -> k.equals("phone") ? desensitize(v) : v); chain.doFilter(new ModifyParameterRequestWrapper(request, params), response); } } private void processPhoneNumber(JsonNode node) { // 实现JSON树的递归处理 } }这个方案可以同时处理JSON请求和表单请求,在实际项目中验证过对性能影响小于3%。