重庆分公司
重庆分公司，新征程启航
为企业提供网站建设、域名注册、服务器等服务
Controller实现ReplicaSetController的示例分析
这篇文章给大家介绍Controller实现ReplicaSetController的示例分析，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。
目前累计服务客户上1000+，积累了丰富的产品开发及服务经验。以网站设计水平和技术实力，树立企业形象，为客户提供成都网站设计、成都网站制作、外贸网站建设、网站策划、网页设计、网络营销、VI设计、网站改版、漏洞修补等服务。成都创新互联始终以务实、诚信为根本，不断创新和提高建站品质，通过对领先技术的掌握、对创意设计的研究、对客户形象的视觉传递、对应用系统的结合，为客户提供更好的一站式互联网解决方案，携手广大客户，共同发展进步。
Controller的实现基本上都是通过SharedInformer的结构去监听etcd上某种资源的变更，然后再执行对应的业务逻辑。
以ReplicaSetController为例，介绍一个controller如何与整个manager组合在一起。
controller启动
controllers都是在NewControllerInitializers()方法中引入到manager里的：
|
startReplicaSetController是启动函数，如下：
|
创建过程如下：
|
Replica Set资源变更回调
Informer监听到的变更最终会回调到syncReplicaSet方法上，但当中会穿越多个协程，逻辑比较复杂。用一个时序图近似表示如下：
1.Controller变更通知
这里的controller是Informer层的结构，对于资源变更会触发HandleDeltas()方法。HandleDeltas方法会调用sharedProcessor.distribute方法，将Delta传入到processListener的channel上，等待被处理。
2.processorListener.run
run方法会不断拉取listener自己本地channel中的变更，并根据ActionType分发到注册的handler上的不同方法里。
在上文介绍的NewReplicaSetController()函数里，可以看到AddFunc对应的回调函数是enqueueReplicaSet。最终会把delta放入ReplicaSetController自己的queue队列中，等待controller处理。
3.ReplicaSetController.processNextItem
processNextItem方法会处理RepliaSetController.queue当中的变更信息，最终调用syncReplicaSet方法来处理变更，确保Pods和配置一致。
每个Controller的处理逻辑都不相同，但与manager & informer的交互大体类似。
ReplicaSetController的分析中可以再次看出go实现中，调用顺序和传统面向对象语言有很大差异。
关于Controller实现ReplicaSetController的示例分析就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。
当前名称：Controller实现ReplicaSetController的示例分析
文章网址：http://cqcxhl.com/article/pcgihh.html