8

我正在使用 GRPC-Java 1.1.2。在一个活动的 GRPC 会话中，我打开了一些双向流。当客户端断开连接时，有没有办法从客户端清除它们？当我尝试断开连接时，我运行以下查找固定次数然后断开连接，但我可以在服务器端看到以下错误（但不确定它是否由另一个问题引起）：

与客户端断开连接

while (!channel.awaitTermination(3, TimeUnit.SECONDS)) {
// check for upper bound and break if so
}
channel.shutdown().awaitTermination(3, TimeUnit.SECONDS);

服务器上的错误

E0414 11:26:48.787276000 140735121084416 ssl_transport_security.c:439] SSL_read returned 0 unexpectedly.
E0414 11:26:48.787345000 140735121084416 secure_endpoint.c:185]        Decryption error: TSI_INTERNAL_ERROR
4

2 回答 2

7

如果您想从客户端关闭 gRPC（服务器端或双向）流，则必须将 rpc 调用附加到Context.CancellableContextpackage 中io.grpc。

假设你有一个 rpc：

service Messaging {
    rpc Listen (ListenRequest) returns (stream Message) {}
}

在客户端，您将像这样处理它：

public class Messaging {
    private Context.CancellableContext mListenContext;

    private MessagingGrpc.MessagingStub getMessagingAsyncStub() {
    /* return your async stub */
    }

    public void listen(final ListenRequest listenRequest, final StreamObserver<Message> messageStream) {

        Runnable listenRunnable = new Runnable() {
            @Override
            public void run() {
                Messaging.this.getMessagingAsyncStub().listen(listenRequest, messageStream);
            }

        if (mListenContext != null && !mListenContext.isCancelled()) {
            Log.d(TAG, "listen: already listening");
            return;
        }

        mListenContext = Context.current().withCancellation();
        mListenContext.run(listenRunnable);
    }

    public void cancelListen() {
        if (mListenContext != null) {
            mListenContext.cancel(null);
            mListenContext = null;
        }
    }
}

调用cancelListen()将模拟错误“CANCELLED”，连接将被关闭，并且onError您的StreamObserver<Message> messageStream将被调用并带有可抛出的消息：“CANCELLED”。

于 2017-05-29T07:23:45.117 回答
3

如果您使用shutdownNow()它，它将更积极地关闭您拥有的 RPC 流。此外，您需要致电shutdown()或shutdownNow()在致电之前致电awaitTermination()。

也就是说，更好的解决方案是在关闭通道之前优雅地结束所有 RPC。

于 2017-04-17T21:03:20.487 回答