我应该在gRPC Java中重用StreamObservators吗？

Question

我是gRPC的新手，正在编写一个应用程序，其中8个客户端每秒向gRPC服务器发送50k个异步请求。我知道我应该为每个客户端重用该通道，但是流观察者怎么样？现在每次客户端发出请求时，我都会创建一个新的流观察者。这会是瓶颈吗？如果有任何回复，我将不胜感激！

Answer 1

不需要为每个请求创建StreamObserver。只需通过StreamObserver#onNext发送请求，发送完所有请求后，即可将其关闭。

        StreamObserver<HelloMessage> requestObserver = stub.sayHello(streamObserver);

        for (int i = 0; i < 100; i++) {
            HelloMessage message = HelloMessage.newBuilder()
                                               .setMessage(i + " Server Stream")
                                               .build();

            requestObserver.onNext(message);
        }
        requestObserver.onCompleted();