干净地从客户端关闭GRPC-Java中的所有开放流

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了干净地从客户端关闭GRPC-Java中的所有开放流，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1718字，纯文字阅读大概需要3分钟。

内容图文

我正在使用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

解决方法:

如果要从客户端关闭gRPC(服务器端或双向)流,则必须使用程序包io.grpc中的Context.CancellableContext附加rpc调用.

假设你有一个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()将模拟错误,’CANCELED’,连接将关闭,以及StreamObserver的onError< Message>将使用throwable消息调用messageStream：’CANCELED’.

内容总结

以上是互联网集市为您收集整理的干净地从客户端关闭GRPC-Java中的所有开放流全部内容，希望文章能够帮你解决干净地从客户端关闭GRPC-Java中的所有开放流所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端