- 1单例模式：二-懒汉模式（Lazy）
- 2搜索和数据库查询到底有什么区别
- 3关于”TCP直接返回“_tcp原路返回
- 4深入理解nginx的动态变量机制(完整版)
- 5Pandas四、Grouping(分组)和Sorting(排序)_pandas group sort
- 6vscode搭建openVINO(2020.03)开发环境(Makefile)，Ubuntu18.04（下）_ubuntu 20.04 vscode 配置 openvino 2022.3 环境
- 7如何使用Sora？Sora小白教程一文通_sora 如何使用
- 8JAVA毕业设计固定资产管理系统计算机源码+lw文档+系统+调试部署+数据库_基于java+jdbc+sqlserver的固定资产管理系统设计与实现
- 9基于Python的大数据分析实战篇（一）_python大数据处理与分析
- 10Centos7.2 安装zabbix3.X_see "systemctl status sshd.service" and "journalct
「连载」边缘计算（二十一）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调用链剖析就全部结束了。
「未完待续……」
