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框架的项目,我们使用micro命令,可以创建微服务,web项目等,具体用法如下:
micro new [command options][arguments...]
new #创建 通过指定相对于$GOPATH的目录路径,创建一个新的微服务。
#指定服务的命名空间
--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
创建服务
- ==micro new —type srv bj38 —— 创建一个微服务项目!==
上面一条指令会出现下图所示文件。
- main.go : 项目的入口文件。
- handler/: 处理 grpc 实现的接口。对应实现接口的子类,都放置在 handler 中。
- proto/: 预生成的 protobuf 文件。
- Dockerfile:部署微服务使用的 Dockerfile
- Makefile:编译文件。—— 快速编译 protobuf 文件。 直接使用make proto不用之前那个很长的
查看创建的项目
- makefile 编译 proto
- 查看 make proto生 成 的 文件:
- xxx.pb.go
- xxx.micro.go
- RegisterBj38Handler()【168行】服务端用 ———— 对应 grpc RegisterXXXService()
- NewBj38Service()【47行】客户端用 —— 对应 grpc NewXXXClient() —— 对应自己封装的 IintXXX
查看 main.go
func main() {
// New Service -- 初始化服务器对象.
service := micro.NewService(
micro.Name("go.micro.srv.bj38"), // 服务器名
micro.Version("latest"), // 版本
)
// Initialise service 与newService作用一致,但优先级高.后续代码运行期,初始化才有使用的必要.
//service.Init()
// Register Handler --- 注册服务
bj38.RegisterBj38Handler(service.Server(), new(handler.Bj38))
// Register Struct as Subscriber -- redis 发布订阅.
//micro.RegisterSubscriber("go.micro.srv.bj38", service.Server(), new(subscriber.Bj38))
// Register Function as Subscriber
//micro.RegisterSubscriber("go.micro.srv.bj38", service.Server(), subscriber.Handler)
// Run service --- 运行服务
if err := service.Run(); err != nil {
log.Fatal(err)
}
}
创建 micro 服务
命令:micro new —type srv test66
框架默认自带服务发现:mdns。
使用consul服务发现:
1. 初始consul服务发现: consulReg := consul.NewRegistry()
2. 在 NewService 中 添加 服务。 micro.Registry(consulReg ),使用 go-micro框架 创建 客户端
补充 http 相关知识:
- 路由器:资源分发
- 路由:请求分发。
- service.HandleFunc(“/test77/call”, handler.Test77Call)
- 将 /test77/call 这个请求,通过 回到函数 Test77Call() 处理。
- service.HandleFunc(“/test77/call”, handler.Test77Call)
URL:
- 组成:https://ip+port/资源路径
- https://ip+port/ 找到 pc机,找到 对应进程
- 资源路径:在代码中,称之为路由。
- “/ ” : 代表 主机上进程 对应的默认资源。
- 组成:https://ip+port/资源路径
GET —— 查 —— 获取数据
- Post —— 增 —— 增加数据
- Put —— 改 —— 更新数据
-
使用 gin 框架创建最简单的web
func main() {
// 1. 初始化路由 -- 官网:初始化 web 引擎
router := gin.Default()
// 2. 做路由匹配
router.GET("/", func(context *gin.Context) {
context.Writer.WriteString("hello world!")
})
// 3. 启动运行
router.Run(":8080")
}
gin 框架的客户端 与 微服务 对接
- 封装回调函数, 给 router.Get() 设置
- 拷贝 微服务的 “ 密码本” protobuf 到 web 中
- 修改 protobuf文件的 包名。 test66别名 “test66web/proto/test66”
- 实现 回调函数:
- 初始化客户端。 microClient := NewTeset66Sevice(服务名,client.DefaultClient)
- 调用远程服务。 resp, err := microClient.Call(context.TODO, &test66.Request{ })
- 将 返回的 数据, 显示到 浏览器。 context.Writer.WriteString(resp.Msg); ```go package main
import ( “github.com/gin-gonic/gin” “fmt” test66 “test66web/proto/test66” // test66 为包的别名. “github.com/micro/go-micro/client” “context” )
func CallRemote(ctx *gin.Context) { // 1. 初始化客户端 microClient := test66.NewTest66Service(“go.micro.srv.test66”, client.DefaultClient) fmt.Println()
// 2. 调用远程服务
resp, err := microClient.Call(context.TODO(), &test66.Request{
Name:"xiaowang",
})
if err != nil {
fmt.Println("call err:", err)
return
}
// 为了方便查看, 在打印之前将结果返回给浏览器
ctx.Writer.WriteString(resp.Msg)
fmt.Println(resp, err)
}
func main() { // 1. 初始化路由 — 官网:初始化 web 引擎 router := gin.Default()
// 2. 做路由匹配
router.GET("/", CallRemote)
// 3. 启动运行
router.Run(":8080")
指定 consul 服务发现到 go-micro 服务和 gin 框架客户端中
- mdns服务发现: (组播)支持的服务,必须是本地服务, 局域网内的服务。
修改 go-micro 微服务
- consulReg := consul.NewRegistry() 初始化 consul服务发现
添加 服务 service := micro.NewService(
micro.Name(“go.micro.srv.test66”), micro.Registry(consulReg),
micro.Version(“latest”), )-
修改 gin 框架 web服务 (客户端)
consulReg := consul.NewRegistry() 初始化 consul服务发现
- microClinet := micro.NewService( micro.Registry(consulReg ) )
- test66.NewTest66Service(“服务名”,microClinet.Client() )
测试:浏览器键入: 192.168.6.108:8080 ——> hello xiaowang
REST
REST全称是Representational State Transfer: 表述性 状态 转义
本质:一种代码设计风格。 web开发中常用。——遵循风格!
使用:一般以 http 4 种请求方法, 来确定对某一资源(URI:标识符。名词)的 固定操作。
- 获取数据:GET
- 添加数据:POST
- 修改数据:PUT
删除数据:Delete
满足 REST 设计风格的, 称之为 “RESTful”<br />
MVC
是一种常见的 “代码组织架构”, 可以在开发中,对数据进行处理并解耦。
- model:模型。 处理数据库相关的文件。
- veiw:视图。处理显示相关的文件。 网站:html
- controller:控制器。处理具体业务! 联动 m 和 v
- MVC 与语言无关!是常见的 代码组织架构。