public class Request<T> implements Serializable {
    //header：攜帶需要傳遞的信息
    private RequestHeader header;
    //業(yè)務(wù)參數(shù)
    private T bizModel;
    //...省略get set
}
public class RequestHeader implements Serializable {

    //調(diào)用鏈唯一ID
    private String traceId;
    //當(dāng)前用戶Id
    private String userId;
    //上游調(diào)用方appId
    private String callAppId;
    //...省略get set
}

    @ApiMethod
    @PostMapping("/test")
    @ApiOperation(value = "test", notes = "", response = String.class)
    public Response<ExampleRespDTO> test(@RequestBody Request<ExampleReqDTO> req) {
        ExampleRespDTO exampleRespDTO = new ExampleRespDTO();
        exampleRespDTO.setName(req.getBizModel().getName());

        //輸出當(dāng)前應(yīng)用的header信息
         System.out.println("上游的traceId："+RequestContext.getHeader().getTraceId());
        System.out.println("上游的callAppId："+RequestContext.getHeader().getCallAppId());
        System.out.println("上游的userId："+RequestContext.getHeader().getUserId());


        /***
         * 模擬調(diào)用其他應(yīng)用服務(wù)
         * 通過(guò)RPCRequest 來(lái)構(gòu)建request對(duì)象
         */
        Request<OtherAppServiceReqDTO>  otherAppServiceReqDTORequest =RPCRequest.createRequest(new OtherAppServiceReqDTO());

        //輸出下游應(yīng)用的header信息
        System.out.println("調(diào)用下游的traceId："+otherAppServiceReqDTORequest.getHeader().getTraceId());
        System.out.println("調(diào)用下游的callAppId："+otherAppServiceReqDTORequest.getHeader().getCallAppId());
        System.out.println("調(diào)用下游的userId："+otherAppServiceReqDTORequest.getHeader().getUserId());

        return Response.successResponse(exampleRespDTO);
    }

public class RPCRequest {
    public static <T> Request<T> createRequest(T requestData){
        Request<T> request = new Request();
        RequestHeader requestHeader=new RequestHeader();
        requestHeader.setTraceId(RequestContext.getHeader().getTraceId());
        requestHeader.setUserId(RequestContext.getHeader().getUserId());
        requestHeader.setCallAppId(AppConfig.CURRENT_APP_ID);
        request.setHeader(requestHeader);
        request.setBizModel(requestData);
        return request;
    }
}

public class RequestContext {
  private static ThreadLocal<RequestHeader> threadLocal=new ThreadLocal<>();
   public static void setHeader(RequestHeader header){
       threadLocal.set(header);
   }
   public static RequestHeader getHeader(){
       return threadLocal.get();
   }
   public static void clear(){
       threadLocal.remove();
   }
}

public class ApiHandler {
    public ApiHandler() {
    }

    public Response handleApiMethod(ProceedingJoinPoint pjp, ApiMethod apiMethod) {
        //獲取上游調(diào)用方的request header
        Object[] args = pjp.getArgs();
        Request request = (Request) args[0];
        RequestHeader header = request.getHeader();
        //將header加入到當(dāng)前request 到ThreadLocal保存
        RequestContext.setHeader(header);
        Response response = null;
        try {
            //構(gòu)建response header
            ResponseHeader responseHeader = new ResponseHeader();
            responseHeader.setTraceId(RequestContext.getHeader().getTraceId());
            //執(zhí)行service方法
            response = (Response) pjp.proceed(args);
            response.setHeader(responseHeader);

        } catch (Throwable throwable) {
            throwable.printStackTrace();
        }finally {
            //清除ThreadLocal中當(dāng)前請(qǐng)求的header 對(duì)象
            RequestContext.clear();
        }
        return response;

    }
}