Grpc双方向ストリーミング - サーバーはメッセージ交換を開始できますか？

Question

私のシナリオは

サーバが開始

サーバーとクライアントは、クライアントにメッセージを送信し、（サーバがメッセージ交換を開始する）

クライアントがメッセージを受信して​​いる場合、応答

で返信、ありますですから、grpc-javaのサンプルコードで助けてください。

クライアントがメッセージをサーバーに送信するのは、そのサーバーが応答を返すためです。メッセージを送る

Answer 1

Serverはまず、私はgrpcは、RPC層でのクライアントへの真のサーバー開始の呼び出しをサポートしていないと思う双方向ストリーミング

https://grpc.io/docs/reference/java/generated-code.html

// Client Side: 
volatile StreamObserver<Message> requestOb; 

StreamObserver<Message> responseOb = new StreamObserver<>() { 
    @Override public void onNext(Message msg) { requestOb.onNext(msg); } 
    @Override public void onError(Throwable t) { requestOb.onError(t); } 
    @Override public void onCompleted() { requestOb.onCompleted(); } 
} 
requestOb = stub.echoTheServer(responseOb); 

// Server side: 
@Override 
public StreamObserver<Message> echoTheServer(StreamObserver<Message> responseOb) { 
    for (int i = 0; i < 100; i++) { 
    responseOb.onNext(new Message()); 
    } 
    responseOb.onComplete(); 
    return new StreamObserver<Message>() { 
    @Override public void onNext(Message msg) {} 
    @Override public void onError(Throwable t) { responseOb.onError(t); } 
    @Override public void onCompleted() {} 
    } 
}