From 4864df85868fee59d7d77dba06a4254300161d1d Mon Sep 17 00:00:00 2001 From: chuntaojun Date: Fri, 31 Mar 2023 11:49:44 +0800 Subject: [PATCH] =?UTF-8?q?feat:gateway=E6=94=AF=E6=8C=81=E4=B8=8A?= =?UTF-8?q?=E6=8A=A5=E8=B0=83=E7=94=A8=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../enhancement/scg/EnhancedPolarisHttpClient.java | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/spring-cloud-tencent-rpc-enhancement/src/main/java/com/tencent/cloud/rpc/enhancement/scg/EnhancedPolarisHttpClient.java b/spring-cloud-tencent-rpc-enhancement/src/main/java/com/tencent/cloud/rpc/enhancement/scg/EnhancedPolarisHttpClient.java index ec68806b9..9a89a4598 100644 --- a/spring-cloud-tencent-rpc-enhancement/src/main/java/com/tencent/cloud/rpc/enhancement/scg/EnhancedPolarisHttpClient.java +++ b/spring-cloud-tencent-rpc-enhancement/src/main/java/com/tencent/cloud/rpc/enhancement/scg/EnhancedPolarisHttpClient.java @@ -34,6 +34,8 @@ import com.tencent.polaris.api.rpc.ServiceCallResult; import com.tencent.polaris.client.api.SDKContext; import io.netty.handler.codec.http.HttpHeaders; import org.apache.commons.lang.StringUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import reactor.netty.Connection; import reactor.netty.http.client.HttpClient; import reactor.netty.http.client.HttpClientConfig; @@ -44,6 +46,8 @@ import org.springframework.http.HttpStatus; public class EnhancedPolarisHttpClient extends HttpClient { + private static final Logger LOG = LoggerFactory.getLogger(EnhancedPolarisHttpClient.class); + private final RpcEnhancementReporterProperties properties; private final SDKContext context; private final ConsumerAPI consumerAPI; @@ -87,7 +91,12 @@ public class EnhancedPolarisHttpClient extends HttpClient { if (Objects.nonNull(context)) { result.setCallerIp(context.getConfig().getGlobal().getAPI().getBindIP()); } - consumerAPI.updateServiceCallResult(result); + try { + consumerAPI.updateServiceCallResult(result); + } + catch (Throwable ex) { + LOG.error("update service call result fail", ex); + } } }; private HttpClient target;