背景

go-micro给我们提供了一个非常便捷的方式来快速搭建微服务，而且并不需要提前系统了解micro，下面用一个简单的示例来快速实现一个服务。

创建Proto文件

因为我们要做微服务，那么就一定有服务端和客户端，这两个端通过什么格式进行内容传输，就涉及到了序列化，比较主流的序列化协议就是JSON和Protobuf，因为Protobuf是以二进制传输的，体积比较小，所以传输速度也相对较快，今天就以protobuf来进行演示。

greeter.protoGreeter
syntax = "proto3";
package protos;

service Greeter {
    rpc Hello (Request) returns (Response) {
    };
}

message Request {
    string name = 1;
}

message Response {
    string greeting = 2;
}

生成Go文件

protoc
$ protoc
Usage: protoc [OPTION] PROTO_FILES
Parse PROTO_FILES and generate output based on the options given:
  -IPATH, --proto_path=PATH   Specify the directory in which to search for
                              imports.  May be specified multiple times;
                              directories will be searched in order.  If not
                              ……

可以通过官方文档提示的命令进行安装。

go get github.com/micro/protoc-gen-micro/v2
greeter.proto
protoc --proto_path=./protos --micro_out=./protos --go_out=./protos ./protos/greeter.proto
--proto_path--micro_out.go--go_out.go

可以根据需求自定义输出目录，我这边输出到了protos目录，现在可以看到protos目录中生成了两个文件。

greeter.pb.go
greeter.pb.micro.go

实现服务

因为刚才已经通过protobuf定义了服务的接口，所以接下来需要实现对应的服务。

第一步，实现定义的服务接口

greeter.pb.micro.gogreeter.protoGreeterHandler
type GreeterHandler interface {
	Hello(context.Context, *Request, *Response) error
}

我们需要先实现该接口，接下来创建server.go文件，定义结构体Greeter，并实现Hello方法。

type Greeter struct {
}

func (g *Greeter) Hello(context context.Context, req *protos.Request, rsp *protos.Response) error {
	rsp.Greeting = "Hello " + req.Name
	return nil
}
greeter.bp.goHello

第二步，初始化服务

greeter
func main() {
	service := micro.NewService(
		micro.Name("greeter"),
	)
	service.Init()
}
micro.NewServiceservice.Init

第三步，注册服务到handler

func main() {
	service := micro.NewService(
		micro.Name("greeter"),
	)
	service.Init()
	err := protos.RegisterGreeterHandler(service.Server(), new(Greeter))
	if err != nil {
		fmt.Println(err)
	}
}

第四步，将服务跑起来

	if err := service.Run(); err != nil {
		fmt.Println(err)
	}

完整代码如下

package main

import (
	"context"
	"fmt"

	"github.com/micro/go-micro/v2"
)

type Greeter struct {
}

func (g *Greeter) Hello(context context.Context, req *Request, rsp *Response) error {
	rsp.Greeting = "Hello " + req.Name
	return nil
}

func main() {
	service := micro.NewService(
		micro.Name("greeter"),
	)
	service.Init()

	err := protos.RegisterGreeterHandler(service.Server(), new(Greeter))
	if err != nil {
		fmt.Println(err)
	}

	if err := service.Run(); err != nil {
		fmt.Println(err)
	}
}

现在将服务端跑起来。

$ go run server.go
2020-03-27 11:28:20 Starting [service] greeter
2020-03-27 11:28:20 Server [grpc] Listening on [::]:63763
2020-03-27 11:28:20 Registry [mdns] Registering node: greeter-8afc1183-a159-4473-a567-c13b83d1d75c

实现客户端

client.go
func main() {
	service := micro.NewService(micro.Name("greeter.client"))
	service.Init()

	greeter := protos.NewGreeterService("greeter", service.Client())
	rsp, err := greeter.Hello(context.TODO(), &protos.Request{Name: "pingye"})
	if err != nil {
		fmt.Println(err)
	}
	fmt.Println(rsp.Greeting)
}
Hello pingye
$ go run client.go
Hello pingye

服务注册到了哪里？

greeterRegistry
2020-03-27 11:28:20 Starting [service] greeter
2020-03-27 11:28:20 Server [grpc] Listening on [::]:63763
2020-03-27 11:28:20 Registry [mdns] Registering node: greeter-8afc1183-a159-4473-a567-c13b83d1d75c

Registry是go-micro的注册模块，作用是将服务注册到某个介质，以方便客户端使用。注册模块默认支持cache、consul、etcd、k8s、mdns、memory等多种介质，默认使用的是mdns。

var (
	DefaultRegistry = NewRegistry()

	// Not found error when GetService is called
	ErrNotFound = errors.New("service not found")
	// Watcher stopped error when watcher is stopped
	ErrWatcherStopped = errors.New("watcher stopped")
)

mdns主要用于在没有传统DNS服务器的情况下，在局域网中实现主机之间的发现与通讯，它遵从DNS协议。

Go语言组件示例开源库，欢迎star https://github.com/EnochZg/golang-examples