node.js - grpc 客户端断开连接时我可以收到通知吗?

标签 node.js grpc

只要客户端不再监听流,我就需要在服务器中捕获。我认为这样可以:

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...') })
}

我的目的是客户端连接、指定事件类型并接收事件流。然后连接将挂起,直到 Ctrl+C 和“客户端离开...”被记录到控制台。

客户端代码如下:

function main() {
  const client = 
    new EventStore('localhost:50051', grpc.credentials.createInsecure())

  const call = client.getEvents({ type: 'Done' })
  call.on('data', (event) => console.log(event))
}

一切都按预期工作,只有 call.on('end') 的回调永远不会触发。我从gRPC Tutorial获得了这方面的基础知识但我一定错过了一些东西。

最佳答案

客户端突然断开连接,而没有正确地与服务器通信,最终应该在服务器上触发“取消”事件。这就是你应该倾听的。我还建议在发生这种情况时采用某种方法来停止写入流。

您的方法看起来像一元请求/流响应方法。这意味着在服务器端,您有一个可写流,并且可写流没有“结束”事件。这是可读流上的一个事件,表明您已阅读完毕。

关于node.js - grpc 客户端断开连接时我可以收到通知吗?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/46700751/

相关文章:

javascript - 在rabbitmq中获取路由/绑定(bind) key

javascript - MQTT 主题和唯一性问题

go - 是否可以向 protobuf 服务添加自定义方法类型?

ios - xcode9中grpc报错GPR_UNREACHABLE_COD如何修正

node.js - 如何实现嵌套 Node 获取调用?

javascript - Socket.io 重新授权

java - io.grpc.netty.NettyServerTransport 通知终止

docker - goproxy 背后的 gPRC 返回证书错误,在没有代理的情况下工作正常

node.js - 如何将元数据添加到nodejs grpc调用

node.js:如何检测空的标准输入流?