如何取消GRPC流呼叫？
取消GRPC流呼叫可以通过以下步骤实现：
- 在客户端调用中，可以使用
cancel()方法来取消GRPC流呼叫。这个方法会发送一个取消信号给服务器端，告知其停止处理该请求。 - 在服务器端，可以通过监听
context.Context对象的Done()方法来检测是否有取消信号。当客户端调用cancel()方法后，Done()方法会返回一个已关闭的通道，表示取消信号已经发出。 - 在服务器端的处理逻辑中，可以通过检测
Done()方法返回的通道来判断是否需要取消处理。一旦检测到取消信号，可以及时停止处理并返回相应的结果。 - 在客户端，可以在调用GRPC流呼叫的代码中添加错误处理逻辑，以处理取消信号引起的异常情况。
总结起来，取消GRPC流呼叫的步骤包括在客户端调用中使用cancel()方法发送取消信号，服务器端监听context.Context对象的Done()方法来检测取消信号，及时停止处理并返回结果。在客户端的代码中添加错误处理逻辑，以应对取消信号引起的异常情况。
腾讯云提供了一系列与GRPC相关的产品和服务，例如腾讯云容器服务（TKE）可以用于部署和管理GRPC应用，腾讯云负载均衡（CLB）可以用于实现负载均衡和流量控制等功能。您可以访问腾讯云官网了解更多关于这些产品的详细信息和使用指南。
参考链接：
相关·内容
我正在使用这个的代码来创建我的GRPC异步服务器：
#include <memory>
#include <iostream>
#include <string>
#include <thread>
#include <grpcpp/grpcpp.h>
#include <grpc/support/log.h>
#ifdef BAZEL_BUILD
#include "examples/protos/helloworld.grpc.pb.h"
#else
#include "helloworld
浏览 13提问于2020-10-10得票数 1
我正在学习android的gRPC，java是客户端，Node js是服务器端。现在，我想创建一个视频呼叫应用程序。我应该使用gRPC或其他框架来完成此任务吗？如果没有，你能给我另一个建议吗？谢谢
浏览 0提问于2020-05-29得票数 1
1回答
我有这个简单的代码来从谷歌PubSub订阅中提取消息： #include "google/pubsub/v1/pubsub.grpc.pb.h"
#include "google/pubsub/v1/pubsub.pb.h"
#include "grpc++/grpc++.h"
#include "base/logging.h"
int main() {
auto creds = grpc::GoogleDefaultCredentials();
auto stub = std::make_unique<goo
浏览 9提问于2020-07-17得票数 0
使用Python gRPC，当设置了threading.Event时，我希望能够取消来自客户端的长时间运行的一元流调用。 def application(stub: StreamsStub, event: threading.Event):
stream = stub.Application(ApplicationStreamRequest())
try:
for resp in stream:
print(resp)
except grpc.RpcError as e:
print(e) 目前，我使用chann
浏览 27提问于2019-03-14得票数 0
1回答
我使用Node.js连接到使用执行长时间运行任务的服务器。
在作业进行期间，服务器向客户端( Node.js应用程序)发送单向流。我需要实现一个停止按钮，并被告知关闭将停止正在进行的工作。
这是我目前的代码：
let express = require('express'),
router = express.Router(),
grpc = require('grpc'),
srv = grpc.load(__dirname + '/job_handler.proto').ns;
let startJob = (job
浏览 3提问于2015-12-04得票数 2
回答已采纳
我正在gRPC流上的python线程中侦听，这个线程永远不会结束：
responses = some_grpc_stub.FunctionThatReturnsStream()
for response in responses:
on_event(response)
我想要这样做一段时间，然后停止监听，这样on_event就不会再次被调用，可能在流完成之前。
我该怎么做？是否有一种正确的方法只需关闭运行此循环的线程？或者是否有办法使responses结束过早，这样迭代结束，线程就可以运行到完成？
浏览 10提问于2022-05-11得票数 1
回答已采纳
“对文本的演讲”在一段时间后抛出一个错误：
Grpc.Core.RpcException: Status(StatusCode=OutOfRange，Detail=“音频超时错误:没有音频的持续时间很长。音频应该接近实时发送”)。
另一个错误是：
Grpc.Core.RpcException: Status(StatusCode=Cancelled，Detail=“操作被取消”)
如何避免这些错误？这两个错误都在起作用：
if (firstMessage == false) {
// var buffer = new byte[32 * 1024];
var b
浏览 0提问于2019-07-10得票数 6
当多个客户端同时向GRPC服务器发出相同的呼叫时，服务器是否异步应答这些呼叫？如果我想让服务器同步处理调用，我是否应该使用某种锁，比如AsyncSemaphore？使用这种模式，在GRPC取消呼叫或客户端断开连接之前，我可以“保留”正在进行的呼叫(例如，两个客户端同时发出相同的呼叫，其中一个阻塞，直到第一个客户端的呼叫被应答)？GRPC在这方面有关键的超时吗？
浏览 6提问于2017-09-08得票数 1
我正在通过gRPC cpp示例来尝试学习。在调试流示例时，我注意到服务器上对grpc_impl::ServerReaderWriter::Read的调用会一直阻塞，直到另一端写入或流结束。 我们应该如何使服务器足够健壮，使其能够处理客户端在发送初始消息后挂起或忘记关闭流？ 也许它会调用RPC并向我发送三条消息，但永远不会关闭。似乎不存在此调用的超时版本。 在这种情况下，不是所有客户端的整个通信线程都被阻塞了吗？
浏览 121提问于2020-10-21得票数 0
回答已采纳
1回答
grpc流到底是如何在反向代理上工作的？我的理解是，将在客户端和反向代理之间建立持久连接，而反向代理和我的服务器之间的连接不是持久的--那么，坐在反向代理后面的实际服务器如何继续通过持久化连接向客户端发送消息呢？
另外，假设我希望保持持久连接来处理推送通知(也就是说，我的服务器跟踪持久连接，在我的服务器端发生了一些事情，我想通知一个特定的客户端，我得到那个特定客户端的流/持久连接，然后通过它发送一条消息)。
浏览 1提问于2020-04-01得票数 3
回答已采纳
在gRPC的Node.js版本(grpc-js)中，是如何实现的？
对于Go实现(grpc-go)，逻辑主要在 (flowcontrol.go，bdp_estimator.go)中；同时，它被描述为。然而，我找不到任何关于grpc-js的东西。
我主要感兴趣的是Node.js接收器何时发送WINDOW_UPDATE帧。
浏览 17提问于2021-02-13得票数 0
我注意到grpc支持最后期限设置。
auto deadline = std::chrono::system_clock::now() + std::chrono::seconds(timeout_sec);
context->set_deadline(deadline);
但是对于下面的代码
// context_ and stream_ has already been created beforehand.
UpdateClientDeadline(context_.get(), timeout_sec);
stream_->Read(response);
最后期限在这里行不通
浏览 17提问于2022-11-27得票数 1
2回答
在写之前关闭了Grpc流
、、、
我有一个应用程序，根据客户端的请求，通过GRPC从数据库中流数据。
当客户端在流完成之前关闭时。这个错误正在日志中抛出，但我不知道如何捕获它以关闭底层数据库连接，从而导致db连接泄漏。
我正在使用Java和grpc版本1.23.0。
try {
... events is a stream retrieved from DB
StreamObservers.copyWithFlowControl(response, new StreamObserverWithCallbacks<>(
responseObserve
浏览 0提问于2019-08-27得票数 0
回答已采纳
2回答
让我们假设我们为gRPC开发了一个自定义的低级传输。我们如何才能将其“插入”到gRPC c++应用程序接口中，以便我们可以将其用于通道？
浏览 1提问于2017-11-06得票数 6
2回答
我试图定义一个gRPC服务，其中客户端可以订阅接收广播消息，他们也可以发送消息。
syntax = "proto3";
package Messenger;
service MessengerService {
rpc SubscribeForMessages(User) returns (stream Message) {}
rpc SendMessage(Message) returns (Close) {}
}
message User {
string displayName = 1;
}
message Message {
Us
浏览 11提问于2020-06-17得票数 7
回答已采纳
1回答
grpc低层遥测测井
、、、、
我试图在较低的级别上度量我的服务的延迟。环顾四周，我发现可以向grpc构建器添加一个addStreamTracerFactory。
我完成了这样一个简单的实现，并打印了日志：
val server = io.grpc.netty.NettyServerBuilder.forPort(ApplicationConfig.Service.bindPort).addStreamTracerFactory(ServerStreamTracerFactory)....
class Telemetry(fullMethodName: String, headers: Metadata) extends
浏览 1提问于2019-04-03得票数 0
回答已采纳
2回答
我试图了解Go上下文取消在客户端服务通信(例如，任何gRPC API调用)下的工作方式。
假设客户端取消了上下文。这是否会导致向服务器发出新的HTTP请求，从而取消上一个/正在进行的gRPC请求的上下文通信？服务器如何知道客户端是否取消了上下文？
浏览 13提问于2022-10-21得票数 1
回答已采纳
1回答
我有一个像这样运行的gRPC服务：
server.addService(PassportService, implementation);
server.bind(mfeConfig().grpc.passport, grpc.ServerCredentials.createInsecure());
server.start();
我可以从客户那里打电话给我：
const request = new GetConsoleUserRequest();
const meta = new grpc.Metadata();
meta.add('__.grpc.exchanged-token&#
浏览 6提问于2020-03-03得票数 0
回答已采纳
1回答
在我看来，内置的对gRPC的取消支持在以下意义上是相当激进的:如果我在客户端调用取消，通信通道就会立即关闭。服务器会得到通知，并且可以进行清理工作，但是在清理完成后，似乎没有机会通知客户端。
如果我想要下面的“软取消”行为，我该怎么办？
cancellationServer接收取消请求并启动清理服务器，并关闭通信通道客户端被告知取消过程已完成
可以使用请求流和oneof关键字实现此行为：
service ServiceName{
rpc Communicate (stream Request) returns (Response);
}
message Request {
o
浏览 18提问于2022-02-12得票数 1
回答已采纳
1回答
我在RPC文档中看到了以下4种类型的grpc：
- rpc SayHello(HelloRequest) returns (HelloResponse) {...}
- rpc LotsOfReplies(HelloRequest) returns (stream HelloResponse) {...}
- rpc LotsOfGreetings(stream HelloRequest) returns (HelloResponse) {...}
- rpc BidiHello(stream HelloRequest) returns (stream HelloResponse) {
浏览 0提问于2019-05-28得票数 2
1回答
目前，我正在学习gRPC，所有的东西都感觉像一堆我努力拼凑起来的时髦词汇。
我理解gRPC使用proto缓冲区，但是它们与普通的JSON配置有什么不同呢？
浏览 2提问于2022-12-01得票数 0
回答已采纳
我使用的是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.SECON
浏览 0提问于2017-04-14得票数 9
我正在创建Android应用程序，它使用gRPC与服务器进行通信。我几乎没有什么服务方法。使用简单的rpc方法进行通信没有问题，但是我对bidirectional streaming有问题。
我收到一条消息ServerToClient，然后收到错误：io.grpc.StatusRuntimeException: CANCELLED: Cancelled
这是我的服务：
service CommunicationGateway {
[...]
rpc CommunicationChannel(stream ClientToServer) returns (stream Serve
浏览 0提问于2018-09-13得票数 0
回答已采纳
我正在尝试编写一个python客户端来终止gRPC流
原件：
rpc Start (StartParameters) returns (stream Progress) {}
在客户端中，当我准备终止流时，我尝试调用stream.cancel()，然后当我打印捕获的流的事件时，它不打印事件。我看到了例外
<_Rendezvous of RPC that terminated with:
status = StatusCode.CANCELLED
details = "Locally cancelled by application!"
debug_
浏览 41提问于2019-07-16得票数 0
回答已采纳
1回答
我编写了一个客户机，它启动到grpc服务器的多个连接来请求一些东西。一旦收到回复，我想停止所有其他的grpc调用。我使用一个事件来控制这个过程。
但是，我不知道如何优雅地终止grpc调用。以下是我所做的。代码将导致错误:打开的文件太多。有人能帮我吗？如何优雅地终止grpc调用？
def request_something(event):
with grpc.insecure_channel(ip) as channel:
stub = GrpcServiceStub(channel)
req = Request()
response_fu
浏览 4提问于2022-11-10得票数 0
我正在尝试使用grpc来实现pub sub模式，但是我对如何正确地这样做感到有点困惑。
我的原型：rpc call (google.protobuf.Empty) returns (stream Data);
客户端：
asynStub.call(Empty.getDefaultInstance(), new StreamObserver<Data>() {
@Override
public void onNext(Data value) {
// process a data
@Override
浏览 0提问于2019-03-01得票数 8
回答已采纳
2回答
将服务重定向到双向grpc
、、、、
我目前正在开发一个grpc服务器，它将接收来自第一个服务器的流grpc调用，并将这些调用重定向到第二个服务器，并将响应从第二个服务器重定向到第一个服务器。
我有两个proto文件
第一个文件：
syntax = "proto3";
package first.proto.pack;
service FirstProtoService {
rpc StreamingCall(stream RequestToFirstServer) returns (stream ResponseForFirstServer){}
}
message RequestToFirstServ
浏览 10提问于2021-10-06得票数 2
回答已采纳
在调用gRPC方法时，我偶尔会收到取消错误。
下面是我的客户端代码(使用grpc-java 1.22.0库)：
public class MyClient {
private static final Logger logger = LoggerFactory.getLogger(MyClient.class);
private ManagedChannel channel;
private FooGrpc.FooStub fooStub;
private final StreamObserver<Empty> responseObserver
浏览 2提问于2019-07-19得票数 12
回答已采纳
由于所有的StreamObserver (CallStreamObserver，ServerCallStreamObserver)类都被标记为实验性，那么通过向服务器发送停止发送消息的信号，允许客户端优雅地取消流媒体服务的稳定方法是什么？
另外，如果我决定使用这些类来实现这个功能，我是否可以假设，除非我升级了grpc版本，否则我会没事吗？
浏览 1提问于2018-10-03得票数 3
回答已采纳
2回答
我正在学习用gRPC实现node.js的东西。我读到gRPC和微服务间的通信是很好的结合。
gRPC在微服务间通信环境中解决不了REST的问题是什么？
为什么要使用gRPC进行微业务间的通信？
浏览 6提问于2021-07-13得票数 1
我指的是以下节点-grpc客户端示例：
//create a client
var client = new hello_proto.Greeter('localhost:50051',
grpc.credentials.createInsecure());
//issue the call
client.sayHello({name: user}, function(err, response) {
console.log('Greeting:', response.m
浏览 4提问于2017-10-05得票数 1
回答已采纳
是否可以使用使两台远程主机之间的所有呼叫都使用在gRPC外部建立的TCP连接？我还想确定这个TCP连接是否可以为多个gRPC调用进行多路复用，这些调用可以是双向的，并且gRPC不会关闭套接字。
其目的是当gRPC的两端跨越防火墙时能够使用gRPC。防火墙只允许建立从防火墙内部发起的单个TCP连接。
对于这些需求，只有C++和Java实现可以在任何一方。
浏览 36提问于2016-09-24得票数 0
2回答
gRPC的Go库提供了创建您自己的自定义拦截器(即中间件函数)的接口，我正在尝试编写两个日志拦截器。第一个是Unary Server Interceptor，我可以使用传入拦截器函数的对象轻松地记录请求参数。
func loggingUnary(context context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {
start := time.Now()
resp, err := handler(context,
浏览 1提问于2018-06-26得票数 4
我正在使用go-grpc创建双向流。当我拔下电缆时，服务器在很长一段时间内都不知道客户端死机了。在这种情况下，我如何检测客户端已不在？
浏览 2提问于2017-12-21得票数 2
回答已采纳
我有一个gRPC服务器，其主要内容如下：
syntax = "proto3";
service MyServicer {
rpc DoSomething(stream InputBigData) returns (stream OutputBigData) {}
}
message InputBigData {
bytes data = 1;
}
message OutputBigData {
bytes data = 1;
}
我的服务器是用以下Python代码创建的：
server = grpc.server(futures.ThreadPoolExe
浏览 2提问于2020-09-24得票数 1
1回答
我有一个一元拦截器，它包含以下代码：
func (m Middlewares) LocationInterceptor(c context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {
ctx := c.(HarmonyContext)
location, ok := req.(interface{ GetLocation() *corev1.Location })
if !ok {
panic
浏览 1提问于2020-08-17得票数 3
1回答
在“google.golang.org/ grpc /code”中引入了一些错误，一些错误可以由grpc生成，有些不能生成，grpc流应该对应于http2.0中的流。然后，我想知道这是否意味着当那些grpc流抛出异常时TCP连接有错误，所以我只需要重新连接TCP连接，还是我有一些只用于重新连接流的方法(例如重新连接流，等等)。
for {
request, err3 := stream.Recv()
if err3 == io.EOF {
return nil
}
if err3 != nil {
浏览 3提问于2022-07-28得票数 0
回答已采纳
我有两个微服务，即ProductService和BillingService。两者都是用.Net核心web项目编写的。
1. Product service has an endpoint like : httpget- v1/product/bed/b1
2. BillingService has an endpoint like: httpget - v1/billing/b1
产品服务将作为回报，通过httpget -v1/b1/b1呼叫计费服务，以获取价格细节。现在，他们都在讨论http1 / rest表示。
我的要求是让他们通过gRPC在.Net核心上进行通信(产品通话和计费)。
浏览 12提问于2022-03-30得票数 0
1回答
我的messages.proto文件中有以下模式：
message Person {
string id = 1;
string first_name = 2;
string last_name = 3;
string email = 4;
string alias = 5;
}
//CREATE, DELETE, UPDATE RESPONSES AND REQUESTS Messages
message ListPersonsRequest {
ListOptions options = 1;
}
message ListPersonsResponse {
浏览 12提问于2022-11-04得票数 1
回答已采纳
1回答
我是Grpc呼叫的新手。
目前，我正在使用Grpc.Core创建一个"Channel“的新实例。请参阅下面的代码。
Channel channel = new Channel("127.0.0.1:50051", ChannelCredentials.Insecure);
现在，我想在创建通道时添加一个连接超时。这对Grpc.Core来说是可能的吗？
我知道可以使用“Grpc.Net.Client”添加选项。然而，它只适用于.Net Core2.1，而我的项目并不针对该框架。
浏览 41提问于2021-05-25得票数 1
1回答
我正在尝试在用户离开视图时立即将Twillio呼叫置于保留状态，无论是由用户还是由任何中断(如接通另一个呼叫)。 func addObservers() {
NotificationCenter.default.addObserver(self,
selector: #selector(applicationDidBecomeActive),
name: UIApplicatio
浏览 15提问于2020-06-29得票数 0
回答已采纳
我们有一个自定义的ServerInterceptor，用于记录我们的grpc服务器接收到的每个调用。它将传递给next::startCall的next::startCall封装为一个SimpleForwardingServerCall，该SimpleForwardingServerCall覆盖close(Status,Metadata)，用于记录调用的状态并跟踪interceptCall和close之间的总时间。我们预期这会导致日志记录状态和跟踪每个接收到的呼叫所用的时间。
我们发现了一种情况，即我们的拦截器登录到了interceptCall的主体中，然后内部拦截器在其interceptCal
浏览 1提问于2017-10-30得票数 2
回答已采纳
1回答
当我查看服务器调用的grpc自动生成类和grpc中给出的示例示例时，我可以看到我们扩展了ImplBase类并覆盖了服务方法。如下所示：
static class communicationImpl extends communicationImplBase
在C++中，为了实现异步服务，我们使用AsyncService而不是服务类扩展我们的实现。但是在java生成的Grpc类中，我看不到另一个名为/以异步开头的类。我在其中看到的唯一与服务器相关的类是以ImplBase结尾的类。那么，如何设置服务器，以便在grpc中异步处理请求？
浏览 0提问于2017-03-24得票数 3
回答已采纳
我正在运行一个示例管道，我的环境是这样的。 python "SaiStudy - Apache-Beam-Spark.py“--runner=PortableRunner --job_endpoint=192.168.99.102:8099 我的Spark在Docker Container上运行，我可以看到JobService正在以8099的速度运行。 我收到以下错误: grpc._channel._MultiThreadedRendezvous:已终止的RPC的状态：<_MultiThreadedRendezvous = StatusCode.UNAVAILABLE deta
浏览 16提问于2020-10-24得票数 0
我正在nodejs中实现一个grpc服务器。grpc很棒。我想知道是否可以从grpc服务器向客户端发送消息(不是请求/响应)？ 我知道我们在全双工的grpc中有双向通信。这意味着这是我们在socket.io(websocket)中拥有的类似功能。我们如何将消息推送到单个客户端？有可能追踪到grpc客户端吗？或者更好的是，得到一个心跳？
浏览 194提问于2021-01-23得票数 0
我的项目(在golang中)有一个用例，在这个用例中，我需要打开从单个GRPC客户端到单个/多个GRPC服务器的几个流。
说我的原始文件是-
syntax = "proto3";
package helloworld;
// The greeting service definition.
service Greeter {
// Sends a greeting
rpc SayHello (stream HelloRequest) returns (stream HelloReply) {}
}
// The request message containing
浏览 1提问于2021-06-21得票数 1
1回答
如果我的Go stream双向流服务器无限地在上循环，当我的客户的 gRPC 超出范围并获得GC‘s？时，如何关闭连接？
假设我使用Go来执行gRPC双向流调用：
syntax = "proto3";
package mystical;
service Unicorn {
rpc RainbowStream(stream Rainbow) returns (stream Rainbow);
}
我有一个服务器实现，我将在我的gRPC服务器注册：
type Server struct {}
func (serv *Server) RainbowStream(str
浏览 0提问于2018-06-10得票数 3
回答已采纳
1回答
因此，我用命令peer channel create -f config/allarewelcome.tx -o orderer.example.com:7050 -c allarewelcome创建了一个使用cli容器的通道，并得到了这些消息。该频道最终被创建，如你所见，但我想知道发生了什么。有谁有主意吗？
已初始化 UTC channelCmd InitCmdFactory -> INFO 001背书机和订货机连接
UTC cli.common readBlock -> INFO 002获得状态：&{SERVICE_UNAVAILABLE}
UTC channelCmd
浏览 4提问于2020-01-08得票数 0
当我们创建一个managedChannelBuilder并使用它调用一个grpc服务调用时，我们可以使用它服务多少个客户端？这个频道不是在单独的服务呼叫之后关机吗？假设我有一个REST接口，它可以从浏览器和这些REST服务方法中接受REST调用，我正在对一个独立的grpc服务器进行grpc客户端调用。同时，我可以期望客户端连接在4000到5000之间。我能如何利用这个managedChannelBuilder。我只需要一个吗？还是我需要汇集多个通道建设者？
浏览 3提问于2017-03-30得票数 4
回答已采纳
Grpc.Core 2.38.0
我有一组应用程序参与使用grpc流进行进程间通信。我们不时地注意到服务器进程中的锁定和内存耗尽(由于锁)无法完成对IAsyncStreamWriter.WriteAsync(...)的调用
最近对grpc (.net)的更改已经将WriteAsync API更改为接受CancellationToken，但是在Grpc.Core包中不能使用。
浏览 8提问于2022-06-17得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
