时间戳

首页 > 解决方案 > 如果客户端在 GRPC 服务器端流中重新启动，如何继续流？

java - 如果客户端在 GRPC 服务器端流中重新启动，如何继续流？

问题描述

    @Override
    public void response(RequestApp request, Grpc.Stub asyncStub) {

        StreamObserver<Dto> streamObserver = new StreamObserver<Dto>() {
            @Override
            public void onNext(Response response) {
                LOGGER.info("Response is received.");
            }

            @Override
            public void onError(Throwable thrwbl) {
                LOGGER.error("Get error.");
            }

            @Override
            public void onCompleted() {
                LOGGER.info("Stream is completed.");
            }
        };

        asyncStub.method(request, streamObserver);
}

Grpc Client 代码如上所示。这里有服务器端流。如果客户端重新启动，在服务器端流启动后，如何继续这个流？

标签： javastreamgrpcserver-sidestub

解决方案

如果连接因任何原因丢失，您将无法恢复正在进行的流。如果您希望服务器从数据流中的前一个点开始发送数据，您可以让客户端在请求中包含一个令牌，服务器可以使用该令牌作为从哪里开始的指示。

推荐阅读