本文共计1414个文字，预计阅读时间需要6分钟。

Go微服务框架go-micro架构学习（源码分析），Go语言社区，Golang程序员社群+产品团队的小项目，从立项到上线，随时间和需求不断扩展，将越来越复杂，最终变成一个大项目。

go微服务框架go-micro架构学习(源码分析),Go语言社区,Golang程序员人脉社

产品嘴里的一个小项目，从立项到开发上线，随着时间和需求的不断激增，会越来越复杂，变成一个大项目，如果前期项目架构没设计的不好，代码会越来越臃肿，难以维护，后期的每次产品迭代上线都会牵一发而动全身。项目微服务化，松耦合模块间的关系，是一个很好的选择，随然增加了维护成本，但是还是很值得的。 

微服务化项目除了稳定性我个人还比较关心的几个问题：

     一: 服务间数据传输的效率和安全性。

     二: 服务的动态扩充，也就是服务的注册和发现，服务集群化。

     三: 微服务功能的可订制化，因为并不是所有的功能都会很符合你的需求，难免需要根据自己的需要二次开发一些功能。

go-micro是go语言下的一个很好的rpc微服务框架，功能很完善，而且我关心的几个问题也解决的很好：

     一：服务间传输格式为protobuf，效率上没的说，非常的快，也很安全。

     二：go-micro的服务注册和发现是多种多样的。我个人比较喜欢etcdv3的服务服务发现和注册。

     三：主要的功能都有相应的接口，只要实现相应的接口，就可以根据自己的需要订制插件。

     业余时间把go-micro的源码系统地读了一遍，越读越感觉这个框架写的好，从中也学到了很多东西。就想整理一系列的帖子，把学习go-micro的心得和大家分享。

通信流程

go-micro的通信流程大至如下:

  Server监听客户端的调用，和Brocker推送过来的信息进行处理。并且Server端需要向Register注册自己的存在或消亡，这样Client才能知道自己的状态。

    Register服务的注册的发现。

    Client端从Register中得到Server的信息，然后每次调用都根据算法选择一个的Server进行通信，当然通信是要经过编码/解码，选择传输协议等一系列过程的。

    如果有需要通知所有的Server端可以使用Brocker进行信息的推送。

    Brocker 信息队列进行信息的接收和发布。

     go-micro之所以可以高度订制和他的框架结构是分不开的，go-micro由8个关键的interface组成，每一个interface都可以根据自己的需求重新实现，这8个主要的inteface也构成了go-micro的框架结构。

这些接口go-micir都有他自己默认的实现方式，还有一个go-plugins是对这些接口实现的可替换项。你也可以根据需求实现自己的插件。

    

通过 go-plugins 可以设置其他服务发现，如mdns, etcd,etcdv3,zookeeper,kubernetes.等等。

#部分代码import "github.com/micro/go-plugins/registry/etcdv3"// 我这里用的etcd 做为服务发现，如果使用consul可以去掉 etcdv3.NewRegistry()//etcd.NewRegistry()//mdns.NewMDNSService()//zookeeper.NewRegistry()//kubernetes.NewRegistry()service := micro.NewService(micro.Name("greeter"),micro.Version("latest"),micro.Metadata(map[string]string{"type": "hello world"}))service.Init()

这篇帖子主要是给大家介绍go-micro的主体结构和这些接口的功能，具体细节以后的文章我们再慢慢说。

Transort

服务之间通信的接口。也就是服务发送和接收的最终实现方式，是由这些接口定制的。

源码：

// Package transport is an interface for synchronous communicationpackage transportimport ("time")type Message struct {Header map[string]stringBody []byte}type Socket interface {Recv(*Message) errorSend(*Message) errorClose() errorLocal() stringRemote() string}type Client interface {Socket}type Listener interface {Addr() stringClose() errorAccept(func(Socket)) error}// Transport is an interface which is used for communication between// services. It uses socket send/recv semantics and had various// implementations {HTTP, RabbitMQ, NATS, ...}type Transport interface {Init(...Option) errorOptions() OptionsDial(addr string, opts ...DialOption) (Client, error)Listen(addr string, opts ...ListenOption) (Listener, error)String() string}type Option func(*Options)type DialOption func(*DialOptions)type ListenOption func(*ListenOptions)var (DefaultTransport Transport = newHTTPTransport()DefaultDialTimeout = time.Second * 5)func NewTransport(opts ...Option) Transport {return newHTTPTransport(opts...)}

 Transport 的Listen方法是一般是Server端进行调用的，他监听一个端口，等待客户端调用。

    Transport 的Dial就是客户端进行连接服务的方法。他返回一个Client接口，这个接口返回一个Client接口，这个Client嵌入了Socket接口，这个接口的方法就是具体发送和接收通信的信息。

    // type Greeter struct {}//// func (g *Greeter) Hello(context, request, response) error {// return nil// }//type Handler interface {Name() stringHandler() interface{}Endpoints() []*registry.EndpointOptions() HandlerOptions}// Subscriber interface represents a subscription to a given topic using// a specific subscriber function or object with endpoints.type Subscriber interface {Topic() stringSubscriber() interface{}Endpoints() []*registry.EndpointOptions() SubscriberOptions}type Option func(*Options)var (DefaultAddress = ":0"DefaultName = "server"DefaultVersion = "latest"DefaultId = uuid.New().String()DefaultServer Server = newRpcServer()DefaultRouter = newRpcRouter())// DefaultOptions returns config options for the default servicefunc DefaultOptions() Options {return DefaultServer.Options()}// Init initialises the default server with options passed infunc Init(opt ...Option) {if DefaultServer == nil {DefaultServer = newRpcServer(opt...)}DefaultServer.Init(opt...)}// NewServer returns a new server with options passed infunc NewServer(opt ...Option) Server {return newRpcServer(opt...)}// NewSubscriber creates a new subscriber interface with the given topic// and handler using the default serverfunc NewSubscriber(topic string, h interface{}, opts ...SubscriberOption) Subscriber {return DefaultServer.NewSubscriber(topic, h, opts...)}// NewHandler creates a new handler interface using the default server// Handlers are required to be a public object with public// endpoints. Call to a service endpoint such as Foo.Bar expects// the type:////type Foo struct {}//func (f *Foo) Bar(ctx, req, rsp) error {//return nil//}//func NewHandler(h interface{}, opts ...HandlerOption) Handler {return DefaultServer.NewHandler(h, opts...)}// Handle registers a handler interface with the default server to// handle inbound requestsfunc Handle(h Handler) error {return DefaultServer.Handle(h)}// Subscribe registers a subscriber interface with the default server// which subscribes to specified topic with the brokerfunc Subscribe(s Subscriber) error {return DefaultServer.Subscribe(s)}// Run starts the default server and waits for a kill// signal before exiting. Also registers/deregisters the serverfunc Run() error {if err := Start(); err != nil {return err}ch := make(chan os.Signal, 1)signal.Notify(ch, syscall.SIGTERM, syscall.SIGINT, syscall.SIGKILL)log.Logf("Received signal %s", <-ch)return Stop()}// Start starts the default serverfunc Start() error {config := DefaultServer.Options()log.Logf("Starting server %s id %s", config.Name, config.Id)return DefaultServer.Start()}// Stop stops the default serverfunc Stop() error {log.Logf("Stopping server")return DefaultServer.Stop()}// String returns name of Server implementationfunc String() string {return DefaultServer.String()}

参考链接：yq.aliyun.com/articles/633797

➢了解更多Go语言知识：study.163.com/course/introduction/1210620804.htm