Java gRPC客户端重试日志缺失问题及获取方法咨询

问题1：为何配置重试后gRPC未输出重试日志？ #

• gRPC Java客户端默认日志级别较高：重试相关核心逻辑（如io.grpc.internal.RetryingCall类）的日志默认是DEBUG级别，如果你的日志框架（Logback、Log4j2等）未将io.grpc.internal包的日志级别调整为DEBUG，这些重试细节会被过滤，不会输出。
• 重试配置未实际触发：检查service config是否正确设置了重试触发条件，比如指定的方法名、可重试状态码（如UNAVAILABLE、RESOURCE_EXHAUSTED）、重试次数上限等。如果请求不符合重试规则，自然不会产生重试行为，也就没有日志。
• 自定义逻辑屏蔽日志：如果客户端添加了自定义ClientInterceptor，可能在拦截逻辑中覆盖了gRPC内部的日志输出；或者日志框架的全局配置屏蔽了gRPC相关包的日志。

问题2：能否在客户端记录每次重试行为？ #

完全可以，以下是几种实用方案：

方案1：调整日志级别输出原生重试日志 #

修改日志框架配置（以Logback为例），将gRPC内部包的日志级别设为DEBUG：

<logger name="io.grpc.internal" level="DEBUG" additivity="false">
    <appender-ref ref="YOUR_APPENDER"/>
</logger>

调整后就能看到gRPC原生的重试日志，比如：Retrying call. Previous attempt count: 1, error: Status{code=UNAVAILABLE, description=...}。

方案2：自定义客户端拦截器记录重试细节 #

实现ClientInterceptor，通过包装Call和Listener捕获重试事件，自定义日志格式：

public class RetryLoggingInterceptor implements ClientInterceptor {
    private static final Logger logger = LoggerFactory.getLogger(RetryLoggingInterceptor.class);
    private static final Metadata.Key<String> PREVIOUS_ATTEMPTS =
            Metadata.Key.of("grpc-previous-rpc-attempts", Metadata.ASCII_STRING_MARSHALLER);

    @Override
    public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(MethodDescriptor<ReqT, RespT> method,
                                                               CallOptions callOptions, Channel next) {
        return new ForwardingClientCall.SimpleForwardingClientCall<ReqT, RespT>(next.newCall(method, callOptions)) {
            @Override
            public void start(Listener<RespT> responseListener, Metadata headers) {
                Listener<RespT> wrappedListener = new ForwardingClientCallListener.SimpleForwardingClientCallListener<RespT>(responseListener) {
                    @Override
                    public void onClose(Status status, Metadata trailers) {
                        String attempts = trailers.get(PREVIOUS_ATTEMPTS);
                        if (attempts != null && Integer.parseInt(attempts) > 0) {
                            logger.info("RPC重试完成 | 方法: {} | 重试次数: {} | 最终状态: {}",
                                    method.getFullMethodName(), attempts, status.getCode());
                        }
                        super.onClose(status, trailers);
                    }
                };
                super.start(wrappedListener, headers);
            }
        };
    }
}

将拦截器添加到客户端：

ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 9090)
        .intercept(new RetryLoggingInterceptor())
        .build();

方案3：利用gRPC Metrics收集重试指标 #

通过gRPC的MetricRecorder收集重试次数、延迟等指标，结合日志输出：

MetricRecorder metricRecorder = MetricRecorder.create();
ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 9090)
        .setMetricRecorder(metricRecorder)
        .build();
// 定期输出累计重试次数
ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
executor.scheduleAtFixedRate(() -> {
    long retryCount = metricRecorder.getMetrics().getRetryCount();
    logger.info("累计RPC重试次数: {}", retryCount);
}, 0, 1, TimeUnit.MINUTES);

内容的提问来源于stack exchange，提问作者Ravi Teja Muddada