WellaceZ edited a comment on issue #1564: Provider停机过程中,consumer的新请求报The 
request is rejected和Failed to send request, local:not connected问题
URL: 
https://github.com/apache/servicecomb-java-chassis/issues/1564#issuecomment-583367429
 
 
   另外还有个问题,Provider停机时,在等待现有线程(存在耗时任务)处理这个过程中:
   ### 
【问题3】由于Provider实例自身是STOPPING的状态,那么耗时任务如果想调用另一个Provider(自身作为Consumer)的接口,将无法调用成功,这个问题要怎么处理?
   日志如下:
   2020-02-07 17:56:22.922|WARN 
|a2266adca6534011a51021b6d65b3ec3||[pool-3-thread-1]|AppInterceptor.java:delFailed:218|service
 param error.
   org.apache.servicecomb.swagger.invocation.exception.InvocationException: 
InvocationException: code=503;msg=CommonExceptionData [message=The request is 
rejected. Cannot process the request due to STATUS = STOPPING]
           at 
org.apache.servicecomb.core.SCBEngine.ensureStatusUp(SCBEngine.java:333)
           at 
org.apache.servicecomb.provider.pojo.Invoker$InvokerMeta.isValid(Invoker.java:61)
           at 
org.apache.servicecomb.provider.pojo.Invoker.invoke(Invoker.java:126)
           at com.sun.proxy.$Proxy65.listSettings(Unknown Source)
           at 
com.huawei.hicloud.kit.tokensdk.util.TokenApiWrapper.listSettings(TokenApiWrapper.java:41)
           at 
com.huawei.hicloud.kit.tokensdk.settings.ConfigurationWrapper.refreshSettingsCache(ConfigurationWrapper.java:378)
           at 
com.huawei.hicloud.kit.tokensdk.settings.ConfigurationWrapper.getValue(ConfigurationWrapper.java:394)
           at 
com.huawei.hicloud.kit.tokensdk.settings.SysConfigurationWrapper.getProperty(SysConfigurationWrapper.java:41)
           at 
com.huawei.hicloud.kit.tokensdk.settings.ConfigurationWrapper.getInt(ConfigurationWrapper.java:263)
           at 
com.huawei.hicloud.kit.tokensdk.settings.ConfigurationWrapper.getInt(ConfigurationWrapper.java:270)
           at 
com.huawei.hicloud.kit.base.common.FeatureController.getMod(FeatureController.java:84)
           at 
com.huawei.hicloud.kit.base.common.FeatureController.isFeatureEnable(FeatureController.java:78)
           at 
com.huawei.hicloud.kit.favorite.handler.FavoriteApiGetFavoritesHandler.getFavorites(FavoriteApiGetFavoritesHandler.java:65)
           at 
com.huawei.hicloud.kit.favorite.handler.FavoriteApiGetFavoritesHandler.getFavorite(FavoriteApiGetFavoritesHandler.java:129)
           at 
com.huawei.hicloud.kit.favorite.controller.FavoriteServiceController.getFavorite(FavoriteServiceController.java:64)
           at 
com.huawei.hicloud.kit.datamanager.controller.FavoriteApiController.getFavorite(FavoriteApiController.java:84)
           at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
           at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
           at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
           at java.lang.reflect.Method.invoke(Method.java:498)
           at 
org.apache.servicecomb.swagger.engine.SwaggerProducerOperation.doInvoke(SwaggerProducerOperation.java:180)
           at 
org.apache.servicecomb.swagger.engine.SwaggerProducerOperation.syncInvoke(SwaggerProducerOperation.java:165)
           at 
org.apache.servicecomb.swagger.engine.SwaggerProducerOperation.invoke(SwaggerProducerOperation.java:119)
           at 
org.apache.servicecomb.core.handler.impl.ProducerOperationHandler.handle(ProducerOperationHandler.java:40)
           at org.apache.servicecomb.core.Invocation.next(Invocation.java:204)
           at 
org.apache.servicecomb.bizkeeper.BizkeeperCommand.lambda$construct$2(BizkeeperCommand.java:79)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
           at rx.Observable.unsafeSubscribe(Observable.java:8666)
           at 
rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:52)
           at 
rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:36)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
           at rx.Observable.unsafeSubscribe(Observable.java:8666)
           at 
rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:52)
           at 
rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:36)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50)
           at 
rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)
           at rx.Observable.unsafeSubscribe(Observable.java:8666)
           at 
rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:52)
           at 
rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:36)
           at rx.Observable.subscribe(Observable.java:8759)
           at rx.Observable.subscribe(Observable.java:8726)
           at rx.Observable.subscribe(Observable.java:8619)
           at 
org.apache.servicecomb.bizkeeper.BizkeeperHandler.handle(BizkeeperHandler.java:78)
           at org.apache.servicecomb.core.Invocation.next(Invocation.java:204)
           at 
org.apache.servicecomb.qps.ProviderQpsFlowControlHandler.handle(ProviderQpsFlowControlHandler.java:38)
           at org.apache.servicecomb.core.Invocation.next(Invocation.java:204)
           at 
com.huawei.hicloud.kit.framework.interceptor.validation.ValidationHandler.handle(ValidationHandler.java:68)
           at org.apache.servicecomb.core.Invocation.next(Invocation.java:204)
           at 
com.huawei.hicloud.kit.framework.interceptor.app.AppInterceptor.handle(AppInterceptor.java:133)
           at org.apache.servicecomb.core.Invocation.next(Invocation.java:204)
           at 
org.apache.servicecomb.common.rest.AbstractRestInvocation.doInvoke(AbstractRestInvocation.java:243)
           at 
org.apache.servicecomb.common.rest.AbstractRestInvocation.invoke(AbstractRestInvocation.java:217)
           at 
org.apache.servicecomb.common.rest.AbstractRestInvocation.runOnExecutor(AbstractRestInvocation.java:201)
           at 
org.apache.servicecomb.common.rest.AbstractRestInvocation.lambda$scheduleInvocation$0(AbstractRestInvocation.java:160)
           at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
           at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
           at java.lang.Thread.run(Thread.java:748)
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to