From 8cf212fb132edfd27385f704fc79e743e1e448a2 Mon Sep 17 00:00:00 2001 From: lbw Date: Wed, 13 Jan 2021 14:12:00 +0800 Subject: [PATCH] =?UTF-8?q?:lock:=20=E4=BF=AE=E5=A4=8D=E5=AE=89=E5=85=A8?= =?UTF-8?q?=EF=BC=8C=E5=BC=BA=E8=BD=AC=E7=B1=BB=E5=9E=8B=E5=A4=B1=E8=B4=A5?= =?UTF-8?q?=E5=88=A4=E6=96=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../pigx/common/gray/rule/GrayRoundRobinLoadBalancer.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pigx-common/pigx-common-gray/src/main/java/com/pig4cloud/pigx/common/gray/rule/GrayRoundRobinLoadBalancer.java b/pigx-common/pigx-common-gray/src/main/java/com/pig4cloud/pigx/common/gray/rule/GrayRoundRobinLoadBalancer.java index d49f099c8..ab143c6c3 100755 --- a/pigx-common/pigx-common-gray/src/main/java/com/pig4cloud/pigx/common/gray/rule/GrayRoundRobinLoadBalancer.java +++ b/pigx-common/pigx-common-gray/src/main/java/com/pig4cloud/pigx/common/gray/rule/GrayRoundRobinLoadBalancer.java @@ -66,6 +66,10 @@ public class GrayRoundRobinLoadBalancer extends RoundRobinLoadBalancer { } DefaultRequestContext requestContext = (DefaultRequestContext) request.getContext(); + if (!(requestContext.getClientRequest() instanceof RequestData)){ + return super.choose(request).block(); + } + RequestData clientRequest = (RequestData) requestContext.getClientRequest(); HttpHeaders headers = clientRequest.getHeaders();