ARTS - Week 4

@Slf4j
public class BaseRpc {
  public static <T, R> T invoke(Function<R, ServiceResponse<T>> function, String logPrefix, R r) {
    Long startTime = System.currentTimeMillis();
    // 1. 打印入参
    log.info("{} is starting RPC, the request is {}", logPrefix, r);
    ServiceResponse<T> response = null;
    try {
    // 2. 执行RPC
      response = function.apply(r);
    } catch (Exception e) {
    // 3. 打印error日志
      log.error("{} throws an Exception", logPrefix, e);
      return null;
    } finally {
    // 4. 给监控上传调用时间
      LogUtil.recordTime(logPrefix, startTime);
    }
    // 5. 打印response为空时的日志
    if (Objects.isNull(response) || !response.isSuccess() || Objects.isNull(response.getResult())) {
      log.info("{} has NULL result", logPrefix);
      return null;
    }
    // 6. 打印结果
    log.info("{} the result is {}", logPrefix, response.getResult());
    return response.getResult();
  }
}
// 调用方
BatchMemberConfigReq request = buildMembershipStoreRequest(indexRequest, storeBaseInfoList);
List<MemberConfigDTO> responseList = BaseRpc
	.invoke(r -> memberService.batchQueryMembershipAndConfig(r),
  	"memberService.batchQueryMembershipAndConfig", request);