ZuulProxy 在应该执行故障转移时失败，并显示“RibbonCommand 超时且没有可用的后备”

2024-05-01

简短的介绍：我试图让 ZuulProxy 来处理实例故障转移，但它抛出 ZuulException：转发错误，而不是使用工作实例的结果进行响应。

详细描述：我的设置是一台独立的 Eureka Server、一台 ConfigServer、一台 ZuulProxy (@EnableZuulProxy) 和两个服务实例，所有这些都在 Eureka 中注册。

一切都在 spring-cloud-starter-parent Angel.SR3 上运行

My 服务发现：

@SpringBootApplication
@EnableEurekaServer
public class EurekaServer {
    public static void main(String[] args) {
        SpringApplication.run(EurekaServer.class, args);
    }
}

My 配置服务器：

@SpringBootApplication
@EnableAutoConfiguration
@EnableConfigServer
@ComponentScan
@EnableDiscoveryClient
public class ConfigserverApplication {

  public static void main(String[] args) {
    SpringApplication.run(ConfigserverApplication.class, args);
  }
}

My Zuul代理：

@SpringBootApplication
@EnableAutoConfiguration
@ComponentScan
@EnableDiscoveryClient
@EnableZuulProxy
public class ZuulProxy {
  public static void main(String[] args) {
    SpringApplication.run(ZuulProxy.class, args);
  }
}

The 路由规则 in zuul:

zuul.ignoredServices=*
zuul.routes.examplems=/example/**

My 服务实例：

@SpringBootApplication
@Configuration
@EnableAutoConfiguration
@EnableDiscoveryClient
@ComponentScan(basePackages = "se.example.microservices")
@EnableSwagger
public class Application {

  public static void main(String[] args) throws Exception{
    SpringApplication.run(Application.class, args);
  }

我的服务实例使用以下方式自行注册spring.application.name=examplems

当我启动两个服务实例并通过 zuulproxy 发出请求时，一切正常，它会轮询到我的两个服务实例的请求。但是当我停止其中一个实例时，Zuul 仍然尝试将请求转发到已停止的实例几次，然后失败并显示：

com.netflix.zuul.exception.ZuulException: Forwarding error
Caused by: com.netflix.hystrix.exception.HystrixRuntimeException: examplemsRibbonCommand timed-out and no fallback available.

我期望对已停止实例的请求超时并透明地故障转移到正在运行的实例。真正奇怪的是，zuul（根据日志）似乎首先尝试多次停止的实例（这当然是失败的），然后它将请求转发到工作实例，得到一个好的答案，但不是转发对客户端的 OK 回答会抛出异常，导致响应失败，状态为 500！？

请查看日志（我的工作实例位于主机 PMD11286 上，我的停止实例位于 PMD11933 上）：

2015-08-20 08:45:46.343  INFO 7700 --- [nio-9050-exec-9] o.s.c.n.zuul.filters.ProxyRouteLocator   : Finding route for path: /example/ping/delay
2015-08-20 08:45:46.343 DEBUG 7700 --- [nio-9050-exec-9] o.a.h.impl.conn.DefaultClientConnection  : Connection 0.0.0.0:50251<->172.20.120.39:9060 closed
2015-08-20 08:45:46.343 DEBUG 7700 --- [nio-9050-exec-9] .a.h.i.c.DefaultClientConnectionOperator : Connecting to PMD11933:9060
2015-08-20 08:45:47.372 DEBUG 7700 --- [nio-9050-exec-9] .a.h.i.c.DefaultClientConnectionOperator : Connect to PMD11933:9060 timed out. Connection will be retried using another IP address
2015-08-20 08:45:47.372 DEBUG 7700 --- [nio-9050-exec-9] .a.h.i.c.DefaultClientConnectionOperator : Connecting to PMD11933:9060
2015-08-20 08:45:48.386 DEBUG 7700 --- [nio-9050-exec-9] .a.h.i.c.DefaultClientConnectionOperator : Connect to PMD11933:9060 timed out. Connection will be retried using another IP address
2015-08-20 08:45:48.386 DEBUG 7700 --- [nio-9050-exec-9] .a.h.i.c.DefaultClientConnectionOperator : Connecting to PMD11933:9060
2015-08-20 08:45:49.416 DEBUG 7700 --- [nio-9050-exec-9] .a.h.i.c.DefaultClientConnectionOperator : Connect to PMD11933:9060 timed out. Connection will be retried using another IP address
2015-08-20 08:45:49.416 DEBUG 7700 --- [nio-9050-exec-9] .a.h.i.c.DefaultClientConnectionOperator : Connecting to PMD11933:9060
2015-08-20 08:45:50.430 DEBUG 7700 --- [N_MANAGER_TIMER] o.a.h.i.c.t.ThreadSafeClientConnManager  : Closing expired connections
2015-08-20 08:45:50.430 DEBUG 7700 --- [N_MANAGER_TIMER] o.a.h.impl.conn.tsccm.ConnPoolByRoute    : Closing expired connections
2015-08-20 08:45:50.446 DEBUG 7700 --- [nio-9050-exec-9] .a.h.i.c.DefaultClientConnectionOperator : Connect to PMD11933:9060 timed out. Connection will be retried using another IP address
2015-08-20 08:45:50.446 DEBUG 7700 --- [nio-9050-exec-9] .a.h.i.c.DefaultClientConnectionOperator : Connecting to PMD11933:9060
2015-08-20 08:45:51.475 DEBUG 7700 --- [nio-9050-exec-9] .a.h.i.c.DefaultClientConnectionOperator : Connect to PMD11933:9060 timed out. Connection will be retried using another IP address
2015-08-20 08:45:51.475 DEBUG 7700 --- [nio-9050-exec-9] .a.h.i.c.DefaultClientConnectionOperator : Connecting to PMD11933:9060
2015-08-20 08:45:52.505 DEBUG 7700 --- [nio-9050-exec-9] o.a.h.impl.conn.DefaultClientConnection  : Connection 0.0.0.0:50251<->172.20.120.39:9060 closed
2015-08-20 08:45:52.505 DEBUG 7700 --- [nio-9050-exec-9] o.a.h.impl.conn.DefaultClientConnection  : Connection 0.0.0.0:50251<->172.20.120.39:9060 shut down
2015-08-20 08:45:52.505 DEBUG 7700 --- [nio-9050-exec-9] o.a.h.impl.conn.DefaultClientConnection  : Connection 0.0.0.0:50251<->172.20.120.39:9060 closed
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] o.a.h.client.protocol.RequestAddCookies  : CookieSpec selected: ignoreCookies
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] o.a.h.client.protocol.RequestAuthCache   : Auth cache not set in the context
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] o.a.h.c.p.RequestTargetAuthentication    : Target auth state: UNCHALLENGED
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] o.a.h.c.p.RequestProxyAuthentication     : Proxy auth state: UNCHALLENGED
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] o.a.h.impl.conn.DefaultClientConnection  : Sending request: GET /ping/delay HTTP/1.1
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  >> "GET /ping/delay HTTP/1.1[\r][\n]"
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  >> "x-forwarded-host: 127.0.0.1:9050[\r][\n]"
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  >> "x-forwarded-prefix: /example[\r][\n]"
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  >> "accept-encoding: deflate, gzip[\r][\n]"
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  >> "user-agent: curl/7.42.1[\r][\n]"
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  >> "accept: */*[\r][\n]"
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  >> "Netflix.NFHttpClient.Version: 1.0[\r][\n]"
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  >> "X-netflix-httpclientname: examplems[\r][\n]"
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  >> "Host: PMD11286:9060[\r][\n]"
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  >> "Connection: Keep-Alive[\r][\n]"
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  >> "[\r][\n]"
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.headers                  : >> GET /ping/delay HTTP/1.1
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.headers                  : >> x-forwarded-host: 127.0.0.1:9050
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.headers                  : >> x-forwarded-prefix: /example
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.headers                  : >> accept-encoding: deflate, gzip
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.headers                  : >> user-agent: curl/7.42.1
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.headers                  : >> accept: */*
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.headers                  : >> Netflix.NFHttpClient.Version: 1.0
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.headers                  : >> X-netflix-httpclientname: examplems
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.headers                  : >> Host: PMD11286:9060
2015-08-20 08:45:52.520 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.headers                  : >> Connection: Keep-Alive
2015-08-20 08:45:52.630 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  << "HTTP/1.1 200 OK[\r][\n]"
2015-08-20 08:45:52.630 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  << "Server: Apache-Coyote/1.1[\r][\n]"
2015-08-20 08:45:52.630 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  << "X-Application-Context: examplems:9060[\r][\n]"
2015-08-20 08:45:52.630 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  << "Content-Type: text/plain;charset=UTF-8[\r][\n]"
2015-08-20 08:45:52.630 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  << "Content-Length: 76[\r][\n]"
2015-08-20 08:45:52.630 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  << "Date: Thu, 20 Aug 2015 06:45:52 GMT[\r][\n]"
2015-08-20 08:45:52.630 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  << "[\r][\n]"
2015-08-20 08:45:52.630 DEBUG 7700 --- [nio-9050-exec-9] o.a.h.impl.conn.DefaultClientConnection  : Receiving response: HTTP/1.1 200 OK
2015-08-20 08:45:52.630 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.headers                  : << HTTP/1.1 200 OK
2015-08-20 08:45:52.630 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.headers                  : << Server: Apache-Coyote/1.1
2015-08-20 08:45:52.630 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.headers                  : << X-Application-Context: examplems:9060
2015-08-20 08:45:52.630 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.headers                  : << Content-Type: text/plain;charset=UTF-8
2015-08-20 08:45:52.630 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.headers                  : << Content-Length: 76
2015-08-20 08:45:52.630 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.headers                  : << Date: Thu, 20 Aug 2015 06:45:52 GMT
2015-08-20 08:45:52.630 DEBUG 7700 --- [nio-9050-exec-9] org.apache.http.wire                     :  << "Svar efter 100 ms v[0xc3][0xa4]ntan. Kan [0xc3][0xa4]ndras med: ?time=200  15-08-20 08:45:52,618"
2015-08-20 08:45:52.630  WARN 7700 --- [nio-9050-exec-9] o.s.c.n.z.filters.post.SendErrorFilter   : Error during filtering

com.netflix.zuul.exception.ZuulException: Forwarding error
        at org.springframework.cloud.netflix.zuul.filters.route.RibbonRoutingFilter.forward(RibbonRoutingFilter.java:142)
        at org.springframework.cloud.netflix.zuul.filters.route.RibbonRoutingFilter.run(RibbonRoutingFilter.java:107)
        at com.netflix.zuul.ZuulFilter.runFilter(ZuulFilter.java:112)
        at com.netflix.zuul.FilterProcessor.processZuulFilter(FilterProcessor.java:197)
        at com.netflix.zuul.FilterProcessor.runFilters(FilterProcessor.java:161)
        at com.netflix.zuul.FilterProcessor.route(FilterProcessor.java:120)
        at com.netflix.zuul.ZuulRunner.route(ZuulRunner.java:84)
        at com.netflix.zuul.http.ZuulServlet.route(ZuulServlet.java:111)
        at com.netflix.zuul.http.ZuulServlet.service(ZuulServlet.java:77)
        at org.springframework.web.servlet.mvc.ServletWrappingController.handleRequestInternal(ServletWrappingController.java:158)
        at org.springframework.cloud.netflix.zuul.web.ZuulController.handleRequestInternal(ZuulController.java:43)
        at org.springframework.web.servlet.mvc.AbstractController.handleRequest(AbstractController.java:146)
        at org.springframework.web.servlet.mvc.SimpleControllerHandlerAdapter.handle(SimpleControllerHandlerAdapter.java:50)
        at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:959)
        at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:893)
        at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:966)
        at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:857)
        at javax.servlet.http.HttpServlet.service(HttpServlet.java:618)
        at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:842)
        at javax.servlet.http.HttpServlet.service(HttpServlet.java:725)
        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:291)
        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)
        at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:52)
        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:239)
        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)
        at org.springframework.boot.actuate.autoconfigure.EndpointWebMvcAutoConfiguration$ApplicationContextHeaderFilter.doFilterInternal(EndpointWebMvcAutoConfiguration.java:291)
        at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:239)
        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)
        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:239)
        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)
        at org.springframework.boot.actuate.trace.WebRequestTraceFilter.doFilterInternal(WebRequestTraceFilter.java:102)
        at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:239)
        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)
        at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:85)
        at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:239)
        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)
        at org.springframework.boot.actuate.autoconfigure.MetricFilterAutoConfiguration$MetricsFilter.doFilterInternal(MetricFilterAutoConfiguration.java:90)
        at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)
        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:239)
        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)
        at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:219)
        at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:106)
        at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:501)
        at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:142)
        at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:79)
        at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:88)
        at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:516)
        at org.apache.coyote.http11.AbstractHttp11Processor.process(AbstractHttp11Processor.java:1086)
        at org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:659)
        at org.apache.coyote.http11.Http11NioProtocol$Http11ConnectionHandler.process(Http11NioProtocol.java:223)
        at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1558)
        at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.run(NioEndpoint.java:1515)
        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: com.netflix.hystrix.exception.HystrixRuntimeException: examplemsRibbonCommand timed-out and no fallback available.
        at com.netflix.hystrix.AbstractCommand$16.call(AbstractCommand.java:782)
        at com.netflix.hystrix.AbstractCommand$16.call(AbstractCommand.java:769)
        at rx.internal.operators.OperatorOnErrorResumeNextViaFunction$1.onError(OperatorOnErrorResumeNextViaFunction.java:77)
        at rx.internal.operators.OperatorDoOnEach$1.onError(OperatorDoOnEach.java:70)
        at rx.internal.operators.OperatorDoOnEach$1.onError(OperatorDoOnEach.java:70)
        at rx.internal.operators.OperatorDoOnEach$1.onError(OperatorDoOnEach.java:70)
        at com.netflix.hystrix.AbstractCommand$DeprecatedOnFallbackHookApplication$1.onError(AbstractCommand.java:1444)
        at com.netflix.hystrix.AbstractCommand$FallbackHookApplication$1.onError(AbstractCommand.java:1334)
        at com.netflix.hystrix.HystrixCommand$2.call(HystrixCommand.java:314)
        at com.netflix.hystrix.HystrixCommand$2.call(HystrixCommand.java:306)
        at rx.Observable$1.call(Observable.java:144)
        at rx.Observable$1.call(Observable.java:136)
        at rx.Observable$1.call(Observable.java:144)
        at rx.Observable$1.call(Observable.java:136)
        at rx.Observable$1.call(Observable.java:144)
        at rx.Observable$1.call(Observable.java:136)
        at rx.Observable$1.call(Observable.java:144)
        at rx.Observable$1.call(Observable.java:136)
        at rx.Observable$1.call(Observable.java:144)
        at rx.Observable$1.call(Observable.java:136)
        at rx.Observable$1.call(Observable.java:144)
        at rx.Observable$1.call(Observable.java:136)
        at rx.Observable$1.call(Observable.java:144)
        at rx.Observable$1.call(Observable.java:136)
        at rx.Observable$1.call(Observable.java:144)
        at rx.Observable$1.call(Observable.java:136)
        at rx.Observable$1.call(Observable.java:144)
        at rx.Observable$1.call(Observable.java:136)
        at rx.Observable$1.call(Observable.java:144)
        at rx.Observable$1.call(Observable.java:136)
        at rx.Observable.unsafeSubscribe(Observable.java:7466)
        at rx.internal.operators.OperatorOnErrorResumeNextViaFunction$1.onError(OperatorOnErrorResumeNextViaFunction.java:78)
        at rx.internal.operators.OperatorDoOnEach$1.onError(OperatorDoOnEach.java:70)
        at rx.internal.operators.OperatorDoOnEach$1.onError(OperatorDoOnEach.java:70)
        at com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$1.run(AbstractCommand.java:923)
        at com.netflix.hystrix.strategy.concurrency.HystrixContextRunnable$1.call(HystrixContextRunnable.java:41)
        at com.netflix.hystrix.strategy.concurrency.HystrixContextRunnable$1.call(HystrixContextRunnable.java:37)
        at com.netflix.hystrix.strategy.concurrency.HystrixContextRunnable.run(HystrixContextRunnable.java:57)
        at com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$2.tick(AbstractCommand.java:943)
        at com.netflix.hystrix.util.HystrixTimer$1.run(HystrixTimer.java:98)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        ... 1 common frames omitted
Caused by: java.util.concurrent.TimeoutException: null
        at com.netflix.hystrix.AbstractCommand$9.call(AbstractCommand.java:589)
        at com.netflix.hystrix.AbstractCommand$9.call(AbstractCommand.java:570)
        at rx.internal.operators.OperatorOnErrorResumeNextViaFunction$1.onError(OperatorOnErrorResumeNextViaFunction.java:77)
        ... 15 common frames omitted

如果我等待一两分钟，服务就会从 eureka 中删除，最终会传播到 zuulproxy，这意味着停止的服务不再有流量。但我的假设是，ribbon/hysterix 会更优雅/快速地处理无响应的服务。

有什么提示/建议吗？谢谢马格努斯

1/ 超时

Zuul 请求由 Hystrix 监控，其目的（在该应用程序中）是对长时间运行的请求应用超时。

Hystrix 提供了两种不同的方式来执行命令和强制超时：SEMAPHORE 和 THREAD 执行隔离。

当使用线程隔离时，Hystrix 命令在线程池中的单独线程上执行。然后，Hystrix“暂停”保存传入请求的线程，直到从下游服务器收到响应或发生超时。

当使用SEMAPHORE隔离时，Hystrix命令在请求线程上执行。仅在从下游服务器收到响应后才会检测到超时。因此，如果您将 Zuul/Hystrix 配置为 5 秒超时，并且您的服务需要 30 秒才能完成，则您的客户端只会在 30 秒后收到超时通知 - 即使服务成功响应（！）

Netflix 建议默认执行 THREAD，除非在极少数情况下。不幸的是，由于我不知道的原因，SpringCloud Zuul 集成将其更改为 SEMAPHORE。看为什么 ZUUL 强制 SEMAPHORE 隔离来执行其 Hystrix 命令？ https://stackoverflow.com/questions/29965817/why-is-zuul-forcing-a-semaphore-isolation-to-execute-its-hystrix-commands了解更多信息。

这解释了为什么尽管已成功联系剩余的实时服务器，您仍收到 500 错误。

2/ RETRY

功能区用于对远程服务进行实际调用。它使用 Eureka 提供的信息来确定可用的服务和相应的地址。 Eureka 使用每 30 秒更新一次的本地缓存。因此，正如 @spencergibb 所说，它可能会在一段时间内保留过时的信息（死服务器） - 但这是预期的。

当功能区连接/联系服务失败时，会自动重试。可以将其配置为在尝试另一个服务器之前重试同一服务器几次。我不记得默认值或实际的配置属性，但我个人一直在使用以下设置：

# Max number of retries on the same server (excluding the first try)
ribbon.maxAutoRetries = 1

# Max number of next servers to retry (excluding the first server)
ribbon.MaxAutoRetriesNextServer = 2

3/ 连接超时

从您的日志来看，远程服务的连接尝试失败大约需要 1 秒。这对于停止服务来说已经很长时间了。尝试连接到没有服务侦听的 TCP 端口应该会立即失败（至少在主机/IP 可达且连接尝试不会徒劳无功的情况下）...

连接超时由以下属性控制 - 确保将其设置为下降值：

# Connect timeout used by Apache HttpClient
ribbon.ConnectTimeout=3000

# Read timeout used by Apache HttpClient
ribbon.ReadTimeout=5000

希望这些信息可以帮助您解决问题；-)

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

springCloud

ZuulProxy 在应该执行故障转移时失败，并显示“RibbonCommand 超时且没有可用的后备” 的相关文章

Eureka Server：如何实现高可用

我是 Spring Cloud 的新手我读了this doc http cloud spring io spring cloud static spring cloud html service discovery eureka clie
使用配置服务器加载多个属性

我已经成功测试了从 SVN 存储库加载属性目前在我的配置服务器中我提供了 URI 和默认标签 trunk 并且我在下面有应用程序特定属性trunk 以下是我使用的应用程序的内容application yml并能够成功拉取属性 sprin
Spring Cloud AWS - 无效标头发布 SNS 通知

我正在尝试使用org springframework cloud aws messaging core NotificationMessagingTemplate 来自 Spring Cloud AWS 将通知发布到 SNS 主题每次发布
Spring Cloud Zuul代理网关不从Spring Boot应用程序加载css、js

我使用 Spring Cloud Zuul 代理创建了一个网关应用程序网关应用程序工作正常但它没有加载静态文件如 img css 和 js 文件我在我的中添加了以下设置应用程序属性我的网关应用程序的文件 zuul routes de
无法从 Kubernetes 中的 Spring Boot 客户端从远程 Spring 配置获取值

这是我的客户端的 bootstrap yml spring cloud config enabled true uri http localhost 8888 label master spring application name mic
是否可以使用 Spring API Gateway 进行威胁防护？

我将使用 Netflix Zuul 实现 API 网关是否可以设置任何规则来防止 SQL注入 XML 威胁防护 JSON 威胁防护我发现只有外部解决方案 API 网关支持它 None
Zuul 反向代理与 Keycloak 服务器

我正在使用 Zuul 反向代理实用程序配置 Spring Cloud Angel SR6 应用程序以隐藏内部服务端口我的 zuul 边缘服务发布在 8765 端口我的组织服务发布在 8083 端口当我在没有安全性的情况下访问应用程
迁移 Feign Load Balancer 实现以兼容 Spring cloud 2020.0.0

我有以下与 Spring Cloud 一起使用的 Feign 负载均衡器的实现Hoxtan SR6依赖关系 import feign auth BasicAuthRequestInterceptor import org apache ht
使用环境覆盖 Spring Cloud Config 值

有没有办法用另一个属性源特别是系统环境覆盖通过 Spring Cloud Config Server 设置的属性我知道我可以通过循环来手动完成Environment对象的PropertySources 但如果我可以设置它以便boots
Eureka检测服务状态

Context 我们使用 Spring Cloud Netflix 和 Eureka 作为服务发现使用 Zuul 来代理服务并对其进行负载平衡微服务使用NodeJS实现并使用NPM模块注册到Eurekaeureka js 客户端 ht
使用 Spring Boot 和 Netflix Zuul 的简单反向代理

我正在寻找使用 Spring Boot 实现一个简单的反向代理即轻松添加路线能够在每个路由的基础上添加自定义身份验证根据需要添加其他标头我查看了提供的设施 EnableZuulProxy注释但它似乎太重量级了因为我不想使用 E
将 SpringCloudSleuth 与 AWS X-Ray 集成

我有一个使用 Springboot 应用程序运行 Fargate 实例的 ECS 集群并且希望以最少的代码更改来启用跟踪我开始研究两种方法使用 AWS Xray 步骤 gt 添加依赖项添加 WSXRayServletFilter 在
Spring Cloud Zuul 在实例关闭时重试并转发到其他可用实例

使用 Camden SR5 作为 spring cloud 依赖项并使用 spring boot 1 5 2 RELEASE 在我当前的设置中我有尤里卡服务器配置服务器在随机端口上运行 zuul网关服务器和 2 个服务实例在随
自定义Zuul异常

我在 Zuul 中有一个场景其中 URL 路由的服务也可能已关闭因此响应正文会在 JSON 正文响应中抛出 500 HTTP Status 和 ZuulException timestamp 1459973637928 status
如何使用swagger-codegen-maven-plugin生成spring cloud feign客户端

我想使用 swagger codegen 生成我的假客户端代码但我找不到可以引导我执行此操作的文档我有一个使用 spring cloud 的微服务几个使用 spring cloud feign 接口来请求数据的 api 服务我希望我
如何管理共享库中的 spring-cloud bootstrap 属性？

我正在构建一个库该库为使用我们的应用程序提供固执己见的配置Spring Cloud Config Eureka设置这个想法是将此配置作为自定义启动器提供在各个微服务应用程序中很少或没有与 Spring Cloud 相关的样板此时我
Spring Cloud Kubernetes + Spring Cloud Gateway：无法找到 k8s 服务的实例

我正在使用 Spring Cloud Kubernetes Spring Cloud Gateway SCG 但在 GKE 上部署应用程序时遇到一些问题 SCG 找不到 k8s 服务我仍然收到此错误 There was an unexpe
Spring Cloud Gateway 全局异常处理和自定义错误响应

我有一个自定义过滤器可以在使用 Spring Cloud Gateway 调用实际 API 之前对每个请求进行身份验证 Spring Cloud中有没有办法像Spring提供 ControllerAdvice一样集中处理异常我想全局处理
从 GitHub 上托管的 Spring Cloud Config Server 访问存储库的身份验证问题

我在 GitHub 上的存储库中托管配置如果我将回购公开一切都好但如果我将其设为私有我将面临 org eclipse jgit errors TransportException https github com my user m
无法将 POST 方法与 Feign 一起使用

我正在尝试为 stockfigher 游戏 api 编写包装器只是为了了解 feign 的工作原理但我对第一个 POST 方法有疑问 RequestMapping method RequestMethod POST value venu

随机推荐

Django 添加类到表单字段

我们正在寻找一种解决方案将 CSS 类属性添加到 Django 表单的
在 Makefile 的先决条件列表中使用目标的目录路径

我编写了一个脚本它接收两个以 cfg 结尾的文件并输出一个以 cmp 结尾的文件我想将其包含在我的 Makefile 中因为一些源代码文件依赖于此 cmp 文件在我的 Makefile 中我想这样做 cmp cfg dir def
Spring休眠异常

当我启动 SpringMVC 时出现以下异常 Apr 28 2012 6 08 23 PM org apache catalina core AprLifecycleListener init INFO The APR based Apa
如何让 Docker 容器访问主机上的 dnsmasq 本地 DNS 解析器？

Docker 容器可能会通过多种方式对 DNS 设置感到困惑只需在 SO 或更广泛的互联网上搜索 Docker DNS 即可了解我的意思建议的常见解决方法之一是将 dnsmasq 设置为主机系统上的本地 DNS 解析器将其绑定到do
使用 Google Collections 创建弱多重地图

是否有与 MultiMaps 的 MapMaker 相当的工具目前我像这样创建缓存 public static Map
带有checked和after标签的css表单复选框样式[重复]

这个问题在这里已经有答案了我正在尝试在不使用 JavaScript 或 JQuery 的情况下设计一个表单它包括一系列复选框这个想法是如果未选中复选框则在复选框后显示某个 gif 否则后面不显示任何内容这是我的代码 input
设计 XML 模式的最佳实践是什么？ [关闭]

Closed 这个问题需要多问focused help closed questions 目前不接受答案作为一名业余软件开发人员我仍在学术界我编写了一些 XML 文档模式我经常遇到导致 XML 文档难看的设计错误因为我不完全确定
pandas_datareader 无法在 jupyter-notebook (Anaconda) 中工作

ModuleNotFoundError Traceback 最近一次调用最后一次在 3 从matplotlib导入样式 4 将 pandas 导入为 pd gt 5 将 pandas datareader data 导入为 web 6 7
匹配 MySQL 中单词/后缀的相似/变体

我如何匹配 MySQL 中单词的变体例如搜索 accountancy 应匹配 accountant accountants accounting 等我使用共享主机因此无法向 MySQL 添加任何功能例如 levenshtein 我想
如何在 Android 上的 SharedPreferences 中保存/存储对象？

我需要在很多地方获取用户对象其中包含很多字段登录后我想保存存储这些用户对象我们如何实现这样的场景呢我无法像这样存储它 SharedPreferences Editor prefsEditor myPrefs edit prefs
如何安装和使用 YAML-Cpp

我想学习 YAML 并将其与 C 一起使用但我一直在尝试设置YAML Cpp 让我解释一下到目前为止我所做的事情我下载了源代码版本0 5 1 安装的 Cmake 适用于 Windows 安装了 Boost 库为 Visual Stu
使用 Airflow BigqueryOperator 向 BigQuery 表添加标签

我必须向 bigquery 表添加标签我知道可以通过 BigQuery UI 来完成此操作但如何通过气流运算符来完成此操作 Use case 用于计费和搜索目的由于多个团队在同一项目和数据集下工作我们需要将各个团队创建的所有表组合在
Python 3 中的“raw_input()”和“input()”有什么区别？ [复制]

这个问题在这里已经有答案了有什么区别raw input and input 在 Python 3 中不同之处在于raw input Python 3 x 中不存在而input 做其实老raw input 已更名为input 和旧的
Django：如何从单独的多个服务器提供用户提交的图像和缩略图？

对于我的 Django 网站我想接受用户提交的图片从这些图像生成缩略图将原始图像和缩略图放在单独的多个专用于提供图像的服务器上我需要多个独立的服务器来提供图像缩略图以确保我有足够的 IO 性能构建这样的分布式图像服务系统的最
如何为Data-First自动创建的实体添加数据注释？

如果模型优先我们使用 MetadataType typeof ConceptMetadataSource 附加一个包含所有数据注释的 MetadataSource 文件例如 HiddenInput DisplayValue false
如果这段代码不是玩笑，那么它到底是如何工作的呢？

class Tree def initialize d d d end def to s l r gt d end def total d is a Numeric d 0 email protected cdn cgi l email p
如何删除 Laravel 5 中的帖子资源？

Laravel 5 版本我正在开发一个新的 laravel 5 版本的项目由于某种原因我无法删除帖子当我按删除时它只会将我重定向到帖子显示页面其 id 例如 post 3 我得到一个空白的白色页面当我返回索引视图时我会看到所
C# 和 .Net 垃圾收集器性能

我正在尝试用 C 和 NET 制作游戏并且计划实现更新游戏世界中游戏对象的消息这些消息将是 C 引用对象我想要这种方法因为如果我希望游戏是多人游戏那么通过网络发送它们会更容易但是如果我有很多消息对于垃圾收集器来说不是压力很大吗
如何选择非“唯一”行

我有下表我必须从中获取非唯一行 id idA infos 0 201 1899 1 205 1955 2 207 1955 3 201 1959 我想获取该列的所有行infos 具有相同的idA至少有两行的值上表的查询输出必须是 inf
ZuulProxy 在应该执行故障转移时失败，并显示“RibbonCommand 超时且没有可用的后备”

简短的介绍我试图让 ZuulProxy 来处理实例故障转移但它抛出 ZuulException 转发错误而不是使用工作实例的结果进行响应详细描述我的设置是一台独立的 Eureka Server 一台 ConfigServer 一台

ZuulProxy 在应该执行故障转移时失败，并显示“RibbonCommand 超时且没有可用的后备”

ZuulProxy 在应该执行故障转移时失败，并显示“RibbonCommand 超时且没有可用的后备” 的相关文章

随机推荐

热门标签