解决HttpServletRequest流数据不可重复读

　　背景介绍
　　甲方客户的生产系统，有安全风险预警和安全事件快速溯源要求，需要做一套日志管理规范。
　　要求我们接入的系统，要对用户登录、注册、密码修改等重要场景，严格按照提供的格式，输出相应的日志。
　　后续通过filebeat对接，收集我们系统上的日志信息。
　　简单来说，就是应用系统，处理接口请求时，统一打印相应日志。问题描述
　　成熟且常见的日志统一打印方案，就是使用AOP技术，自定义注解，在切面上使用环绕通知Around，拦截请求，获取Controller类上方法的入参、出参即可。
　　奈何业务场景使用到的接口，以前的人在实现的时候，使用了如下方式：RequestMapping（valueauth，method｛RequestMethod。POST，RequestMethod。GET，RequestMethod。OPTIONS｝）publicvoidauth（HttpServletRequestreq，HttpServletResponseresp）｛authService。auth（req，resp）；｝
　　把传参直接丢在HttpServletRequest中。
　　返回参数，又是采用HttpServletResponse输出。publicvoidprintResult（HttpServletRequestreq，HttpServletResponseresp，Stringaction，intcode，Stringmsg，Objectresult）｛PrintWriterpnull；RetretnewRet（）；GsongsonnewGsonBuilder（）。setDateFormat（yyyyMMddHH：mm：ss）。serializeNulls（）。create（）；try｛presp。getWriter（）；ret。setRspCode（code）；ret。setRspDesc（msg）；ret。setData（result）；p。write（gson。toJson（ret））；return；｝catch（Exceptione）｛logger。error（e。getMessage（））；｝finally｛p。flush（）；p。close（）；｝｝
　　不像平时熟练的做法，把具体入参和出参，用对象封装，直接放在方法上即可。
　　因为上面的做法，导致我们在拦截器中，想提前拦截请求获取传参，使用request。getParameter（）等方法时，能拿到参数。但是在具体接口业务流程中，再使用request。getParameter（）等方法，传入参数就获取不到了。
　　因为流只能被读一次。
　　因此就抛出一个问题：Request和Response怎么重复读取？解决方案
　　使用request。getParameter（）等方法，最终会调用getInputStream方法。
　　需要重写HttpServletRequestWrapper包装类，在调用getInputStream方法时，将流数据同时写到缓存。
　　后面想获取参数，直接读取缓存数据即可。
　　这样就可以实现Request的内容多次读取。实现代码封装request
　　自定义类ContentCachingRequestWrapperimportjavax。servlet。ReadListener；importjavax。servlet。ServletInputStream；importjavax。servlet。http。HttpServletRequest；importjavax。servlet。http。HttpServletRequestWrapper；importjava。io。BufferedReader；importjava。io。ByteArrayInputStream；importjava。io。IOException；importjava。io。InputStreamReader；importjava。nio。charset。StandardCharsets；重写HttpServletRequestWrapperAuthor：linzengruiDate：2021112215：33publicclassContentCachingRequestWrapperextendsHttpServletRequestWrapper｛privatefinalbyte〔〕body；publicContentCachingRequestWrapper（HttpServletRequestrequest）｛super（request）；StringBuildersbnewStringBuilder（）；try（BufferedReaderreadernewBufferedReader（newInputStreamReader（request。getInputStream（），StandardCharsets。UTF8）））｛Stringline；while（（linereader。readLine（））！null）｛sb。append（line）；｝｝catch（IOExceptione）｛e。printStackTrace（）；｝bodysb。toString（）。getBytes（StandardCharsets。UTF8）；｝OverridepublicBufferedReadergetReader（）throwsIOException｛returnnewBufferedReader（newInputStreamReader（getInputStream（）））；｝OverridepublicServletInputStreamgetInputStream（）throwsIOException｛finalByteArrayInputStreaminputStreamnewByteArrayInputStream（body）；returnnewServletInputStream（）｛OverridepublicbooleanisFinished（）｛returnfalse；｝OverridepublicbooleanisReady（）｛returnfalse；｝OverridepublicvoidsetReadListener（ReadListenerreadListener）｛｝Overridepublicintread（）throwsIOException｛returninputStream。read（）；｝｝；｝publicbyte〔〕getBody（）｛returnbody；｝｝封装response
　　自定义类ContentCachingResponseWrapperimportjavax。servlet。ServletOutputStream；importjavax。servlet。WriteListener；importjavax。servlet。http。HttpServletResponse；importjavax。servlet。http。HttpServletResponseWrapper；importjava。io。；重写HttpServletResponseWrapperAuthor：linzengruiDate：2021112219：45publicclassContentCachingResponseWrapperextendsHttpServletResponseWrapper｛privateByteArrayOutputStreambyteArrayOutputStream；privateServletOutputStreamservletOutputStream；privatePrintWriterprintWriter；publicContentCachingResponseWrapper（HttpServletResponseresponse）｛super（response）；byteArrayOutputStreamnewByteArrayOutputStream（）；servletOutputStreamnewServletOutputStream（）｛OverridepublicbooleanisReady（）｛returnfalse；｝OverridepublicvoidsetWriteListener（WriteListenerwriteListener）｛｝Overridepublicvoidwrite（intb）throwsIOException｛byteArrayOutputStream。write（b）；｝｝；printWriternewPrintWriter（byteArrayOutputStream）；｝OverridepublicPrintWritergetWriter（）｛returnprintWriter；｝OverridepublicServletOutputStreamgetOutputStream（）throwsIOException｛returnservletOutputStream；｝publicbyte〔〕toByteArray（）｛returnbyteArrayOutputStream。toByteArray（）；｝｝过滤器Filter拦截请求
　　拦截器LogFilter使用上面封装的包装类，即可获取传参。Slf4jWebFilter（urlPatterns）publicclassLogFilterimplementsFilter｛Overridepublicvoidinit（FilterConfigfilterConfig）throwsServletException｛｝OverridepublicvoiddoFilter（ServletRequestrequest，ServletResponseresponse，FilterChainchain）throwsIOException，ServletException｛使用重写HttpServletRequestWrapper的自定义包装类ContentCachingRequestWrapperrequestWrappernewContentCachingRequestWrapper（（HttpServletRequest）request）；使用重写HttpServletResponseWrapper的自定义包装类ContentCachingResponseWrapperresponseWrappernewContentCachingResponseWrapper（（HttpServletResponse）response）；只能执行一次获取流方法try（ServletOutputStreamoutputStreamresponse。getOutputStream（））｛获取传参StringrequestParamJsonnewString（requestWrapper。getBody（））；log。info（requestParamJson｛｝，requestParamJson）；具体方法执行流程chain。doFilter（requestWrapper，responseWrapper）；触发获取流操作后，可以从缓存多次拿数据StringrespDataJsonnewString（responseWrapper。toByteArray（））；log。info（respDataJson｛｝，respDataJson）；TODO写日志需要重新写入内容，否则流无输出内容outputStream。write（respDataJson。getBytes（StandardCharsets。UTF8））；outputStream。flush（）；｝catch（Exceptione）｛e。printStackTrace（）；｝｝Overridepublicvoiddestroy（）｛｝｝springboot启动类添加注解ServletComponentScan
　　注意：启动类要加上注解ServletComponentScan识别上面注入的Filter。importorg。springframework。boot。SpringApplication；importorg。springframework。boot。web。servlet。ServletComponentScan；ServletComponentScanSpringBootApplicationpublicclassSpringBootApplication｛publicstaticvoidmain（String〔〕args）｛SpringApplication。run（SpringBootApplication。class，args）；｝｝
　　具体业务接口，原来的逻辑保持不变，仍然可以获取到入参。