小编max*_*040的帖子

如何避免gRPC异步服务器在启动时流式传输丢失的消息?

我已经实现了消息的异步服务器流,并且已经进行了调用rpc的测试,然后使消息从服务器发送出去,然后等待onNext()

有时测试失败,因为在我引起消息后,rpc调用到达了服务器。如果在服务器端添加300毫秒的睡眠,则该睡眠将持续失败。

我尝试添加withWaitForReady(),但没有帮助。

在服务器端的方法完成之前,是否存在阻止异步存根的标准方法?

protocol-buffers grpc grpc-java

6
推荐指数
0
解决办法
170
查看次数

标签 统计

grpc ×1

grpc-java ×1

protocol-buffers ×1