从流读取时Grpc服务器中未处理异常
从流读取时，gRPC服务器中未处理异常是指在gRPC服务器处理流式请求时，发生了未被正确处理的异常。
在gRPC中，流式请求是指客户端和服务器之间可以连续发送多个消息的请求。当服务器在处理这些请求时，可能会发生各种异常情况，例如网络连接中断、数据格式错误、权限问题等。如果这些异常没有被正确处理，就会导致服务器无法正常处理请求，甚至可能导致服务器崩溃。
为了解决这个问题，我们可以采取以下措施：
- 异常处理：在gRPC服务器中，应该对可能发生的异常进行捕获和处理。可以使用try-catch语句块来捕获异常，并根据具体情况进行相应的处理，例如记录日志、返回错误信息给客户端等。
- 错误码和错误信息：在处理异常时，可以使用错误码和错误信息来标识和描述异常。错误码可以用于快速定位和识别异常类型，而错误信息可以提供给客户端以便进行相应的处理。
- 断线重连：当发生网络连接中断等异常情况时，可以考虑实现断线重连机制。通过在客户端和服务器之间建立新的连接，可以恢复到正常的通信状态，确保请求的连续性和完整性。
- 监控和告警：为了及时发现和解决异常情况，可以在gRPC服务器中设置监控和告警机制。通过监控服务器的运行状态和性能指标，可以及时发现异常并采取相应的措施，例如发送告警通知、自动重启服务器等。
在腾讯云的产品中，可以使用腾讯云的云原生产品来构建和部署gRPC服务器，例如腾讯云容器服务 TKE、腾讯云函数计算 SCF 等。这些产品提供了高可用、弹性扩展、自动化管理等特性，可以帮助我们更好地处理和解决gRPC服务器中未处理异常的问题。
参考链接：
相关·内容
1回答
不支持Grpc抛出指定的方法。
、、、、
我试图调用实现代码优先服务的grpc服务器。如果我将CallOptions添加到传递承载令牌的服务方法参数中，则无法从客户端调用该服务。
当我执行客户端时，它会抛出以下异常：
未处理异常。System.NotSupportedException:不支持指定的方法。在ProtoBuf.Grpc.Internal.Proxies.ClientBase.ICustomerService_Proxy_0.ICustomerService.CreateCustomer(CreateCustomerCommand，CallOptions )
如果我移除CallOptions参数，然后执行调用，它就会正常
浏览 9提问于2022-08-16得票数 0
1回答
在用grpc编写服务时，我试图通过服务器端推送机制将http/2与websocket进行比较。
我知道对于websocket，客户端将发送一个请求，其中包含升级: WebSocket和Connection:将报头升级到服务器，并建立长期连接。连接建立后，服务器可以自由发送数据。
但是对于grpc来说，由于它是在http/2上从wiki页面路由的，它表示服务器需要预测客户端可能发送的请求，并尽早发送PUSH_PROMISE帧。
以下是我的两个问题：
这是否意味着服务器还需要从客户端接收相应的响应(请求)以响应此PUSH_PROMISE头，以决定客户端是否希望接收或拒绝特定的推送？
在Gr
浏览 10提问于2019-06-24得票数 5
回答已采纳
在gRPC实现中，在同一进程中从具有本地连接的gRPC服务发送对象时是否序列化对象？
假设我们有一个包含A和B类的java进程，如果A类使用gRPC客户端向B类支持的gRPC服务器发送数据，那么客户机和服务器是否共享一个Java对象引用，或者数据是通过已建立的本地Netty连接序列化和发送的？
浏览 0提问于2021-06-17得票数 0
回答已采纳
我正在通过gRPC cpp示例来尝试学习。在调试流示例时，我注意到服务器上对grpc_impl::ServerReaderWriter::Read的调用会一直阻塞，直到另一端写入或流结束。 我们应该如何使服务器足够健壮，使其能够处理客户端在发送初始消息后挂起或忘记关闭流？ 也许它会调用RPC并向我发送三条消息，但永远不会关闭。似乎不存在此调用的超时版本。 在这种情况下，不是所有客户端的整个通信线程都被阻塞了吗？
浏览 121提问于2020-10-21得票数 0
回答已采纳
我使用的是“流式RPC”API，其中MyRequests和MyResponse都是流的。
service MyStreamedService {
rpc myOperation(**stream** MyRequest) returns (**stream** MyResponse)
}
下面是包装gRPC流的类的稍微简化的版本；
public class MyStreamWrapper implements StreamObserver<MyResponse> {
public MyStreamWrapper(ManagedChannel myChannel) {
浏览 2提问于2021-09-16得票数 1
回答已采纳
我在.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
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
回答已采纳
我尝试在flutter中使用grpc，但在调用某些方法时收到此错误。 错误:flutter/lib/ui/ui_dart_state.cc(186)未处理的异常: gRPC错误(2，HTTP/2错误:连接错误:连接被强制终止。(errorCod e: 10) 版本: grpc：^2.1.3协议grpc：^1.0.1 protoc_plugin：^19.0.1 我的初始化grpc的代码： class GrpcClientSingleton {
late ClientChannel client;
static final GrpcClientSingleton _singleton
浏览 14提问于2021-03-24得票数 1
通过mac终端安装npm。
使用npm命令安装botium客户端：npm install -g botium-cli
按照本中的指示：
还分配了一个DialogFlow实例和项目配置的其他细节，如上述链接教程中所示。
在建立botium客户端和DialogFlow之间的连接时遇到的错误：
错误:0906D06C:PEM routines:PEM_read_bio:no起始线(节点:25129) UnhandledPromiseRejectionWarning: UnhandledPromiseRejectionWarning:无法向对话框发送消息：{ Error: 14不可用:从插件获取元数
浏览 1提问于2018-10-10得票数 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
回答已采纳
1回答
当im试图打开测试页面时，出现了一个未处理的异常，这是因为
标记与另一行中的结尾不匹配，我试图添加闭包标记，但在添加函数开始工作之前会发生错误。
测试页
那么，是否有一种在不失去标记效果的情况下传递标记问题的方法？
这是主要代码：
XElement tree = XElement.Load(toolStripTextBox1.Text);
String s = tree.ToString();
textBox1.Text = String_dealer.addmissing(s);
这是字符串转换器
浏览 0提问于2012-12-21得票数 0
回答已采纳
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回答
我遇到了一个非常奇怪的问题:基本上，我正在用java实现一个服务器流grpc客户端，并且我使用微配置文件作为库/结构。当涉及到自动重试和回退时，Microprofile有非常方便的拦截器，但是它依赖于在拦截注释函数中抛出的异常，否则不会触发重试。
对于不常用的grpc调用，这很好，它的工作原理与普通REST调用非常相似。但是，当使客户端到grpc服务器端流时，protobuf将创建它自己的线程，并请求一个回调来处理onNext、onError和onCompleted。因此，当在流作用域中调用onError时，抛出的任何异常都不会被发送回用于启动流的任何函数，因此不会抛出任何异常来触发@Retr
浏览 2提问于2020-03-26得票数 1
回答已采纳
我正试图正确地处理gRPC错误(应用程序)。
基本上，我需要将错误的详细信息从gRPC服务器传输到客户端，但我发现很难理解StreamObserver.onError();的正确用法。
方法医生说：
“从流接收终止错误。可能只调用一次，如果调用，则必须是最后调用的方法。特别是如果onError的实现引发异常，则不允许进一步调用任何方法。”
这个“不允许进一步调用”是什么意思？在我维护的应用程序中，他们调用了其他的gRPC方法，并获得了java.lang.IllegalStateException: call already closed，根据文档，这是很好的。
我想知道--在收到错误后
浏览 7提问于2020-10-08得票数 4
回答已采纳
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
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
当请求失败时，记录HTTP请求主体的最佳方法是什么？
我正在记录未处理的异常，方法是重写异常记录器：
public class AiExceptionLogger : ExceptionLogger
{
public override void Log(ExceptionLoggerContext context)
{
if (context != null && context.Exception != null)
{
ExceptionTelemetry telemetry = new Excepti
浏览 1提问于2017-05-03得票数 7
回答已采纳
我想在服务器端返回grpc错误代码和描述。我试过这个
function sayHello(call, callback) {
callback({error: {code: 400, message: "invalid input"});
}
但我从客户那里得到了这个异常
{ Error: Unknown Error
at /home/thanh/email/node_modules/grpc/src/node/src/client.js:434:17 code: 2, metadata: Metadata { _internal_repr: {} } }
如果我不
浏览 3提问于2017-03-16得票数 6
回答已采纳
我在C++中使用gRPC。我有异步服务器和同步客户端。rpc是双向流类型。
下面是我用客户端发送消息的方式：
class ConnectionService {
public:
ConnectionService(std::shared_ptr<Channel> channel)
: stub_(Connection::NewStub(channel)) {}
void HearthBeat() {
ClientContext context;
std::shared_ptr<grpc::Client
浏览 0提问于2020-10-12得票数 3
我在go中有一个使用gRPC的服务器，在react客户端上，我正在使用grpc web和grpcwebproxy，我一直试图将我的客户端连接到服务器上，但总是得到错误代码2，并显示消息: Response closed with headers。还有没有人遇到过这个问题？我现在使用的是grpc-web的improbable eng实现。
浏览 0提问于2019-05-29得票数 3
我正在nodejs中实现一个grpc服务器。grpc很棒。我想知道是否可以从grpc服务器向客户端发送消息(不是请求/响应)？ 我知道我们在全双工的grpc中有双向通信。这意味着这是我们在socket.io(websocket)中拥有的类似功能。我们如何将消息推送到单个客户端？有可能追踪到grpc客户端吗？或者更好的是，得到一个心跳？
浏览 194提问于2021-01-23得票数 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
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
我有一个用Go编写的grpc服务器，运行良好。rpc：Send (stream FromClientMessage) returns (stream FromServerMessage)
当我使用Unity3d客户端时，我可以发送一个消息：
_requestStream.WriteAsync(new FromClientMessage {});
它工作正常-服务器接收它。现在服务器发送一条消息。
为了在Unity中接收它，我使用了教程中的示例代码：
Task.Run(async() =>
{
var stream = _client.Send().ResponseStream;
浏览 7提问于2022-01-21得票数 0
1回答
当我查看服务器调用的grpc自动生成类和grpc中给出的示例示例时，我可以看到我们扩展了ImplBase类并覆盖了服务方法。如下所示：
static class communicationImpl extends communicationImplBase
在C++中，为了实现异步服务，我们使用AsyncService而不是服务类扩展我们的实现。但是在java生成的Grpc类中，我看不到另一个名为/以异步开头的类。我在其中看到的唯一与服务器相关的类是以ImplBase结尾的类。那么，如何设置服务器，以便在grpc中异步处理请求？
浏览 0提问于2017-03-24得票数 3
回答已采纳
3回答
尝试编写.ply解析器以在OpenGL中使用.ply模型。
尝试开始读取.ply文件并将其中的所有行写出来。我的程序会这样做，但是当它打印出最后一行时，我会得到未处理的异常：
在 parser.exe: 0xC0000005中0x62aad540 (msvcr100d.dll)处未处理的异常:访问冲突读取位置0x00000000。
这是我的密码：
#include <iostream>
#include <fstream>
#include <string>
#include <stdio.h>
using namespace std;
浏览 11提问于2012-03-01得票数 2
回答已采纳
1回答
Grails应用程序未启动
、、、、
在尝试启动Grails应用程序时，我一整天都在收到这些错误。
失败:生成失败，出现异常。
出了问题:配置项目':server'.时出现了问题
无法解决配置的所有依赖关系:服务器:运行时。无法解析io.grpc:grpc:1.30.1。所需: project :server > io.grpc:grpc-core:1.30.1 >无法解析io.grpc:grpc:1.30.1。>无法列出io.grpc:grpc-api的版本。>无法从加载Maven元数据。>不能得到'‘。从服务器接收状态代码403 :禁忌无法解析net.minidev:jso
浏览 0提问于2021-06-07得票数 0
我在客户端和服务器之间有grpc连接。
在开始时，客户端向服务器发送消息并建立连接。
服务器有一个后台进程，在检查某些东西和条件为真后，它应该向客户端发送消息。
我该怎么做呢？
浏览 1提问于2021-03-18得票数 0
1回答
我试图从C#客户端连接到GRPC，但是客户端通道无法连接到服务器。
我希望在连接到GRPC服务器时不会出现问题，GRPC服务器是由Go编写和托管的，而客户端是用C#编写的。
因此，设置了我的Go Server连接：
lis, err := net.Listen("tcp", ":50051")
if err != nil {
log.Fatalf("Failed to listen: %v", err)
}
s := grpc.NewServer()
pb.Register**ServiceServer(s, &server
浏览 21提问于2020-06-04得票数 7
回答已采纳
我是gRPC的新手。在使用proto文件创建java存根之后，当从客户端发送newBlocking请求时，我将在生成的java存根文件的loginAPI存根中获得一个异常。服务器正在启动，但是客户端得到了一个异常。
客户代码：
userBlockingStub userStub = userGrpc.newBlockingStub(channel);
生成的Java存根文件：
public static userBlockingStub newBlockingStub(io.grpc.Channel channel) {
return new userBlockingStub(chan
浏览 8提问于2022-06-13得票数 0
1回答
我正在尝试构建一个异步gRPC C++客户端，它使用ClientAsyncReaderWriter实例向服务器发送流消息，或从服务器接收流消息。客户端和服务器在需要的时候相互发送消息。如何检查是否有来自服务器的消息？
ClientAsyncReaderWriter实例有一个绑定的完成队列。我尝试通过调用Next()和AsyncNext()函数来检查完成队列，以查看是否有任何事件表明有来自服务器的消息。但是，即使有来自服务器的消息，完成队列也没有事件。
class AsyncClient {
public:
AsyncClient(std::shared_ptr<grpc::Cha
浏览 21提问于2019-11-08得票数 1
回答已采纳
我有一个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
这是我在program.cs中的“完整”代码。
var builder = WebApplication.CreateBuilder(args);
builder.Host.UseWindowsService();
// Add services to the container.
builder.Services.AddGrpc();
var app = builder.Build();
// Configure the HTTP request pipeline.
app.MapGrpcService<GreeterService>();
app.MapGet("
浏览 8提问于2022-07-10得票数 0
回答已采纳
正如在中所解释的那样，默认流程是客户机连接到服务器并发送请求，服务器对这些请求有充分的响应(很好，希望如此)。
我对在新项目中使用grpc很感兴趣，但是流程必须是反向的。我要客户回答问题。但是它不可能是服务器，因为它会隐藏在防火墙后面，并且可能不会监听端口。
我需要的流程是：
服务器正像往常一样监听
客户端像往常一样连接到服务器
从那时起，服务器提出问题(发送请求)，客户端回答这些问题，而不是像往常那样反过来。
有什么方法可以用grpc来实现吗？它可以涉及服务器端的网络配置，但在客户端是不可能的。
浏览 0提问于2018-04-18得票数 0
我使用gRPC在dotnet核心3.1中定义和实现了一个C#服务。我有一个流调用定义如下：
service MyService {
rpc MyStreamingProcedure(Point) returns (stream ResponseValue);
}
在服务中生成它。
public virtual global::System.Threading.Tasks.Task MyStreamingProcedure(global::MyService.gRPC.Point request, grpc::IServerStreamWriter<global::MyServic
浏览 4提问于2020-03-05得票数 1
我从客户端获取数据并将其保存到本地主机.I上的本地驱动器中，检查了它是否有221 1Gb的文件，但是对1GB文件的测试提供了以下例外：
System.OutOfMemoryException类型的未处理异常发生在mscorlib.dll中
下面是出现异常的服务器端的代码。
更新
服务器：
public void Thread()
{
TcpListener tcpListener = new TcpListener(ipaddr, port);
tcpListener.Start();
Mes
浏览 5提问于2014-12-26得票数 0
我正在使用Protobuf和gRPC进行实验，并正在学习Go基础教程：
从关于的文档中可以看出，并发使用相同的ClientConn似乎是安全的。但我不能任何关于一个人创造的存根/客户端。
假设我通过HTTP请求接收数据，我希望通过gRPC作为protobuf转发该数据，然后响应该HTTP。我应该在每次处理HTTP请求时创建一个客户机/存根，还是在设置HTTP服务器时创建客户机/存根，并在设置HTTP处理程序时传递客户机/存根？
例句:我想这样可以。
var opts []grpc.DialOption
conn, err := grpc.Dial("127.0.0.1:1234"
浏览 8提问于2022-07-19得票数 1
回答已采纳
1回答
我只是发现在C++中，当使用AsyncService时，即使不请求新请求，gRPC仍然会从网络读取数据。这在我的系统中造成了巨大的内存使用量。
详细情况：
我有一个客户端，它将向服务器发送大量请求。
在服务器端，我没有请求任何请求。服务器在cq_->Next(&tag, &ok)中被阻塞，但一直在消耗内存。在我的系统里造成了一个OOM。
因此，我的问题是，当我不请求新请求时，如何防止服务器从网络中读取数据？也就是说，如何做服务器端的背压，这样我就可以节省内存？
有人能帮我吗？谢谢!
编辑:复制
我给您做了一个简单的例子来重现这个问题，代码是基于正式的v1.46.3代码库的
浏览 20提问于2022-05-29得票数 1
1回答
我很难使用对话框、v2、和。
请注意，我已经看到了与有关这些方法的Stack溢出帖子，以及关于如何进行这些api调用的有用的Google。我是哑巴，请帮帮忙。
具体来说，我试图发送用户输入以从我的Dialogflow代理调用一个意图，并且我已经创建了一个RestController来使用类定义所放置的RestController注释。
由于某些原因，即使我已经创建了一个服务帐户，并且在我的GCP帐户中为它选择了对话框流角色，但我仍然收到一个PERMISSION_DENIED错误。
我将按以下顺序发布代码：
我的弹簧休息控制器类
我的春季申请课
我的春天pom.xml
Tomca
浏览 0提问于2018-07-15得票数 1
我有一个Kafka应用程序，我创建了自定义的生产/消费/未处理异常处理程序，所有这些都返回CONTINUE继续处理，尽管有异常。卡夫卡流是否在这种情况下提交偏移量？我看了一下代码，似乎没有，但这对我来说没有多大意义。
浏览 8提问于2022-06-22得票数 0
回答已采纳
我在一个容器应用程序上启用了gRPC协议&现在服务调用失败了。我猜我又错过了一步？♂️
az containerapp dapr enable --name blah
--resource-group blah
--dapr-app-protocol grpc
失败: Microsoft.AspNetCore.Server.Kestrel13
连接id "0HMI4QJ3KEQS9"，请求id "0HMI4QJ3KEQS9:00000002"
浏览 8提问于2022-06-02得票数 0
2回答
我的代码是：
StreamReader r = new StreamReader("temp.txt");
string str = r.ReadLine();
Console.WriteLine(str);
StreamWriter w = new StreamWriter("temp.txt");
w.WriteLine("new text");
str = r.ReadLine();
Console.WriteLine(str);
当我运行它时，它抛出一个未处理的异常，并且无法访问该文件。我确信文件的路径是正确的，并且它没有写保护。
浏览 13提问于2021-08-05得票数 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
我有一个HTTP服务器，它通过GRPC连接到网关。网关也连接到其他网关。GRPC微型服务。流程如下：
客户端-> HttpServer -> GRPC服务器(网关) -> GRPC微服务服务器X
我目前处理错误的方式是这样的(如果有更好的练习，请告诉我)，我只会展示简洁的代码。
GRPC微服务服务器X
@GrpcMethod() get(clientDetails: Records.UserDetails.AsObject): Records.RecordResponse.AsObject {
this.logger.log("Get Record for
浏览 9提问于2020-02-17得票数 3
回答已采纳
我试图从visual studio获取Access数据库的图片--这是我的代码：
var DBPath = Application.StartupPath + "\\Bd.mdb";
Console.Write("Ruta: " + Application.StartupPath);
conn = new OleDbConnection("Provider=Microsoft.Jet.OleDb.4.0;"+"DataSource=" + DBPath);
conn.Open();
OleDbCommand cmd = n
浏览 1提问于2016-11-08得票数 0
回答已采纳
Grpc.Core 2.38.0
我有一组应用程序参与使用grpc流进行进程间通信。我们不时地注意到服务器进程中的锁定和内存耗尽(由于锁)无法完成对IAsyncStreamWriter.WriteAsync(...)的调用
最近对grpc (.net)的更改已经将WriteAsync API更改为接受CancellationToken，但是在Grpc.Core包中不能使用。
浏览 8提问于2022-06-17得票数 0
grpc_impl::ServerReaderWriter/grpc_impl::internal::ReaderInterface实现了NextMessageSize()，但是从命名上看，它只返回下一条消息的大小，从线程和文档来看，返回值似乎只是一个上限。
对于流式应用程序(例如音频/视频、文本、任何实时双工流)，了解从客户端到达的数据的数量是很有帮助的，这样就可以对数据进行批量处理，或者测量非实时性，或者适应可变的流速率等等。
谢谢你的指点和解释。
浏览 5提问于2020-01-10得票数 0
回答已采纳
我有几个程序是用C#在Windows上编写的，并注意到它们都会打印STDERR的未处理异常。我找不到任何关于这方面的文档，什么是专门为STDERR编写的例外？是否有选项可以启用/禁用此选项，或以其他方式控制它如何打印异常文本？
我很好奇.NET或C#应用程序是否能够可靠地向STDERR输出未处理的异常，也许开发人员可以使用编译器或其他选项完全禁用该功能(类似于，或者如果程序由于未处理的异常而崩溃，其方式不被打印到STDERR上。
浏览 1提问于2015-12-02得票数 4
回答已采纳
当我开始为grpc服务器服务实现全局错误处理程序时，遇到了一个问题。问题是，当我收到验证错误时，我不想记录它，但我想返回一个包含信息的RpcException给客户端，而在其他异常中，我记录它并返回一个未处理的错误。问题是，为什么在捕获ValidationException和抛出RpcException之后，我多次进入catch块(异常e)？对于这两次被调用的事实，我上面描述的逻辑对我来说是分解的。执行情况如下：
public class ExceptionInterceptor : Interceptor
{
private readonly ILogger<Exception
浏览 5提问于2022-09-28得票数 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
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
