Java中的gRPC -阻塞/非阻塞存根
gRPC是一种高性能、开源的远程过程调用（RPC）框架，它可以在Java中使用。gRPC基于Google开发的Protocol Buffers（简称protobuf）进行数据序列化和通信，提供了简单、高效、跨语言的服务定义和通信能力。
阻塞/非阻塞存根是gRPC中的两种不同的调用方式。
- 阻塞存根（Blocking Stub）： 阻塞存根是一种同步的调用方式，客户端发起调用后会一直等待服务器返回结果，直到结果返回或超时。在阻塞存根中，客户端调用方法后会被阻塞，直到服务器返回结果或发生错误。这种方式适用于对实时性要求不高的场景，可以简化代码逻辑。
- 非阻塞存根（Non-blocking Stub）： 非阻塞存根是一种异步的调用方式，客户端发起调用后不会等待服务器返回结果，而是立即返回一个Future对象，可以通过该对象获取调用结果。在非阻塞存根中，客户端可以继续执行其他操作，不需要等待服务器返回结果。这种方式适用于对实时性要求较高的场景，可以提高系统的并发性能。
gRPC的阻塞/非阻塞存根可以根据具体的业务需求选择使用。在Java中，可以使用gRPC提供的代码生成工具根据.proto文件生成对应的存根代码，并根据需要选择阻塞或非阻塞的调用方式。
推荐的腾讯云相关产品： 腾讯云提供了云原生应用开发和部署的解决方案，可以使用腾讯云容器服务（Tencent Kubernetes Engine，TKE）来部署和管理gRPC服务。TKE是一种高度可扩展的容器管理服务，支持自动化部署、弹性伸缩和高可用性。您可以通过以下链接了解更多关于腾讯云容器服务的信息： https://cloud.tencent.com/product/tke
此外，腾讯云还提供了云原生应用开发的Serverless解决方案，可以使用腾讯云函数计算（Tencent Cloud Serverless Cloud Function，SCF）来构建和部署gRPC服务。SCF是一种无服务器计算服务，可以根据实际请求进行自动扩缩容，并且只需按实际使用量付费。您可以通过以下链接了解更多关于腾讯云函数计算的信息： https://cloud.tencent.com/product/scf
相关·内容
2回答
我正在尝试创建一个java grpc客户端来与go中的服务器进行通信。我是grpc的新手，所以我正在学习本教程。在这些示例中，它们指的是阻塞和非阻塞存根，它们似乎是从中的其他地方导入的。import io.grpc.examples.routeguide.RouteGuideGrpc.RouteGuideBlockingStub;
import
浏览 60提问于2017-07-28得票数 8
回答已采纳
2回答
我想知道是否有人尝试过使用if来测试gRPC应用程序。我希望
BeanShell采样器中Java方法的应用每个线程会创建一个单独的TCP连接吗？我们已经在python和locust.io
浏览 5提问于2017-03-25得票数 8
回答已采纳
1回答
我们目前正在使用grpc启动包实现一个高吞吐量的春季引导应用程序，这是一个基于客户端服务器的应用程序。我们正在将遗留的REST端点CRUD操作迁移到GRPC。为了获得这项服务的最佳设计，我们需要以下问题的帮助：
如果一个不可变的GRPC阻塞存根客户端实例被多个线程访问，这是否是一个阻塞调用，即在任何给定时间只执行一个RPC调用。根据google文档，建议不要使用阻塞</em
浏览 5提问于2022-02-14得票数 2
1回答
我在java应用程序中使用gRPC (无阻塞存根)，两个函数调用之间的响应时间约为5-8ms。我想把它降下来。你有什么建议？有可能吗？
浏览 0提问于2018-12-13得票数 2
回答已采纳
我想让客户端的流媒体阻塞。该协议的定义可以如下所示：
那么，如何使调用阻塞/同步呢？有可能吗？
浏览 17提问于2020-07-13得票数 4
回答已采纳
我想我可能对gRPC通道、存根和传输的工作原理不太了解。我有一个Android应用程序，它创建一个通道和一个单一的阻塞存根，并在应用程序初始化时将其注入dagger。当我需要进行grpc调用时，我的客户机中有一个方法，它调用具有该存根的方法。在应用程序空闲一段时间后，我的所有调用都会返回DEADLINE_EXCEEDED错误，尽管服务器日志中没有显示任何调用。.withDeadli
浏览 124提问于2019-01-17得票数 1
1回答
问题的标题可能没有那么详细，因为我正在尝试实现混合的功能。我希望根据调用者发送的标头对调用者进行授权，并将此信息传播到gRPC方法处理程序。问题出在授权过程的异步本质上。RespT]): ServerCall.Listener[ReqT] = private val stash = new java.util.concurrent.ConcurrentLinkedQueueRight(BOTID_CONT
浏览 6提问于2017-05-05得票数 9
1回答
gRPC:创建阻塞存根或未来存根
、、、、
最近，我正在研究如何构建gRPC客户端与服务器的交互。我写了一个gRPC服务：然后我应该使用存根(另一个java应用程序)在客户端调用它。这两种类型的存根有什么不同？中是如何工作的，但是我不知道gRPC内部发生了什么，以及哪种类型的存根</
浏览 12提问于2018-01-24得票数 3
回答已采纳
我有一个用maven protoc插件0.4.2和grpc版本0.8.0编译的grpc服务代码。我试图在datafflow 1.4.0中使用这个生成的代码，但是当我尝试使用阻塞存根创建grpc客户端时，我得到了这个错误。(Pipeline.java:186)
浏览 1提问于2016-03-04得票数 1
1回答
阅读这篇关于在quarkus https://quarkus.io/guides/grpc-service-consumption中使用gRPC服务的博客 通过运行“mvn compile”，已成功从api提供程序提供的proto文件生成代码。但在尝试构建应用程序时出现错误 “只有基于Mutiny和io.grpc.Channel的Mutiny服务接口、阻塞存根、反应式存根可以通过@GrpcCli
浏览 57提问于2021-10-04得票数 0
1回答
我正在用Kotlin编写一个客户端应用程序，在该应用程序中，我需要调用一个GRPC服务，该服务具有基于未来的和阻塞的存根。如果我选择使用未来的选项，我将需要在某个时候做一些类似于CompletableFuture.get()调用的事情，这意味着我无论如何都会阻塞。
那么，这个案子中的一个和另一个有什么区别？还是一样的？
浏览 7提问于2022-11-23得票数 1
回答已采纳
我正在尝试开发一个使用grpc阻塞存根连接到后端服务器的应用程序。 public LoginDataSource() {
public Result<LoggedInUser> login(Str
浏览 56提问于2020-05-18得票数 0
1回答
协议缓冲区不会生成服务存根
、、、、
我在GRPC中从我的.proto文件生成存根时遇到了一些问题。containing the greetings string message = 1;该文件确实会生成协议缓冲区代码，但我没有从中获得任何服务存根也就是说，我不能使用阻塞存根。
我尝试使用"java_multiple_files=true“修复，但这只是将生成的原型文件拆分为几个单独的原型
浏览 10提问于2016-07-21得票数 5
回答已采纳
我正在尝试用java GRPC客户端(netty和okhttp)连接go服务器。但是它们都是不可用的: io异常间歇性地抛出。public SomeServiceGrpc.SomeServiceBlockingStub getBlockingStub() {
return SomeServiceGrpc.new
浏览 97提问于2019-10-21得票数 3
回答已采纳
1回答
我有一个方法startServer()，它可以启动一个简单的cpp grpc服务器。
我想让server->Wait()调用是非阻塞的，而不需要处理维护完成队列或处理RPC调用的额外开销。我深入研究了grpc服务器的异步风格，但没有找到任何简单的示例来在不增加任何额外开销的情况下做到这一点。除了在单独的线程上运行这个函数之外，有没有什么简单的方法可以让这个函数成为非阻
浏览 3提问于2020-04-21得票数 0
我在GRPC文档中找不到关于这个的任何东西。GRPC期望我的StreamObserver.onNext()实现是非阻塞的吗？如果GRPC确实阻塞(例如拒绝新请求、排队等待新请求等)，它对GRPC有什么影响？
浏览 0提问于2018-12-04得票数 0
回答已采纳
我有一个grpc客户端应用程序，它可能会经常阻塞，这会导致它在一段时间内无法调用grpc Recv函数。在这种情况下，grpc服务器上的行为是什么？grpc服务器的Send调用会阻塞吗？在客户端调用Recv之前它会阻塞吗？
浏览 0提问于2020-04-30得票数 0
我在使用转换后的协议缓冲区消息到Spring引导微服务时遇到了问题。 我尝试在Rest控制器中使用以下语句，但不起作用。
浏览 39提问于2020-10-19得票数 2
1回答
我正在尝试从我的Android应用程序中用TLS访问一个定制的GRPC服务器(Anki机器人)。之后，我创建一个请求消息并用存
浏览 0提问于2019-02-09得票数 0
回答已采纳
它是关于gRPC服务器编程模型的。为了最大化gRPC服务器吞吐量，gRPC服务器需要将接收到的请求委托给非GRPC线程，并为每个请求提供一个回调。当非GRPC线程完成任务时，它们通知gRPC服务器通过为这些异步处理的请求调用配备好的回调来响应gRPC客户机。这对于grpc是可能的吗？我注意到回调机制有一个实验性的</em
浏览 42提问于2020-05-21得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
