Fix Repeat Add trace interceptor

Author: huicunjun

apm-sniffer/apm-sdk-plugin/grpc-1.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/grpc/v1/define/AbstractServerImplBuilderInstrumentation.java

@@ -65,8 +65,7 @@ public boolean isOverrideArgs() {
     protected ClassMatch enhanceClass() {
         return MultiClassNameMatch.byMultiClassMatch(
                 "io.grpc.internal.AbstractServerImplBuilder", //grpc version <= 1.58.1
-                "io.grpc.internal.ServerImplBuilder", //grpc version >= 1.59.0
-                "io.grpc.internal.ForwardingServerBuilder" //grpc version >= 1.59.0
+                "io.grpc.internal.ServerImplBuilder" //grpc version >= 1.59.0
         );
     }
 }

apm-sniffer/apm-sdk-plugin/grpc-1.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/grpc/v1/server/AbstractServerImplBuilderInterceptor.java

@@ -20,7 +20,9 @@
 
 import io.grpc.ServerBuilder;
 
+import java.lang.reflect.Field;
 import java.lang.reflect.Method;
+import java.util.List;
 
 import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.EnhancedInstance;
 import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.InstanceMethodsAroundInterceptor;
@@ -32,12 +34,23 @@
 public class AbstractServerImplBuilderInterceptor implements InstanceMethodsAroundInterceptor {
     @Override
     public void beforeMethod(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
-        MethodInterceptResult result) {
+                             MethodInterceptResult result) throws Throwable {
         if (objInst.getSkyWalkingDynamicField() == null) {
             ServerBuilder<?> builder = (ServerBuilder) objInst;
-            ServerInterceptor interceptor = new ServerInterceptor();
-            builder.intercept(interceptor);
-            objInst.setSkyWalkingDynamicField(interceptor);
+            Field field = findField(builder.getClass());
+            if (field != null) {
+                field.setAccessible(true);
+                List<?> interceptors = (List<?>) field.get(builder);
+                boolean hasCustomInterceptor = interceptors.stream()
+                        .anyMatch(i -> i.getClass() == ServerInterceptor.class);
+
+                if (!hasCustomInterceptor) {
+                    ServerInterceptor interceptor = new ServerInterceptor();
+                    builder.intercept(interceptor);
+                    objInst.setSkyWalkingDynamicField(interceptor);
+                }
+
+            }
         }
     }
 
@@ -52,4 +65,16 @@ public void handleMethodException(EnhancedInstance objInst, Method method, Objec
         Class<?>[] argumentsTypes, Throwable t) {
 
     }
+
+    private static Field findField(Class<?> clazz) {
+        while (clazz != null) {
+            for (Field f : clazz.getDeclaredFields()) {
+                if (f.getName().equals("interceptors")) {
+                    return f;
+                }
+            }
+            clazz = clazz.getSuperclass();
+        }
+        return null;
+    }
 }