go-micro开启grpc

开启go mod

1
2
3
4
go env -w GO111MODULE=on

#阿里云
go env -w GOPROXY=https://mirrors.aliyun.com/goproxy/,direct

安装protobuf编译器

官网教程

必须保证proto的版本>=3

1
2
3
sudo apt update
sudo apt install protobuf-compiler
protoc --version  # Ensure compiler version is 3+

安装protoc-grpc插件

官网教程

1
2
go install google.golang.org/protobuf/cmd/protoc-gen-go@v1.28
go install google.golang.org/grpc/cmd/protoc-gen-go-grpc@v1.2

配置环境变量

这一步主要是使用protoc-gen-go

1
2
3
4
5
#在.bashrc文件最下面添加
export PATH="$PATH:$(go env GOPATH)/bin"

#shell里运行
source ~/.bashrc

https://github.com/go-micro/generator

micro框架（V4版本）

官网网址：https://github.com/go-micro
包含

  • Framework - The core Go framework for development
  • Generator - Protobuf code generation to use with protoc
  • Examples - Individual examples for use cases & features
  • Dashboard - Browser based access for Go Micro services
  • Plugins - Implementations for redis, kafka, etcd, gRPC..
  • Demo - A full feaured demo app
  • CLI - Command line interfac

安装protobuf编译器

1
2
3
sudo apt update
sudo apt install protobuf-compiler
protoc --version  # Ensure compiler version is 3+

安装proto-micro插件

1
2
go install google.golang.org/protobuf/cmd/protoc-gen-go@latest
go install github.com/go-micro/generator/cmd/protoc-gen-micro@latest

生成micro文件

1
protoc --proto_path=. --go_out=. --micro_out=. *.proto

example

1.准备greeter.proto文件

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
syntax = "proto3";

package greeter;
option go_package = "/proto;greeter";

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

message Request {
	string name = 1;
}

message Response {
	string msg = 1;
}

2.生成code

1
protoc --proto_path=. --micro_out=. --go_out=. greeter.proto

Plugins注册到consul

(1)查看文件https://github.com/go-micro/plugins/blob/main/v4/registry/consul/go.mod
(2)导入包名github.com/go-micro/plugins/v4/registry/consul
(3)代码示例

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
package main

import (
    "time"
    "github.com/go-micro/plugins/v4/registry/consul"
    "go-micro.dev/v4"
    "filestore-server/service/account/handler"
    proto "filestore-server/service/account/proto"
)

func main() {
    registry := consul.NewRegistry() //consul

    // 创建服务时指定注册中心
    service := micro.NewService(
        micro.Name("go.micro.service.account"),
        micro.RegisterTTL(time.Second*10),      // 声明超时时间, 避免consul不主动删掉已失去心跳的服务节点
		micro.RegisterInterval(time.Second*5),
        micro.Registry(registry),
    )

    service.Init()

    //注册服务
    proto.RegisterUserServiceHandler(service.Server(), new(handler.User))

    //开启服务
    if err := service.Run(); err != nil {
        panic(err)
    }
}

micro使用grpc协议

https://github.com/go-micro/plugins/blob/main/v4/server/grpc/README.md

微服务 > grpc配置
#微服务
go-micro开启grpc
http://example.com/2023/12/05/grpc/go语言开启grpc/
作者
Mrxiad
发布于
2023年12月5日
许可协议