gRPC Java実装v0.15がデータを失った可能性がありますが、v1で修正されましたか？背圧？

Question

私はgRPC（javaバージョン）のv0.15で作業していましたが、クライアントが遅い場合、一部のデータが失われる可能性があるという問題に直面しました。私。サーバーは、5ミルの記録を発し、クライアントは約80パーセントを受け取ることができます。

このような状況に対処するには、マイクロサービス間の通信にgRPCを使用したい場合には、私に問題と思われるローカルの 'バッファ'を実装する必要がありました。

この問題はv1で修正されたのでしょうか？私はgRPCディスカッションの中で（グーグルで）対応する問題を見てきたことを覚えていますが、今はそれを見つけることができません。

私は何とかバックプレッシャーと相関していると思いますが、gRPCにバックプレッシャーが入っていますか？私のテストでは、io.netty.util.internal.OutOfDirectMemoryErrorで1.0.2が吹き飛ばします： バックプレッシャーを手動で実装する必要がありますか？

Answer 1

メッセージを送信しただけであっても、クライアントが受信したことを意味するものではありません。私はあなたの問題は、制御/背圧を流れるように関連していると思わ同意するだろう

No generic method for determining message receipt or providing acknowledgement is provided. Applications are expected to utilize normal payload messages for such signals, as a response naturally acknowledges its request.

：ClientCallとServerCall APIは、としてそれを記述します。 StreamObserverをServerCallStreamObserverにキャストし、メモリ使用を制御するためにsetOnReadyHandler()とisReady()を使用する必要があります。 brief example in an issue commentがあります。