CN113254097B - 配置信息的下发方法和装置、电子设备和存储介质 - Google Patents
配置信息的下发方法和装置、电子设备和存储介质 Download PDFInfo
- Publication number
- CN113254097B CN113254097B CN202110518068.9A CN202110518068A CN113254097B CN 113254097 B CN113254097 B CN 113254097B CN 202110518068 A CN202110518068 A CN 202110518068A CN 113254097 B CN113254097 B CN 113254097B
- Authority
- CN
- China
- Prior art keywords
- target
- configuration information
- message
- edge node
- task
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
- 238000000034 method Methods 0.000 title claims abstract description 83
- 230000002085 persistent effect Effects 0.000 claims description 24
- 238000004891 communication Methods 0.000 claims description 18
- 230000002688 persistence Effects 0.000 claims description 15
- 238000004590 computer program Methods 0.000 claims description 11
- 230000004044 response Effects 0.000 claims description 11
- 238000004806 packaging method and process Methods 0.000 claims description 6
- 238000012790 confirmation Methods 0.000 claims description 5
- 238000005516 engineering process Methods 0.000 abstract description 6
- 238000010586 diagram Methods 0.000 description 8
- 230000008859 change Effects 0.000 description 5
- 230000008569 process Effects 0.000 description 5
- 238000012545 processing Methods 0.000 description 4
- 230000000694 effects Effects 0.000 description 3
- 238000007726 management method Methods 0.000 description 3
- 230000007246 mechanism Effects 0.000 description 3
- 230000003287 optical effect Effects 0.000 description 3
- 230000000737 periodic effect Effects 0.000 description 3
- 230000008878 coupling Effects 0.000 description 2
- 238000010168 coupling process Methods 0.000 description 2
- 238000005859 coupling reaction Methods 0.000 description 2
- 238000002716 delivery method Methods 0.000 description 2
- 230000006870 function Effects 0.000 description 2
- 238000012544 monitoring process Methods 0.000 description 2
- 230000002093 peripheral effect Effects 0.000 description 2
- 230000006978 adaptation Effects 0.000 description 1
- 230000005540 biological transmission Effects 0.000 description 1
- 238000013500 data storage Methods 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 238000012546 transfer Methods 0.000 description 1
- 238000012795 verification Methods 0.000 description 1
- 239000002699 waste material Substances 0.000 description 1
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/44—Arrangements for executing specific programs
- G06F9/445—Program loading or initiating
- G06F9/44505—Configuring for program initiating, e.g. using registry, configuration files
- G06F9/4451—User profiles; Roaming
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/54—Interprogram communication
- G06F9/546—Message passing systems or structures, e.g. queues
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F2209/00—Indexing scheme relating to G06F9/00
- G06F2209/54—Indexing scheme relating to G06F9/54
- G06F2209/547—Messaging middleware
Landscapes
- Engineering & Computer Science (AREA)
- Software Systems (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Computer And Data Communications (AREA)
Abstract
本申请提供了一种配置信息的下发方法和装置、电子设备和存储介质,其中,该方法包括:获取待下发的第一配置信息,其中,所述第一配置信息为与目标边缘节点对应的增量配置信息,所述目标边缘节点为分布式系统中的边缘节点;生成第一目标消息,其中,所述第一目标消息中携带有所述第一配置信息;通过目标消息中间件将所述第一目标消息发送给所述目标边缘节点,以将所述第一配置信息下发给所述目标边缘节点。通过本申请,解决了相关技术中的配置信息的下发方式存在由于依赖网络状况导致的容错性差的问题。
Description
技术领域
本申请涉及信息技术领域,尤其涉及一种配置信息的下发方法和装置、电子设备和存储介质。
背景技术
目前,CDN(Content Delivery Network,内容分发网络)系统为一个大型的分布式系统,涉及的节点及设备数量众多,设备数量可多达几万甚至更多。为了管理上万台设备上的CDN应用,则需要中心–边缘的架构程序来管理。
为了高可用性,一个节点上分配几台设备用于部署Agent(即,代理)程序。Agent会有成百上千个实例,Agent的运行也是需要一些配置参数,例如,限速、并发数、节点状态等。这些配置参数可能会随时需要变更。手动登录节点去修改配置参数存在很多弊端,例如,有安全隐患、部分操作人员并没有登录节点的权限、及时性差等。
为了保证配置信息可以及时下发到Agent(即,配置信息下发的实时性),相关技术中采用的配置信息下发方式为:中央部署配置中心服务,边缘Agent建立与中央的Socket(即,套接字)连接,配置中心有变更实时推送至边缘Agent,边缘Agent配置生效。
上述配置信息的下发方式在容错性上明显不足,若出现网络抖动,会丢失配置信息。而全网各地节点非常多,网络情况复杂,随时都会出现节点到中央网络情况不好的情况。由此可见,相关技术中的配置信息的下发方式,存在由于依赖网络状况导致的容错性差的问题。
发明内容
本申请提供了一种配置信息的下发方法和装置、电子设备和存储介质,以至少解决相关技术中的配置信息的下发方式存在由于依赖网络状况导致的容错性差的问题。
根据本申请实施例的一个方面,提供了一种配置信息的下发方法,包括:获取待下发的第一配置信息,其中,所述第一配置信息为与目标边缘节点对应的增量配置信息,所述目标边缘节点为分布式系统中的边缘节点;生成第一目标消息,其中,所述第一目标消息中携带有所述第一配置信息;通过目标消息中间件将所述第一目标消息发送给所述目标边缘节点,以将所述第一配置信息下发给所述目标边缘节点。
可选地,获取待下发的所述第一配置信息包括:接收目标对象发送的目标任务,其中,所述目标任务为待所述目标边缘节点执行的任务;根据所述目标任务的任务属性和所述目标边缘节点的节点属性,生成所述第一配置信息。
可选地,根据所述目标任务的任务属性和所述目标边缘节点的节点属性,生成所述第一配置信息包括:根据所述目标任务的任务属性,生成第一子配置信息,其中,所述第一子配置信息为与所述目标任务关联的配置信息;根据所述目标任务的任务属性以及所述目标边缘节点的节点属性,生成第二子配置信息,其中,所述第二子配置信息为与所述目标边缘节点关联的配置信息,所述第一配置信息包括所述第一子配置信息和所述第二子配置信息。
可选地,生成所述第一目标消息包括:将所述第一配置信息封装到与所述目标任务对应的任务消息中,得到目标任务消息,其中,所述第一目标消息为所述目标任务消息。
可选地,在通过所述目标消息中间件将所述第一目标消息发送给所述目标边缘节点之后,所述方法还包括:在将所述第一目标消息发送给所述目标边缘节点之后的目标时间内未接收到所述目标边缘节点响应所述第一目标消息返回的确认消息的情况下,通过所述目标消息中间件将所述第一目标消息重新发送给所述目标边缘节点。
可选地,在获取待下发的所述第一配置信息之前,所述方法还包括:接收所述目标边缘节点发送的目标指示消息,其中,所述目标指示消息用于指示所述目标边缘节点待获取全量配置信息;响应所述目标指示消息,获取待下发的第二配置信息,其中,所述第二配置信息为与所述目标边缘节点对应的全量配置信息;生成第二目标消息,其中,所述第二目标消息中携带有所述第二配置信息;通过所述目标消息中间件将所述第二目标消息发送给所述目标边缘节点,以将所述第二配置信息下发给所述目标边缘节点。
可选地,在通过所述目标消息中间件将所述第一目标消息发送给所述目标边缘节点之后,所述方法还包括:定时获取待下发的第三配置信息,其中,所述第三配置信息为与所述目标边缘节点对应的全量配置信息;生成第三目标消息,其中,所述第三目标消息中携带有所述第三配置信息;通过所述目标消息中间件将所述第三目标消息发送给所述目标边缘节点,以将所述第三配置信息下发给所述目标边缘节点。
根据本申请实施例的另一个方面,还提供了一种配置信息的下发方法,包括:接收目标中心节点通过目标消息中间件发送的第一目标消息,其中,所述目标中心节点为分布式系统中的中心节点,所述第一目标消息携带有第一配置信息,所述第一配置信息为下发给目标边缘节点的增量配置信息;使用所述第一配置信息更新所述目标边缘节点上已持久化的配置信息,得到目标配置信息;将所述目标配置信息持久化到所述目标边缘节点上。
可选地,接收所述目标中心节点通过所述目标消息中间件发送的所述第一目标消息包括:接收所述目标中心节点通过所述目标消息中间件发送的目标任务消息,其中,所述目标任务消息是与待所述目标边缘节点执行的目标任务对应的任务消息,所述目标任务消息中封装有所述第一配置信息,所述第一目标消息为所述目标任务消息。
可选地,在接收所述目标中心节点通过所述目标消息中间件发送的所述第一目标消息之前,所述方法还包括:在所述目标边缘节点上与所述分布式系统对应的监听程序启动、且所述目标边缘节点上不存在已持久化的配置信息的情况下,向所述目标中心节点发送目标指示消息,其中,所述目标指示消息用于指示所述目标边缘节点待获取全量配置信息;接收所述目标中心节点响应所述目标指示消息通过所述目标消息中间件发送的第二目标消息,其中,所述第二目标消息中携带有第二配置信息,所述第二配置信息为下发给所述目标边缘节点的全量配置信息;将第二目标消息中携带的所述第二配置信息持久化到所述目标边缘节点上。
可选地,在将所述目标配置信息持久化到所述目标边缘节点上之后,所述方法还包括:接收所述目标中心节点通过所述目标消息中间件定时发送的第三目标消息,其中,所述第三目标消息中携带有第三配置信息,所述第三配置信息为下发给所述目标边缘节点的全量配置信息;将所述第三目标消息中携带的所述第三配置信息持久化到所述目标边缘节点上。
根据本申请实施例的又一个方面,还提供了一种配置信息的下发装置,包括:第一获取单元,用于获取待下发的第一配置信息,其中,所述第一配置信息为与目标边缘节点对应的增量配置信息,所述目标边缘节点为分布式系统中的边缘节点;第一生成单元,用于生成第一目标消息,其中,所述第一目标消息中携带有所述第一配置信息;第一发送单元,用于通过目标消息中间件将所述第一目标消息发送给所述目标边缘节点,以将所述第一配置信息下发给所述目标边缘节点。
可选地,所述第一获取单元包括:第一接收模块,用于接收目标对象发送的目标任务,其中,所述目标任务为待所述目标边缘节点执行的任务;生成模块,用于根据所述目标任务的任务属性和所述目标边缘节点的节点属性,生成所述第一配置信息。
可选地,所述生成模块包括:第一生成子模块,用于根据所述目标任务的任务属性,生成第一子配置信息,其中,所述第一子配置信息为与所述目标任务关联的配置信息;第二生成子模块,用于根据所述目标任务的任务属性以及所述目标边缘节点的节点属性,生成第二子配置信息,其中,所述第二子配置信息为与所述目标边缘节点关联的配置信息,所述第一配置信息包括所述第一子配置信息和所述第二子配置信息。
可选地,所述第一生成单元包括:封装模块,用于将所述第一配置信息封装到与所述目标任务对应的任务消息中,得到目标任务消息,其中,所述第一目标消息为所述目标任务消息。
可选地,所述装置还包括:第二发送单元,用于在通过所述目标消息中间件将所述第一目标消息发送给所述目标边缘节点之后,在将所述第一目标消息发送给所述目标边缘节点之后的目标时间内未接收到所述目标边缘节点响应所述第一目标消息返回的确认消息的情况下,通过所述目标消息中间件将所述第一目标消息重新发送给所述目标边缘节点。
可选地,所述装置还包括:接收单元,用于在获取待下发的所述第一配置信息之前,接收所述目标边缘节点发送的目标指示消息,其中,所述目标指示消息用于指示所述目标边缘节点待获取全量配置信息;第二获取单元,用于响应所述目标指示消息,获取待下发的第二配置信息,其中,所述第二配置信息为与所述目标边缘节点对应的全量配置信息;第二生成单元,用于生成第二目标消息,其中,所述第二目标消息中携带有所述第二配置信息;第三发送单元,用于通过所述目标消息中间件将所述第二目标消息发送给所述目标边缘节点,以将所述第二配置信息下发给所述目标边缘节点。
可选地,所述装置还包括:第三获取单元,用于在通过所述目标消息中间件将所述第一目标消息发送给所述目标边缘节点之后,定时获取待下发的第三配置信息,其中,所述第三配置信息为与所述目标边缘节点对应的全量配置信息;第三生成单元,用于生成第三目标消息,其中,所述第三目标消息中携带有所述第三配置信息;第四发送单元,用于通过所述目标消息中间件将所述第三目标消息发送给所述目标边缘节点,以将所述第三配置信息下发给所述目标边缘节点。
根据本申请实施例的又一个方面,还提供了一种配置信息的下发装置,包括:第一接收单元,用于接收目标中心节点通过目标消息中间件发送的第一目标消息,其中,所述目标中心节点为分布式系统中的中心节点,所述第一目标消息携带有第一配置信息,所述第一配置信息为下发给目标边缘节点的增量配置信息;更新单元,用于使用所述第一配置信息更新所述目标边缘节点上已持久化的配置信息,得到目标配置信息;第一持久化单元,用于将所述目标配置信息持久化到所述目标边缘节点上。
可选地,所述第一接收单元包括:第二接收模块,用于接收所述目标中心节点通过所述目标消息中间件发送的目标任务消息,其中,所述目标任务消息是与待所述目标边缘节点执行的目标任务对应的任务消息,所述目标任务消息中封装有所述第一配置信息,所述第一目标消息为所述目标任务消息。
可选地,所述装置还包括:第五发送单元,用于在接收所述目标中心节点通过所述目标消息中间件发送的所述第一目标消息之前,在所述目标边缘节点上与所述分布式系统对应的监听程序启动、且所述目标边缘节点上不存在已持久化的配置信息的情况下,向所述目标中心节点发送目标指示消息,其中,所述目标指示消息用于指示所述目标边缘节点待获取全量配置信息;第二接收单元,用于接收所述目标中心节点响应所述目标指示消息通过所述目标消息中间件发送的第二目标消息,其中,所述第二目标消息中携带有第二配置信息,所述第二配置信息为下发给所述目标边缘节点的全量配置信息;第二持久化单元,用于将所述第二目标消息中携带的所述第二配置信息持久化到所述目标边缘节点上。
可选地,所述装置还包括:第三接收单元,用于在将所述目标配置信息持久化到所述目标边缘节点上之后,接收所述目标中心节点通过所述目标消息中间件定时发送的第三目标消息,其中,所述第三目标消息中携带有第三配置信息,所述第三配置信息为下发给所述目标边缘节点的全量配置信息;第三持久化单元,用于将所述第三目标消息中携带的所述第三配置信息持久化到所述目标边缘节点上。
根据本申请实施例的又一个方面,还提供了一种电子设备,包括处理器、通信接口、存储器和通信总线,其中,处理器、通信接口和存储器通过通信总线完成相互间的通信;其中,存储器,用于存储计算机程序;处理器,用于通过运行所述存储器上所存储的所述计算机程序来执行上述任一实施例中的方法步骤。
根据本申请实施例的又一个方面,还提供了一种计算机可读的存储介质,该存储介质中存储有计算机程序,其中,该计算机程序被设置为运行时执行上述任一实施例中的方法步骤。
在本申请实施例中,通过消息中间件向边缘节点推送增量配置信息的方式,通过获取待下发的第一配置信息,其中,第一配置信息为与目标边缘节点对应的增量配置信息,目标边缘节点为分布式系统中的边缘节点;生成第一目标消息,其中,第一目标消息中携带有第一配置信息;通过目标消息中间件将第一目标消息发送给目标边缘节点,以将第一配置信息下发给目标边缘节点,由于采用消息中间件进行配置信息的推送,而消息中间件本身带有容错功能,可以实现减少推送对网络状况的依赖的目的,并且,由于下发的是增量配置信息而不是全量配置信息,可以实现以较小的消息体下发配置信息的目的,达到了提高配置信息下发的容错性、提高配置下发速度、以及降低网络带宽占用的技术效果,进而解决了相关技术中的配置信息的下发方式存在由于依赖网络状况导致的容错性差的问题。
附图说明
此处的附图被并入说明书中并构成本说明书的一部分,示出了符合本申请的实施例,并与说明书一起用于解释本申请的原理。
为了更清楚地说明本申请实施例或现有技术中的技术方案,下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍,显而易见地,对于本领域普通技术人员而言,在不付出创造性劳动性的前提下,还可以根据这些附图获得其他的附图。
图1是根据本申请实施例的一种可选的配置信息的下发方法的硬件环境的示意图;
图2是根据本申请实施例的一种可选的配置信息的下发方法的流程示意图;
图3是根据本申请实施例的另一种可选的配置信息的下发方法的流程示意图;
图4是根据本申请实施例的一种可选的配置信息的下发方法的示意图;
图5是根据本申请实施例的又一种可选的配置信息的下发方法的流程示意图;
图6是根据本申请实施例的一种可选的配置信息的下发装置的结构框图;
图7是根据本申请实施例的另一种可选的配置信息的下发装置的结构框图;
图8是根据本申请实施例的一种可选的电子设备的结构框图。
具体实施方式
为了使本技术领域的人员更好地理解本申请方案,下面将结合本申请实施例中的附图,对本申请实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例仅仅是本申请一部分的实施例,而不是全部的实施例。基于本申请中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例,都应当属于本申请保护的范围。
需要说明的是,本申请的说明书和权利要求书及上述附图中的术语“第一”、“第二”等是用于区别类似的对象,而不必用于描述特定的顺序或先后次序。应该理解这样使用的数据在适当情况下可以互换,以便这里描述的本申请的实施例能够以除了在这里图示或描述的那些以外的顺序实施。此外,术语“包括”和“具有”以及他们的任何变形,意图在于覆盖不排他的包含,例如,包含了一系列步骤或单元的过程、方法、系统、产品或设备不必限于清楚地列出的那些步骤或单元,而是可包括没有清楚地列出的或对于这些过程、方法、产品或设备固有的其它步骤或单元。
首先,在对本申请实施例进行描述的过程中出现的部分名词或者术语适用于如下解释:
1、节点,一个节点一般是指一批设备组成的虚拟集合,也可以是单独的一个设备,可以不限于为物理机、虚拟机、容器等。
2、Agent,Agent是指部署在边缘节点的管理机上、用于管理该节点里所有设备上的应用的程序。
3、刷新,对于CDN,如果源站内容变更时,CDN边缘设备上还保留着旧的内容,那么用户访问的还是旧内容,这就需要刷新程序将CDN边缘设备上缓存的旧内容清除掉。
根据本申请实施例的一个方面,提供了一种配置信息的下发方法。可选地,在本实施例中,上述配置信息的下发方法可以应用于如图1所示的由终端102和服务器104所构成的硬件环境中。如图1所示,服务器104通过网络与终端102进行连接,可用于为终端或终端上安装的客户端提供服务(如游戏服务、应用服务等),可在服务器上或独立于服务器设置数据库,用于为服务器104提供数据存储服务。
上述网络可以包括但不限于以下至少之一:有线网络,无线网络。上述有线网络可以包括但不限于以下至少之一:广域网,城域网,局域网,上述无线网络可以包括但不限于以下至少之一:WIFI(Wireless Fidelity,无线保真),蓝牙。终端102可以并不限定于为PC、手机、平板电脑等。
本申请实施例的配置信息的下发方法可以由服务器104来执行,也可以由终端102来执行,还可以是由服务器104和终端102共同执行。其中,终端102执行本申请实施例的配置信息的下发方法也可以是由安装在其上的客户端来执行。
以由服务器104来执行本实施例中的配置信息的下发方法为例,图2是根据本申请实施例的一种可选的配置信息的下发方法的流程示意图,如图2所示,该方法的流程可以包括以下步骤:
步骤S202,获取待下发的第一配置信息,其中,第一配置信息为与目标边缘节点对应的增量配置信息,目标边缘节点为分布式系统中的边缘节点。
本实施例中的配置信息的下发方法可以应用于在分布式系统中进行节点配置信息下发的场景。上述分布式系统可以具有中心(或者称中央)-边缘节点架构,即,该分布式系统(例如,CDN)可以包含中心节点和边缘节点。中心节点可以是一个服务器集群(或者称中央集群)或单实例应用,可以但不限于部署在一台机器、多台机器集群、虚拟机、云主机、容器中。一个边缘节点可以是一台机器或多台机器,边缘节点上的管理应用和边缘集群应用可以是一个应用,也可以是多个应用。此外,边缘节点中的设备可以但不限于为物理机、云主机、容器等可部署应用的媒介。可选地,本实施例中的配置信息的下发方法可以是由分布式系统中的中心节点(即,中央)所执行的。
为解决相关技术中的配置信息下发方式存在的容错性不足的情况,可以采用定期轮询的方式进行配置信息下发,即,中央部署配置中心服务,边缘Agent定时轮询发送HTTP(HyperText Transfer Protocol,超文本传输协议)请求至中央,获取最新配置。此处,除了HTTP以外,发送请求使用的也可以是其他基于TCP(Transmission Control Protocol,传输控制协议)协议的协议。
然而,对于上述定期轮询的方式,中央与边缘一般是采用外网进行通信,定时轮询,会额外增加流量,浪费带宽资源;并且,配置下发的实时性取决于轮询时间间隔。
可选地,在本实施例中,可以采用消息机制来增加容错性。通过中央管理边缘节点设备,由消息中间件向边缘节点推送增量配置信息的方式进行配置信息的下发,即,在配置信息有变更时通过消息中间件进行增量下发。
例如,目标中心节点可以获取待下发给目标边缘节点的第一配置信息,该第一配置信息是该目标边缘节点的增量配置信息,也即,相对于已下发给目标边缘节点的配置信息所变更的配置信息。
步骤S204,生成第一目标消息,其中,第一目标消息中携带有第一配置信息;
对于第一配置信息,目标中心节点可以将其封装到一个消息中,从而生成第一目标消息,生成的第一目标消息中携带有第一配置信息。
配置信息可以是与其他信息一起发送的,例如,可以携带在任务消息中进行发送,也可以是单独进行发送的,例如,通过单独的消息发送。本实施例中对此不作限定。
步骤S206,通过目标消息中间件将第一目标消息发送给目标边缘节点,以将第一配置信息下发给目标边缘节点。
目标中心节点上的消息中间件为目标消息中间件,即,目标消息中间件为目标中心节点上的消息中间件。目标中心节点可以通过目标消息中间件将第一目标消息推送给目标边缘节点,从而可以将第一配置信息下发给目标边缘节点。
该目标消息中间件可以包含与目标边缘节点对应的一个或多个消息队列,例如,目标消息队列。通过所述目标消息中间件将所述第一目标消息发送给所述目标节点可以包括:将第一目标消息路由到与目标节点对应的目标消息队列中,其中,目标消息中间件包括目标消息队列;通过目标消息中间件将目标消息队列中的第一目标消息推送给目标节点。
通过上述步骤S202至步骤S206,获取待下发的第一配置信息,其中,第一配置信息为与目标边缘节点对应的增量配置信息,目标边缘节点为分布式系统中的边缘节点;生成第一目标消息,其中,第一目标消息中携带有第一配置信息;通过目标消息中间件将第一目标消息发送给目标边缘节点,以将第一配置信息下发给目标边缘节点,解决了相关技术中的配置信息的下发方式存在由于依赖网络状况导致的容错性差的问题,提高了配置信息下发的容错性,提高了配置下发速度,降低了网络带宽占用。
作为一种可选的实施例,获取待下发的第一配置信息包括:
S11,接收目标对象发送的目标任务,其中,目标任务为待目标边缘节点执行的任务;
S12,根据目标任务的任务属性和目标边缘节点的节点属性,生成第一配置信息。
在中央管理边缘节点设备(即,边缘节点下的边缘设备)时,会下发大量的任务去执行,例如,刷新任务。中心节点可以采用消息中间件,将任务缓存在消息队列中。边缘Agent可以根据自身的情况去消费任务,然后执行任务。在下发任务消息时,可以将任务执行所需的配置参数(即,配置信息)随任务消息下发至边缘Agent,进而影响任务的执行。
对于上述配置信息的下发方式,由于配置信息与任务一起下发,所以配置下发的实时性可以得到保证。然而,由于每条任务消息都携带大量相同的配置信息(例如,设备列表),导致消息体变大,下发速度变慢,带宽增加。
可选地,在本实施例中,可以将重复的配置信息只随任务下发一次(或者,少量次数),在配置信息有变更时增量进行下发,从而减小消息体的大小。
目标中心节点可以接收目标对象(对应于目标用户)提交的目标任务,该目标任务可以是目标刷新任务。目标任务可以是由目标中心节点上用于提供接收任务服务的程序执行的。在接收到目标对象提交的目标任务之后,目标中心节点可以判断目标任务下发至哪些节点去执行,即,确定执行目标任务的目标边缘节点。这里,目标边缘节点的数量可以为一个或多个,向每个边缘节点下发配置信息及下发任务的方式是类似的。
在接收目标对象发送的目标任务之后,目标中心节点可以获取第一配置信息。例如,目标中心节点可以根据目标任务的特性(即,任务属性,例如,任务所属的域名)及要下发的节点(即,目标边缘节点的节点属性),生成第一配置信息。生成第一配置信息的过程可以是:目标中心节点可以根据目标任务的任务属性和目标边缘节点的节点属性,生成与目标边缘节点对应的目标全量配置信息;将目标全量配置信息相对于已下发给目标边缘节点的配置信息的变更,确定为第一配置信息。
例如,刷新中央接收到用户提交的刷新任务后,判断任务将下发至哪些节点去执行,根据任务的特性及要下发的节点,生成相应的配置信息。
通过本实施例,在接收到待边缘节点执行的任务时,根据根据任务的特性及要下发的节点,生成相应的配置信息,可以保证配置下发的及时性。
作为一种可选的实施例,根据目标任务的任务属性和目标边缘节点的节点属性,生成第一配置信息包括:
S21,根据目标任务的任务属性,生成第一子配置信息,其中,第一子配置信息为与目标任务关联的配置信息;
S22,根据目标任务的任务属性以及目标边缘节点的节点属性,生成第二子配置信息,其中,第二子配置信息为与目标边缘节点关联的配置信息,第一配置信息包括第一子配置信息和第二子配置信息。
配置信息可以有多种,可以包含与边缘节点关联的配置信息(即,与节点相关的配置信息),例如,节点状态信息,节点下的设备列表,设备IP(Internet Protocol,网际互连协议)地址,设备状态信息等;可以包含与任务关联的配置信息(即,与节点不相关的的配置信息),例如,任务超时时间,任务执行重试次数。
由于下发任务最终的目标均为节点,可以把所有的配置信息均归属于某个节点,节点相关的配置信息很容易就归属于某个或者某些节点。如果是全局的任务超时时间,则可以归属至所有的节点。
对于目标任务,目标中心节点可以根据目标任务的任务属性,生成第一子配置信息,该第一子配置信息可以是与目标任务关联的配置信息,例如,目标任务的任务超时时间,目标任务的任务执行重试次数。
目标中心节点可以根据目标任务的任务属性以及目标边缘节点的节点属性,生成第二子配置信息,该第二子配置信息可以是与目标边缘节点关联的配置信息,例如,目标边缘节点的节点状态信息,目标边缘节点下的边缘设备的设备列表,目标边缘节点下的边缘设备的设备IP地址,目标边缘节点下的边缘设备的设备状态信息等。
第一配置信息可以包括上述第一子配置信息和第二子配置信息中的至少一个。这里,需要说明的是,由于第一配置信息是与目标边缘节点对应的增量配置信息,其包含与目标任务关联的配置信息和与目标边缘节点关联的配置信息中的至少一个。如果某些任务没有造成边缘节点上配置信息的变更,则可以不想该边缘节点下发配置信息。
通过本实施例,根据任务的任务属性和边缘节点的节点属性生成与目标任务关联的配置信息和与目标边缘节点关联的配置信息,可以提高配置信息生成的准确性。
作为一种可选的实施例,生成第一目标消息包括:
S31,将第一配置信息封装到与目标任务对应的任务消息中,得到目标任务消息,其中,第一目标消息为目标任务消息。
增量下发的配置可以是与任务一起发送的,也可以是单独使用使用消息队列发送的。可选地,为了降低系统复杂性,可以将配置随任务一起下发。例如,中央可以根据配置信息的变化情况,选择恰当的时机将配置信息随任务消息一并下发至节点上。
在生成第一配置信息之后,目标中心节点可以将第一配置信息封装到与目标任务对应的任务消息中,从而得到目标任务消息。上述第一目标消息即为目标任务消息。
通过本实施例,将配置信息随任务消息一并下发至边缘节点上,可以降低系统复杂度,同时提高配置下发的及时性。
作为一种可选的实施例,在通过目标消息中间件将第一目标消息发送给目标边缘节点之后,上述方法还包括:
S41,在将第一目标消息发送给目标边缘节点之后的目标时间内未接收到目标边缘节点响应第一目标消息返回的确认消息的情况下,通过目标消息中间件将第一目标消息重新发送给目标边缘节点。
可选地,在本实施例中,如果遇到网络抖动,可以利用消息中间件本身带有容错功能(即,消息的确认机制)来保证配置信息不丢失:在成功接收消息后,边缘节点可发送应答ACK(Acknowledge,确认),确认消息接收。
在将第一目标消息发送给目标边缘节点之后,目标中心节点可以等待接收目标边缘节点在接收到第一目标消息之后所返回的确认消息。如果在一定时间(即,发送第一目标消息之后的目标时间)内未接收到目标边缘节点返回的确认消息,目标中心节点可以通过目标消息中间件将第一目标消息重新发送给目标边缘节点,以保证该第一配置信息可以被目标边缘节点成功接收。
通过本实施例,在未接收到边缘节点返回的确认消息时重新下发携带配置信息的消息,可以提高配置信息下发的成功率。
作为一种可选的实施例,在获取待下发的第一配置信息之前,上述方法还包括:
S51,接收目标边缘节点发送的目标指示消息,其中,目标指示消息用于指示目标边缘节点待获取全量配置信息;
S52,响应目标指示消息,获取待下发的第二配置信息,其中,第二配置信息为与目标边缘节点对应的全量配置信息;
S53,生成第二目标消息,其中,第二目标消息中携带有第二配置信息;
S54,通过目标消息中间件将第二目标消息发送给目标边缘节点,以将第二配置信息下发给目标边缘节点。
如果由于某些原因导致目标边缘节点需要从目标中心节点获取全量配置信息(例如,边缘节点上的监听程序启动时,不存在先前持久化的配置信息),目标边缘节点可以主动从目标中心节点拉取本节点的全量配置信息。目标边缘节点可以向目标中心节点发送目标指示消息,该目标指示消息用于指示目标边缘节点待获取全量配置信息。
在接收到目标指示消息之后,目标中心节点可以获取目标边缘节点的全量配置信息,即,第二配置信息,将该第二配置信息封装到一个消息内,得到第二目标消息,并将得到的第二目标消息通过目标消息中间件发送给目标边缘节点,从而将第二配置信息下发给目标边缘节点。第二目标消息的生成过程以及通过目标消息中间件发送第二目标消息的方式与前述类似,在此不做赘述。
通过本实施例,在必要时由边缘节点从中心节点主动拉取全量配置信息,可以保证边缘节点及时进入就绪状态,提高边缘节点执行任务的及时性。
作为一种可选的实施例,在通过目标消息中间件将第一目标消息发送给目标边缘节点之后,上述方法还包括:
S61,定时获取待下发的第三配置信息,其中,第三配置信息为与目标边缘节点对应的全量配置信息;
S62,生成第三目标消息,其中,第三目标消息中携带有第三配置信息;
S63,通过目标消息中间件将第三目标消息发送给目标边缘节点,以将第三配置信息下发给目标边缘节点。
除了在配置信息变更时进行增量下发以外,中心节点还可以定时向边缘节点下发全量配置信息,以保证边缘节点上的配置信息的准确性。同时,定时下发全量配置信息,可以避免边缘节点由于丢失配置信息导致无法进行配置信息的增量更新,进而影响边缘节点上任务执行的及时性。在此情况下,如果由于某些原因导致目标边缘节点需要从目标中心节点获取全量配置信息,边缘节点也可以等待中心节点下发的全量配置信息。
通过目标消息中间件将第一目标消息发送给目标边缘节点之后(也可以是将第一目标消息发送给目标边缘节点之前),目标中心节点可以定时获取目标边缘节点的全量配置信息,即,第三配置信息,将该第三配置信息封装到一个消息内,得到第三目标消息,并将得到的第三目标消息通过目标消息中间件发送给目标边缘节点,从而将第三配置信息下发给目标边缘节点。第三目标消息的生成过程以及通过目标消息中间件发送第三目标消息的方式与前述类似,在此不做赘述。
通过本实施例,通过中心节点定时向边缘节点下发一份完整的节点相关配置信息,可以保证边缘节点上的配置信息的准确性,还可以保证边缘节点上任务执行的及时性。
根据本申请实施例的另一个方面,提供了一种配置信息的下发方法。可选地,在本实施例中,上述配置信息的下发方法可以应用于如图1所示的由终端102和服务器104所构成的硬件环境中。已经进行过说明的,在此不做赘述。
以由服务器104来执行本实施例中的配置信息的下发方法为例,图3是根据本申请实施例的另一种可选的配置信息的下发方法的流程示意图,如图3所示,该方法的流程可以包括以下步骤:
S302,接收目标中心节点通过目标消息中间件发送的第一目标消息,其中,目标中心节点为分布式系统中的中心节点,第一目标消息携带有第一配置信息,第一配置信息下发给目标边缘节点的增量配置信息。
本实施例中的配置信息的下发方法可以应用于前述在分布式系统中进行节点配置信息下发的场景。在本实施例中,上述配置信息的下发方法可以是由分布式系统中的边缘节点所执行的。
目标边缘节点可以接收目标中心节点通过目标消息中间件发送的第一目标消息,该第一目标消息可以是目标中心节点采用与前述相同或者类似的方式生成的,已经进行过描述的,在此不做赘述。
S304,使用第一配置信息更新目标边缘节点上已持久化的配置信息,得到目标配置信息。
在接收到第一配置信息之前,目标边缘节点上可以有已持久化的配置信息。该第一配置信息是相对于目标边缘节点上已持久化的配置信息所变更的配置信息,即,配置信息变更。
在接收到第一配置信息之后,目标边缘节点可以根据第一配置信息和目标边缘节点上已持久化的配置信息,生成待持久化的目标配置信息。例如,目标边缘节点可以使用第一配置信息更新已持久化的配置信息,得到目标配置信息。
S306,将目标配置信息持久化到目标边缘节点上。
目标配置信息是与目标边缘节点对应的全量配置信息(是一份全量的配置信息),目标边缘节点可以将目标配置信息持久化到目标边缘节点上。
在目标边缘节点上进行持久化保存目标配置信息之后,后续的相关任务可以均使用该目标边缘节点上先前持久化的配置信息,而不需要在每个消息任务中均封装对应的全部配置参数(例如,设备IP地址等未发生变化的配置参数可以不必封装),从而可以减小下发任务的消息体大小,提升下发速度,降低网络带宽。
通过上述步骤S302至步骤S306,接收目标中心节点通过目标消息中间件发送的第一目标消息,其中,目标中心节点为分布式系统中的中心节点,第一目标消息携带有第一配置信息,第一配置信息为下发给目标边缘节点的增量配置信息;使用第一配置信息更新目标边缘节点上已持久化的配置信息,得到目标配置信息;将目标配置信息持久化到目标边缘节点上,解决了相关技术中的配置信息的下发方式存在由于依赖网络状况导致的容错性差的问题,提高了配置信息下发的容错性,提高了配置下发速度,降低了网络带宽占用。
作为一种可选的实施例,接收目标中心节点通过目标消息中间件发送的第一目标消息包括:
S71,接收目标中心节点通过目标消息中间件发送的目标任务消息,其中,目标任务消息是与待目标边缘节点执行的目标任务对应的任务消息,目标任务消息中封装有第一配置信息,第一目标消息为目标任务消息。
可选地,在本实施例中,目标中心节点可以采用与前述相同或者类似的方式将第一配置信息封装到与目标任务对应的任务消息中,得到目标任务消息,并将目标任务消息通过目标消息中间件发送给目标边缘节点。目标边缘节点可以接收到目标中心节点发送的上述目标任务消息。
通过本实施例,将配置信息随任务消息一并下发至边缘节点上,可以降低系统复杂度,同时提高配置下发的及时性。
作为一种可选的实施例,在接收目标中心节点通过目标消息中间件发送的第一目标消息之前,上述方法还包括:
S81,在目标边缘节点上与分布式系统对应的监听程序启动、且目标边缘节点上不存在已持久化的配置信息的情况下,向目标中心节点发送目标指示消息,其中,目标指示消息用于指示目标边缘节点待获取全量配置信息;
S82,接收目标中心节点响应目标指示消息通过目标消息中间件发送的第二目标消息,其中,第二目标消息中携带有第二配置信息,第二配置信息为下发给目标边缘节点的全量配置信息;
S83,将第二目标消息中携带的第二配置信息持久化到目标边缘节点上。
目标边缘节点上与分布式系统对应的监听程序(监听程序Agent,例如,监听消息服务Agent)启动(例如,重启)后,如果未获取到先前持久化的配置信息(可能是持久化信息丢失或者新装设备之前并未持久化过),则可以等待目标中心节点全量配置信息下发后,进入就绪状态,开始接收任务。
可选地,目标边缘节点也可以向目标中心节点发送上述目标指示消息,接收目标中心节点响应该目标指示消息通过目标消息中间件发送的上述第二目标消息,并将第二目标消息中携带的第二配置信息持久化保存到目标边缘节点上。
例如,节点监听程序启动时,若不存在先前持久化的配置信息,可以向中央发送一条启动消息(目标指示消息的一种示例)。中央收到消息后,可以向此节点下发全量配置信息。节点监听程序Agent收到全量配置信息后,开始就绪接收处理任务。
通过本实施例,在必要时由边缘节点从中心节点主动拉取全量配置信息,可以保证边缘节点及时进入就绪状态,提高边缘节点执行任务的及时性。
作为一种可选的实施例,在将目标配置信息持久化到目标边缘节点上之后,上述方法还包括:
S91,接收目标中心节点通过目标消息中间件定时发送的第三目标消息,其中,第三目标消息中携带有第三配置信息,第三配置信息为下发给目标边缘节点的全量配置信息;
S92,将第三目标消息中携带的第三配置信息持久化到目标边缘节点上。
目标中心节点可以采用与前述相同或者类似的方式定时向目标边缘节点发送上述第三目标消息。目标边缘节点在接收到第三目标消息之后,可以将第三目标消息中携带的第三配置信息持久化保存到目标边缘节点上。
通过本实施例,通过中心节点定时向边缘节点下发一份完整的节点相关配置信息,可以保证边缘节点上的配置信息的准确性,还可以保证边缘节点上任务执行的及时性。
可选示例对本申请实施例中的配置信息的下发方法进行解释说明。在本示例中,分布式系统为CDN,目标任务为刷新任务(即,刷新系统任务),中心节点为刷新中央,监听程序为监听消息服务Agent。
为了保证在中心修改配置参数,边缘Agent能够立即生效(在允许的延迟内),本示例中提供的配置信息的下发方法是一种跨公网分布式任务管理系统的配置信息下发方案。如图4和图5所示,本可选示例中的配置信息的下发方法的流程可以包括以下步骤:
步骤S502,接收到用户提交的目标刷新任务,生成目标任务消息。
刷新中央(例如,刷新中央的接收任务服务)接收到用户提交的目标刷新任务后,对该目标刷新任务进行校验。在校验通过之后,可以组装必要的信息(包含配置信息),得到该与该目标刷新任务对应的目标任务消息。例如,刷新中央可以判断任务将下发至哪些节点去执行,根据任务的特性及要下发的节点,生成相应的配置信息,并封装至目标任务消息中。配置信息下发并非每次都下发全量配置信息,也可以为增量下发。
步骤S504,通过消息中间件将生成的目标任务消息推送给对应的目标节点。
根据任务要执行的目标节点,刷新中央可以将任务消息路由到消息中间件中相应的节点队列(目标消息队列的一种示例),并由消息中间件将生成的任务消息推送给对应的目标节点。
步骤S506,目标节点的管理机上的监听消息服务Agent接收到该目标任务消息,将该任务消息发送至本节点中的各设备,由各设备执行对应的刷新任务。
目标节点上的监听消息服务在接收到目标任务消息之后,可以解析出相应的配置信息,根据任务信息及配置信息,将任务发送至本节点下的设备上执行任务。
这里,节点在收到配置信息变更或全量配置信息后,可以生成一份全量的信息后持久化,此后(即便是在重启应用的情况下)也会使用此持久化配置信息执行任务。
需要说明的是,虽然以刷新系统为例进行说明,但是本示例中的配置信息下发方案,对于除了刷新系统以外的其它类似中央-边缘节点架构的任务下发系统同样适用。
通过本示例,采用消息机制进行配置信息下发,可以增加配置下发的容错性;将在变更时下发配置信息与定时下发配置信息相结合,可以大大减少消息体大小,提升下发速度,降低外网网络带宽;将配置信息随任务一起下发,可以降低系统复杂性。
需要说明的是,对于前述的各方法实施例,为了简单描述,故将其都表述为一系列的动作组合,但是本领域技术人员应该知悉,本申请并不受所描述的动作顺序的限制,因为依据本申请,某些步骤可以采用其他顺序或者同时进行。其次,本领域技术人员也应该知悉,说明书中所描述的实施例均属于优选实施例,所涉及的动作和模块并不一定是本申请所必须的。
通过以上的实施方式的描述,本领域的技术人员可以清楚地了解到根据上述实施例的方法可借助软件加必需的通用硬件平台的方式来实现,当然也可以通过硬件,但很多情况下前者是更佳的实施方式。基于这样的理解,本申请的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来,该计算机软件产品存储在一个存储介质(如ROM(Read-Only Memory,只读存储器)/RAM(Random Access Memory,随机存取存储器)、磁碟、光盘)中,包括若干指令用以使得一台终端设备(可以是手机,计算机,服务器,或者网络设备等)执行本申请各个实施例所述的方法。
根据本申请实施例的又一个方面,还提供了一种用于实施上述配置信息的下发方法的配置信息的下发装置。图6是根据本申请实施例的一种可选的配置信息的下发装置的结构框图,如图6所示,该装置可以包括:
第一获取单元602,用于获取待下发的第一配置信息,其中,第一配置信息为与目标边缘节点对应的增量配置信息,目标边缘节点为分布式系统中的边缘节点;
第一生成单元604,与第一获取单元602相连,用于生成第一目标消息,其中,第一目标消息中携带有第一配置信息;
第一发送单元606,与第一生成单元604相连,用于通过目标消息中间件将第一目标消息发送给目标边缘节点,以将第一配置信息下发给目标边缘节点。
需要说明的是,该实施例中的第一获取单元602可以用于执行上述步骤S202,该实施例中的第一生成单元604可以用于执行上述步骤S204,该实施例中的第一发送单元606可以用于执行上述步骤S206。
通过上述模块,获取待下发的第一配置信息,其中,第一配置信息为与目标边缘节点对应的增量配置信息,目标边缘节点为分布式系统中的边缘节点;生成第一目标消息,其中,第一目标消息中携带有第一配置信息;通过目标消息中间件将第一目标消息发送给目标边缘节点,以将第一配置信息下发给目标边缘节点,解决了相关技术中的配置信息的下发方式存在由于依赖网络状况导致的容错性差的问题,提高了配置信息下发的容错性,提高了配置下发速度,降低了网络带宽占用。
作为一种可选的实施例,第一获取单元602包括:
第一接收模块,用于接收目标对象发送的目标任务,其中,目标任务为待目标边缘节点执行的任务;
生成模块,用于根据目标任务的任务属性和目标边缘节点的节点属性,生成第一配置信息。
作为一种可选的实施例,生成模块包括:
第一生成子模块,用于根据目标任务的任务属性,生成第一子配置信息,其中,第一子配置信息为与目标任务关联的配置信息;
第二生成子模块,用于根据目标任务的任务属性以及目标边缘节点的节点属性,生成第二子配置信息,其中,第二子配置信息为与目标边缘节点关联的配置信息,第一配置信息包括第一子配置信息和第二子配置信息。
作为一种可选的实施例,第一生成单元604包括:
封装模块,用于将第一配置信息封装到与目标任务对应的任务消息中,得到目标任务消息,其中,第一目标消息为目标任务消息。
作为一种可选的实施例,上述装置还包括:
第二发送单元,用于在通过目标消息中间件将第一目标消息发送给目标边缘节点之后,在将第一目标消息发送给目标边缘节点之后的目标时间内未接收到目标边缘节点响应第一目标消息返回的确认消息的情况下,通过目标消息中间件将第一目标消息重新发送给目标边缘节点。
作为一种可选的实施例,上述装置还包括:
接收单元,用于在获取待下发的第一配置信息之前,接收目标边缘节点发送的目标指示消息,其中,目标指示消息用于指示目标边缘节点待获取全量配置信息;
第二获取单元,用于响应目标指示消息,获取待下发的第二配置信息,其中,第二配置信息为与目标边缘节点对应的全量配置信息;
第二生成单元,用于生成第二目标消息,其中,第二目标消息中携带有第二配置信息;
第三发送单元,用于通过目标消息中间件将第二目标消息发送给目标边缘节点,以将第二配置信息下发给目标边缘节点。
作为一种可选的实施例,上述装置还包括:
第三获取单元,用于在通过目标消息中间件将第一目标消息发送给目标边缘节点之后,定时获取待下发的第三配置信息,其中,第三配置信息为与目标边缘节点对应的全量配置信息;
第三生成单元,用于生成第三目标消息,其中,第三目标消息中携带有第三配置信息;
第四发送单元,用于通过目标消息中间件将第三目标消息发送给目标边缘节点,以将第三配置信息下发给目标边缘节点。
根据本申请实施例的又一个方面,还提供了一种用于实施上述配置信息的下发方法的配置信息的下发装置。图7是根据本申请实施例的另一种可选的配置信息的下发装置的结构框图,如图7所示,该装置可以包括:
第一接收单元702,用于接收目标中心节点通过目标消息中间件发送的第一目标消息,其中,目标中心节点为分布式系统中的中心节点,第一目标消息携带有第一配置信息,第一配置信息为下发给目标边缘节点的增量配置信息;
更新单元704,与第一接收单元702相连,用于使用第一配置信息更新目标边缘节点上已持久化的配置信息,得到目标配置信息;
第一持久化单元706,与更新单元704相连,用于将目标配置信息持久化到目标边缘节点上。
需要说明的是,该实施例中的第一接收单元702可以用于执行上述步骤S302,该实施例中的更新单元704可以用于执行上述步骤S304,该实施例中的第一持久化单元706可以用于执行上述步骤S306。
通过上述模块,接收目标中心节点通过目标消息中间件发送的第一目标消息,其中,目标中心节点为分布式系统中的中心节点,第一目标消息携带有第一配置信息,第一配置信息为下发给目标边缘节点的增量配置信息;使用第一配置信息更新目标边缘节点上已持久化的配置信息,得到目标配置信息;将目标配置信息持久化到目标边缘节点上,解决了相关技术中的配置信息的下发方式存在由于依赖网络状况导致的容错性差的问题,提高了配置信息下发的容错性,提高了配置下发速度,降低了网络带宽占用。
作为一种可选的实施例,第一接收单元702包括:
第二接收模块,用于接收目标中心节点通过目标消息中间件发送的目标任务消息,其中,目标任务消息是与待目标边缘节点执行的目标任务对应的任务消息,目标任务消息中封装有第一配置信息,第一目标消息为目标任务消息。
作为一种可选的实施例,上述装置还包括:
第五发送单元,用于在接收目标中心节点通过目标消息中间件发送的第一目标消息之前,在目标边缘节点上与分布式系统对应的监听程序启动、且目标边缘节点上不存在已持久化的配置信息的情况下,向目标中心节点发送目标指示消息,其中,目标指示消息用于指示目标边缘节点待获取全量配置信息;
第二接收单元,用于接收目标中心节点响应目标指示消息通过目标消息中间件发送的第二目标消息,其中,第二目标消息中携带有第二配置信息,第二配置信息为下发给目标边缘节点的全量配置信息;
第二持久化单元,用于将第二目标消息中携带的第二配置信息持久化到目标边缘节点上。
作为一种可选的实施例,上述装置还包括:
第三接收单元,用于在将目标配置信息持久化到目标边缘节点上之后,接收目标中心节点通过目标消息中间件定时发送的第三目标消息,其中,第三目标消息中携带有第三配置信息,第三配置信息为下发给目标边缘节点的全量配置信息;
第三持久化单元,用于将第三目标消息中携带的第三配置信息持久化到目标边缘节点上。
此处需要说明的是,上述模块与对应的步骤所实现的示例和应用场景相同,但不限于上述实施例所公开的内容。需要说明的是,上述模块作为装置的一部分可以运行在如图1所示的硬件环境中,可以通过软件实现,也可以通过硬件实现,其中,硬件环境包括网络环境。
根据本申请实施例的又一个方面,还提供了一种用于实施上述配置信息的下发方法的电子设备,该电子设备可以是服务器、终端、或者其组合。
图8是根据本申请实施例的一种可选的电子设备的结构框图,如图8所示,包括处理器802、通信接口804、存储器806和通信总线808,其中,处理器802、通信接口804和存储器806通过通信总线808完成相互间的通信,其中,
存储器806,用于存储计算机程序;
处理器802,用于执行存储器806上所存放的计算机程序时,实现如下步骤:
获取待下发的第一配置信息,其中,第一配置信息为与目标边缘节点对应的增量配置信息,目标边缘节点为分布式系统中的边缘节点;
生成第一目标消息,其中,第一目标消息中携带有第一配置信息;
通过目标消息中间件将第一目标消息发送给目标边缘节点,以将第一配置信息下发给目标边缘节点。
可选地,在本实施例中,处理器802,用于执行存储器806上所存放的计算机程序时,实现如下步骤:
接收目标中心节点通过目标消息中间件发送的第一目标消息,其中,目标中心节点为分布式系统中的中心节点,第一目标消息携带有第一配置信息,第一配置信息为下发给目标边缘节点的增量配置信息;
使用第一配置信息更新目标边缘节点上已持久化的配置信息,得到目标配置信息;
将目标配置信息持久化到目标边缘节点上。
可选地,在本实施例中,上述的通信总线可以是PCI(Peripheral ComponentInterconnect,外设部件互连标准)总线、或EISA(Extended Industry StandardArchitecture,扩展工业标准结构)总线等。该通信总线可以分为地址总线、数据总线、控制总线等。为便于表示,图8中仅用一条粗线表示,但并不表示仅有一根总线或一种类型的总线。
通信接口用于上述电子设备与其他设备之间的通信。
存储器可以包括RAM,也可以包括非易失性存储器(non-volatile memory),例如,至少一个磁盘存储器。可选地,存储器还可以是至少一个位于远离前述处理器的存储装置。
作为一种示例,该存储器806中可以但不限于包括上述配置信息的下发装置中的第一获取单元602、第一生成单元604和第一发送单元606。此外,还可以包括但不限于上述配置信息的下发装置中的其他模块单元,本示例中不再赘述。
作为另一种示例,该存储器806中可以但不限于包括上述配置信息的下发装置中的第一接收单元702、更新单元704和第一持久化单元706。此外,还可以包括但不限于上述配置信息的下发装置中的其他模块单元,本示例中不再赘述。
上述处理器可以是通用处理器,可以包含但不限于:CPU(Central ProcessingUnit,中央处理器)、NP(Network Processor,网络处理器)等;还可以是DSP(DigitalSignal Processing,数字信号处理器)、ASIC(Application Specific IntegratedCircuit,专用集成电路)、FPGA(Field-Programmable Gate Array,现场可编程门阵列)或者其他可编程逻辑器件、分立门或者晶体管逻辑器件、分立硬件组件。
可选地,本实施例中的具体示例可以参考上述实施例中所描述的示例,本实施例在此不再赘述。
本领域普通技术人员可以理解,图8所示的结构仅为示意,实施上述配置信息的下发方法的设备可以是终端设备,该终端设备可以是智能手机(如Android手机、iOS手机等)、平板电脑、掌上电脑以及移动互联网设备(Mobile Internet Devices,MID)、PAD等终端设备。图8其并不对上述电子设备的结构造成限定。例如,电子设备还可包括比图8中所示更多或者更少的组件(如网络接口、显示装置等),或者具有与图8所示的不同的配置。
本领域普通技术人员可以理解上述实施例的各种方法中的全部或部分步骤是可以通过程序来指令终端设备相关的硬件来完成,该程序可以存储于一计算机可读存储介质中,存储介质可以包括:闪存盘、ROM、RAM、磁盘或光盘等。
根据本申请实施例的又一个方面,还提供了一种存储介质。可选地,在本实施例中,上述存储介质可以用于执行本申请实施例中上述任一项配置信息的下发方法的程序代码。
可选地,在本实施例中,上述存储介质可以位于上述实施例所示的网络中的多个网络设备中的至少一个网络设备上。
可选地,在本实施例中,存储介质被设置为存储用于执行以下步骤的程序代码:
获取待下发的第一配置信息,其中,第一配置信息为与目标边缘节点对应的增量配置信息,目标边缘节点为分布式系统中的边缘节点;
生成第一目标消息,其中,第一目标消息中携带有第一配置信息;
通过目标消息中间件将第一目标消息发送给目标边缘节点,以将第一配置信息下发给目标边缘节点。
可选地,在本实施例中,存储介质被设置为存储用于执行以下步骤的程序代码:
接收目标中心节点通过目标消息中间件发送的第一目标消息,其中,目标中心节点为分布式系统中的中心节点,第一目标消息携带有第一配置信息,第一配置信息为下发给目标边缘节点的增量配置信息;
使用第一配置信息更新目标边缘节点上已持久化的配置信息,得到目标配置信息;
将目标配置信息持久化到目标边缘节点上。
可选地,本实施例中的具体示例可以参考上述实施例中所描述的示例,本实施例中对此不再赘述。
可选地,在本实施例中,上述存储介质可以包括但不限于:U盘、ROM、RAM、移动硬盘、磁碟或者光盘等各种可以存储程序代码的介质。
上述本申请实施例序号仅仅为了描述,不代表实施例的优劣。
上述实施例中的集成的单元如果以软件功能单元的形式实现并作为独立的产品销售或使用时,可以存储在上述计算机可读取的存储介质中。基于这样的理解,本申请的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的全部或部分可以以软件产品的形式体现出来,该计算机软件产品存储在存储介质中,包括若干指令用以使得一台或多台计算机设备(可为个人计算机、服务器或者网络设备等)执行本申请各个实施例所述方法的全部或部分步骤。
在本申请的上述实施例中,对各个实施例的描述都各有侧重,某个实施例中没有详述的部分,可以参见其他实施例的相关描述。
在本申请所提供的几个实施例中,应该理解到,所揭露的客户端,可通过其它的方式实现。其中,以上所描述的装置实施例仅仅是示意性的,例如所述单元的划分,仅仅为一种逻辑功能划分,实际实现时可以有另外的划分方式,例如多个单元或组件可以结合或者可以集成到另一个系统,或一些特征可以忽略,或不执行。另一点,所显示或讨论的相互之间的耦合或直接耦合或通信连接可以是通过一些接口,单元或模块的间接耦合或通信连接,可以是电性或其它的形式。
所述作为分离部件说明的单元可以是或者也可以不是物理上分开的,作为单元显示的部件可以是或者也可以不是物理单元,即可以位于一个地方,也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部单元来实现本实施例中所提供的方案的目的。
另外,在本申请各个实施例中的各功能单元可以集成在一个处理单元中,也可以是各个单元单独物理存在,也可以两个或两个以上单元集成在一个单元中。上述集成的单元既可以采用硬件的形式实现,也可以采用软件功能单元的形式实现。
以上所述仅是本申请的优选实施方式,应当指出,对于本技术领域的普通技术人员来说,在不脱离本申请原理的前提下,还可以做出若干改进和润饰,这些改进和润饰也应视为本申请的保护范围。
Claims (13)
1.一种配置信息的下发方法,其特征在于,包括:
获取待下发的第一配置信息,包括:接收目标对象发送的目标任务,所述目标任务为待目标边缘节点执行的任务,根据所述目标任务的任务属性和所述目标边缘节点的节点属性,生成所述第一配置信息,其中,所述第一配置信息为与目标边缘节点对应的增量配置信息,所述目标边缘节点为分布式系统中的边缘节点;
生成第一目标消息,其中,所述第一目标消息中携带有所述第一配置信息;
通过目标消息中间件将所述第一目标消息发送给所述目标边缘节点,以将所述第一配置信息下发给所述目标边缘节点,其中,所述目标消息中间件为目标中心节点上的消息中间件。
2.根据权利要求1所述的方法,其特征在于,根据所述目标任务的任务属性和所述目标边缘节点的节点属性,生成所述第一配置信息包括:
根据所述目标任务的任务属性,生成第一子配置信息,其中,所述第一子配置信息为与所述目标任务关联的配置信息;
根据所述目标任务的任务属性以及所述目标边缘节点的节点属性,生成第二子配置信息,其中,所述第二子配置信息为与所述目标边缘节点关联的配置信息,所述第一配置信息包括所述第一子配置信息和所述第二子配置信息。
3.根据权利要求1所述的方法,其特征在于,生成所述第一目标消息包括:
将所述第一配置信息封装到与所述目标任务对应的任务消息中,得到目标任务消息,其中,所述第一目标消息为所述目标任务消息。
4.根据权利要求1所述的方法,其特征在于,在通过所述目标消息中间件将所述第一目标消息发送给所述目标边缘节点之后,所述方法还包括:
在将所述第一目标消息发送给所述目标边缘节点之后的目标时间内未接收到所述目标边缘节点响应所述第一目标消息返回的确认消息的情况下,通过所述目标消息中间件将所述第一目标消息重新发送给所述目标边缘节点。
5.根据权利要求1所述的方法,其特征在于,在获取待下发的所述第一配置信息之前,所述方法还包括:
接收所述目标边缘节点发送的目标指示消息,其中,所述目标指示消息用于指示所述目标边缘节点待获取全量配置信息;
响应所述目标指示消息,获取待下发的第二配置信息,其中,所述第二配置信息为与所述目标边缘节点对应的全量配置信息;
生成第二目标消息,其中,所述第二目标消息中携带有所述第二配置信息;
通过所述目标消息中间件将所述第二目标消息发送给所述目标边缘节点,以将所述第二配置信息下发给所述目标边缘节点。
6.根据权利要求1至5中任一项所述的方法,其特征在于,在通过所述目标消息中间件将所述第一目标消息发送给所述目标边缘节点之后,所述方法还包括:
定时获取待下发的第三配置信息,其中,所述第三配置信息为与所述目标边缘节点对应的全量配置信息;
生成第三目标消息,其中,所述第三目标消息中携带有所述第三配置信息;
通过所述目标消息中间件将所述第三目标消息发送给所述目标边缘节点,以将所述第三配置信息下发给所述目标边缘节点。
7.一种配置信息的下发方法,其特征在于,包括:
接收目标中心节点通过目标消息中间件发送的第一目标消息,包括:接收所述目标中心节点通过所述目标消息中间件发送的目标任务消息,所述目标任务消息是与待目标边缘节点执行的目标任务对应的任务消息,所述目标任务消息中封装有第一配置信息,所述第一目标消息为所述目标任务消息,其中,所述目标中心节点为分布式系统中的中心节点,所述第一目标消息携带有第一配置信息,所述第一配置信息为下发给目标边缘节点的增量配置信息,所述目标消息中间件为目标中心节点上的消息中间件;
使用所述第一配置信息更新所述目标边缘节点上已持久化的配置信息,得到目标配置信息;
将所述目标配置信息持久化到所述目标边缘节点上。
8.根据权利要求7所述的方法,其特征在于,在接收所述目标中心节点通过所述目标消息中间件发送的所述第一目标消息之前,所述方法还包括:
在所述目标边缘节点上与所述分布式系统对应的监听程序启动、且所述目标边缘节点上不存在已持久化的配置信息的情况下,向所述目标中心节点发送目标指示消息,其中,所述目标指示消息用于指示所述目标边缘节点待获取全量配置信息;
接收所述目标中心节点响应所述目标指示消息通过所述目标消息中间件发送的第二目标消息,其中,所述第二目标消息中携带有第二配置信息,所述第二配置信息为下发给所述目标边缘节点的全量配置信息;
将所述第二目标消息中携带的所述第二配置信息持久化到所述目标边缘节点上。
9.根据权利要求7至8中任一项所述的方法,其特征在于,在将所述目标配置信息持久化到所述目标边缘节点上之后,所述方法还包括:
接收所述目标中心节点通过所述目标消息中间件定时发送的第三目标消息,其中,所述第三目标消息中携带有第三配置信息,所述第三配置信息为下发给所述目标边缘节点的全量配置信息;
将所述第三目标消息中携带的所述第三配置信息持久化到所述目标边缘节点上。
10.一种配置信息的下发装置,其特征在于,包括:
第一获取单元,用于获取待下发的第一配置信息,包括:接收目标对象发送的目标任务,所述目标任务为待目标边缘节点执行的任务,根据所述目标任务的任务属性和所述目标边缘节点的节点属性,生成所述第一配置信息,其中,所述第一配置信息为与目标边缘节点对应的增量配置信息,所述目标边缘节点为分布式系统中的边缘节点;
第一生成单元,用于生成第一目标消息,其中,所述第一目标消息中携带有所述第一配置信息;
第一发送单元,用于通过目标消息中间件将所述第一目标消息发送给所述目标边缘节点,以将所述第一配置信息下发给所述目标边缘节点,其中,所述目标消息中间件为目标中心节点上的消息中间件。
11.一种配置信息的下发装置,其特征在于,包括:
第一接收单元,用于接收目标中心节点通过目标消息中间件发送的第一目标消息,包括:接收所述目标中心节点通过所述目标消息中间件发送的目标任务消息,所述目标任务消息是与待目标边缘节点执行的目标任务对应的任务消息,所述目标任务消息中封装有第一配置信息,所述第一目标消息为所述目标任务消息,其中,所述目标中心节点为分布式系统中的中心节点,所述第一目标消息携带有第一配置信息,所述第一配置信息为下发给目标边缘节点的增量配置信息,所述目标消息中间件为目标中心节点上的消息中间件;
更新单元,用于使用所述第一配置信息更新所述目标边缘节点上已持久化的配置信息,得到目标配置信息;
第一持久化单元,用于将所述目标配置信息持久化到所述目标边缘节点上。
12.一种电子设备,包括处理器、通信接口、存储器和通信总线,其中,所述处理器、所述通信接口和所述存储器通过所述通信总线完成相互间的通信,其特征在于,
所述存储器,用于存储计算机程序;
所述处理器,用于通过运行所述存储器上所存储的所述计算机程序来执行权利要求1至6中任一项所述的方法步骤、或者来执行权利要求7至9中任一项所述的方法步骤。
13.一种计算机可读的存储介质,其特征在于,所述存储介质中存储有计算机程序,其中,所述计算机程序被设置为运行时执行权利要求1至6中任一项中所述的方法步骤、或者执行权利要求7至9中任一项中所述的方法步骤。
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202110518068.9A CN113254097B (zh) | 2021-05-12 | 2021-05-12 | 配置信息的下发方法和装置、电子设备和存储介质 |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202110518068.9A CN113254097B (zh) | 2021-05-12 | 2021-05-12 | 配置信息的下发方法和装置、电子设备和存储介质 |
Publications (2)
Publication Number | Publication Date |
---|---|
CN113254097A CN113254097A (zh) | 2021-08-13 |
CN113254097B true CN113254097B (zh) | 2024-09-13 |
Family
ID=77223101
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN202110518068.9A Active CN113254097B (zh) | 2021-05-12 | 2021-05-12 | 配置信息的下发方法和装置、电子设备和存储介质 |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN113254097B (zh) |
Families Citing this family (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN114363163A (zh) * | 2021-12-09 | 2022-04-15 | 北京六方云信息技术有限公司 | 基于https的设备部署方法、系统、设备及介质 |
Citations (2)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN111046065A (zh) * | 2019-10-28 | 2020-04-21 | 北京大学 | 可扩展的高性能分布式查询处理方法及装置 |
CN111901421A (zh) * | 2020-07-28 | 2020-11-06 | 腾讯科技(深圳)有限公司 | 一种数据处理方法及相关设备 |
Family Cites Families (5)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US7177917B2 (en) * | 2000-12-27 | 2007-02-13 | Softwired Ag | Scaleable message system |
US20200136930A1 (en) * | 2018-10-24 | 2020-04-30 | CA Software Österreich GmbH | Application environment provisioning |
CN109688235B (zh) * | 2019-03-18 | 2019-07-05 | 北京金山云网络技术有限公司 | 虚拟网络业务处理方法、装置和系统,控制器,存储介质 |
CN112118309A (zh) * | 2020-09-16 | 2020-12-22 | 三星电子(中国)研发中心 | 音频翻译方法和系统 |
CN112732793A (zh) * | 2021-01-14 | 2021-04-30 | 京东数字科技控股股份有限公司 | 业务数据的处理方法和装置、存储介质、电子装置 |
-
2021
- 2021-05-12 CN CN202110518068.9A patent/CN113254097B/zh active Active
Patent Citations (2)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN111046065A (zh) * | 2019-10-28 | 2020-04-21 | 北京大学 | 可扩展的高性能分布式查询处理方法及装置 |
CN111901421A (zh) * | 2020-07-28 | 2020-11-06 | 腾讯科技(深圳)有限公司 | 一种数据处理方法及相关设备 |
Also Published As
Publication number | Publication date |
---|---|
CN113254097A (zh) | 2021-08-13 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN107590001B (zh) | 负载均衡方法及装置、存储介质、电子设备 | |
US8069251B2 (en) | System and/or method for client-driven server load distribution | |
WO2020093500A1 (zh) | 智能调度方法、终端设备、边缘节点集群与智能调度系统 | |
CN110661849A (zh) | 一种请求处理方法、装置、电子设备及存储介质 | |
WO2017101366A1 (zh) | Cdn服务节点的调度方法及服务器 | |
CN112118315A (zh) | 数据处理系统、方法、装置、电子设备和存储介质 | |
WO2020036879A1 (en) | In situ triggered function as a service within a service mesh | |
US10425475B2 (en) | Distributed data management | |
CN109104368B (zh) | 一种请求连接方法、装置、服务器及计算机可读存储介质 | |
CN113794652B (zh) | 数据处理方法、装置、电子设备及存储介质 | |
CN103873597A (zh) | 分布式网页下载方法和系统 | |
US11303521B1 (en) | Support platform with bi-directional communication channel for performing remote actions on computing devices | |
US20230353467A1 (en) | Methods and apparatus for determining low latency network connectivity in computing systems | |
CN111212135A (zh) | 消息订阅方法、装置、系统、电子设备及存储介质 | |
CN113254097B (zh) | 配置信息的下发方法和装置、电子设备和存储介质 | |
CN110661673A (zh) | 一种心跳检测的方法及装置 | |
CN115499432A (zh) | 家庭终端算力资源管理系统及算力资源调度方法 | |
US11444882B2 (en) | Methods for dynamically controlling transmission control protocol push functionality and devices thereof | |
CN105933298B (zh) | 用于执行传输控制协议握手的设备和方法 | |
CN111090818B (zh) | 资源管理方法、资源管理系统、服务器及计算机存储介质 | |
CN108259576B (zh) | 一种软硬件实时信息传输系统和方法 | |
CN116248582A (zh) | 物联网通信方法、电子设备及物联网系统 | |
CN115150333A (zh) | 拥塞控制方法、装置、计算机设备和存储介质 | |
US20220141279A1 (en) | Client-side measurement of computer network conditions | |
CN113746851A (zh) | 一种支持实时解析grpc请求的代理系统和方法 |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
PB01 | Publication | ||
PB01 | Publication | ||
SE01 | Entry into force of request for substantive examination | ||
SE01 | Entry into force of request for substantive examination | ||
GR01 | Patent grant | ||
GR01 | Patent grant |