go proto 微服务

brew install consulCopy

go get google.golang.org/grpc
go get github.com/golang/protobuf/protoc-gen-go
go get github.com/micro/go-micro //Micro 框架
go get github.com/micro/protoc-gen-micro //protoc micro插件
go get github.com/micro/micro //micro工具包Copy

#移动到src目录
sudo mv protoc-3.11.4-osx-x86_64.zip /usr/local/src 
#重命名
mv protoc-3.11.4-osx-x86_64.zip protoc-3.11.4.zip
#解压
unzip protoc-3.11.4.zip
#创建软连，只要能把protoc放入可执行环境中即可，随便哪个目录啦
ln -s /usr/local/src/protoc-3.11.4/bin/protoc $GOPATH/bin/protocCopy

syntax = "proto3";

service User {
  rpc Hello(Request) returns (Response) {}
  rpc Age(AgeRequest)returns(AgeResponse){}
}

message AgeRequest {
}

message AgeResponse{
  int32 age = 10;
}

message Request {
  string name = 1;
}

message Response {
  string msg = 1;
}Copy

protoc -I ./protos/ --go_out=./message user.proto --micro_out=./message/ ./protos/user.proto
#自动生成user.pb.go 和user.pb.micro.goCopy

package main


import (
    "context"
    proto "demo/go-micro/message"
    "fmt"
    micro "github.com/micro/go-micro"
)

type User struct{}

func (u *User) Hello(ctx context.Context, req *proto.Request, res *proto.Response) error {
    res.Msg = "Hello " + req.Name
    return nil
}

func (u *User) Age(ctx context.Context, request *proto.AgeRequest, response *proto.AgeResponse) error {
    response.Age = 18
    return nil
}

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

    service.Init()

    proto.RegisterUserHandler(service.Server(), new(User))

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

package main

import (
    "context"
    "fmt"
    proto "demo/go-micro/message"
    micro "github.com/micro/go-micro"
    "strconv"
)

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

    user := proto.NewUserService("user", service.Client())

    //调用Hello方法
    res, err := user.Hello(context.TODO(), &proto.Request{Name: "User from client"})
    if err != nil {
        fmt.Println(err)
    }
    fmt.Println(res.Msg)

    //调用Age方法
    resAge, errAge := user.Age(context.TODO(), &proto.AgeRequest{})
    if errAge != nil {
        fmt.Println(errAge)
    }

    fmt.Println("我的年纪是:" + strconv.Itoa(int(resAge.Age)))
}Copy

consul agent -devCopy

cd server
go run main.goCopy

cd client
go run main.go
#输出： Hello User from client
#输出： 我的年纪是:18Copy

micro
#打开 http://localhost:8082/registryCopy