忽略gRPC服务端响应流时，服务不可用无报错的解决方法咨询

问题原因 #

gRPC阻塞式服务端流式RPC的存根方法返回Iterator<Response>时，实际的请求发送和连接建立操作会延迟到第一次调用迭代器的hasNext()或next()方法时执行。如果直接忽略返回的迭代器，相当于没有触发实际的请求流程，自然不会检测到服务不可用的错误。

解决方案 #

1. 触发迭代器初始化（最简单的兼容方案） #

调用一次迭代器的hasNext()方法，强制触发请求发送和连接检测，此时若服务不可用，会立即抛出StatusRuntimeException: UNAVAILABLE。后续无需处理迭代器的其余内容：

Iterator<Response> responseIterator = blockingStub.send(request);
try {
    // 触发请求流程，检测服务可用性
    responseIterator.hasNext();
} catch (StatusRuntimeException e) {
    // 处理服务不可用等错误
    throw e;
}
// 无需处理后续响应

2. 修改服务定义为单向RPC（最彻底的方案） #

如果业务逻辑确实不需要服务端返回任何响应，可以将gRPC服务定义修改为单向RPC（fire-and-forget），此时阻塞式存根的方法会返回void，调用时会立即触发请求，服务不可用会直接抛出错误：

// 原服务定义（服务端流式）
rpc send(Request) returns (stream Response);

// 修改为单向RPC
rpc send(Request) returns ();

生成的存根代码会变为：

void send(Request request);

调用时直接执行blockingStub.send(request);，服务不可用时会立刻抛出预期的异常。

3. 使用异步存根监听错误（非阻塞场景） #

如果需要非阻塞调用但仍要及时检测服务错误，可以使用异步存根，通过StreamObserver监听错误事件，同时忽略响应内容：

// 创建异步存根
AsyncStub asyncStub = AsyncStub.newStub(channel);

CountDownLatch latch = new CountDownLatch(1);

StreamObserver<Response> responseObserver = new StreamObserver<Response>() {
    @Override
    public void onNext(Response value) {
        // 忽略响应内容
    }

    @Override
    public void onError(Throwable t) {
        // 捕获服务不可用等错误
        Status status = Status.fromThrowable(t);
        if (status.getCode() == Status.Code.UNAVAILABLE) {
            // 执行错误处理逻辑
        }
        latch.countDown();
    }

    @Override
    public void onCompleted() {
        latch.countDown();
    }
};

// 发送请求
StreamObserver<Request> requestObserver = asyncStub.send(responseObserver);
requestObserver.onNext(request);
requestObserver.onCompleted();

// 同步等待请求完成（按需使用）
latch.await();

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