biuaxia

go get -u google.golang.org/grpc  

go get -u github.com/golang/protobuf/protoc-gen-go  

syntax = "proto3"; // バージョン宣言、Protocol Buffers v3を使用  

package pb; // パッケージ名  

// 挨拶サービスを定義  
service Greeter {  
    // SayHello メソッド  
    rpc SayHello (HelloRequest) returns (HelloReply) {}  
}  

// 名前を含むリクエストメッセージ  
message HelloRequest {  
    string name = 1;  
}  

// 挨拶文を含むレスポンスメッセージ  
message HelloReply {  
    string message = 1;  
}  

protoc -I helloworld/ helloworld/pb/helloworld.proto --go_out=plugins=grpc:helloworld  

package main  

import (  
    "fmt"  
    "net"  

    pb "gRPC_demo/helloworld/pb"  
    "golang.org/x/net/context"  
    "google.golang.org/grpc"  
    "google.golang.org/grpc/reflection"  
)  

type server struct{}  

func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {  
    return &pb.HelloReply{Message: "Hello " + in.Name}, nil  
}  

func main() {  
    // ローカルの8972ポートをリッスン  
    lis, err := net.Listen("tcp", ":8972")  
    if err != nil {  
        fmt.Printf("failed to listen: %v", err)  
        return  
    }  
    s := grpc.NewServer() // gRPCサーバーを作成  
    pb.RegisterGreeterServer(s, &server{}) // gRPCサーバーにサービスを登録  

    reflection.Register(s) // 指定されたgRPCサーバーにサーバーリフレクションサービスを登録  
    // Serveメソッドはlisで受信接続を受け入れ、各接続のためにServerTransportとserverのgoroutineを作成します。  
    // このgoroutineはgRPCリクエストを読み取り、登録されたハンドラーを呼び出して応答します。  
    err = s.Serve(lis)  
    if err != nil {  
        fmt.Printf("failed to serve: %v", err)  
        return  
    }  
}  

cd helloworld/server  
go build  
./server  

package main  

import (  
    "context"  
    "fmt"  

    pb "gRPC_demo/helloworld/pb"  
    "google.golang.org/grpc"  
)  

func main() {  
    // サーバーに接続  
    conn, err := grpc.Dial(":8972", grpc.WithInsecure())  
    if err != nil {  
        fmt.Printf("faild to connect: %v", err)  
    }  
    defer conn.Close()  

    c := pb.NewGreeterClient(conn)  
    // サーバーのSayHelloを呼び出す  
    r, err := c.SayHello(context.Background(), &pb.HelloRequest{Name: "q1mi"})  
    if err != nil {  
        fmt.Printf("could not greet: %v", err)  
    }  
    fmt.Printf("Greeting: %s !\n", r.Message)  
}  

cd helloworld/client/  
go build  
./client  

$ ./client  
Greeting: Hello q1mi!  

./gRPC_demo  
├── go.mod  
├── go.sum  
└── helloworld  
    ├── client  
    │   ├── client  
    │   └── client.go  
    │   ├── client.py  
    ├── pb  
    │   ├── helloworld.pb.go  
    │   └── helloworld.proto  
    └── server  
        ├── server  
        └── server.go  

python -m grpc_tools.protoc -I helloworld/pb/ --python_out=helloworld/client/ --grpc_python_out=helloworld/client/ helloworld/pb/helloworld.proto  

helloworld_pb2.py  
helloworld_pb2_grpc.py  

# coding=utf-8  

import logging  

import grpc  

import helloworld_pb2  
import helloworld_pb2_grpc  

def run():  
    # 注意(gRPC Python Team): .close()メソッドはchannelで使用可能です。  
    # そして、with文がコードの要件に合わない場合に使用するべきです。  
    with grpc.insecure_channel('localhost:8972') as channel:  
        stub = helloworld_pb2_grpc.GreeterStub(channel)  
        response = stub.SayHello(helloworld_pb2.HelloRequest(name='q1mi'))  
    print("Greeter client received: {}!".format(response.message))  

if __name__ == '__main__':  
    logging.basicConfig()  
    run()  

gRPC_demo $ python helloworld/client/client.py  
Greeter client received: Hello q1mi!