1. 홈
  2. 질의 응답
  3. apache camel http4 오류 처리

apache camel http4 오류 처리

2016-10-21 2 views
0

Camel 2.17에서 2.18로 업그레이드 한 후 이상한 문제가 발생했습니다. 내 라우터 클래스에서 들어오는 요청을 처리하기 위해 다음 스 니펫이 있습니다.apache camel http4 오류 처리

application.yml

camel.endpoint.my.servletEndpoint: servlet:///activate?httpMethodRestrict=POST,OPTIONS

CamelRouter.java

from("{{camel.endpoint.my.servletEndpoint}}") 
      .doTry() 
       .process(myRequestProcessor) 
       .to("{{camel.endpoint.my.trigger}}") 
      .doCatch(IllegalArgumentException.class) 
       .to("{{camel.endpoint.httpError.badRequest}}") 
      .doCatch(IllegalStateException.class) 
       .to("{{camel.endpoint.httpError.badState}}") 
      .end(); 

// HTTP Error endpoints 
from("{{camel.endpoint.httpError.badRequest}}") 
     .process(new HttpErrorHandler(HttpStatus.BAD_REQUEST)); 
from("{{camel.endpoint.httpError.badState}}") 
     .process(new HttpErrorHandler(HttpStatus.INTERNAL_SERVER_ERROR));

MyRequestProcessor : 특정 오류가과 같이 에러 처리의 대상이다면 좋은 요청은 체인을 통과된다. java

,343,210

} 낙타 2.17에서 예상대로이 일

- MyRequestProcessor 처리하는 동안, IllegalArgumentException를 throw 할 때, 라우터 클래스는 그것을 잡을 따라 처리 할 것입니다. 그러나 업그레이드 후, 나는 이제 IOException: Stream closed 오류가 발생합니다. HTTP 응답 Exchange가 어떤 이유로 닫 혔기 때문입니까? 스택 추적 :

org.apache.camel.RuntimeCamelException: java.io.IOException: Stream closed 
at org.apache.camel.http.common.HttpMessage.createBody(HttpMessage.java:74) 
at org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:47) 
at org.apache.camel.http.common.DefaultHttpBinding.doWriteResponse(DefaultHttpBinding.java:386) 
at org.apache.camel.http.common.DefaultHttpBinding.writeResponse(DefaultHttpBinding.java:322) 
at org.apache.camel.http.common.CamelServlet.doService(CamelServlet.java:210) 
at org.apache.camel.http.common.CamelServlet.service(CamelServlet.java:74) 
at javax.servlet.http.HttpServlet.service(HttpServlet.java:729) 
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:230) 
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:165) 
at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:52) 
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:192) 
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:165) 
at org.springframework.boot.web.filter.ApplicationContextHeaderFilter.doFilterInternal(ApplicationContextHeaderFilter.java:55) 
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) 
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:192) 
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:165) 
at org.springframework.boot.actuate.trace.WebRequestTraceFilter.doFilterInternal(WebRequestTraceFilter.java:105) 
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) 
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:192) 
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:165) 
at org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:317) 
at org.springframework.security.web.access.intercept.FilterSecurityInterceptor.invoke(FilterSecurityInterceptor.java:127) 
at org.springframework.security.web.access.intercept.FilterSecurityInterceptor.doFilter(FilterSecurityInterceptor.java:91) 
at org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) 
at org.springframework.security.web.access.ExceptionTranslationFilter.doFilter(ExceptionTranslationFilter.java:115) 
at org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) 
at org.springframework.security.web.session.SessionManagementFilter.doFilter(SessionManagementFilter.java:137) 
at org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) 
at org.springframework.security.web.authentication.AnonymousAuthenticationFilter.doFilter(AnonymousAuthenticationFilter.java:111) 
at org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) 
at org.springframework.security.web.servletapi.SecurityContextHolderAwareRequestFilter.doFilter(SecurityContextHolderAwareRequestFilter.java:169) 
at org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) 
at org.springframework.security.web.savedrequest.RequestCacheAwareFilter.doFilter(RequestCacheAwareFilter.java:63) 
at org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) 
at org.springframework.security.web.authentication.logout.LogoutFilter.doFilter(LogoutFilter.java:121) 
at org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) 
at org.springframework.security.web.header.HeaderWriterFilter.doFilterInternal(HeaderWriterFilter.java:66) 
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) 
at org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) 
at org.springframework.security.web.context.SecurityContextPersistenceFilter.doFilter(SecurityContextPersistenceFilter.java:105) 
at org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) 
at org.springframework.security.web.context.request.async.WebAsyncManagerIntegrationFilter.doFilterInternal(WebAsyncManagerIntegrationFilter.java:56) 
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) 
at org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) 
at org.springframework.security.web.FilterChainProxy.doFilterInternal(FilterChainProxy.java:214) 
at org.springframework.security.web.FilterChainProxy.doFilter(FilterChainProxy.java:177) 
at org.springframework.web.filter.DelegatingFilterProxy.invokeDelegate(DelegatingFilterProxy.java:346) 
at org.springframework.web.filter.DelegatingFilterProxy.doFilter(DelegatingFilterProxy.java:262) 
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:192) 
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:165) 
at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:99) 
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) 
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:192) 
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:165) 
at org.springframework.web.filter.HttpPutFormContentFilter.doFilterInternal(HttpPutFormContentFilter.java:89) 
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) 
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:192) 
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:165) 
at org.springframework.web.filter.HiddenHttpMethodFilter.doFilterInternal(HiddenHttpMethodFilter.java:77) 
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) 
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:192) 
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:165) 
at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:197) 
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) 
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:192) 
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:165) 
at org.springframework.boot.actuate.autoconfigure.MetricsFilter.doFilterInternal(MetricsFilter.java:107) 
at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) 
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:192) 
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:165) 
at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:198) 
at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:108) 
at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:472) 
at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:140) 
at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:79) 
at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:87) 
at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:349) 
at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:784) 
at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66) 
at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:802) 
at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1410) 
at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49) 
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 
at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) 
at java.lang.Thread.run(Thread.java:745) 
Caused by: java.io.IOException: Stream closed 
    at org.apache.catalina.connector.InputBuffer.read(InputBuffer.java:335) 
    at org.apache.catalina.connector.CoyoteInputStream.read(CoyoteInputStream.java:155) 
    at org.apache.camel.util.IOHelper.copy(IOHelper.java:196) 
    at org.apache.camel.util.IOHelper.copy(IOHelper.java:169) 
    at org.apache.camel.util.IOHelper.copyAndCloseInput(IOHelper.java:218) 
    at org.apache.camel.util.IOHelper.copyAndCloseInput(IOHelper.java:214) 
    at org.apache.camel.http.common.HttpHelper.readResponseBodyFromInputStream(HttpHelper.java:244) 
    at org.apache.camel.http.common.HttpHelper.readRequestBodyFromServletRequest(HttpHelper.java:195) 
    at org.apache.camel.http.common.DefaultHttpBinding.parseBody(DefaultHttpBinding.java:572) 
    at org.apache.camel.http.common.HttpMessage.createBody(HttpMessage.java:72) 
    ... 85 common frames omitted

왜 이것이 작동을 멈출 수 있는지 알려주는 전문가가 있습니까? 종속성이 호환되는지 확인했습니다 (Apache Camel 2.18, Spring Boot 1.4.1). 또한 Spring Boot (및 Camel-Spring-Boot)가 CamelServlet 및 CamelContext의 자동 구성을 모두 처리하도록 할 것입니다. 감사합니다.

출처

2016-10-21 smboykin777

+0

어떤 이유로 연결이 닫히지 않았습니까? 우편 배달부 등에서 게시하는 경우 어떻게됩니까? –

답변

0

사실, Camel을 업그레이드하면 HttpErrorHandler 구현 문제가있는 것으로 보입니다. 다음과 같이 내가 CamelRouter 코드 블록을 재 설계하면, 문제는 도망 갔어요 :

// HTTP Error endpoints 
// *** reimplemented HttpErrorHandler as a bean, now passing status codes as messages to be handled 
from("{{camel.endpoint.my.servletEndpoint}}") 
      .doTry() 
       .process(myRequestProcessor) 
       .to("{{camel.endpoint.my.trigger}}") 
      .doCatch(IllegalArgumentException.class) 
       .transform(constant(HttpStatus.BAD_REQUEST)) 
       .process(httpErrorHandler); 
      .doCatch(IllegalStateException.class) 
       .transform(constant(HttpStatus.INTERNAL_SERVER_ERROR)) 
       .process(httpErrorHandler); 
      .end();

나는 원래 코드가 (이 :) 심하게 일 경우에도) 작동이 중지 이유를 완전히 이해하고 말할 수 없다 - 아마도 그것은 시도했습니다 어떻게 든 들어오는 HTTP 교환 재사용 -하지만 깨끗한 코드로 충분할 것 같습니다.

출처

2016-10-28 15:39:01 smboykin777

관련 문제

 관련 문제