gRPC流被取消
gRPC是一种高性能、开源的远程过程调用（RPC）框架，它可以在客户端和服务器之间进行快速、高效的通信。gRPC使用Protocol Buffers作为接口定义语言（IDL），可以定义服务和消息的结构，并生成相应的代码。
gRPC流被取消是指在gRPC通信过程中，由于某种原因，流的传输被取消或中断。这可能是由于网络故障、连接中断、客户端或服务器异常等原因引起的。
在gRPC中，流可以分为两种类型：单向流和双向流。单向流只允许一方向另一方发送消息，而双向流允许双方同时发送和接收消息。
当gRPC流被取消时，可以采取以下措施来处理：
- 重试机制：可以在流被取消后尝试重新建立连接，并重新发送数据。这可以通过设置重试策略和超时时间来实现。
- 错误处理：可以根据具体的错误类型进行相应的处理。例如，如果是网络故障导致的取消，可以尝试重新连接或通知用户重新尝试。
- 日志记录：在流被取消时，可以记录相关的错误信息和上下文，以便进行故障排除和分析。
- 异常处理：可以在代码中捕获流被取消的异常，并根据需要进行相应的处理，例如回滚事务或通知相关方。
对于gRPC流被取消的处理，腾讯云提供了一系列相关产品和服务，例如：
- 腾讯云容器服务（Tencent Kubernetes Engine，TKE）：提供高可用、弹性伸缩的容器集群，可以用于部署和管理gRPC服务。
- 腾讯云负载均衡（Tencent Cloud Load Balancer，CLB）：提供流量分发和负载均衡的服务，可以将请求均匀地分发给后端的gRPC服务。
- 腾讯云云原生数据库TDSQL：提供高可用、可扩展的数据库服务，可以用于存储和管理gRPC服务的数据。
- 腾讯云云函数（Tencent Cloud Function，SCF）：提供无服务器的计算服务，可以用于处理和响应gRPC请求。
更多关于腾讯云相关产品和服务的详细信息，请参考腾讯云官方网站：腾讯云。
相关·内容
“对文本的演讲”在一段时间后抛出一个错误：
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
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
我正在使用这个的代码来创建我的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
我正在gRPC流上的python线程中侦听，这个线程永远不会结束：
responses = some_grpc_stub.FunctionThatReturnsStream()
for response in responses:
on_event(response)
我想要这样做一段时间，然后停止监听，这样on_event就不会再次被调用，可能在流完成之前。
我该怎么做？是否有一种正确的方法只需关闭运行此循环的线程？或者是否有办法使responses结束过早，这样迭代结束，线程就可以运行到完成？
浏览 10提问于2022-05-11得票数 1
回答已采纳
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
回答已采纳
使用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回答
目前，我正在学习gRPC，所有的东西都感觉像一堆我努力拼凑起来的时髦词汇。
我理解gRPC使用proto缓冲区，但是它们与普通的JSON配置有什么不同呢？
浏览 2提问于2022-12-01得票数 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
回答已采纳
1回答
我正在尝试从某个GRPC服务器接收流，其中的代码对我来说是不可访问的。
下面是我的GRPC客户端的代码：
class Client():
def __init__ (self, grpcIP, grpcPort, params):
self.channel = grpc.insecure_channel('%s:%d' % (grpcIP, grpcPort))
grpc.channel_ready_future(self.channel).result()
self.stub = pb2_grpc.DataCloneSt
浏览 1提问于2019-02-26得票数 0
关于zio-grpc双流关闭调用的咨询:何时关闭？我正在使用grpcurl来测试bistream，但是zio-grpc服务器端不会太快地关闭(过一段时间就会关闭)。
我正在通过Stream.ensuring观看grpc服务器端流关闭事件。详情如下：
请求流的：通过forkDomaen在光纤中使用请求流:我假设如果流关闭，grpc请求流将被关闭。
request
.mapM { reqItem =>
// do action here
UIO(println(s"test get some data from request item: ${
浏览 13提问于2022-10-17得票数 0
回答已采纳
我在.NET中使用GRPC创建了一个简单的容器来上传文件，容器在我的本地机器上工作得很好，并且远程地由Nginx服务器代理。在部署容器时，我可以顺利地将文件流到服务器。然而，当我等待答复时：
var response = await stream.ResponseAsync;
我得到以下例外：
异常: HTTP/2服务器重置流。HTTP/2错误代码'INTERNAL_ERROR‘(0x2)."，DebugException="System.IO.IOException:请求被中止。-> System.Net.Http.Http2StreamException: H
浏览 5提问于2021-10-16得票数 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
我在C#中使用gRPC，并不断组合两个CancellationToken并将其传递给gRPC服务器:1是我的“全局”取消令牌(例如，如果用户点击了“取消”按钮)，第二个是处理我的超时。我看到gRPC还有一个deadline选项，我可以将其提供给每个调用。我想知道我是否仍然可以简单地在服务器上使用CancellationToken？截止日期后会被取消吗？或者我应该将它与服务器上调用的每个方法中的deadline变量结合使用？
这将允许我这样做：
await client.MethodAsync( parametersHere,
cancellationToken: GlobalCanc
浏览 29提问于2019-11-06得票数 0
回答已采纳
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
回答已采纳
我正在通过gRPC cpp示例来尝试学习。在调试流示例时，我注意到服务器上对grpc_impl::ServerReaderWriter::Read的调用会一直阻塞，直到另一端写入或流结束。 我们应该如何使服务器足够健壮，使其能够处理客户端在发送初始消息后挂起或忘记关闭流？ 也许它会调用RPC并向我发送三条消息，但永远不会关闭。似乎不存在此调用的超时版本。 在这种情况下，不是所有客户端的整个通信线程都被阻塞了吗？
浏览 121提问于2020-10-21得票数 0
回答已采纳
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
回答已采纳
1回答
在我看来，内置的对gRPC的取消支持在以下意义上是相当激进的:如果我在客户端调用取消，通信通道就会立即关闭。服务器会得到通知，并且可以进行清理工作，但是在清理完成后，似乎没有机会通知客户端。
如果我想要下面的“软取消”行为，我该怎么办？
cancellationServer接收取消请求并启动清理服务器，并关闭通信通道客户端被告知取消过程已完成
可以使用请求流和oneof关键字实现此行为：
service ServiceName{
rpc Communicate (stream Request) returns (Response);
}
message Request {
o
浏览 18提问于2022-02-12得票数 1
回答已采纳
1回答
我正在使用gRPC，在接收流时，我不知道如何关闭客户端和服务器之间的连接。客户机和服务器都是用Python编写的。
例如，我的服务器从队列中读取消息，并生成每条消息。我的想法是，客户机订阅服务器并开始接收这些消息。
我的问题是：
我希望每当CTRL+C被按下时，客户机就会被杀死，但是它会被当前的代码卡住。怎样才能做好呢？
服务器如何意识到客户端已停止侦听？
我的nbi.proto文件：
syntax = "proto3";
service Messenger {
rpc subscribe(Null) return (stream Message) {}
浏览 0提问于2018-01-25得票数 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流到底是如何在反向代理上工作的？我的理解是，将在客户端和反向代理之间建立持久连接，而反向代理和我的服务器之间的连接不是持久的--那么，坐在反向代理后面的实际服务器如何继续通过持久化连接向客户端发送消息呢？
另外，假设我希望保持持久连接来处理推送通知(也就是说，我的服务器跟踪持久连接，在我的服务器端发生了一些事情，我想通知一个特定的客户端，我得到那个特定客户端的流/持久连接，然后通过它发送一条消息)。
浏览 1提问于2020-04-01得票数 3
回答已采纳
我正在尝试实现一个异步GRPC服务器，每当客户端进行调用时，它都会得到不确定的消息流。我翻阅了正式文件。它没有涵盖我希望为每个RPC保持流打开的场景。本文- 通过将回调处理程序对象再次放置在完成队列中来解决保持流打开的问题。
该条建议：
if (HasData())
{
responder_.Write(reply_, this);
}
else
{
grpc::Alarm alarm;
alarm.Set(completion_queue_, gpr_now(gpr_clock_type::GPR_CLOCK_REALTIME), this);
}
我尝试使用本文中建
浏览 3提问于2020-10-01得票数 1
我使用的是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
1回答
当您在GRPC中对流响应执行onNext()时，它会将其排队以进行传输，这将分配给直接缓冲区内存，而不是堆，因为这样的java.lang.OutOfMemoryError: Direct buffer memory不会生成有用的堆转储。这可以通过创建
message Chunk {
bytes data = 1
}
而会导致这个触发。正确的解决方法是确保服务器不会做任何愚蠢的事情，比如发送许多小块，但这仍然可能是可能关闭服务的DoS攻击的矢量。
我的问题是在GRPC中，是否在服务器端设置了限制数量并进一步阻塞onNext，直到队列减少，并在传输时间过长时取消操作的超时？这样，它就不会关闭服
浏览 6提问于2022-02-05得票数 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编写的异步C++服务器。我希望检测到客户端连接的丢失--无论是网络连接丢失，还是客户端崩溃等等。我看到了对备活通道参数的引用，我尝试了这些设置的各种组合，例如：
builder.AddChannelArgument(GRPC_ARG_KEEPALIVE_TIME_MS, 10000);
builder.AddChannelArgument(GRPC_ARG_KEEPALIVE_TIMEOUT_MS, 10000);
builder.AddChannelArgument(GRPC_ARG_KEEPALIVE_PERMIT_WITHOUT_CALLS, 1);
builder.A
浏览 7提问于2020-08-17得票数 0
回答已采纳
在调用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的Node.js版本(grpc-js)中，是如何实现的？
对于Go实现(grpc-go)，逻辑主要在 (flowcontrol.go，bdp_estimator.go)中；同时，它被描述为。然而，我找不到任何关于grpc-js的东西。
我主要感兴趣的是Node.js接收器何时发送WINDOW_UPDATE帧。
浏览 17提问于2021-02-13得票数 0
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
回答已采纳
我正在运行一个示例管道，我的环境是这样的。 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
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
回答已采纳
我的项目(在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
2回答
让我们假设我们为gRPC开发了一个自定义的低级传输。我们如何才能将其“插入”到gRPC c++应用程序接口中，以便我们可以将其用于通道？
浏览 1提问于2017-11-06得票数 6
Grpc.Core 2.38.0
我有一组应用程序参与使用grpc流进行进程间通信。我们不时地注意到服务器进程中的锁定和内存耗尽(由于锁)无法完成对IAsyncStreamWriter.WriteAsync(...)的调用
最近对grpc (.net)的更改已经将WriteAsync API更改为接受CancellationToken，但是在Grpc.Core包中不能使用。
浏览 8提问于2022-06-17得票数 0
我已经创建了一个GRPC服务器- Go中的流式rpc，客户端在Dart中。
通常，在本地运行服务器时，如果客户端在服务器仍在服务流时提前断开连接，则流rpc中的context将被取消，服务器将停止为流服务。
但是在云运行中，这是不一样的，当客户端断开连接时，服务器不会取消context。因此，除非容器达到超时限制，否则不会通知服务器从客户端关闭流。
因此，如果超时设置为1小时，那么即使客户端提前断开连接，服务器也要计费1小时。
云运行是否需要一些特殊的魔法，还是目前不支持？
目前唯一的解决办法是使用较小的超时(~1分钟)，然后在客户端创建重试逻辑。
浏览 9提问于2020-10-14得票数 2
回答已采纳
1回答
通过Python服务器无法工作
、、、、
我已经通过gRPC开发了Python服务器，然后将它构建到容器中并部署到云中运行，
我的gRPC服务器正在与TensorFlow应用程序集成。实际上，tensorflow用于图像ML，但这是一个示例代码。
class Calculator(calculator_pb2_grpc.CalculatorServiecer):
def Calculate(self, request, context):
try:
# Processing
return #protobuf message
except
浏览 2提问于2020-08-25得票数 3
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
回答已采纳
我有一个.NET gRPC服务器/客户端应用程序。它已经起作用了。但是现在，我在grpc客户端中的所有服务器调用中都出现了以下错误：
*Grpc.Core.RpcException: Status(StatusCode=Cancelled, Detail="Cancelled")
bei System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
bei System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNot
浏览 125提问于2019-08-18得票数 0
我正在使用GRPC连接到一个服务。有时调用是成功的，有时是异常的Received unexpected EOS on DATA frame from server.失败。
我找不到原因。以下是打电话的代码：
public class LmServiceClientImpl implements LmServiceClient {
LMAttributeServiceGatewayGrpc.LMAttributeServiceGatewayBlockingStub lmAttributeServiceGatewayBlockingStub;
@Autowired
@Q
浏览 5提问于2020-05-12得票数 2
2回答
可以在gRPC上运行iOS服务器吗？
假设我们希望使用gRPC框架来定义API等等，现在我们希望在同一个进程中部署一个gRPC服务器，应用程序通过InprocessChannel进行连接。
是否有一个用于gRPC的iOS端口允许这样做？
浏览 0提问于2017-11-02得票数 3
这里是一个gRPC新手的问题。
我们有一个源系统，它公开了一个双向gRPC流。为了扩展我们的应用程序，我们希望并行处理流数据。有没有可能让并发/多个gRPC客户端在数据处理/确认过程等过程中不发生任何冲突地从流中消费？
谢谢
浏览 32提问于2020-03-10得票数 1
2回答
我试图了解Go上下文取消在客户端服务通信(例如，任何gRPC API调用)下的工作方式。
假设客户端取消了上下文。这是否会导致向服务器发出新的HTTP请求，从而取消上一个/正在进行的gRPC请求的上下文通信？服务器如何知道客户端是否取消了上下文？
浏览 13提问于2022-10-21得票数 1
回答已采纳
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
回答已采纳
I0804 13:52:46.505722 0 C:\jenkins\workspace\gRPC_build_artifacts\platform\windows\workspace_csharp_ext_windows_x86\src\core\lib\surface\call.c:1802: grpc_call_start_batch(call=05BEFFD8, ops=05EFED58, nops=6, tag=05BC64E0, reserved=00000000) I0804 13:52:46.505722 0 C:\jenkins\workspace\gRPC_build_ar
浏览 1提问于2017-08-04得票数 0
回答已采纳
我正在创建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
回答已采纳
每当客户端不再侦听流时，我就需要在服务器中捕获。我以为这样就行了
function getEvents(call) {
const { type } = call.request
EVENTS
.filter((e) => e.type === type)
.foreach((event) => call.write(event))
call.on('end', () => { console.log('client left...') })
}
我的目的是让客户端连接，指定事件类型，并接收事件流。然后连接将挂起，
浏览 5提问于2017-10-12得票数 1
回答已采纳
1回答
有一个gRPC流服务器和客户机。客户端通过gRPC双向流拨号到服务器。服务器运行在一个昆宾女码头上。
在对kubeness服务器进行一次升级之后，当试图向流服务器发送请求时，客户端总是会收到EOF错误。我发现TCP连接是活动的。为什么？
我是否需要在grpc中调用"NewStream“API来重新创建一个新的strean？
func (cc *ClientConn) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error)
如果我在拨
浏览 2提问于2019-10-11得票数 0
1回答
我想使用grpc将一个示例视频文件从后端grpc服务传输到浏览器，我做了一些基于的调整。顺便说一句，特使的配置没有什么变化。视频文件被分割成17块，我可以在浏览器中接收到17条消息，但是里面什么都没有，该怎么做才能得到数据呢？
原型定义：
syntax = "proto3";
package helloworld;
service Greeter {
rpc SayHello (HelloRequest) returns (stream HelloReply);
}
message HelloRequest {}
message HelloReply {
byt
浏览 1提问于2020-07-03得票数 0
回答已采纳
1回答
在尝试从排序器获取配置块时，我们在排序器端收到以下警告，尽管我们能够成功获取该块。有谁能告诉我们为什么这条警告消息是从订单方发出的？我们能安全地忽略同样的问题吗？
2019-03-18 05:37:47.304 UTC [common.deliver] Handle -> WARN 020 Error reading from 127.0.0.1:48474: rpc error: code = Canceled desc = context canceled
2019-03-18 05:37:47.304 UTC [comm.grpc.server] 1 -> INFO 021
浏览 0提问于2019-03-18得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
