入门Go Micro

 go-mrcro 是一个可插入RPC分布式系统开发的框架。它支持{json,proto}-rpc的编码方式.可以使用consul 或者其余方式的服务发现,默认是用consul.提供随机散列的负载均衡.

目录结构

client.go

service.go

proto/greeter.proto

建立一个greeter.proto

syntax = "proto3";

service Greeter {
	rpc Hello(HelloRequest) returns (HelloResponse) {}
}

message HelloRequest {
	string name = 1;
}

message HelloResponse {
	string greeting = 2;
}复制代码

cd proto 进入到proto文件啊下,执行:

protoc --proto_path=$GOPATH/src:. --micro_out=. --go_out=. greeter.proto复制代码

生成greeter.micro.go , greeter.pb.go

服务发现

装好consul

brew install consul

运行consul

consul agent -dev -advertise=127.0.0.1

若是您想使用etcd代替consul ，导入插件并在二进制文件中设置命令行标志。

import ( _ "github.com/micro/go-plugins/registry/etcd" )

service --registry=etcd --registry_address=127.0.0.1:2379

简单服务 service.go

package main

import (
	"context"
	"fmt"

	micro "github.com/micro/go-micro"
	proto "github.com/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
}

func main() {
	// Create a new service. Optionally include some options here.
	service := micro.NewService(
		micro.Name("greeter"),
	)

	// Init will parse the command line flags.
	service.Init()

	// Register handler
	proto.RegisterGreeterHandler(service.Server(), new(Greeter))

	// Run the server
	if err := service.Run(); err != nil {
		fmt.Println(err)
	}
}复制代码

简单客户端: client.go

package main

import (
	"context"
	"fmt"

	micro "github.com/micro/go-micro"
	proto "github.com/micro/examples/service/proto"
)


func main() {
	// Create a new service. Optionally include some options here.
	service := micro.NewService(micro.Name("greeter.client"))
	service.Init()

	// Create new greeter client
	greeter := proto.NewGreeterService("greeter", service.Client())

	// Create new greeter 
        clientgreeter := proto.NewGreeterService("greeter", service.Client())
        ticker := time.NewTicker(time.Second)
        for{   
              // Call the greeter   
            rsp, err := greeter.Hello(context.TODO(), &proto.HelloRequest{Name: "lizhongxuan !!!"})   
            if err != nil {      
                fmt.Println(err)   
                }   
            // Print response   
            fmt.Println(rsp.Greeting)   
            <- ticker.C
        }

	// Print response
	fmt.Println(rsp.Greeting)
}复制代码

运行

go run client.go复制代码

能够修更名字,运行多个试试,看下负载均衡.当一个服务都没有的时候,会panic.