gPRC代理方式详细介绍

简介: gPRC代理方式详细介绍

🌷🍁 博主猫头虎 带您 Go to New World.✨🍁

🦄 博客首页——猫头虎的博客🎐

🐳《面试题大全专栏》 文章图文并茂🦕生动形象🦖简单易学!欢迎大家来踩踩~🌺

🌊 《IDEA开发秘籍专栏》学会IDEA常用操作,工作效率翻倍~💐

🌊 《100天精通Golang(基础入门篇)》学会Golang语言,畅玩云原生,走遍大小厂~💐

🪁🍁 希望本文能够给您带来一定的帮助🌸文章粗浅,敬请批评指正!🍁🐥



gPRC代理方式

在gRPC中,代理方式决定了客户端与服务端之间的通信模式。本文将详细介绍gRPC的三种主要代理方式:BlockingStub、Stub和FutureStub,并通过Java代码示例展示FutureStub的使用。

摘要

本文详细探讨了gRPC的三种主要代理方式:BlockingStub、Stub和FutureStub,并通过Java代码示例展示了FutureStub的实际应用。

导语

在分布式系统中,如何选择合适的通信模式是至关重要的。gRPC作为一个高性能、开源的RPC框架,为我们提供了多种代理方式。但是,这些代理方式有何不同,又该如何选择呢?

引言

“在分布式通信的大海中,代理方式就像是航向的指南针,指引我们选择最佳的通信路径。gRPC的多种代理方式为我们提供了丰富的选择,但每种方式都有其独特的应用场景。”

1. BlockingStub

阻塞通信方式:当使用BlockingStub进行通信时,客户端会等待服务端的响应。在此期间,客户端线程会被阻塞,直到收到响应或发生错误。

2. Stub

异步通信方式:与BlockingStub不同,Stub提供了非阻塞的通信方式。客户端不会等待服务端的响应,而是通过监听器处理服务端返回的消息。

3. FutureStub

同步异步通信方式:FutureStub结合了同步和异步的特点,它基于Netty的Future进行操作。值得注意的是,FutureStub只能应用于一元RPC。

FutureStub代码示例:

public class GrpcClient7 {
    public static void main(String[] args) {
        ManagedChannel managedChannel = ManagedChannelBuilder.forAddress("localhost", 9000).usePlaintext().build();
        try {
            TestServiceGrpc.TestServiceFutureStub testServiceFutureStub = TestServiceGrpc.newFutureStub(managedChannel);
            ListenableFuture<TestProto.TestResponse> responseListenableFuture = testServiceFutureStub.testSuns(TestProto.TestRequest.newBuilder().setName("xiaojren").build());
            /* 同步操作
            TestProto.TestResponse testResponse = responseListenableFuture.get();
            System.out.println(testResponse.getResult());*/
            /*  responseListenableFuture.addListener(() -> {
                System.out.println("异步的rpc响应 回来了....");
            }, Executors.newCachedThreadPool());*/
            Futures.addCallback(responseListenableFuture, new FutureCallback<TestProto.TestResponse>() {
                @Override
                public void onSuccess(TestProto.TestResponse result) {
                    System.out.println("result.getResult() = " + result.getResult());
                }
                @Override
                public void onFailure(Throwable t) {
                }
            }, Executors.newCachedThreadPool());
            System.out.println("后续的操作....");
            managedChannel.awaitTermination(12, TimeUnit.SECONDS);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            managedChannel.shutdown();
        }
    }
}

通过上述代码,我们可以看到如何使用FutureStub进行异步通信,并通过ListenableFuture和回调函数处理服务端的响应。

总之,gRPC提供了多种代理方式,以满足不同的通信需求。了解这些代理方式及其特点,可以帮助我们更好地设计和实现gRPC客户端。

几种代理方式对比

  • BlockingStub:这是一个阻塞通信方式,客户端在等待服务端响应时会被阻塞。适用于需要即时响应的场景。
  • Stub:提供了异步通信方式,客户端不会被阻塞,而是通过监听器处理返回的消息。适用于高并发、高响应的场景。
  • FutureStub:结合了同步和异步的特点,基于Netty的Future进行操作。尽管它提供了异步的能力,但只能应用于一元RPC。

总结

gRPC的代理方式为开发者提供了多种选择,但关键在于根据实际的应用场景选择最合适的方式。无论是需要即时响应的应用,还是高并发的系统,gRPC都能为我们提供稳定和高效的解决方案。

参考资料

  1. gRpc官方文档:https://grpc.io/docs/
  2. “Practical gRPC” by Joshua Humphries, David Konsumer, David Muto, and Robert Ross.
  3. “gRPC Up and Running” by Kasun Indrasiri and Danesh Kuruppu.


原创声明

======= ·

  • 原创作者: 猫头虎

作者wx: [ libin9iOak ]

学习 复习

本文为原创文章,版权归作者所有。未经许可,禁止转载、复制或引用。

作者保证信息真实可靠,但不对准确性和完整性承担责任

未经许可,禁止商业用途。

如有疑问或建议,请联系作者。

感谢您的支持与尊重。

点击下方名片,加入IT技术核心学习团队。一起探索科技的未来,共同成长。


目录
打赏
0
0
0
0
719
分享
相关文章
java版gRPC实战之四:客户端流
客户端流式RPC,适用于客户端提交大量数据到服务端的场景,一起来体验一下
1618 1
java版gRPC实战之四:客户端流
gRPC中interceptor拦截器的总结和实践
gRPC中的interceptor拦截器分为客户端拦截器和服务端拦截器,分别是在客户端和服务端的请求被发送出去之前进行处理的逻辑。常见的使用场景有:(1)请求日志记录及监控;(2)添加请求头数据、以便代理转发使用;(3)请求或者结果重写。
645 0
gRPC中interceptor拦截器的总结和实践
一文搞懂 Kafka consumer 与 broker 交互机制与原理
AutoMQ致力于打造下一代云原生Kafka系统,解决Kafka痛点。本文深入解析Kafka Consumer与Broker的交互机制,涉及消费者角色、核心组件及常用接口。消费者以group形式工作,包括leader和follower。交互流程涵盖FindCoordinator、JoinGroup、SyncGroup、拉取消息和退出过程。文章还探讨了broker的consumer group状态管理和rebalance原理。AutoMQ团队分享Kafka技术,感兴趣的话可以关注他们。
738 3
一文搞懂 Kafka consumer 与 broker 交互机制与原理
Spring Boot与Cassandra数据库的集成应用
Spring Boot与Cassandra数据库的集成应用
|
8月前
|
在Spring Boot中,可以通过控制`@PostConstruct`注解方法的执行顺序来实现初始化时的顺序控制
在Spring Boot中,可以通过控制`@PostConstruct`注解方法的执行顺序来实现初始化时的顺序控制
592 1
Apache Cassandra 内置及自定义数据类型
到目前为止,我们在使用 CQL 建表的时候使用到了一些数据类型,比如 text、timeuuid等。本文将介绍 Apache Cassandra 内置及自定义数据类型。和其他语言一样,CQL 也支持一系列灵活的数据类型,包括基本的数据类型,集合类型以及用户自定义数据类(User-Defined Types,UDTs)。
3584 0
Redisson官方文档 - 7. 分布式集合
Redisson在Redis基础上提供了一些列的分布式集合。
12444 0

热门文章

最新文章

AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等