「连载」边缘计算（二十一）02-26：边缘部分源码（源码分析篇）
（接上篇）
DeviceTwin struct组成剖析
该部分对DeviceTwin struct的组成进行剖析。接着devicetwin struct调用链剖析的实例化DeviceTwin struct（dt := DeviceTwin{}）往下剖析，进入DeviceTwin struct的定义，具体如下所示。
| KubeEdge/edge/pkg/devicetwin/devicetwin.go |
| //DeviceTwin the module type DeviceTwin struct { context *context.Context dtcontroller *DTController } |
DeviceTwin struct的定义由 *context.Context 和 *DTController两部分组成。其中，*context.Context可以参考8.3.2,这里不再赘述。下面重点剖析DTController。
DTController的定义具体如下所示。
| KubeEdge/edge/pkg/devicetwin/dtcontroller.go |
| //DTController controller for devicetwin type DTController struct { HeartBeatToModule map[string]chan interface{} DTContexts *dtcontext.DTContext DTModules map[string]dtmodule.DTModule Stop chan bool } |
在DTController struct定义中发现\*dtcontext.DTContext和dtmodule.DTModule的定义具体如下所示。
| KubeEdge/edge/pkg/devicetwin/dtcontext/dtcontext.go |
| //DTContext context for devicetwin type DTContext struct { GroupID string NodeID string CommChan map[string]chan interface{} ConfirmChan chan interface{} ConfirmMap *sync.Map ModulesHealth *sync.Map ModulesContext *context.Context DeviceList *sync.Map DeviceMutex *sync.Map Mutex *sync.RWMutex // DBConn *dtclient.Conn State string } |
从DTContext struct的定义可以看出，DTContext struct主要用来实现devicetwin的通信和缓存。DTModule.DTModule struct定义如下所示。
| KubeEdge/edge/pkg/devicetwin/dtmodule/dtmodule.go |
| //DTModule module for devicetwin type DTModule struct { Name string Worker dtmanager.DTWorker } |
在 DTModule struct定义中，dtmanager.DTWorker是interface type，定义如下所示。
| KubeEdge/edge/pkg/devicetwin/dtmanager/dtworker.go |
| //DTWorker worker for devicetwin type DTWorker interface { Start() } |
从dtmanager.DTWorker的interface type可以推测DTModule有多种类型，而且都实现了DTWorker interface。KubeEdge/edge/pkg/devicetwin/dtmodule/dtmodule.go中的InitWorker()就是用来实例化DTModule的多种类型的，具体定义如下所示。
| KubeEdge/edge/pkg/devicetwin/dtmodule/dtmodule.go |
| // InitWorker init worker func (dm *DTModule) InitWorker(recv chan interface{}, confirm chan interface{}, heartBeat chan interface{}, dtContext *dtcontext.DTContext) { switch dm.Name { case dtcommon.MemModule: dm.Worker = dtmanager.MemWorker{ Group: dtcommon.MemModule, Worker: dtmanager.Worker{ ReceiverChan: recv, ConfirmChan: confirm, HeartBeatChan: heartBeat, DTContexts: dtContext, }, } ... } |
从InitWorker()函数的定义中可以梳理出，DTModule有MemWorker、TwinWorker、DeviceWorker和CommWorker四种类型。
到此，EdgeCore中devicetwin的struct调用链剖析就全部结束了。
「未完待续……」