Wie kann ich einen Go gRPC auf der Serverseite mit Standard IO arbeiten lassen?

Question

Ich bin ein Neuling von gRPC, und hier ist mein Problem. Ich versuche, einen Dienst zu schreiben myOwnService in einen gRPC Dienst gemäß der folgenden Service-Methode zu entlarven:

rpc HighFive (stream HighRequest) returns (stream HighReply) {} 

Der serverseitigen Code ist wie folgt:

func (s *server) HighFive(stream pb.Greeter_HighFiveServer) error {  
    // Oops, don't know how to do here ... 
    myOwnService(stdin io.ReadCloser, stdout io.WriteCloser) 
    return nil 
} 

func myOwnService(stdin io.ReadCloser, stdout io.WriteCloser) error {  
    // read input from stdin, do something, the write result to stdout 
    ... 
    return nil 
} 

Wie Sie oben sehen können, Ich habe keine Ahnung, wie man stream mit io.Reader und io.Writer in meinem ursprünglichen Dienst arbeiten, so dass der Anrufer des HighFive gRPC-Dienstes Daten lesen und schreiben kann, wie normalerweise myOwnService aufruft.

[Update] Meine aktuellen Meldungen wie diese sind, aber Sie können sie bei Bedarf ändern:

message HighRequest { 
    bytes content = 1; 
} 

message HighReply { 
    bytes content = 1; 
} 

Answer 1

Per the gRPC Basics tutorial section on Bidirectional streaming RPC, jeden Anruf auf Ihren streamRecv Methode des Parameters werden Sie eine dekodiert HighRequest Nachricht, nicht ein Byte-Stream, wie Sie für Ihre myOwnService Funktion erwarten.

Nun, wenn Ihre HighRequest Nachricht ein Feld von Typen bytes oder string enthält, können Sie möchten, dass Feld Inhalt in myOwnService als stdin Parameter füttern von dem rohen []byte Wert über bytes.NewReader wickeln.

Ich sehe jedoch, dass myOwnService fordert eine io.ReadCloser. Ich weiß nicht, warum Sie myOwnService erwarten, um seinen Eingabeparameter zu schließen, aber ich vertraue Ihnen gut genug, dass Sie es benötigen, um dann ioutil.NopCloser zu empfehlen, um diese Anforderung trivial zu erfüllen.

Sketching:

// Next tag: 2 
message HighRequest { 
    bytes content = 1; 
} 

func (s *server) HighFive(stream pb.Greeter_HighFiveServer) error { 
    for req, err := stream.Recv(); { 
    if err != nil { 
     if err == io.EOF { 
     return nil 
     } 
     return err 
    } 
    in := ioutil.NopCloser(bytes.NewReader(req.Content)) 
    out := /* ... */ 
    if err := myOwnService(in, out); err != nil { 
     return err 
    } 
    } 
}