Merge pull request #601 from 15911075183ma/fix-feign-traceId

fix：修复高并发下traceId重复问题

Author: mazp99

dongtai-core/src/main/java/io/dongtai/iast/core/bytecode/enhance/plugin/framework/feign/FeignSyncHandlerAdapter.java

@@ -8,7 +8,9 @@
 import org.objectweb.asm.MethodVisitor;
 
 public class FeignSyncHandlerAdapter extends AbstractClassVisitor {
-    private static final String FEIGN_SYNC_HANDLER_INVOKE = "feign.SynchronousMethodHandler.invoke(java.lang.Object[])";
+    //此HOOK点添加header有并发安全风险，故修改为executeAndDecode
+//    private static final String FEIGN_SYNC_HANDLER_INVOKE = "feign.SynchronousMethodHandler.invoke(java.lang.Object[])";
+    private static final String FEIGN_SYNC_HANDLER_INVOKE = "feign.SynchronousMethodHandler.executeAndDecode(feign.RequestTemplate,feign.Request$Options)";
 
     public FeignSyncHandlerAdapter(ClassVisitor classVisitor, ClassContext context) {
         super(classVisitor, context);

dongtai-core/src/main/java/io/dongtai/iast/core/handler/hookpoint/service/trace/FeignService.java

@@ -8,23 +8,18 @@
 import io.dongtai.iast.core.utils.TaintPoolUtils;
 import io.dongtai.log.DongTaiLog;
 
-import java.lang.reflect.Field;
 import java.lang.reflect.Method;
 import java.util.concurrent.atomic.AtomicInteger;
 
 public class FeignService {
+
     public static void solveSyncInvoke(MethodEvent event, AtomicInteger invokeIdSequencer) {
         try {
-            if (event.parameterInstances.length != 1) {
-                return;
-            }
+            Object parameterInstance = event.parameterInstances[0];
+
+            Method appendHeader = parameterInstance.getClass().getDeclaredMethod("appendHeader", String.class, String[].class);
+            appendHeader.setAccessible(true);
 
-            Object handlerObj = event.objectInstance;
-            Field metadataField = handlerObj.getClass().getDeclaredField("metadata");
-            metadataField.setAccessible(true);
-            Object metadata = metadataField.get(event.objectInstance);
-            Method templateMethod = metadata.getClass().getMethod("template");
-            Object template = templateMethod.invoke(metadata);
 
             // get args
             Object args = event.parameterInstances[0];
@@ -33,35 +28,28 @@ public static void solveSyncInvoke(MethodEvent event, AtomicInteger invokeIdSequ
             boolean hasTaint = !event.getSourceHashes().isEmpty();
             event.addParameterValue(0, args, hasTaint);
 
-            Method addHeaderMethod = template.getClass().getDeclaredMethod("header", String.class, String[].class);
-            addHeaderMethod.setAccessible(true);
             // clear old traceId header
-            /*
-            防止高并发下的treeMap修改问题，暂时可解决
-             */
-            synchronized (template){
-                //将生成traceId下放到锁内
-                String traceId = ContextManager.nextTraceId();
+            //曾经的hook点在高并发下有线程安全问题，新hook点判断无此问题，除去锁
+            String traceId = ContextManager.nextTraceId();
+            DongTaiLog.trace("InvokeId is {}, request headers is {}",event.getInvokeId(),traceId);
+            appendHeader.invoke(parameterInstance,ContextManager.getHeaderKey(),new String[]{});
+            appendHeader.invoke(parameterInstance,ContextManager.getParentKey(),new String[]{});
+            appendHeader.invoke(parameterInstance,ContextManager.getHeaderKey(),new String[]{traceId});
+            appendHeader.invoke(parameterInstance,ContextManager.getParentKey(),new String[]{String.valueOf(EngineManager.getAgentId())});
+            event.traceId = traceId;
 
-                addHeaderMethod.invoke(template, ContextManager.getHeaderKey(), new String[]{});
-                addHeaderMethod.invoke(template, ContextManager.getParentKey(), new String[]{});
-                addHeaderMethod.invoke(template, ContextManager.getHeaderKey(), new String[]{traceId});
-                addHeaderMethod.invoke(template, ContextManager.getParentKey(),
-                        new String[]{String.valueOf(EngineManager.getAgentId())});
-                event.traceId = traceId;
-            }
             // add to method pool
             event.source = false;
             event.setCallStacks(StackUtils.createCallStack(4));
             int invokeId = invokeIdSequencer.getAndIncrement();
             event.setInvokeId(invokeId);
             event.setPolicyType(PolicyNodeType.PROPAGATOR.getName());
             EngineManager.TRACK_MAP.get().put(invokeId, event);
-        } catch (NoSuchFieldException ignore) {
         } catch (NoSuchMethodException ignore) {
         } catch (Throwable e) {
             DongTaiLog.debug("solve feign invoke failed: {}, {}",
                     e.getMessage(), e.getCause() != null ? e.getCause().getMessage() : "");
         }
     }
+
 }