最新版grpc-demo

 

 

 

grpc-demo on windows

 

1. 生成proto文件

 

>1. 安装grpc protoc生成工具

# https://github.com/protocolbuffers/protobuf/releases

 

>2. golang安装支持.proto文件的plugins

#setting -> plugins -> search "protobuf support"

 

>3. 安装grpc

# go get -u google.golang.org/grpc

 

>4. 安装grpc依赖, 安装成功后，会在$GOPATH/bin目录下生成两个2进制文件

# go install google.golang.org/protobuf/cmd/protoc-gen-go@latest

# go install google.golang.org/grpc/cmd/protoc-gen-go-grpc@latest

 

>5. 加入环境变量

# E:\Go-project\bin

 

6>. 编写data.proto

# mkdir proto

# mkdir ./proto/pb

 

syntax = "proto3";

package test;

option go_package="./pb";

message ProductRequest {

  int32 id = 1;

}

message ProductResponse {

  int32 stock = 1;

}

service ProService {

  rpc GetStockById(ProductRequest) returns (ProductResponse);

}

 

 

>7. 编译proto,生成data.pb.go和data_grpc.pb.go

#protoc --go_out=. --go-grpc_out=. *.proto

 

2. 编写服务器端代码

package main



import (

	"context"

	"fmt"

	"gitee.com/grpc-demo/proto/pb"

	"google.golang.org/grpc"

	"log"

	"net"

)



type Server struct {

	pb.UnimplementedProServiceServer

}



func (s *Server) GetStockById(ctx context.Context, pro *pb.ProductRequest) (*pb.ProductResponse, error) {

	// 业务处理

	return &pb.ProductResponse{

		Stock: pro.Id,

	}, nil

}



func main() {

	fmt.Println("start grpc server")

	listen, err := net.Listen("tcp", ":8012")

	if err != nil {

		log.Fatalf("fail to start server: %v", err)

	}



	s := grpc.NewServer()

	pb.RegisterProServiceServer(s, &Server{})

	err = s.Serve(listen)

	if err != nil {

		log.Fatalf("fail to start grpc-server: %v", err)

	}

}

 

 

3.编写客户端代码

package main



import (

	"context"

	"fmt"

	"gitee.com/grpc-demo/proto/pb"

	"google.golang.org/grpc"

	"google.golang.org/grpc/credentials/insecure"

	"log"

	"time"

)



func main() {

	fmt.Println("start client")

	conn, err := grpc.Dial("127.0.0.1:8012", grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithBlock())

	if err != nil {

		log.Fatalf("fail to dial: %v", err)

	}

	defer conn.Close()



	client := pb.NewProServiceClient(conn)

	ctx, cancel := context.WithTimeout(context.Background(), time.Second)

	defer cancel()





	req := &pb.ProductRequest{

		Id: 256,

	}

	res, err := client.GetStockById(ctx, req)

	if err != nil {

		log.Fatalf("get stock fail: %v", err)

	}

	log.Printf("get stock success: %v", res)

}

 

 

4. 启动服务器

#go run .\server\main.go

#go run .\client\main.go