add rpc helloworld

Author: softcodenet

README.md

@@ -37,4 +37,7 @@ go编程最佳实践
 ## 问题
 
 go-and-json 
-[https://eager.io/blog/go-and-json/](https://eager.io/blog/go-and-json/)
+[https://eager.io/blog/go-and-json/](https://eager.io/blog/go-and-json/)
+
+
+

grpc/README.MD

@@ -0,0 +1,31 @@
+## Golang RPC 相关知识
+
+### 如何根据protoc生成代码 
+
+指定文件目录的方式
+`protoc B.proto --go_out=. --proto_path=$GOPATH/src/B `
+
+已经在文件夹中
+`protoc B.proto --go_out=.`
+
+生成RPC服务
+`protoc -I helloworld/ helloworld/helloworld.proto --go_out=plugins=grpc:helloworld`
+
+### rpc protobuf 入门
+
+http://lameleg.com/tech/rpc-protobuf.html
+
+### 问题
+
+安装protoc-gen-go
+https://github.com/golang/protobuf/issues/365#issuecomment-305240878
+
+https://github.com/golang/protobuf#installation
+
+终端代理解决go依赖被和谐的问题
+
+https://github.com/Quinton/blog/issues/2
+https://github.com/mrdulin/blog/issues/18
+https://droidyue.com/blog/2016/04/04/set-shadowsocks-proxy-for-terminal/index.html
+
+

grpc/helloworld/greeter_client/main.go

@@ -0,0 +1,39 @@
+package main
+
+import (
+	"context"
+	"log"
+	"os"
+	"time"
+
+	pb "../helloworld"
+	"google.golang.org/grpc"
+)
+
+const (
+	address     = "localhost:5051"
+	defaultName = "world"
+)
+
+func main() {
+	// Set up a connection to the server.
+	conn, err := grpc.Dial(address, grpc.WithInsecure())
+	if err != nil {
+		log.Fatalf("did not connect: %v", err)
+	}
+	defer conn.Close()
+	c := pb.NewGreeterClient(conn)
+
+	// Contact the server and print out its response.
+	name := defaultName
+	if len(os.Args) > 1 {
+		name = os.Args[1]
+	}
+	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
+	defer cancel()
+	r, err := c.SayHello(ctx, &pb.HelloRequest{Name: name})
+	if err != nil {
+		log.Fatalf("could not greet: %v", err)
+	}
+	log.Printf("Greeting: %s", r.Message)
+}

grpc/helloworld/greeter_server/main.go

@@ -0,0 +1,38 @@
+package main
+
+import (
+	"context"
+	"log"
+	"net"
+
+	pb "../helloworld"
+
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/reflection"
+)
+
+const (
+	port = ":5051"
+)
+
+// server is used to implement helloworld.GreeterServer.
+type server struct{}
+
+// SayHello implements helloworld.GreeterServer
+func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {
+	return &pb.HelloReply{Message: "Hello " + in.Name}, nil
+}
+
+func main() {
+	lis, err := net.Listen("tcp", port)
+	if err != nil {
+		log.Fatalf("failed to listen: %v", err)
+	}
+	s := grpc.NewServer()
+	pb.RegisterGreeterServer(s, &server{})
+	// Register reflection service on gRPC server.
+	reflection.Register(s)
+	if err := s.Serve(lis); err != nil {
+		log.Fatalf("failed to serve: %v", err)
+	}
+}

grpc/helloworld/helloworld/helloworld.pb.go

@@ -0,0 +1,23 @@
+syntax = "proto3";
+
+option java_multiple_files = true;
+option java_package = "io.grpc.examples.helloworld";
+option java_outer_classname = "HelloWorldProto";
+
+package helloworld;
+
+// The greeting service definition.
+service Greeter {
+    // Send a greeting
+    rpc SayHello (HelloRequest) returns (HelloReply) {}
+}
+
+// The request message containing the user's name.
+message HelloRequest {
+    string name = 1;
+}
+
+// The response message containing the greetings
+message HelloReply {
+    string message = 1;
+}

grpc/helloworld/helloworld/helloworld.proto

@@ -0,0 +1,26 @@
+package main
+
+import (
+	"fmt"
+	"runtime"
+	"sync"
+)
+
+func main() {
+	runtime.GOMAXPROCS(1)
+	wg := sync.WaitGroup{}
+	wg.Add(20)
+	for i := 0; i < 10; i++ {
+		go func() {
+			fmt.Println("i: ", i)
+			wg.Done()
+		}()
+	}
+	for i := 0; i < 10; i++ {
+		go func(i int) {
+			fmt.Println("i: ", i)
+			wg.Done()
+		}(i)
+	}
+	wg.Wait()
+}