필터에서 요청을받을 수있는 방법

Question

요청 본문의 모든 요청과 메시지를 내 REST 웹 서비스 프로젝트에 기록하려고합니다. 나는 봄과 json 메시지를 사용한다. 하지만 java.lang.IllegalStateException가 발생합니다. getReader()가이 요청에 대해 이미 호출되었습니다. 어떻게 해결할 수 있습니까? 또는 다른 방법이 있습니까?

web.xml을

<?xml version="1.0" encoding="UTF-8"?> 
<web-app version="2.5" 
    xmlns="http://java.sun.com/xml/ns/javaee" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"> 
    <welcome-file-list> 
     <welcome-file>index.jsp</welcome-file> 
    </welcome-file-list> 
    <context-param> 
     <param-name>contextConfigLocation</param-name> 
     <param-value>/WEB-INF/spring/root-context.xml</param-value> 
    </context-param> 
    <listener> 
     <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class> 
    </listener> 
    <servlet> 
     <servlet-name>appServlet</servlet-name> 
     <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class> 
     <init-param> 
      <param-name>contextConfigLocation</param-name> 
      <param-value>/WEB-INF/spring/appServlet/servlet-context.xml</param-value> 
     </init-param> 
     <load-on-startup>1</load-on-startup> 
    </servlet> 
    <servlet-mapping> 
     <servlet-name>appServlet</servlet-name> 
     <url-pattern>/</url-pattern> 
    </servlet-mapping> 
    <filter> 
     <filter-name>LogFilter</filter-name> 
     <filter-class>com.cmpolaris.system.LogFilter</filter-class> 
    </filter> 
    <filter-mapping> 
     <filter-name>LogFilter</filter-name> 
     <url-pattern>/*</url-pattern> 
    </filter-mapping> 
</web-app> 

내 필터의 봄-beans.xml 환경

<?xml version="1.0" encoding="UTF-8"?> 
<beans:beans xmlns="http://www.springframework.org/schema/mvc" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xmlns:util="http://www.springframework.org/schema/util" 
    xmlns:beans="http://www.springframework.org/schema/beans" 
    xmlns:context="http://www.springframework.org/schema/context" 
    xsi:schemaLocation="http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd 
     http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd 
     http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsd 
     http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd"> 

    <!-- DispatcherServlet Context: defines this servlet's request-processing infrastructure --> 

    <!-- Enables the Spring MVC @Controller programming model --> 
    <annotation-driven /> 

    <!-- Handles HTTP GET requests for /resources/** by efficiently serving up static resources in the ${webappRoot}/resources directory --> 
    <resources mapping="/resources/**" location="/resources/" /> 

    <!-- Resolves views selected for rendering by @Controllers to .jsp resources in the /WEB-INF/views directory --> 
    <beans:bean class="org.springframework.web.servlet.view.InternalResourceViewResolver"> 
     <beans:property name="prefix" value="/WEB-INF/views/" /> 
     <beans:property name="suffix" value=".jsp" /> 
    </beans:bean> 

    <!-- Configure to plugin JSON as request and response in method handler --> 
    <beans:bean class="org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter"> 
     <beans:property name="messageConverters"> 
      <beans:list> 
       <beans:ref bean="jsonMessageConverter"/> 
      </beans:list> 
     </beans:property> 
    </beans:bean> 

    <!-- Configure bean to convert JSON to POJO and vice versa --> 
    <beans:bean id="jsonMessageConverter" class="org.springframework.http.converter.json.MappingJackson2HttpMessageConverter"> 
    </beans:bean> 

    <context:component-scan base-package="com.cmpolaris" /> 

</beans:beans> 

doFilter(). 나는이 예외에 직면

public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain)throws IOException, ServletException { 
     // Get the IP address of client machine. 
     String ipAddress = request.getRemoteAddr(); 

     // Log the IP address and current timestamp. 
     logger.info("IP " + ipAddress + ", Time " + new Date().toString()); 

     logger.info("Request Message"); 
     logger.info(CharStreams.toString(request.getReader())); 

     // Pass request back down the filter chain 
     chain.doFilter(request, response); 

    } 

는

INFO : com.cmpolaris.system.LogFilter - IP 192.168.1.95, Time Wed Sep 03 13:23:31 MMT 2014 
    INFO : com.cmpolaris.system.LogFilter - Request Message 
    INFO : com.cmpolaris.system.LogFilter - {"userId":"KTT","pwd":"ktdt","devID":"","userGroup":"SaleMan"} 
    Sep 3, 2014 1:23:31 PM org.apache.catalina.core.StandardWrapperValve invoke 
    SEVERE: Servlet.service() for servlet [appServlet] in context with path [/cmpolaris] threw exception [Request processing failed; nested exception is java.lang.IllegalStateExcepti 
    on: getReader() has already been called for this request] with root cause 
    java.lang.IllegalStateException: getReader() has already been called for this request 
     at org.apache.catalina.connector.Request.getInputStream(Request.java:1052) 
     at org.apache.catalina.connector.RequestFacade.getInputStream(RequestFacade.java:368) 
     at org.springframework.http.server.ServletServerHttpRequest.getBody(ServletServerHttpRequest.java:131) 
     at org.springframework.http.converter.json.MappingJackson2HttpMessageConverter.readJavaType(MappingJackson2HttpMessageConverter.java:178) 
     at org.springframework.http.converter.json.MappingJackson2HttpMessageConverter.read(MappingJackson2HttpMessageConverter.java:173) 
     at org.springframework.web.servlet.mvc.method.annotation.AbstractMessageConverterMethodArgumentResolver.readWithMessageConverters(AbstractMessageConverterMethodArgumentResolver. 
    java:143) 
     at org.springframework.web.servlet.mvc.method.annotation.RequestResponseBodyMethodProcessor.readWithMessageConverters(RequestResponseBodyMethodProcessor.java:180) 
     at org.springframework.web.servlet.mvc.method.annotation.RequestResponseBodyMethodProcessor.resolveArgument(RequestResponseBodyMethodProcessor.java:95) 
     at org.springframework.web.method.support.HandlerMethodArgumentResolverComposite.resolveArgument(HandlerMethodArgumentResolverComposite.java:77) 
     at org.springframework.web.method.support.InvocableHandlerMethod.getMethodArgumentValues(InvocableHandlerMethod.java:162) 
     at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:123) 
     at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:104) 
     at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandleMethod(RequestMappingHandlerAdapter.java:745) 
     at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:686) 
     at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:80) 
     at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:925) 
     at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:856) 
     at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:936) 
     at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:838) 
     at javax.servlet.http.HttpServlet.service(HttpServlet.java:641) 
     at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:812) 
     at javax.servlet.http.HttpServlet.service(HttpServlet.java:722) 
     at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:304) 
     at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210) 
     at com.cmpolaris.system.LogFilter.doFilter(LogFilter.java:32) 
     at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:243) 
     at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210) 
     at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:240) 
     at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:164) 
     at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:164) 
     at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:100) 
     at org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:562) 
     at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:118) 
     at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:394) 
     at org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:243) 
     at org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.process(Http11Protocol.java:188) 
     at org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.process(Http11Protocol.java:166) 
     at org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor.run(JIoEndpoint.java:302) 
     at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source) 
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) 
     at java.lang.Thread.run(Unknown Source) 

Answer 1

요청 개체를 체인 필터로 전달하기 전에 다른 클래스로 래핑하십시오. 그런 식으로 사용 된 스트림 문제를 피할 수 있습니다. 먼저 포장,

public class AuthenticationRequestWrapper extends HttpServletRequestWrapper { 

    private final String payload; 

    public AuthenticationRequestWrapper (HttpServletRequest request) throws AuthenticationException { 
     super(request); 

     // read the original payload into the payload variable 
     StringBuilder stringBuilder = new StringBuilder(); 
     BufferedReader bufferedReader = null; 
     try { 
      // read the payload into the StringBuilder 
      InputStream inputStream = request.getInputStream(); 
      if (inputStream != null) { 
       bufferedReader = new BufferedReader(new InputStreamReader(inputStream)); 
       char[] charBuffer = new char[128]; 
       int bytesRead = -1; 
       while ((bytesRead = bufferedReader.read(charBuffer)) > 0) { 
        stringBuilder.append(charBuffer, 0, bytesRead); 
       } 
      } else { 
       // make an empty string since there is no payload 
       stringBuilder.append(""); 
      } 
     } catch (IOException ex) { 
      log.error("Error reading the request payload", ex); 
      throw new AuthenticationException("Error reading the request payload", ex); 
     } finally { 
      if (bufferedReader != null) { 
       try { 
        bufferedReader.close(); 
       } catch (IOException iox) { 
        // ignore 
       } 
      } 
     } 
     payload = stringBuilder.toString(); 
    } 

    @Override 
    public ServletInputStream getInputStream() throws IOException { 
     final ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(payload.getBytes()); 
     ServletInputStream inputStream = new ServletInputStream() { 
      public int read() 
       throws IOException { 
       return byteArrayInputStream.read(); 
      } 
     }; 
     return inputStream; 
    } 
} 

하고 첫 필터 :

public void doFilter(ServletRequest req, ServletResponse resp, FilterChain chain) throws IOException, ServletException { 
     // use wrapper to read multiple times the content 
     AuthenticationRequestWrapper request = new AuthenticationRequestWrapper((HttpServletRequest) req); 
     HttpServletResponse response = (HttpServletResponse) resp; 
     chain.doFilter(request,response); 
} 

Answer 2

당신은 요청 덤퍼 필터를 알고 계십니까? 스택 추적에 따르면 tomcat을 사용하고 있습니다. 자세한 내용은 http://tomcat.apache.org/tomcat-7.0-doc/config/filter.html#Request_Dumper_Filter을 참조하십시오.

Answer 3

사용 AbstractRequestLoggingFilter의 서브 클래스 중 하나를하고 설정이 클래스 (taken from here)을 사용할 수 있습니다 예를 들어

includePayload 속성은 true (기본값은 false)입니다.

Commons Logging을 사용하여 메시지를 기록하는 것을 사용하려는 경우 CommonsRequestLoggingFilter을 web.xml에 추가하고 includePayload 속성에 대한 초기화 매개 변수를 포함하십시오.

<filter> 
    <filter-name>LogFilter</filter-name> 
    <filter-class>org.springframework.web.filter.CommonsRequestLoggingFilter</filter-class> 
    <init-param> 
     <param-name>includePayload</param-name> 
     <param-value>true</param-value> 
    </init-param>  
</filter> 
<filter-mapping> 
    <filter-name>LogFilter</filter-name> 
    <url-pattern>/*</url-pattern> 
</filter-mapping> 

는 클라이언트 (사용자가 sessionId가, 클라이언트) true에 includeClientInfo 속성을 설정에 대한 자세한 정보를 포함합니다.

디버그 로깅이 켜져있을 때만 메시지가 기록되므로 CommonsRequestLoggingFilter의 로그 수준이 최소한 debug인지 확인하십시오.

필터는 요청을 여러 번 읽을 수 있도록 요청을 래퍼에 래핑합니다.