如何在Micronaut中为弹性GRPC Client设置调用超时？

以下是几种在Micronaut gRPC客户端中设置调用超时的可行方案：

1. 配置文件全局/客户端级配置 #

通过application.yml或application.properties可以为所有gRPC客户端设置默认超时，也可以针对特定客户端单独配置：

grpc:
  client:
    # 全局所有gRPC客户端的默认超时
    default:
      deadline: 5s
    # 针对标注@GrpcClient("user-service")的客户端单独设置超时
    user-service:
      deadline: 10s

注：deadline支持的时间单位包括ms（毫秒）、s（秒）、m（分钟）等。

2. 编程式设置单次调用超时 #

如果需要为某一次特定的gRPC调用单独设置超时，可以通过CallOptions在调用时动态配置：

import io.grpc.CallOptions;
import io.micronaut.grpc.annotation.GrpcClient;
import jakarta.inject.Singleton;

@Singleton
public class UserClientService {
    private final UserServiceGrpc.UserServiceBlockingStub userServiceStub;

    public UserClientService(@GrpcClient("user-service") UserServiceGrpc.UserServiceBlockingStub userServiceStub) {
        this.userServiceStub = userServiceStub;
    }

    public UserResponse getUserById(String userId) {
        // 为本次调用设置3秒超时
        CallOptions timeoutOptions = CallOptions.DEFAULT.withDeadlineAfter(3, java.util.concurrent.TimeUnit.SECONDS);
        return userServiceStub.withCallOptions(timeoutOptions).getUser(GetUserRequest.newBuilder().setId(userId).build());
    }
}

3. 结合重试配置实现弹性调用 #

你已经在使用重试配置，可以将超时与重试规则结合，让客户端在超时或服务不可用时自动重试：

grpc:
  client:
    user-service:
      deadline: 5s
      retry:
        enabled: true
        max-retry-attempts: 3
        # 指定触发重试的gRPC状态码，DEADLINE_EXCEEDED对应超时
        retry-on-statuses: [DEADLINE_EXCEEDED, UNAVAILABLE, RESOURCE_EXHAUSTED]

内容的提问来源于stack exchange，提问作者Javier Toja