2. daemon详解——APIServer

Server接收用户通过client发来的请求，按照路由规则分发，交给后端处理完毕后将结果返回至client

专注于为中小企业提供成都网站制作、成都网站设计服务,电脑端+手机端+微信端的三站合一,更高效的管理,为中小企业调兵山免费做网站提供优质的服务。我们立足成都，凝聚了一批互联网行业人才，有力地推动了上1000+企业的稳健成长，帮助中小企业通过网站建设实现规模扩充和转变。

之前说到 start() 中的 NewDaemon() 是初始化Daemon的核心逻辑，APIServer的创建在 start() 中。

初始化router的过程同样在 start() 里。

那么，还需要关注一下middleware。它的初始化在start中的 initMiddlewares() ，形参用到了cli.api、serverConfig、pluginStore。

pluginStore在上一行的 plugin.NewStore() 完成初始化，它返回一个Store对象，其中最重要的是定义了注册回调函数的接口

initMiddlewares 定义了不同的中间件，包括：

重新回到上面的 handlerWithGlobalMiddlewares() 函数，它内部有一个循环，遍历了使用的middlewares，对每个middleware调用 WrapHandler()

Middleware的作用docker的解释是：

WrapHandler对于不同的middleware有不同的实现版本，它的原型是

在创建好APIServer，连接上Daemon，创建、设置好Router之后，APIServer就可以向外提供服务了，它提供的是一个HTTP Server之上标准的RESTful-API，对用户非常友好。

APIServer的真正运行采用go routine的方式， go cli.api.wait() 真正启动了APIServer。采用go routine的原因是：如果APIServer出错，daemon会随之退出，采用go routine可以在出错的时候尝试重启，保证docker的正常运行。在wait函数中调用了serveAPI()，由于之前可能和多个Daemon建立了连接，所以对每个HTTP server，调用 Serve() 函数。

Serve函数为每个client的连接建立goroutine的服务，服务会解析request，调用handler，返回结果。

该函数并不是docker开发者自己写的，而是调用了GO语言的net/http库。大概里面的函数有： readRequest ， handler := sh.srv.Handler ， ServeHTTP(ResponseWriter, *Request) 等。由于是系统库，所以先不看了。

附上start中的高层流程：

APIServer是daemon和docker client通信的接口，在daemon的初始化流程中优先级非常高。通过初始化apiserver实例、router实例、middleware实例，系统已经为APIServer提供了完整的运行环境。Middleware为在docker和用户之间做了一层隔离，为用户提供标准的接口，通过middleware，回调函数被注册进router中。

真正运行时，采用goroutine的方式保证了保证了daemon的稳定运行，当request到达APIServer中后，APIServer通过main router进行查找，调用相应的router，也就执行了相应的回调函数的调用，从而实现了对request的处理。

GO语言学习系列八——GO函数(func)的声明与使用

GO是编译性语言，所以函数的顺序是无关紧要的，为了方便阅读，建议入口函数 main 写在最前面，其余函数按照功能需要进行排列

GO的函数 不支持嵌套，重载和默认参数

GO的函数 支持 无需声明变量，可变长度，多返回值，匿名，闭包等

GO的函数用 func 来声明，且左大括号 { 不能另起一行

一个简单的示例：

输出为：

参数：可以传0个或多个值来供自己用

返回：通过用 return 来进行返回

输出为：

上面就是一个典型的多参数传递与多返回值

对例子的说明：

按值传递：是对某个变量进行复制，不能更改原变量的值

引用传递：相当于按指针传递，可以同时改变原来的值，并且消耗的内存会更少，只有4或8个字节的消耗

在上例中，返回值 (d int, e int, f int) { 是进行了命名，如果不想命名可以写成 (int,int,int){ ,返回的结果都是一样的，但要注意:

当返回了多个值，我们某些变量不想要，或实际用不到，我们可以使用 _ 来补位，例如上例的返回我们可以写成 d,_,f := test(a,b,c) ，我们不想要中间的返回值，可以以这种形式来舍弃掉

在参数后面以 变量 ... type 这种形式的，我们就要以判断出这是一个可变长度的参数

输出为：

在上例中， strs ...string 中， strs 的实际值是b,c,d,e,这就是一个最简单的传递可变长度的参数的例子，更多一些演变的形式，都非常类似

在GO中 defer 关键字非常重要，相当于面相对像中的析构函数，也就是在某个函数执行完成后，GO会自动这个；

如果在多层循环中函数里，都定义了 defer ,那么它的执行顺序是先进后出；

当某个函数出现严重错误时， defer 也会被调用

输出为

这是一个最简单的测试了，当然还有更复杂的调用，比如调试程序时，判断是哪个函数出了问题，完全可以根据 defer 打印出来的内容来进行判断，非常快速，这种留给你们去实现

一个函数在函数体内自己调用自己我们称之为递归函数，在做递归调用时，经常会将内存给占满，这是非常要注意的，常用的比如，快速排序就是用的递归调用

本篇重点介绍了GO函数(func)的声明与使用，下一篇将介绍GO的结构 struct

Go语言设计与实现（上）

基本设计思路：

类型转换、类型断言、动态派发。iface，eface。

反射对象具有的方法：

编译优化：

内部实现：

实现 Context 接口有以下几个类型（空实现就忽略了）：

互斥锁的控制逻辑：

设计思路：

（以上为写被读阻塞，下面是读被写阻塞）

总结，读写锁的设计还是非常巧妙的：

设计思路：

WaitGroup 有三个暴露的函数:

部件：

设计思路：

结构：

Once 只暴露了一个方法：

实现：

三个关键点：

细节：

让多协程任务的开始执行时间可控（按顺序或归一）。（Context 是控制结束时间）

设计思路： 通过一个锁和内置的 notifyList 队列实现，Wait() 会生成票据，并将等待协程信息加入链表中，等待控制协程中发送信号通知一个（Signal()）或所有（Boardcast()）等待者（内部实现是通过票据通知的）来控制协程解除阻塞。

暴露四个函数：

实现细节：

部件：

包： golang.org/x/sync/errgroup

作用：开启 func() error 函数签名的协程，在同 Group 下协程并发执行过程并收集首次 err 错误。通过 Context 的传入，还可以控制在首次 err 出现时就终止组内各协程。

设计思路：

结构：

暴露的方法：

实现细节：

注意问题：

包： "golang.org/x/sync/semaphore"

作用：排队借资源（如钱，有借有还）的一种场景。此包相当于对底层信号量的一种暴露。

设计思路：有一定数量的资源 Weight，每一个 waiter 携带一个 channel 和要借的数量 n。通过队列排队执行借贷。

结构：

暴露方法：

细节：

部件：

细节：

包： "golang.org/x/sync/singleflight"

作用：防击穿。瞬时的相同请求只调用一次，response 被所有相同请求共享。

设计思路：按请求的 key 分组（一个 *call 是一个组，用 map 映射存储组），每个组只进行一次访问，组内每个协程会获得对应结果的一个拷贝。

结构：

逻辑：

细节：

部件：

如有错误，请批评指正。

文章标题：go语言wait函数,golang wait
当前路径：http://scyanting.com/article/hsiiie.html