25
4
In a bidirectional streaming setup in gRPC, if one party terminates the TCP connection, for instance, if the server abruptly crashes and restarts, how can the client re-establish the connection? Do we need to handle this manually, or does gRPC itself have mechanisms to address this situation?
在gRPC中的双向流设置中，如果一方终止TCP连接，例如，如果服务器突然崩溃并重新启动，客户端如何重新建立连接？我们需要手动处理这个问题吗？或者gRPC本身有解决这种情况的机制吗？
proto file :
原稿文件：
个人中心
文章发布
退出service LiveService{
rpc Dial(LiveReq)returns(stream LiveResp){}
}
message LiveReq{
}
message LiveResp{
string rtmp = 1;
}
client service:
客户服务：
func handler() {
ctx := context.Background()
req := rpc.LiveReq{}
dial, err := slave.GetLiveClient().Dial(ctx, &req)
if err != nil {
panic(err)
}
for true {
resp, err := dial.Recv() // tcp stop ,server stop
if err != nil {
fmt.Print(err)
}else{
fmt.Print(resp)
}
}
}
how to recover connection?
如何恢复连接？
--------------------------re-edit---------------------------
I did this, check out the link
1.https://github.com/grpc/grpc-go/issues/5507
--------------------------re-edit---------------------------这是我做的，请查看链接1。https://github.com/grpc/grpc-go/issues/5507
Does this answer your question? (i.e. the connection will be re-established automatically but it's up to you to re-establish the stream).
这回答了你的问题吗？(即连接将自动重新建立，但重新建立流取决于您)。
@Brits Thanks your reply。I know the TCP re-establishment method, but I want to restore the rpc stream. Can I only execute "slave.GetLiveClient().Dial(ctx, &req)" again, and can't it be automatically restored?
@英国人感谢你的回复。我知道TCP重建方法，但我想恢复RPC流。只能再次执行Slave.GetLiveClient().Dial(ctx，&req)，不能自动恢复吗？
Correct - if the stream dies (whether due to a network issue or something else) you need to make an RPC call to re-establish it.
正确-如果流终止(无论是由于网络问题还是其他原因)，您需要进行RPC调用以重新建立它。
@Brits look github.com/grpc/grpc-go/issues/5507 and gist.github.com/sosborne1/… . I dit this
@英国人的网站：githorb.com/grpc/grpc-go/Issues/5507和gist.githorb.com/sosborne1/…。我不相信这一点
That just moves the reconnection logic into an Interceptor. This is fine if it achieves your goal; personally I'd rather handle this where the stream is managed because restarting a stream may have unexpected impacts e.g.. loss of data from while the connection was down.
这只是将重新连接逻辑移动到拦截器中。如果它实现了您的目标，这是很好的；就我个人而言，我更愿意在管理流的地方处理这一问题，因为重新启动流可能会产生意想不到的影响。在连接断开时丢失的数据。
25
4
0
我是 javascript 世界的新手。最近我在 nodejs 中开发一个聊天应用程序。所以我有一个叫gracefulshutdown的方法如下。 var gracefulShutdown = fun
如标题所示，我已经能够连接到 Google 游戏服务，在两台设备之间交换数据并且一切正常，除了一件事:断开连接回调 . 我试图拦截 onPeersDisconnected 和 onP2PDisconn
我在 ruby 1.9.3 中有这个: Net::SFTP.start(ENV['SFTP_HOST'], ENV['SFTP_USERNAME'], password: ENV['SFTP_PA
我目前正在设计一个应用程序，它需要连接到设备、写入/读取数据并可靠地关闭连接。目前，我有写/读实体。我的断开连接然后重新连接非常不可靠，实际上经常使手机崩溃，有时甚至使 Eclipse 崩溃。 连接功
我写了下面的代码: $dbh = DBI->connect('dbi:SQLite:mysqlite.db', "", "") || die "Cannot connect: $DBI::errstr
第一个 View Controller 隐藏了导航栏。第二个是带有大标题的可见导航栏。向前过渡很好。 ScrollView 的行为符合预期——导航栏在下拉时拉伸(stretch)，在向上拉时收缩。但是
我写了一个 perl 模块: package sql; use strict; use XML::Simple; use DBI; use DBD::mysql; require Exporter;
我有一个处理图像的多线程 Cocoa 应用程序。该程序有一个进度条和一些文本，显示该过程的进度。这一切都很好。然而，有时界面会卡住并且所有内容都会停止更新。进度条停止移动，百分比计数器中的文本停止更新
使用浏览器客户端，如何在每次通话中设置sounds.disconnect()？有没有办法访问设备单例以修改该设置？我知道我在获得device.ready回调时可以访问，但是我想在每次调用时修改设置。
我很困惑:) 我将 SignalR 与 Asp.Net Core 和 JavaScript 客户端结合使用。我只想检测断开连接并自动重新连接。 经过多次谷歌搜索后，我想出了这个: connection
两台计算机通过套接字连接。如果服务器/客户端关闭连接从他们的末端(即关闭InputStream，OutputStream和Socket)那么我如何通知另一端关于断开连接？我知道有一种方法 - 尝试从
基本上在音乐结束后，我希望机器人与 channel 断开连接。这是我的: const leave = message => { return message.guild.voiceConnecti
我的代码发送 HttpConnection，然后尝试使用 connection.getInputStream() 或 connection.getErrorStream() 反序列化响应。 HttpU
我有一个网站，其中包含一些代码模块，如下所示。您可以从 Bootstrap 更改网格系统的大小。所以这就是为什么我的网格是第一行。使用我当前的代码，它看起来像这样: .label{ backgr
我试图让 Django 在一种情况下不发送信号。添加模型 Delivery 的新实例(在创建 Job 之后)作为模型 Job 的属性时，我不想发送信号，因为该信号应提醒管理员 Job 已被编辑。 不幸
我正在创建套接字服务器。但我不知道，我怎么知道客户端断开连接了？我正在 Windows 下创建服务器并使用 berkeley 套接字功能(读取、发送、连接....)。我最好想要一个跨平台解决方案(没有
我正在使用 this tutorial制作 Node/mongo 应用程序。当我运行 addContact 时，联系人似乎已保存到数据库中，但我收到一条错误消息，指出断开连接功能不是一个功能。谁能告诉
问题:在发出手动 .disconnect() 后如何将客户端重新连接到服务器？ 在我当前的项目中，当用户从 session 中注销时，我需要断开客户端与服务器的连接。我执行了 socket.disco
以下代码基本上可以按预期工作。然而，偏执，我想，为了避免资源泄漏， HttpURLConnection.disconnect用完后需要调用吗？ 我需要调用 InputStream.close 吗？ 我
我不是在考虑排队信号在disconnect()之后仍然在接收线程中传递的问题，而是: 考虑这样一种情况，Sender 对象在线程 1 中生成信号，而线程 2 中有一个 Receiver 对象，它有一个
我是一名优秀的程序员,十分优秀！