gomicro v2--01 grpc介绍

本文是对微服务和gorpc细节的阐述，如果想立刻开始使用gomicro v2 , 请直接移步第二课 go micro v2基本架构搭建。

一、grpc简介

微服务的解决方案有很多，如 专注于服务治理的 dubbo、java的全栈式解决方案springcloud、专注于通讯和跨语言的thrift、当然还有go语言原生的grpc.

一般不考虑跨语言的话，go 的首选方案就是 grpc 。

GRPC 是一个高性能、开源和通用的 RPC 框架，面向移动和 HTTP/2 设计。目前提供 C、Java 和 Go 语言版本，分别是：grpc, grpc-java, grpc-go. 其中 C 版本支持 C, C++, Node.js, Python, Ruby, Objective-C, PHP 和 C# 支持.

GRPC 基于 HTTP/2 标准设计，带来诸如双向流、流控、头部压缩、单 TCP 连接上的多复用请求等特。这些特性使得其在移动设备上表现更好，更省电和节省空间占用。

二、grpc的hello world

1.安装代码生成器。（必须）

//安装代码生成器
$ go install google.golang.org/protobuf/cmd/[email protected]
$ go install google.golang.org/grpc/cmd/[email protected]
//配置path 环境变量linux 系统
$ export PATH="$PATH:$(go env GOPATH)/bin"

2.编写代码

（1）编写.proto文件

首选新建一个项目，新建目录和proto文件如下

把项目初始化为go mod 项目

go mod init testgrpc

greeting.proto

syntax = "proto3";

package greeting_proto; // proto3中需要指明包名
option go_package = "./greeting_proto"; // proto3中需要指明go包名
// 定义Greeter服务，包括服务和函数
service Greeter {
  // Sends a greeting
  rpc SayHello (HelloRequest) returns (HelloReply) {}
  // Sends another greeting
  rpc SayHelloAgain (HelloRequest) returns (HelloReply) {}
}

// 请求数据的定义，包括对象和属性
message HelloRequest {
  string name = 1;
}

//  返回数据的定义，包括对象和属性
message HelloReply {
  string message = 1;
}

(2) 根据proto文件生成代码

$ protoc --go_out=. --go_opt=paths=source_relative --go-grpc_out=. --go-grpc_opt=paths=source_relative proto/greeting.proto

 

注意新生成的 两个go文件

(3) 编写service

 

server/main.go

package main

import (
   "context"
   "flag"
   "fmt"
   "log"
   "net"

   "google.golang.org/grpc"
   pb "testgrpc/greeting_proto"
)

var (
   port = flag.Int("port", 50051, "The server port")
)

// server is used to implement helloworld.GreeterServer.
type server struct {
   pb.UnimplementedGreeterServer
}
// SayHello implements GreeterServer
func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {
   log.Printf("Received: %v", in.GetName())
   return &pb.HelloReply{Message: "Hello " + in.GetName()}, nil
}

// SayHelloAgain implements GreeterServer
func (s *server) SayHelloAgain(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {
   log.Printf("Received: %v", in.GetName())
   return &pb.HelloReply{Message: "Hello again " + in.GetName()}, nil
}

func main() {
   flag.Parse()
   lis, err := net.Listen("tcp", fmt.Sprintf("localhost:%d", *port))
   if err != nil {
      log.Fatalf("failed to listen: %v", err)
   }
   s := grpc.NewServer()
   pb.RegisterGreeterServer(s, &server{})
   log.Printf("server listening at %v", lis.Addr())
   if err := s.Serve(lis); err != nil {
      log.Fatalf("failed to serve: %v", err)
   }
}

我们需要实现greeterServer

 

并且注册它到，开启的微服务中

 

（4）编写client

 

client/main.go

package main

import (
	"context"
	"flag"
	"log"
	"time"

	"google.golang.org/grpc"
	pb "testgrpc/greeting_proto"
)

const (
	defaultName = "world"
)

var (
	addr = flag.String("addr", "localhost:50051", "the address to connect to")
	name = flag.String("name", defaultName, "Name to greet")
)

func main() {
	flag.Parse()
	// Set up a connection to the server.
	conn, err := grpc.Dial(*addr, 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.
	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.GetMessage())
}

(5) 开启服务并调用

开启服务

 

调用服务：

 

三、第二节都干了什么

首先，用要创建的服务创建一个文件夹，如greeting。编写服务的proto服务定义文件。根据服务定义文件生成，go文件。第二个，实现服务端，注意实现的语法，和注册的过程第三，客户点调用，生成的文件中，提供了客户端，只需要传入，服务的ip端口，就可以像函数一样调用了。

单有几点需要，注意：

1.本程序中所有，客户端和服务端再一个项目中，对于微服务，十几甚至上百个服务的情况，这是不可能的。必定调用者，微服务是要分开的。

如何解决这个问题呢，有两种方案可以参考：

(1) 把 greeting_proto单独成一个项目（proto和生成的go文件）:

a.好处是处理简单,只要greeting_proto放到github就能直接使用

b.坏处是多了一个项目需要维护，每次编写完proto,要先上传到github然后才能，调试。时间周期会略长。

（2）把某个微服务的 client、proto 放到 微服务项目的一个 子目录下，服务端，和远程服务的调用都放到本项目下封装编写，其他项目依赖 client ：想使用本地类一样调用微服务：1.好处是可以像调用本地使用远程服务，不会出现 调用放 和服务方proto版本不一致问题。2.坏处是服务端需要被整个依赖，所以所以代码都会暴露再调用方。不能用github 会暴露代码所以需要，go get 需要特殊设置