Go Micro（3）——開發(fā)微服務(wù)
這是一個高等級的說明：怎樣使用 go-micro 來編寫微服務(wù)箱玷，如果你想學(xué)習(xí)更多微服務(wù)的知識以及Micro的整體架構(gòu)，參考以前的文章汰蓉。
什么是 Go Micro?
Go Micro 是一個插件化的基礎(chǔ)框架喜鼓，基于此可以構(gòu)建微服務(wù)。Micro 的設(shè)計哲學(xué)是『可插拔』的插件化架構(gòu)溜歪。在架構(gòu)之外，它默認(rèn)實現(xiàn)了 consul 作為服務(wù)發(fā)現(xiàn)许蓖，通過 http 進行通信蝴猪，通過 protobuf 和 json 進行編解碼。我們一步步深入下去膊爪。
Go Micro 是：
- 一個用
Golang編寫的包 - 一系列插件化的接口定義
- 基于
RPC
Go Micro 為下面的模塊定義了接口：
- 服務(wù)發(fā)現(xiàn)
- 編解碼
- 服務(wù)端自阱、客戶端
- 訂閱、發(fā)布消息
更詳細(xì)的說明可以在這里看到米酬。
Go Micro 從一年多以前開始開發(fā)沛豌，最初只是個人需求，很快我發(fā)現(xiàn)這對那些編寫微服務(wù)的程序員會有很大的價值赃额。它基于我在不同的技術(shù)公司如 google 和 hailo 的開發(fā)經(jīng)驗編寫而成加派。
就像前面提到的，Go Micro 是一個 golang 編寫的插件化架構(gòu)爬早，專注于提供底層的接口定義和基礎(chǔ)工具哼丈。這些接口可以接納各種實現(xiàn)启妹。比如 Registry 接口定義了服務(wù)發(fā)現(xiàn)的接口筛严，默認(rèn)采用了 consul 作為服務(wù)發(fā)現(xiàn)的實現(xiàn)，但也可以采用其他實現(xiàn)比如 etcd 和 zookeeper 等饶米，只要能滿足接口桨啃，就可以使用。
插件化的架構(gòu)意味著如果你想替換底層的實現(xiàn)檬输，你不需要修改任何底層的代碼照瘾。
編寫一個服務(wù)
如果你想直接看代碼，看這里：examples/service
頂層的 Service 接口是構(gòu)建服務(wù)的主要組件丧慈。它把底層的各個包需要實現(xiàn)的接口析命，做了一次封裝。
type Service interface {
Init(...Option)
Options() Options
Client() client.Client
Server() server.Server
Run() error
String() string
}
初始化
一個服務(wù)可以這樣創(chuàng)建 micro.NewService
import "github.com/micro/go-micro"
service := micro.NewService()
參數(shù)可以在創(chuàng)建時傳入
service := micro.NewService(
micro.Name("greeter"),
micro.Version("latest"),
)
所有可選的參數(shù)設(shè)置可以在這里看到
Go Micro 也提供了讀取命令行的方式
import (
"github.com/micro/cli"
"github.com/micro/go-micro"
)
service := micro.NewService(
micro.Flags(
cli.StringFlag{
Name: "environment",
Usage: "The environment",
},
)
)
通過 service.Init 來解析參數(shù)逃默，附加的處理可以通過 micro.Action 解決
service.Init(
micro.Action(func(c *cli.Context) {
env := c.StringFlag("environment")
if len(env) > 0 {
fmt.Println("Environment set to", env)
}
}),
)
Go Micro 提供了提供了預(yù)定義的參數(shù)鹃愤，也會被 service.Init 解析，這里可以看到所有的 flag
定義 API
我們使用 protobuf 文件來定義服務(wù)的 API完域，這是一種方便且嚴(yán)格的定義方式软吐，協(xié)議將會提供給服務(wù)端和客戶端。下面是一個協(xié)議的例子：greeter.proto
syntax = "proto3";
service Greeter {
rpc Hello(HelloRequest) returns (HelloResponse) {}
}
message HelloRequest {
string name = 1;
}
message HelloResponse {
string greeting = 2;
}
這里定義了一個服務(wù)叫做 Greeter吟税，它提供一個接口叫 Hello凹耙，它接受 HelloRequest 的請求姿现，返回 HelloResponse。
生成 API 接口
我們使用 protoc 和 proto-gen-go 這兩個工具來生成代碼肖抱，Go Micro 也會生成客戶端代碼备典，減少工作量，這里需要使用我們 fork 并修改過的 github.com/micro/protobuf意述，與原始版本的區(qū)別是熊经，fork 版本能生成客戶端代碼
go get github.com/micro/protobuf/{proto,protoc-gen-go}
protoc --go_out=plugins=micro:. greeter.proto
生成的代碼可以在 handler 中引用相應(yīng)的包進行使用，下面是生成的一部分代碼
type HelloRequest struct {
Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}
type HelloResponse struct {
Greeting string `protobuf:"bytes,2,opt,name=greeting" json:"greeting,omitempty"`
}
// Client API for Greeter service
type GreeterClient interface {
Hello(ctx context.Context, in *HelloRequest, opts ...client.CallOption) (*HelloResponse, error)
}
type greeterClient struct {
c client.Client
serviceName string
}
func NewGreeterClient(serviceName string, c client.Client) GreeterClient {
if c == nil {
c = client.NewClient()
}
if len(serviceName) == 0 {
serviceName = "greeter"
}
return &greeterClient{
c: c,
serviceName: serviceName,
}
}
func (c *greeterClient) Hello(ctx context.Context, in *HelloRequest, opts ...client.CallOption) (*HelloResponse, error) {
req := c.c.NewRequest(c.serviceName, "Greeter.Hello", in)
out := new(HelloResponse)
err := c.c.Call(ctx, req, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// Server API for Greeter service
type GreeterHandler interface {
Hello(context.Context, *HelloRequest, *HelloResponse) error
}
func RegisterGreeterHandler(s server.Server, hdlr GreeterHandler) {
s.Handle(s.NewHandler(&Greeter{hdlr}))
}
實現(xiàn) handler
服務(wù)端需要注冊 handler 來處理請求欲险，一個 handler 是一個這樣的方法：
func(ctx context.Context, req interface{}, rsp interface{}) error
正如上面看到的镐依，一個 handler 實現(xiàn)了 API 協(xié)議中定義的接口
type GreeterHandler interface {
Hello(context.Context, *HelloRequest, *HelloResponse) error
}
這里是一個 Greeter 的 handler 實現(xiàn)
import proto "github.com/micro/micro/examples/service/proto"
type Greeter struct{}
func (g *Greeter) Hello(ctx context.Context, req *proto.HelloRequest, rsp *proto.HelloResponse) error {
rsp.Greeting = "Hello " + req.Name
return nil
}
handler 需要注冊到某個服務(wù)
service := micro.NewService(
micro.Name("greeter"),
)
proto.RegisterGreeterHandler(service.Server(), new(Greeter))
運行服務(wù)
服務(wù)可以直接調(diào)用 server.Run() 來運行，這會讓服務(wù)監(jiān)聽一個隨機端口天试，這個調(diào)用也會讓服務(wù)將自身注冊到注冊器槐壳，當(dāng)服務(wù)停止運行時，會在注冊器注銷自己喜每。
完整的服務(wù)端
package main
import (
"log"
"github.com/micro/go-micro"
proto "github.com/micro/go-micro/examples/service/proto"
"golang.org/x/net/context"
)
type Greeter struct{}
func (g *Greeter) Hello(ctx context.Context, req *proto.HelloRequest, rsp *proto.HelloResponse) error {
rsp.Greeting = "Hello " + req.Name
return nil
}
func main() {
service := micro.NewService(
micro.Name("greeter"),
micro.Version("latest"),
)
service.Init()
proto.RegisterGreeterHandler(service.Server(), new(Greeter))
if err := service.Run(); err != nil {
log.Fatal(err)
}
}
注意务唐，服務(wù)發(fā)現(xiàn)機制需要首先運行起來，這樣服務(wù)才能注冊到注冊器中带兜，才能被客戶端發(fā)現(xiàn)枫笛。
編寫客戶端
client 包用于向服務(wù)端發(fā)起請求，當(dāng)你創(chuàng)建一個服務(wù)刚照，客戶端可以調(diào)用的接口已經(jīng)自動生成了
調(diào)用上面的服務(wù)可以用下面的客戶端代碼
/ create the greeter client using the service name and client
greeter := proto.NewGreeterClient("greeter", service.Client())
// request the Hello method on the Greeter handler
rsp, err := greeter.Hello(context.TODO(), &proto.HelloRequest{
Name: "John",
})
if err != nil {
fmt.Println(err)
return
}
fmt.Println(rsp.Greeter)
proto.NewGreeterClient 就是我們剛才生成的代碼刑巧，根據(jù)服務(wù)名稱發(fā)送請求。
完整的示例可以在這里看到：go-micro/examples/service
