介绍
micro 是一个用来开发cloud native application的程序工具集,采用的是微服务架构,使用go语言编写。
micro主要包括:
- toolkits
- api - api 网关,服务的唯一入口点
- bot - Slack and hipchat bot. CLI and ChatOps via messaging.
- cli 命令行工具用于和整个系统交互
- new - 一个微服务代码模板生成工具
5 . web - web的控制面板,通过它可以和相应的service进行交互、查询
- framework
即go-micro的部分,一个插件式的基于grpc的分布式开发框架 - plugin - micro的插件
几个部分。
本次的代码阅读主要研究micro的toolkits和framework部分
go-micro
go-micro
├── broker
├── client // service的对外接口
├── cmd
├── codec //编解码器
├── errors //Error接口的实现,提供返回error信息
├── function.go // https://micro.mu/blog/2017/06/06/functions.html
├── function_test.go
├── go-micro.go //go-micro 对外服务接口(service,和相关度 Pub/Sub接口)
├── go-micro.png
├── LICENSE
├── metadata
├── options.go //service的配置Option实现
├── publisher.go //依赖注入Client
├── README.md
├── registry //服务注册器
├── selector //服务选择器(服务发现的负载均衡)
├── server //service 的内部server
├── service.go //封装service的实现
├── service_test.go
├── transport //用于实现点对点通信
├── wrapper.go
└── wrapper_test.go
从上面可以看出go-micro 是一个编写微服务的框架,一个service包括接收请求的server和对外发送请求的client。通信的方式包括点对点的同步通信(transport)和异步通信(Broker)通过事件的pub/sub的方式提供。
设计上把一个类要聚合的内容通过Options的方式替换出去,每一个聚合的对象都是一个Option,然后每个Option都是可以设置的,只要满足了特定的接口即可。
例如:Service 的Options定义
type Options struct {
Broker broker.Broker
Cmd cmd.Cmd
Client client.Client
Server server.Server
Registry registry.Registry
Transport transport.Transport
....
}
具体的每一个项目都是一个Option例如Broker、Cmd、Client、而且每一个Option都是接口形式的定义,例如:
type Broker interface {
Options() Options
Address() string
Connect() error
Disconnect() error
Init(...Option) error
Publish(string, *Message, ...PublishOption) error
Subscribe(string, Handler, ...SubscribeOption) (Subscriber, error)
String() string
}
这样就实现了每一个模块都是可以替换的实现。也就对应了go-micro’s pluggable的设计理念。通过面向接口编程的方式,搭建了整个库的骨架。
组件
一个大概的micro图样。
一个Service 包括Server和Client。Server包括Register、Transport、Broker。Client包括Broker、Transport、Register、Selector。
Register:服务的注册于反注册
Transport : 点对点的同步通信支持
Broker : 异步通信支持(通过事件的 Publicate 和 Subscribe)
Selector : 发现服务 和 选取服务时的负载均衡。
靠这些组件的组合来对外提供Services.