go-micro安装及使用
go-micro安装
做了这么久的铺垫，接着让我们来进入主题，go-micro的学习，首先我们先来安装一下go-micro开发环境。安装步骤如下：
#安装go-micro
go get -u -v github.com/micro/go-micro
#安装工具集
go get -u -v github.com/micro/micro
#安装protobuf插件
go get -u github.com/golang/protobuf/{proto,protoc-gen-go}
go get -u github.com/micro/protoc-gen-micro
或者通过docker镜像安装：
$ docker pull microhq/micro
安装之后输入micro命令，显示如下就证明安装成功
接着我们来看一下go-micro的使用。
go-micro使用
首先我们先来创建一个go micro框架的项目，我们使用micro命令，可以创建微服务，web项目等，具体用法如下：
new Create a new Micro service by specifying a directory path relative to your $GOPATH
#创建 通过指定相对于$GOPATH的目录路径，创建一个新的微服务。
USAGE:
#用法
micro new [command options][arguments...]
#指定服务的命名空间
--namespace "go.micro" Namespace for the service e.g com.example
#服务类型，可以是微服务srv,或者web项目,或者api等
--type "srv" Type of service e.g api, fnc, srv, web
#服务的正式完整定义
--fqdn FQDN of service e.g com.example.srv.service (defaults to namespace.type.alias)
#别名是在指定时作为组合名的一部分使用的短名称 别名
--alias Alias is the short name used as part of combined name if specified
我们常用的就是创建微服务和web项目，如下：
创建一个web项目
micro new --type "web" micro/rpc/web
Creating service go.micro.web.web in /home/itcast/go/src/micro/rpc/web
.
#主函数
├── main.go
#插件文件
├── plugin.go
#被调用处理函数
├── handler
│ └── handler.go
#前端页面
├── html
│ └── index.html
#docker生成文件
├── Dockerfile
├── Makefile
└── README.md
#编译后将web端呼叫srv端的客户端连接内容修改为srv的内容
#需要进行调通
打开我们web项目下的main.go文件，内容如下：
package main
import (
"github.com/micro/go-log"
"net/http"
"github.com/micro/go-web"
"micro/rpc/web/handler"
)
func main() {
// 创建1个web服务
service := web.NewService(
//注册服务名
web.Name("go.micro.web.web"),
//服务的版本号
web.Version("latest"),
//！添加端口
web.Address(":8080"),
)
//服务进行初始化
if err := service.Init(); err != nil {
log.Fatal(err)
}
//处理请求 / 的路由 //当前这个web微服务的 html文件进行映射
service.Handle("/", http.FileServer(http.Dir("html")))
//处理请求 /example/call 的路由 这个相应函数 在当前项目下的handler
service.HandleFunc("/example/call", handler.ExampleCall)
//运行服务
if err := service.Run(); err != nil {
log.Fatal(err)
}
}
接着我们再来看一下我们重点需要操作的文件，handle.go,内容如下：
package handler
import (
"context"
"encoding/json"
"net/http"
"time"
"github.com/micro/go-micro/client"
//将srv中的proto的文件导入进来进行通信的使用
example "micro/rpc/srv/proto/example"
)
//相应请求的业务函数
func ExampleCall(w http.ResponseWriter, r *http.Request) {
// 将传入的请求解码为json
var request map[string]interface{}
if err := json.NewDecoder(r.Body).Decode(&request); err != nil {
http.Error(w, err.Error(), 500)
return
}
// 调用服务
//替换掉原有的服务名
//通过服务名和
exampleClient := example.NewExampleService("go.micro.srv.srv", client.DefaultClient)
rsp, err := exampleClient.Call(context.TODO(), &example.Request{
Name: request["name"].(string),
})
if err != nil {
http.Error(w, err.Error(), 500)
return
}
// we want to augment the response
response := map[string]interface{}{
"msg": rsp.Msg,
"ref": time.Now().UnixNano(),
}
// encode and write the response as json
if err := json.NewEncoder(w).Encode(response); err != nil {
http.Error(w, err.Error(), 500)
return
}
}
创建微服务
$micro new --type "srv" t1/t1
#"srv" 是表示当前创建的微服务类型
#micro是相对于go/src下的文件夹名称 可以根据项目进行设置
#srv是当前创建的微服务的文件名
Creating service go.micro.srv.srv in /home/itcast/go/src/t1/t1
.
#主函数存放位置
├── main.go
#插件
├── plugin.go
#服务提供函数的实现
├── handler
│ └── example.go
#订阅服务
├── subscriber
│ └── example.go
#proto协议
├── proto/example
│ └── example.proto
#docker生成文件
├── Dockerfile
#编译文件
├── Makefile
└── README.md
#插件提示，已安装，可忽略
download protobuf for micro:
brew install protobuf
go get -u github.com/golang/protobuf/{proto,protoc-gen-go}
go get -u github.com/micro/protoc-gen-micro
compile the proto file example.proto:
cd /home/itcast/go/src/micro/rpc/srv
protoc --proto_path=. --go_out=. --micro_out=. proto/example/example.proto
我们来看一下微服务中的main.go文件：
package main
import (
"github.com/micro/go-micro/util/log"
"github.com/micro/go-micro"
"t1/t1/handler"
"t1/t1/subscriber"
t1 "t1/t1/proto/t1"
)
func main() {
// 创建一个micro服务
service := micro.NewService(
micro.Name("go.micro.srv.t1"),
micro.Version("latest"),
)
// 初始化服务
service.Init()
// 注册服务
t1.RegisterT1Handler(service.Server(), new(handler.T1))
// 注册一个发布器
micro.RegisterSubscriber("go.micro.srv.t1", service.Server(), new(subscriber.T1))
// 注册一个函数到发布器
micro.RegisterSubscriber("go.micro.srv.t1", service.Server(), subscriber.Handler)
// 运行服务
if err := service.Run(); err != nil {
log.Fatal(err)
}
}
默认情况下，go micro框架使用的是自己封装的rpc通信，这里我们可以替换成grpc，代码如下：
package main
import (
"github.com/micro/go-micro/util/log"
"github.com/micro/go-micro"
"t1/t1/handler"
"t1/t1/subscriber"
"github.com/micro/go-grpc"//go micro内嵌了grpc框架
t1 "t1/t1/proto/t1"
)
func main() {
// 创建一个micro服务
service := grpc.NewService(
micro.Name("go.micro.srv.t1"),
micro.Version("latest"),
)
// 初始化服务
service.Init()
// 注册服务
t1.RegisterT1Handler(service.Server(), new(handler.T1))
// 注册一个发布器
micro.RegisterSubscriber("go.micro.srv.t1", service.Server(), new(subscriber.T1))
// 注册一个函数到发布器
micro.RegisterSubscriber("go.micro.srv.t1", service.Server(), subscriber.Handler)
// 运行服务
if err := service.Run(); err != nil {
log.Fatal(err)
}
}
服务发现：
在go-micro包中，共有4种注册实现consul、gossip、mdns、memory，前两个都是基于hashicorp公司的协议，mdns则是基于组网广播实现，memory则是本地实现。
consul 依赖hashicorp的组件，但是功能强大、完整
gossip 基于SWIM协议广播，零依赖
mdns 轻量、零依赖，但是对环境有要求，某些环境不支持mdns的无法正常使用
memory 本地解决方案，不可跨主机访问
另外在go-plugins中有其它注册实现，比如etcd、eureka、k8s、nats、zk等等
大体解释下接口中每个方法的作用
- Init 初始化
- Options 获取配置选项
- Register 注册服务
- Deregister 卸载服务
- GetService 获取指定服务
- ListServices 列出所有服务
- Watch watcher 负责侦听变动
- String 注册信息转成字符串描述
package main
import (
"github.com/micro/go-micro/util/log"
"github.com/micro/go-micro"
"t1/t1/handler"
"t1/t1/subscriber"
"github.com/micro/go-grpc"
"github.com/micro/go-micro/registry/consul"
"github.com/micro/go-micro/registry"
t1 "t1/t1/proto/t1"
)
func main() {
//初始化服务发现
reg := consul.NewRegistry(func(options *registry.Options) {
options.Addrs = []string{
"192.168.137.130:8500",
}
})
// 创建一个micro服务
service := grpc.NewService(
micro.Name("go.micro.srv.t1"),
micro.Version("latest"),
micro.Registry(reg),
)
// 初始化服务
service.Init()
// 注册服务
t1.RegisterT1Handler(service.Server(), new(handler.T1))
// 注册一个发布器
micro.RegisterSubscriber("go.micro.srv.t1", service.Server(), new(subscriber.T1))
// 注册一个函数到发布器
micro.RegisterSubscriber("go.micro.srv.t1", service.Server(), subscriber.Handler)
// 运行服务
if err := service.Run(); err != nil {
log.Fatal(err)
}
}
标题：go-micro安装及使用
作者：老白阳
文章地址：https://oldbaiyang.com/articles/2022/05/29/1653803208023.html
-------------------------------------------------------------------------------
老白阳的博客
老白阳的YouTub频道
老白阳的B站频道
老白阳的谷歌博客
Comments
Post a Comment