[feat][*][*]: add interceptor to log request trace

Author: zouxyan

ps-bootstrap/src/main/resources/logback-spring.xml

@@ -85,6 +85,35 @@
         </filter>
     </appender>
 
+    <appender name="reqTraceAppender" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <file>${logging.path}/${APP_NAME}/req_trace.log</file>
+        <encoder>
+            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} -
+                %msg%n
+            </pattern>
+            <charset>UTF-8</charset>
+        </encoder>
+        <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
+            <FileNamePattern>${logging.path}/${APP_NAME}/req_trace.log.%d{yyyy-MM-dd}.%i</FileNamePattern>
+            <maxHistory>7</maxHistory>
+            <maxFileSize>50MB</maxFileSize>
+            <totalSizeCap>500MB</totalSizeCap>
+            <cleanHistoryOnStart>true</cleanHistoryOnStart>
+        </rollingPolicy>
+    </appender>
+    <appender name="full-req-trace" class="ch.qos.logback.classic.AsyncAppender">
+        <!-- 不丢失日志.默认的,如果队列的80%已满,则会丢弃TRACT、DEBUG、INFO级别的日志 -->
+        <discardingThreshold>0</discardingThreshold>
+        <!-- 更改默认的队列的深度,该值会影响性能.默认值为256 -->
+        <queueSize>256</queueSize>
+        <!-- 添加附加的appender,最多只能添加一个 -->
+        <appender-ref ref="reqTraceAppender"/>
+    </appender>
+
+    <logger name="req-trace" level="INFO" additivity="false">
+        <appender-ref ref="full-req-trace"/>
+    </logger>
+
     <root level="INFO">
         <appender-ref ref="CONSOLE"/>
         <appender-ref ref="full-application"/>

ps-server/src/main/java/com/alipay/antchain/bridge/pluginserver/server/CrossChainServiceImpl.java

@@ -28,21 +28,21 @@
 import com.alipay.antchain.bridge.plugins.spi.bbc.IBBCService;
 import com.alipay.antchain.bridge.pluginserver.pluginmanager.IPluginManagerWrapper;
 import com.alipay.antchain.bridge.pluginserver.server.exception.ServerErrorCodeEnum;
+import com.alipay.antchain.bridge.pluginserver.server.interceptor.RequestTraceInterceptor;
 import com.alipay.antchain.bridge.pluginserver.service.*;
 import com.google.protobuf.ByteString;
 import io.grpc.stub.StreamObserver;
 import lombok.extern.slf4j.Slf4j;
 import net.devh.boot.grpc.server.service.GrpcService;
 
-@GrpcService
+@GrpcService(interceptors = RequestTraceInterceptor.class)
 @Slf4j
 public class CrossChainServiceImpl extends CrossChainServiceGrpc.CrossChainServiceImplBase {
     @Resource
     private IPluginManagerWrapper pluginManagerWrapper;
 
     @Override
     public void heartbeat(Empty request, StreamObserver<Response> responseObserver) {
-        log.info("heartbeat from relayer");
         responseObserver.onNext(
                 ResponseBuilder.buildHeartbeatSuccessResp(
                         HeartbeatResponse.newBuilder()
@@ -79,12 +79,6 @@ public void ifDomainAlive(IfDomainAliveRequest request, StreamObserver<Response>
     public void bbcCall(CallBBCRequest request, StreamObserver<Response> responseObserver) {
         String product = request.getProduct();
         String domain = request.getDomain();
-        if (CallBBCRequest.RequestCase.QUERYLATESTHEIGHTREQ == request.getRequestCase()) {
-            log.debug("BBCCall [product: {}, domain: {}, request: {}]", product, domain, request.getRequestCase());
-        } else {
-            log.info("BBCCall [product: {}, domain: {}, request: {}]", product, domain, request.getRequestCase());
-        }
-
         Response resp;
 
         // 1. Startup request needs to be handled separately， because it may need create a service first.

ps-server/src/main/java/com/alipay/antchain/bridge/pluginserver/server/interceptor/RequestTraceInterceptor.java

@@ -0,0 +1,32 @@
+package com.alipay.antchain.bridge.pluginserver.server.interceptor;
+
+import java.net.InetSocketAddress;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import io.grpc.*;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j(topic = "req-trace")
+public class RequestTraceInterceptor implements ServerInterceptor {
+
+    @Override
+    public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) {
+        InetSocketAddress clientAddr = (InetSocketAddress) call.getAttributes().get(Grpc.TRANSPORT_ATTR_REMOTE_ADDR);
+        if (StrUtil.equalsIgnoreCase(call.getMethodDescriptor().getBareMethodName(), "heartbeat")) {
+            if (ObjectUtil.isNull(clientAddr)) {
+                log.info("heartbeat from relayer without address found");
+            } else {
+                log.info("heartbeat from relayer {}:{}", clientAddr.getHostString(), clientAddr.getPort());
+            }
+        } else if (StrUtil.equalsIgnoreCase(call.getMethodDescriptor().getBareMethodName(), "bbcCall")) {
+            if (ObjectUtil.isNull(clientAddr)) {
+                log.debug("bbc call from relayer without address found");
+            } else {
+                log.debug("bbc call from relayer {}:{}", clientAddr.getHostString(), clientAddr.getPort());
+            }
+        }
+
+        return next.startCall(call, headers);
+    }
+}