「连载」边缘计算(十四)02-02:边缘部分源码(源码分析篇)

(接上篇)

CloudCore

本节将对CloudCore进行剖析,对CloudCore组件中功能模块共用的消息框架和各功能模块的具体功能进行深入剖析,具体包括CloudCore功能模块之间通信的消息框架、cloudhub剖析、edgecontroller剖析、devicecontroller剖析。

CloudCore功能模块之间通信的消息框架

CloudCore组件中各个功能模块之间是通过Beehive来组织和管理的。Beehive的消息框架是在CloudCore的功能模块启动的时候启动的,具体如下所示。

KubeEdge/beehive/pkg/core/core.go

import (

...

"GitHub.com/KubeEdge/beehive/pkg/core/context"

)

// StartModules starts modules that are registered

func StartModules() {

coreContext := context.GetContext(context.MsgCtxTypeChannel)

modules := GetModules()

for name, module := range modules {

//Init the module

coreContext.AddModule(name)

//Assemble typeChannels for sendToGroup

coreContext.AddModuleGroup(name, module.Group())

go module.Start(coreContext)

klog.Infof("Starting module %v", name)

}

}

上述代码中,在CloudCore的功能模块启动之前,首先实例化了一个beehive的context,然后再获得各个功能模块,最后用一个for循环逐个启动功能模块,并将已实例化的beehive的context作为参数,传入每个功能模块的启动函数中。这样,CloudCore中独立的功能模块就被beehive的context组织成了一个统一的整体。至于beehive的context是怎么做到的,还需要进入beehive的context的实例化函数context.GetContext()一探究竟。

context.GetContext()函数定义具体如下所示。

KubeEdge/beehive/pkg/core/context/contex_factory.go

// GetContext gets global context instance

func GetContext(contextType string) *Context {

once.Do(func() {

context = &Context{}

switch contextType {

case MsgCtxTypeChannel:

channelContext := NewChannelContext()

context.messageContext = channelContext

context.moduleContext = channelContext

default:

klog.Warningf("Do not support context type:%s", contextType)

}

})

return context

}

context.GetContext()函数定义中的第3行context = &Context{}实例化了一个空context。下面我们分析该实例化context。context 结构体具体如下所示。

KubeEdge/beehive/pkg/core/context/context.go

// Context is global context object

type Context struct {

moduleContext  ModuleContext

messageContext MessageContext

}

//ModuleContext is interface for context module management

type ModuleContext interface {

AddModule(module string)

AddModuleGroup(module, group string)

Cleanup(module string)

}

//MessageContext is interface for message syncing

type MessageContext interface {

// async mode

Send(module string, message model.Message)

Receive(module string) (model.Message, error)

// sync mode

SendSync(module string, message model.Message, timeout time.Duration) ( model.Message, error)

SendResp(message model.Message)

// group broadcast

SendToGroup(moduleType string, message model.Message)

SendToGroupSync(moduleType string, message model.Message, timeout time.Duration) error

}

从上面的Context结构体,可以看出该Context的两个属性——moduleContextmessageContext,它们都是interface类型,所以可以断定该Context不是真身。在函数GetContext()(KubeEdge/beehive/pkg/core/context/context.go)继续往下看,在第6行channelContext := NewChannelContext()有一个context实例化函数NewChannelContext(),进入该函数的定义去看一下它是不是真身。

 「未完待续……

点击下方标题可阅读技术文章

「连载」边缘计算(一)01-16:边缘计算系统逻辑架构(原理篇)
「连载」边缘计算(二)01-17:边缘计算系统逻辑架构(原理篇)
「连载」边缘计算(三)01-18:边缘部分原理解析(原理篇)
「连载」边缘计算(四)01-19:边缘部分原理解析(原理篇)
「连载」边缘计算(五)01-22:边缘部分原理解析(原理篇)
「连载」边缘计算(六)01-23:边缘部分原理解析(原理篇)
「连载」边缘计算(七)01-24:边缘部分原理解析(原理篇)
「连载」边缘计算(八)01-25:边缘部分源码(源码分析篇)
「连载」边缘计算(九)01-26:边缘部分源码(源码分析篇)

「连载」边缘计算(十)01-29:边缘部分源码(源码分析篇)
「连载」边缘计算(十一)01-30:边缘部分源码(源码分析篇)
「连载」边缘计算(十二)01-31:边缘部分源码(源码分析篇)
「连载」边缘计算(十三)02-01:边缘部分源码(源码分析篇)

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/666353.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

请解释Java中的线程池是什么,以及为什么要使用线程池?

在Java中,线程池是一种并发编程的机制,它维护了一个线程队列,用于重用已创建的线程,以便在处理任务时减少线程的创建和销毁开销。线程池提供了一种管理和控制线程执行的方式,可以有效地管理系统资源,提高程…

计算机视觉中的目标跟踪

从保护我们城市的监控系统到自动驾驶车辆在道路上行驶,目标跟踪已经成为计算机视觉中的一项基础技术。本文深入探讨了目标跟踪,探索了其基本原理、多样化的方法以及在现实世界中的应用。 什么是目标跟踪? 目标跟踪是深度学习在计算机视觉中广…

LLVM实战之C源码编译

目录 1. 详细步骤 2. 工作原理 本文将展示使用Clang(C语言前端),把C语言源码转换成LLVM IR 。当然首先需要安装Clang并且把它添加到PATH环境中。 1. 详细步骤 (1)首先准备测试文件,在multiply.c文件编写…

JAVA Web 学习(四)RabbitMQ、Zookeeper

十、消息队列服务器——RabbitMQ RabbitMQ是使用Erlang语言开发的开源消息队列系统,基于AMQP协议来实现。AMQP的主要特征是面向消息、队列、路由(包括点对点和发布/订阅)、可靠性、 安全。AMQP协议更多用在企业系统内,对数据一致性、稳定性和可靠性要求…

ES6-let

一、基本语法 ES6 中的 let 关键字用于声明变量,并且具有块级作用域。 - 语法:let 标识符;let 标识符初始值; - 规则:1.不能重复声明let不允许在相同作用域内重复声明同一个变量2.不存在变量提升在同一作用域内,必须先声明才能试…

JS(react)图片压缩+图片上传

上传dome var fileNodeTakeStock: any createRef();<inputref{fileNodeTakeStock}onChange{showPictureTakeStock}style{{ display: "none" }}id"fileInpBtn"type"file"accept"image/*" //限制上传格式multiple{false}capture&qu…

线阵相机系列-- 1. 什么是线阵相机

线阵相机的概念 根据工业相机像素排列方式的不同&#xff0c;分为面阵相机和线阵相机。面阵相机的像素排列为一个完整的面&#xff0c;一次获取整幅二维图像&#xff0c;而线阵相机的像素以一条线排列&#xff0c;每次得到的图像呈现出一条线&#xff0c;通过设置扫描频率以及…

RK Camera hal 图像处理

soc&#xff1a;RK3568 system:Android12 今天发现外接的USBCamera用Camera 2API打开显示颠倒&#xff0c;如果在APP 里使用Camera1处理这块接口较少&#xff0c;调整起来比较麻烦 RK Camera hal位置&#xff1a;hardware/interfaces/camera 核心的文件在&#xff1a; 开机…

c语言大小写转换

⭐个人主页&#xff1a;黑菜钟-CSDN博客 ❀专栏&#xff1a;c/c_黑菜钟的博客-CSDN博客 前言&#xff1a; 这篇博客主要介绍3种有关大小写转换的方法&#xff0c;以及如何判断大小写的扩展c语言库函数 1.方法 1.1.ASCII编码法 在ASCII编码表中&#xff0c;小写和大写总是差一…

深入理解Istio服务网格(一)数据平面Envoy

一、服务网格概述(service mesh) 在传统的微服务架构中&#xff0c;服务间的调用&#xff0c;业务代码需要考虑认证、熔断、服务发现等非业务能力&#xff0c;在某种程度上&#xff0c;表现出了一定的耦合性 服务网格追求高级别的服务流量治理能力&#xff0c;认证、熔断、服…

文档更新记录

vue-cli3搭建项目_vite cli3搭建项目-CSDN博客 1.8 eslint_"plugins: [\"import\"], // 解决动态导入import语法报错问题 --> -CSDN博客 1.8

N-142基于springboot,vue停车场管理系统

开发工具&#xff1a;IDEA 服务器&#xff1a;Tomcat9.0&#xff0c; jdk1.8 项目构建&#xff1a;maven 数据库&#xff1a;mysql5.7 项目采用前后端分离 前端技术&#xff1a;vueelementUI 服务端技术&#xff1a;springbootmybatis-plus 本项目分为普通用户和管理员…

基于若依的ruoyi-nbcio流程管理系统自定义业务回写状态的一种新方法(一)

更多ruoyi-nbcio功能请看演示系统 gitee源代码地址 前后端代码&#xff1a; https://gitee.com/nbacheng/ruoyi-nbcio 演示地址&#xff1a;RuoYi-Nbcio后台管理系统 更多nbcio-boot功能请看演示系统 gitee源代码地址 后端代码&#xff1a; https://gitee.com/nbacheng/n…

深度学习驱动下的自然语言处理进展及其应用前景

文章目录 每日一句正能量前言技术进步应用场景挑战与前景自然语言处理技术当前面临的挑战未来的发展趋势和前景 伦理和社会影响实践经验后记 每日一句正能量 一个人若想拥有聪明才智&#xff0c;便需要不断地学习积累。 前言 自然语言处理&#xff08;NLP&#xff09;是一项正…

FreeRTOS动态 / 静态创建和删除任务

本篇文章记录我学习FreeRTOS的动态 / 静态创建和删除任务的知识。希望我的分享能给你带来不一样的收获&#xff01;文中涉及FreeRTOS创建和删除任务的API函数&#xff0c;建议读者参考以下文章&#xff1a; FreeRTOS任务相关的API函数-CSDN博客 目录 ​编辑 一、FreeRTOS动态创…

“超越摩尔定律”,存内计算走在爆发的边缘

目录 ​编辑 前言 在后摩尔时代提高计算机性能 六类存内计算技术 1&#xff09;XYZ-CIM 2&#xff09;XZ-CIM 3&#xff09;Z-CIM 4&#xff09;XY-CIM 5&#xff09;X-CIM 6&#xff09;O-CIM 各种CIM技术的原理 1&#xff09;XYZ-CIM&#xff1a;NVM有状态逻辑 2…

ES6-数组的解构赋值

一、数组的解构赋值的规律 - 只要等号两边的模式相同&#xff0c;左边的变量就会被赋予对应的值二、数组的解构赋值的例子讲解 1&#xff09;简单的示例&#xff08;完整的解构赋值&#xff09; 示例 //基本的模式匹配 // a&#xff0c;b,c依次和1&#xff0c;2&#xff0c…

libevent源码解析--event,event_callback,event_base

1.概述 实现一个基础tcp网络库&#xff0c;以基于tcp网络库构建服务端应用&#xff0c;客户端应用为起点&#xff0c;我们的核心诉求有&#xff1a; a. tcp网络库管理工作线程。 b. tcp网络库产生服务端对象&#xff0c;通过启动接口&#xff0c;开启服务端监听。进一步&…

解决gitee文件大小超过100MB——分片上传(每片<100MB)

Gitee 上传文件大小限制为 100MB。如果需要上传大于 100MB 的文件&#xff0c;可以按照以下步骤操作&#xff1a; 1. 将大文件分割成多个小于 100MB 的子文件。 2. 使用 Gitee 的命令行工具 git 分别将这些子文件添加到仓库中。 3. 在仓库中创建一个新文件&#xff08;例如&am…