一种基于数据处理系统的数据处理方法及装置与流程

未命名 07-22 阅读:83 评论:0


1.本技术涉及计算机技术领域,特别是涉及一种基于数据处理系统的数据处理方法及装置。


背景技术:

2.在边缘计算场景中,边缘侧往往存在边缘计算集群,边缘计算集群中具有大量的边缘计算节点(边缘计算节点可以为物理机等),各个边缘计算节点中分别又部署了大量的功能组件,边缘计算场景还涉及中心服务端(具体的场景可以参见图1所示),大量的边缘计算节点往往需要与中心服务端之间进行数据交互。
3.例如,中心服务端中具有边缘计算节点中的各个功能组件为实现其功能需要使用到的数据。如此,在边缘节点中启动功能组件之后,功能组件即可工作以实现其功能,在功能组件工作的场景中,功能组件需要得到中心服务端中的一些数据,然后根据这些数据工作,以实现其功能。如此,各个功能组件均具有从中心服务端中获取各自为实现功能时需要使用到的数据的需求。


技术实现要素:

4.本技术示出了一种基于数据处理系统的数据处理方法及装置。
5.第一方面,本技术示出了一种基于数据处理系统的数据处理方法,数据处理系统至少包括中心服务端以及多个边缘计算节点,各个边缘计算节点中分别具有对接插件,至少一个边缘计算节点中部署有缓存插件或者在数据处理系统还包括的中间件中部署有缓存插件,对接插件与缓存插件之间对接,缓存插件与中心服务端之间对接;所述方法应用于缓存插件,所述方法包括:接收对接插件路由的监听请求,所述监听请求用于监听更新中心服务端中的目标类型的数据的更新事件,所述监听请求是边缘计算节点中的第一功能组件向对接插件传递的;确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接;在存在针对目标类型的数据的监听长连接的情况下,关联所述监听请求与所述监听长连接;在基于所述监听长连接监听到所述更新事件且通过所述监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据与所述监听长连接关联的所述监听请求向对接插件传递更新后的目标类型的数据,以使对接插件接收更新后的目标类型的数据,并向第一功能组件传递更新后的目标类型的数据。
6.在一个可选的实现方式中,所述方法还包括:在不存在针对目标类型的数据的监听长连接的情况下,针对所述监听请求建立缓存插件与中心服务端之间的针对目标类型的数据的监听长连接;在基于建立的监听长连接监听到所述更新事件且通过建立的监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据建立的监听长连接所针对的所述监听请求向对接插件传递更新后的目标类型的数据。
7.在一个可选的实现方式中,所述方法还包括:在缓存插件中缓存更新后的目标类型的数据。
8.在一个可选的实现方式中,所述方法还包括:在缓存插件中缓存有更新前的目标类型的数据的情况下,在缓存插件中删除更新前的目标类型的数据。
9.在一个可选的实现方式中,所述关联所述监听请求与所述监听长连接,包括:在缓存插件中存储所述监听请求的请求标识与针对目标类型的数据的监听长连接的连接标识之间的关联关系;相应地;所述根据与所述监听长连接关联的所述监听请求向对接插件传递更新后的目标类型的数据,包括:根据监听长连接的连接标识获取所述关联关系中的请求标识;根据所述关联关系中的请求标识所对应的所述监听请求向对接插件传递更新后的目标类型的数据。
10.在一个可选的实现方式中,所述确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接,包括:在缓存插件中的监听长连接的连接标识与监听长连接针对的类型之间的映射关系中,查找目标类型对应的连接标识;在映射关系中查找到目标类型对应的连接标识的情况下,确定缓存插件与中心服务端之间存在针对目标类型的数据的监听长连接;目标类型以及目标类型对应的连接标识是在之前建立缓存插件与中心服务端之间的针对目标类型的数据的监听长连接的情况下存储在所述映射关系中的;或者,在所述映射关系中未查找到目标类型对应的连接标识的情况下,确定缓存插件与中心服务端之间不存在针对目标类型的数据的监听长连接。
11.在一个可选的实现方式中,所述监听请求还携带鉴权信息;所述接收对接插件路由的监听请求之后,还包括:提取所述监听请求中携带的鉴权信息;根据所述鉴权信息确定所述监听请求是否为合法请求;在所述监听请求为合法请求的情况下,再确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接。
12.在一个可选的实现方式中,所述方法还包括:接收对接插件路由的查询请求;查询请求是边缘计算节点中的第二功能组件向对接插件传递的;查询请求携带目标类型,查询请求用于主动请求获取更新后的目标类型的数据;在缓存插件中查找更新后的目标类型的数据;根据查询请求向对接插件返回在缓存插件中查找到的、更新后的目标类型的数据,以使对接插件接收在缓存插件中查找到的、更新后的目标类型的数据,并向第二功能组件传递在缓存插件中查找到的、更新后的目标类型的数据。
13.第二方面,本技术示出了一种基于数据处理系统的数据处理方法,数据处理系统至少包括中心服务端以及多个边缘计算节点,各个边缘计算节点中分别具有对接插件,至少一个边缘计算节点中部署有缓存插件或者在数据处理系统还包括的中间件中部署有缓存插件,对接插件与缓存插件之间对接,缓存插件与中心服务端之间对接;所述方法应用于对接插件,所述方法包括:接收边缘计算节点中的第一功能组件传递的监听请求;所述监听请求用于监听更新中心服务端中的目标类型的数据的更新事件。将所述监听请求路由至缓存插件;以使缓存插件接收所述监听请求;确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接;在存在针对目标类型的数据的监听长连接的情况下,关联所述监听请求与所述监听长连接;在基于所述监听长连接监听到所述更新事件且通过所述监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据与所述监听长连接关联的所述监听请求向对接插件传递更新后的目标类型的数据;接收更新后的目标类型的数据;向第一功能组件传递更新后的目标类型的数据。
14.第三方面,本技术示出了一种基于数据处理系统的数据处理装置,数据处理系统
至少包括中心服务端以及多个边缘计算节点,各个边缘计算节点中分别具有对接插件,至少一个边缘计算节点中部署有缓存插件或者在数据处理系统还包括的中间件中部署有缓存插件,对接插件与缓存插件之间对接,缓存插件与中心服务端之间对接;所述装置应用于缓存插件,所述装置包括:第一接收模块,用于接收对接插件路由的监听请求,所述监听请求用于监听更新中心服务端中的目标类型的数据的更新事件,所述监听请求是边缘计算节点中的第一功能组件向对接插件传递的;第一确定模块,用于确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接;关联模块,用于在存在针对目标类型的数据的监听长连接的情况下,关联所述监听请求与所述监听长连接;第一传递模块,用于在基于所述监听长连接监听到所述更新事件且通过所述监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据与所述监听长连接关联的所述监听请求向对接插件传递更新后的目标类型的数据,以使对接插件接收更新后的目标类型的数据,并向第一功能组件传递更新后的目标类型的数据。
15.在一个可选的实现方式中,所述装置还包括:建立模块,用于在不存在针对目标类型的数据的监听长连接的情况下,针对所述监听请求建立缓存插件与中心服务端之间的针对目标类型的数据的监听长连接;第二传递模块,用于在基于建立的监听长连接监听到所述更新事件且通过建立的监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据建立的监听长连接所针对的所述监听请求向对接插件传递更新后的目标类型的数据。
16.在一个可选的实现方式中,所述装置还包括:缓存模块,用于在缓存插件中缓存更新后的目标类型的数据。
17.在一个可选的实现方式中,所述装置还包括:删除模块,用于在缓存插件中缓存有更新前的目标类型的数据的情况下,在缓存插件中删除更新前的目标类型的数据。
18.在一个可选的实现方式中,所述关联模块包括:存储单元,用于在缓存插件中存储所述监听请求的请求标识与针对目标类型的数据的监听长连接的连接标识之间的关联关系;相应地;所述第一传递模块包括:获取单元,用于根据监听长连接的连接标识获取所述关联关系中的请求标识;传递单元,用于根据所述关联关系中的请求标识所对应的所述监听请求向对接插件传递更新后的目标类型的数据。
19.在一个可选的实现方式中,所述第一确定模块包括:查找单元,用于在缓存插件中的监听长连接的连接标识与监听长连接针对的类型之间的映射关系中,查找目标类型对应的连接标识;第一确定单元,用于在映射关系中查找到目标类型对应的连接标识的情况下,确定缓存插件与中心服务端之间存在针对目标类型的数据的监听长连接;目标类型以及目标类型对应的连接标识是在之前建立缓存插件与中心服务端之间的针对目标类型的数据的监听长连接的情况下存储在所述映射关系中的;或者,第二确定单元,用于在所述映射关系中未查找到目标类型对应的连接标识的情况下,确定缓存插件与中心服务端之间不存在针对目标类型的数据的监听长连接。
20.在一个可选的实现方式中,所述监听请求还携带鉴权信息;所述装置还包括:提取模块,用于提取所述监听请求中携带的鉴权信息;第二确定模块,用于根据所述鉴权信息确定所述监听请求是否为合法请求;所述第一确定模块还用于:在所述监听请求为合法请求的情况下,确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接。
21.第四方面,本技术示出了一种基于数据处理系统的数据处理装置,数据处理系统至少包括中心服务端以及多个边缘计算节点,各个边缘计算节点中分别具有对接插件,至少一个边缘计算节点中部署有缓存插件或者在数据处理系统还包括的中间件中部署有缓存插件,对接插件与缓存插件之间对接,缓存插件与中心服务端之间对接;所述装置应用于对接插件,所述装置包括:第二接收模块,用于接收边缘计算节点中的第一功能组件传递的监听请求;所述监听请求用于监听更新中心服务端中的目标类型的数据的更新事件。路由模块,用于将所述监听请求路由至缓存插件;以使缓存插件接收所述监听请求;确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接;在存在针对目标类型的数据的监听长连接的情况下,关联所述监听请求与所述监听长连接;在基于所述监听长连接监听到所述更新事件且通过所述监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据与所述监听长连接关联的所述监听请求向对接插件传递更新后的目标类型的数据;第三接收模块,用于接收更新后的目标类型的数据;第三传递模块,用于向第一功能组件传递更新后的目标类型的数据。
22.第五方面,本技术示出了一种数据处理系统,数据处理系统至少包括中心服务端以及多个边缘计算节点,各个边缘计算节点中分别具有对接插件,至少一个边缘计算节点中部署有缓存插件或者在数据处理系统还包括的中间件中部署有缓存插件,对接插件与缓存插件之间对接,缓存插件与中心服务端之间对接;对接插件用于接收边缘计算节点中的第一功能组件传递的监听请求,向缓存插件路由监听请求;所述监听请求用于监听更新中心服务端中的目标类型的数据的更新事件;缓存插件用于接收对接插件路由的监听请求;确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接;在存在针对目标类型的数据的监听长连接的情况下,关联所述监听请求与所述监听长连接;在基于所述监听长连接监听到所述更新事件且通过所述监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据与所述监听长连接关联的所述监听请求向对接插件传递更新后的目标类型的数据;对接插件用于接收更新后的目标类型的数据,并向第一功能组件传递更新后的目标类型的数据。
23.第六方面,本技术示出了一种电子设备,电子设备包括:处理器;用于存储处理器可执行指令的存储器;其中,处理器被配置为执行如前述的任一方面所示的方法。
24.第七方面,本技术示出了一种非临时性计算机可读存储介质,当存储介质中的指令由电子设备的处理器执行时,使得电子设备能够执行如前述的任一方面所示的方法。
25.第八方面,本技术示出了一种计算机程序产品,当计算机程序产品中的指令由电子设备的处理器执行时,使得电子设备能够执行如前述的任一方面所示的方法。
26.与现有技术相比,本技术包括以下优点:
27.在本技术中,对接节点接收边缘计算节点中的第一功能组件传递的监听请求,将监听请求路由至缓存插件。缓存插件接收对接插件路由的监听请求。监听请求用于监听更新中心服务端中的目标类型的数据的更新事件。缓存插件确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接。在存在针对目标类型的数据的监听长连接的情况下,就可以不针对监听请求实时建立缓存插件与中心服务端之间的针对目标类型的数据的新的监听长连接,可以关联监听请求与已存在的针对目标类型的数据的监听长连接,以使得监听请求可以复用已存在的针对目标类型的数据的监听长连接,从而避免增加缓存
插件与中心服务端之间的针对目标类型的数据的监听长连接的数量,进而避免缓存插件与中心服务端之间的针对目标类型的数据的监听长连接的数量过多,进而避免由于监听长连接的数量过多,以避免各个监听长连接的带宽非常低,进而可以尽可能地降低监听长连接被中心服务端断开的可能性。
28.另外,在基于监听长连接监听到更新事件且通过监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,可以根据与监听长连接关联的监听请求向对接插件传递更新后的目标类型的数据,以使对接插件向第一功能组件传递更新后的目标类型的数据,进而第一功能组件可以得到更新后的目标类型的数据,可以起到确保第一功能组件能够及时得到更新后的目标类型的数据的目的。
附图说明
29.图1是当前的一种场景示意图。
30.图2是本技术的一种数据处理系统的结构框图。
31.图3是本技术的一种数据处理系统的结构框图。
32.图4是本技术的一种缓存插件的结构框图。
33.图5是本技术的一种基于数据处理系统的数据处理方法的步骤流程图。
34.图6是本技术的一种基于数据处理系统的数据处理方法的步骤流程图。
35.图7是本技术的一种基于数据处理系统的数据处理装置的结构框图。
36.图8是本技术的一种基于数据处理系统的数据处理装置的结构框图。
37.图9是本技术的一种装置的结构框图。
具体实施方式
38.为使本技术的上述目的、特征和优点能够更加明显易懂,下面结合附图和具体实施方式对本技术作进一步详细的说明。
39.其中,中心服务端有时候可能会根据实际情况对边缘计算节点中的功能组件为实现其功能需要使用到的这些数据更新,相应地;对于边缘计算节点中的功能组件而言,往往需要根据更新后的数据工作,以使得其实现的功能更准确或完整等。
40.为了使得在中心服务端对这些数据更新后,功能组件能够及时得到更新后的数据以及及时根据更新后的数据工作,在边缘计算节点中可以设置有对接插件,对接插件用于与中心服务端对接,边缘计算节点中的功能组件可以针对这些数据向对接插件发起监听请求,然后对接插件可以根据监听请求建立对接插件与中心服务端之间的监听长连接,以通过监听长连接监听中心服务端对这些数据更新的更新事件,且在通过监听长连接监听到中心服务端对这些数据更新的更新事件的情况下,对接插件可以通过监听长连接以从中心服务端中获取更新后的这些数据,并向功能组件返回更新后的这些数据,以使功能组件可以得到更新后的这些数据,并根据更新后的这些数据工作。
41.监听请求可以包括watch请求等,监听长连接可以包括watch长连接等。
42.然而,发明人发现,有时候,在边缘计算场景中,边缘计算集群的网络的带宽很小,尤其是在边缘计算集群中的边缘计算节点的数量非常大且各个边缘计算节点中的“需要监听其工作时需要使用的数据在中心服务端中是否更新”的功能节点的数量非常多的情况
下,在边缘计算集群中发起的监听请求的数量会非常多,例如,各个边缘计算节点中的对接插件针对边缘计算节点中的每一个功能组件发起的监听请求均需要分别建立对接节点与中心服务端之间的监听长连接,导致各个边缘计算节点分别与中心服务端之间的监听长连接的数量非常多,又由于边缘计算集群的网络的带宽很小,从而导致各个监听长连接的带宽非常低,进而使得对接插件通过监听长连接以从中心服务端中获取更新后的这些数据的速度非常慢,耗费时长非常长,且往往会超时,在超时的情况下,中心服务端会主动断开监听长连接,导致对接插件无法从中心服务端中得到更新后的这些数据,也就无法使得功能组件得到更新后的这些数据,导致功能组件在工作的过程中无法使用到更新后的这些数据。
43.为此,可以尽可能地避免中心服务端主动断开监听长连接。
44.为了实现“尽可能地避免中心服务端主动断开监听长连接”的目的,可以尽可能地提高通过监听长连接以从中心服务端中获取更新后的这些数据的速度,降低耗费的时长,以尽可能地避免超时。
45.为了实现“尽可能地提高通过监听长连接以从中心服务端中获取更新后的这些数据的速度,降低耗费的时长,以尽可能地避免超时”的目的,可以提高监听长连接的带宽,例如,在边缘计算集群的网络的带宽很小的情况下,提高监听长连接的带宽。
46.为了实现“在边缘计算集群的网络的带宽很小的情况下,提高监听长连接的带宽”的目的,提出了本技术的方案。
47.在对本技术的方案介绍之前,先对本技术可能涉及的技术术语进行解释。
48.边缘计算:在靠近数据、物体、用户的一侧,采用网络、计算、存储或应用管理等能力,提供靠近场景的计算服务。
49.list-watch机制:k8s原生支持的一种资源获取机制,通过拉取全量资源和监听变更事件的方式,保证数据的一致性。
50.读写分离:将资源的获取过程拆分为写缓存、读缓存两个操作,使得两个动作互不影响。
51.参见图2和3,示出了本技术的一种数据处理系统,数据处理系统至少包括中心服务端以及多个边缘计算节点。
52.各个边缘计算节点中分别具有对接插件。
53.至少一个边缘计算节点中部署有缓存插件或者在数据处理系统还包括的中间件中部署有缓存插件。
54.缓存插件与对接插件之间相互独立。
55.对接插件与缓存插件之间对接,缓存插件与中心服务端之间对接。
56.边缘计算节点中还部署有功能组件。
57.在一个例子中,在边缘节点中的功能组件需要与中心服务端之间进行数据交互的情况下,功能组件可以依次通过功能组件所在的边缘计算节点中的对接插件、缓存插件(可能位于功能组件所在的边缘计算节点中,也可能不位于功能组件所在的边缘计算节点中)与中心服务端之间进行数据交互。
58.对接插件可以包括:yurthub等。
59.缓存插件可以包括edge-apiserber-proxy等。
60.功能组件可以包括:coredns、hybrinet以及kubeproxy等。
61.在一个可能的情况下,各个边缘计算节点中的对接插件也具有直接与中心服务端之间对接的能力。
62.在一个例子中,参见图3,多个边缘计算节点中的其中一个边缘计算节点中部署有缓存插件,其他边缘计算节点中未部署有缓存插件。
63.各个边缘计算节点中的对接插件均可以与该一个边缘计算节点中的缓存插件对接。缓存插件可以与中心服务端对接。
64.各个边缘计算节点中还部署有功能组件。各个功能组件可以通过其所在的边缘计算节点中的对接插件以及该一个边缘计算节点中的缓存插件获取中心服务端中的数据等。
65.在本技术中,在多个边缘计算节点中,可以先通过选主机制在多个边缘计算节点中选举出master节点,其他节点为slave节点。然后在master节点中部署缓存插件。
66.在一个方式中,各个边缘计算节点的系统资源是相同的,例如,都是同一型号的物理机等。但是,master节点中部署有缓存插件,缓存插件在工作时会占用master节点的系统资源,例如内存、cpu(central processing unit,中央处理器)以及存储空间等。而缓存插件并不会占用slave节点中的系统资源,如此,可以会导致master节点的系统资源被占满而slave节点的系统资源空闲的情况,master节点的系统资源被占满则会导致master节点中的功能组件以及缓存插件无法正常工作,而slave节点的系统资源空闲又会导致系统资源浪费,可见,上述方式中的资源分配的方式不合理。上述方式也无法对缓存插件单独进行资源配置。
67.为此,在另一种方式中,例如,在选举出master节点并在master节点中部署缓存插件之后,可以针对实际情况对master节点配置更多的系统资源(例如包括内存资源以及cpu资源等),以提高缓存插件的性能,尽可能地避免master节点的系统资源被占满,以尽可能地避免master节点中的功能组件以及缓存插件无法正常工作。
68.或者,将多个边缘计算节点在逻辑上组合为一个分布式系统,在选举出master节点并在master节点中部署缓存插件之后,在逻辑上,可以将多个slave节点中的各自的一部分系统资源匀给缓存插件使用,以提高系统资源的利用率。
69.在另一个例子中,参见图4,多个边缘计算节点中均未部署缓存插件,缓存插件部署在独立于中心服务端以及各个边缘计算节点以外的物理机上,此物理机在逻辑上可以看作多个边缘计算节点与中心服务端之间的中间件。
70.在本例子中,缓存插件不受各个边缘计算节点的资源的制约,可以根据实际情况单独为物理机配备较多的系统资源(例如包括内存资源以及cpu资源等),以提高缓存插件的性能。
71.在另一个实施例中,多个边缘计算节点可以是节点集群中的部分边缘节点。例如,节点集群中包括大量的边缘计算节点,可以将节点集群中的大量的边缘计算节点划分为多份,每一份包括多个边缘节点,每一份中的多个边缘计算节点的数量小于节点集群中的大量的边缘计算节点的数量。
72.一份多个边缘计算节点可以组成一个节点池,节点池中包括多个边缘计算节点,将节点集群划分为几份,则可以得到几个节点池。
73.可以为各个节点池分别配备一个不同的缓存插件,也即,一个缓存插件可以专门
用于服务一个节点池中的多个边缘计算节点。
74.在一个实施例中,各个节点池分别对应的缓存插件可以分别与中心服务端对接。
75.或者,在另一个实施例中,在各个节点池分别对应的缓存插件中,可以有其中一部分缓存插件可以与中心服务端之间对接,而另一部分的缓存插件可以与该其中一部分缓存插件对接,如此,可以降低与中心服务端对接的缓存插件的数量。
76.例如,在一个例子中,在各个节点池分别对应的缓存插件中,可以是其中一个缓存插件可以与中心服务端之间对接,而除该其中一个缓存插件以外的其他缓存插件可以与该其中一个缓存插件对接,如此,可以降低与中心服务端对接的缓存插件的数量。
77.其中,若一个对接插件与中心服务端对接,则通过统计发现,该一个对接插件与中心服务端之间的监听长连接的数量有很多,每一个长连接都需要占用一部分带宽,由于边缘侧的带宽总量是有限的,且,若与中心服务端对接的缓存插件有很多,则总体上可能导致每一个长连接的带宽很低,进而可能会导致长连接被中心服务端断开的情况。
78.而本实施例中,降低与中心服务端对接的缓存插件的数量,如此,减少长连接的数量,如此,可以提高各个监听长连接的带宽,进而可以尽可能地降低长连接被中心服务端断开的可能性。
79.在本技术中,在建立一个新的节点池(新的节点池包括多个边缘计算节点)的情况下,可以在新的节点池中部署缓存插件(包括在新的节点池的第一个启动的边缘计算节点中部署缓存插件,或者,在独立于多个边缘计算节点以外的中间件中部署缓存插件),缓存插件可以与中心服务端对接,缓存插件可以在中心服务端中注册自己的信息,以使中心服务端可以感知到新的节点池中具有缓存插件,在新的节点池中的其他边缘计算节点启动之后,会先直连中心服务端,中心服务端向新的节点池中的其他边缘计算节点通知新的节点池中具有缓存插件以及缓存插件的地址,之后,新的节点池中的其他边缘计算节点就可以通过新的节点池中的缓存插件的地址与新的节点池中的缓存插件对接。
80.或者,缓存插件在中心服务端中注册自己的信息之后,可以正式启动成功,可以正常工作,新的节点池中的其他边缘计算节点以及新扩容的边缘计算节点可以监听缓存插件正式启动成功,然后新的节点池中的其他边缘计算节点以及新扩容的边缘计算节点就可以与新的节点池中的缓存插件对接。
81.在一个例子中,图4示出了缓存插件的结构,缓存插件包括:
82.loadbalancer:用于对接中心服务端。
83.资源监听池:负责管理建立的与中心服务端之间的监听长连接,并将更新事件涉及的更新守的数据同步写入缓存,通知到正在监听的多个下游监听请求。
84.持久化缓存:负责持久化缓存全部从中心服务端得到的数据,服务于来自下游的list查询请求。
85.https server:负责解析来自对接插件的请求,提取权限、参数等信息。
86.参见图5,示出了本技术的一种基于数据处理系统的数据处理方法,该方法应用于缓存插件,该方法包括:
87.在步骤s101中,接收对接插件路由的监听请求。监听请求用于监听更新中心服务端中的目标类型的数据的更新事件。监听请求是边缘计算节点中的第一功能组件向对接插件传递的。
88.在本技术中,第一功能组件所在的边缘计算节点是多个边缘计算节点中的其中一个边缘计算节点,在第一功能组件在工作时需要得到中心服务端中的目标类型的数据,另外,有时候中心服务端会对中心服务端中的目标类型的数据更新,得到更新后的目标类型的数据,之后,更新后的目标类型的数据位于中心服务端中,其次,在中心服务端对中心服务端中的目标类型的数据更新的情况下,对于第一功能组件而言,其往往需要及时得到更新后的目标类型的数据,以使得第一功能组件之后在工作时可以使用更新后的目标类型的数据,以使得第一功能组件实现的功能更准确或完整等。
89.为了使得第一功能组件能够及时得到更新后的目标类型的数据,则可以监听更新中心服务端中的目标类型的数据的更新事件,在监听到更新事件的情况下,则说明中心服务端已对中心服务端中的目标类型的数据更新且得到更新后的目标类型的数据,需要及时向第一功能组件提供更新后的目标类型的数据。
90.为此,第一功能组件可以向对接插件提交用于监听更新中心服务端中的目标类型的数据的更新事件的监听请求。对接插件在接收到监听请求之后,可以将监听请求路由至缓存插件,以使缓存插件得到监听请求。
91.在步骤s102中,确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接。
92.监听长连接可以包括tcp(transmission control protocol,传输控制协议)连接等。
93.在本技术中,缓存有监听长连接的连接标识与监听长连接针对的类型之间的映射关系,例如,在缓存插件中存储有监听长连接的连接标识与监听长连接针对的类型之间的映射关系。
94.在历史过程中,每当建立缓存插件与中心服务端之间针对一个类型的数据的监听长连接,则可以在该映射关系中存储建立的监听长连接的连接标识以及该类型,且在断开缓存插件与中心服务端之间针对该一个类型的数据的监听长连接的情况下,可以在该映射关系中删除断开的监听长连接的连接标识以及该类型。
95.相应地;每当建立缓存插件与中心服务端之间针对目标类型的数据的监听长连接,则可以在该映射关系中存储建立的监听长连接的连接标识以及目标类型,且在断开缓存插件与中心服务端之间针对目标类型的数据的监听长连接的情况下,可以在该映射关系中删除断开的监听长连接的连接标识以及目标类型。
96.如此,在本步骤中,可以在缓存插件中的监听长连接的连接标识与监听长连接针对的类型之间的映射关系中,查找目标类型对应的连接标识。
97.在该映射关系中查找到目标类型对应的连接标识的情况下,可以确定缓存插件与中心服务端之间存在针对目标类型的数据的监听长连接。其中,目标类型以及目标类型对应的连接标识是在之前建立缓存插件与中心服务端之间的针对目标类型的数据的监听长连接的情况下存储在映射关系中的。
98.或者,在该映射关系中未查找到目标类型对应的连接标识的情况下,可以确定缓存插件与中心服务端之间不存在针对目标类型的数据的监听长连接。
99.监听长连接的连接标识可以包括监听长连接涉及的端口号等,不同的监听长连接的连接标识不同。
100.类型可以以字符串的形式来表示等。
101.在存在针对目标类型的数据的监听长连接的情况下,在步骤s103中,关联监听请求与针对目标类型的数据的监听长连接。
102.在一个例子中,可以在缓存插件中存储监听请求的请求标识与针对目标类型的数据的监听长连接的连接标识之间的关联关系。
103.监听请求的请求标识可以包括监听请求的id等,不同的监听请求的请求标识不同。
104.在本技术中,在存在针对目标类型的数据的监听长连接的情况下,就可以不针对监听请求建立缓存插件与中心服务端之间的针对目标类型的数据的监听长连接,可以关联监听请求与针对目标类型的数据的监听长连接,以使得监听请求可以复用已存在的针对目标类型的数据的监听长连接,从避免增加缓存插件与中心服务端之间的针对目标类型的数据的监听长连接,进而避免缓存插件与中心服务端之间的针对目标类型的数据的监听长连接的数量过多,进而避免由于监听长连接的数量过多而导致各个监听长连接的带宽非常低,进而可以尽可能地降低监听长连接被中心服务端断开的可能性。
105.在执行步骤s103之后,可以执行步骤s104。
106.在步骤s104中,在基于监听长连接监听到更新事件且通过监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据与监听长连接关联的监听请求向对接插件传递更新后的目标类型的数据。
107.在本步骤中,在缓存插件基于监听长连接监听到更新事件的情况下,则确定中心服务端已对中心服务端中的目标类型的数据更新且得到更新后的目标类型的数据,如此,缓存插件可以通过监听长连接从中心服务端中获取更新后的目标类型的数据。
108.例如,缓存插件可以通过监听长连接向中心服务端发送获取请求,获取请求用于获取更新事件对应的更新后的目标类型的数据。中心服务端可以通过监听长连接接收获取请求,然后通过监听长连接向缓存插件发送更新事件对应的更新后的目标类型的数据。缓存插件可以通过监听长连接接收中心服务端发送的更新事件对应的更新后的目标类型的数据。
109.之后,由于是通过监听长连接从中心服务端中获取到更新后的目标类型的数据的,如此,缓存插件可以获取监听长连接的连接标识,然后根据监听长连接的连接标识获取上述关联关系中(步骤s103中提到的关联关系)的请求标识,然后可以根据请求标识所对应的监听请求向对接插件传递更新后的目标类型的数据。
110.对接插件在接收到更新后的目标类型的数据的情况下,可以向第一功能组件传递更新后的目标类型的数据,以使第一功能组件可以得到更新后的目标类型的数据。
111.在不存在针对目标类型的数据的监听长连接的情况下,在步骤s105中,针对监听请求建立缓存插件与中心服务端之间的针对目标类型的数据的监听长连接。
112.在不存在针对目标类型的数据的监听长连接的情况下,为了能够监听更新事件,则可以针对监听请求建立缓存插件与中心服务端之间的针对目标类型的数据的监听长连接。
113.在本技术中,缓存有监听长连接的连接标识与监听长连接针对的类型之间的映射关系。
114.相应地;在针对监听请求建立缓存插件与中心服务端之间的针对目标类型的数据的监听长连接之后,可以在该映射关系中存储建立的监听长连接的连接标识以及目标类型。
115.待之后在断开缓存插件与中心服务端之间针对目标类型的数据的监听长连接的情况下,可以在该映射关系中删除断开的监听长连接的连接标识以及目标类型。
116.在执行步骤s105之后,可以执行步骤s106。
117.在步骤s106中,在基于建立的监听长连接监听到更新事件且通过建立的监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据建立的监听长连接所针对的监听请求向对接插件传递更新后的目标类型的数据。
118.本步骤具体可以参见步骤s104的描述,在此不做详述。
119.在本技术中,对接节点接收边缘计算节点中的第一功能组件传递的监听请求,将监听请求路由至缓存插件。缓存插件接收对接插件路由的监听请求。监听请求用于监听更新中心服务端中的目标类型的数据的更新事件。缓存插件确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接。在存在针对目标类型的数据的监听长连接的情况下,就可以不针对监听请求实时建立缓存插件与中心服务端之间的针对目标类型的数据的新的监听长连接,可以关联监听请求与已存在的针对目标类型的数据的监听长连接,以使得监听请求可以复用已存在的针对目标类型的数据的监听长连接,从而避免增加缓存插件与中心服务端之间的针对目标类型的数据的监听长连接的数量,进而避免缓存插件与中心服务端之间的针对目标类型的数据的监听长连接的数量过多,进而避免由于监听长连接的数量过多,以避免各个监听长连接的带宽非常低,进而可以尽可能地降低监听长连接被中心服务端断开的可能性。
120.另外,在基于监听长连接监听到更新事件且通过监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,可以根据与监听长连接关联的监听请求向对接插件传递更新后的目标类型的数据,以使对接插件向第一功能组件传递更新后的目标类型的数据,进而第一功能组件可以得到更新后的目标类型的数据,可以起到确保第一功能组件能够及时得到更新后的目标类型的数据的目的。
121.相应地,参见图6,示出了本技术的一种基于数据处理系统的数据处理方法,该方法应用于对接插件,该方法包括:
122.在步骤s201中,接收边缘计算节点中的第一功能组件传递的监听请求;监听请求用于监听更新中心服务端中的目标类型的数据的更新事件。
123.在步骤s202中,将监听请求路由至缓存插件;以使缓存插件接收监听请求;确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接;在存在针对目标类型的数据的监听长连接的情况下,关联监听请求与针对目标类型的数据的监听长连接;在基于监听长连接监听到更新事件且通过监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据与监听长连接关联的监听请求向对接插件传递更新后的目标类型的数据。
124.在步骤s203中,接收更新后的目标类型的数据。
125.在步骤s204中,向第一功能组件传递更新后的目标类型的数据。
126.在本技术中,对接节点接收边缘计算节点中的第一功能组件传递的监听请求,将
监听请求路由至缓存插件。缓存插件接收对接插件路由的监听请求。监听请求用于监听更新中心服务端中的目标类型的数据的更新事件。缓存插件确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接。在存在针对目标类型的数据的监听长连接的情况下,就可以不针对监听请求实时建立缓存插件与中心服务端之间的针对目标类型的数据的新的监听长连接,可以关联监听请求与已存在的针对目标类型的数据的监听长连接,以使得监听请求可以复用已存在的针对目标类型的数据的监听长连接,从而避免增加缓存插件与中心服务端之间的针对目标类型的数据的监听长连接的数量,进而避免缓存插件与中心服务端之间的针对目标类型的数据的监听长连接的数量过多,进而避免由于监听长连接的数量过多,以避免各个监听长连接的带宽非常低,进而可以尽可能地降低监听长连接被中心服务端断开的可能性。
127.另外,在基于监听长连接监听到更新事件且通过监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,可以根据与监听长连接关联的监听请求向对接插件传递更新后的目标类型的数据,以使对接插件向第一功能组件传递更新后的目标类型的数据,进而第一功能组件可以得到更新后的目标类型的数据,可以起到确保第一功能组件能够及时得到更新后的目标类型的数据的目的。
128.在本技术一个实施例中,有时候,在请求监听中心服务端对目标类型的数据更新的更新事件以及请求从中心服务端中获取数据是需要鉴权的。例如,鉴权请求是否合法,在请求合法的情况下,才允许监听中心服务端对目标类型的数据更新的更新事件以及才允许从中心服务端中获取数据。
129.以前是中心服务端对请求鉴权。但是,在本技术中,存在缓存插件,如此,为便于鉴权,可以是缓存插件对请求进行鉴权,将中心服务端与鉴权事项解耦,简化了中心服务端,降低了中心服务端的负荷,且可以避免鉴权事项占用更多的网络资源。
130.例如,监听请求还携带鉴权信息。
131.缓存插件接收对接插件路由的监听请求之后,可以提取监听请求中携带的鉴权信息。根据鉴权信息确定监听请求是否为合法请求。在监听请求为合法请求的情况下,再执行步骤s102:确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接。或者,在监听请求不为合法请求的情况下,结束流程。
132.其中,根据鉴权信息确定监听请求是否为合法请求的确定方式可以参见当前已经存在的方式,本技术对此不加以限定。
133.鉴权信息可以包括token和可选的query参数等。
134.进一步地,在本技术另一实施例中,在缓存插件从中心服务端中得到更新后的目标类型的数据的情况下,可以在缓存插件中缓存更新后的目标类型的数据。
135.如此,待之后有第二功能组件(第二功能组件可以是多个边缘计算节点中的其中一个边缘计算节点中的其中一个功能组件)需要获取中心服务端中的更新后的目标类型的数据,则第二功能组件可以向对接插件(此对接插件可以是第二功能组件所在的边缘计算节点中的对接插件)发起查询请求(第二功能组件可能未针对目标类型的数据发起监听请求,如此,若第二功能组件需要得到更新后的目标类型的数据,则需要发起查询请求,以通过查询请求获取更新后的目标类型的数据),查询请求用于主动请求获取更新后的目标类型的数据,例如,查询请求可以携带目标类型等,类型可以以字符串的形式来表示等。
136.对接插件在接收到第二功能组件传递的查询请求之后,可以将查询请求路由至缓存插件。
137.缓存插件在得到查询请求之后,可以先在缓存插件中查找更新后的目标类型的数据,例如,先根据查询请求携带的目标类型在缓存插件中查找更新后的目标类型的数据,且在缓存插件中能够查找到更新后的目标类型的数据,如此,可以根据查询请求向对接插件返回在缓存插件中查找到的、更新后的目标类型的数据。
138.对接插件可以接收在缓存插件中查找到的、更新后的目标类型的数据,并向第二功能组件传递在缓存插件中查找到的、更新后的目标类型的数据,以使第二功能组件可以得到更新后的目标类型的数据。
139.通过本实施例,由于缓存插件可以得到在缓存插件中缓存的更新后的目标类型的数据,并通过对接插件向第二功能组件提供缓存的更新后的目标类型的数据,如此,缓存插件可以不从中心服务端中实时获取更新后的目标类型的数据,从而可以节省带宽,例如,可以节省边缘侧与中心侧之间的带宽等。
140.也即,针对缓存插件得到的查询请求(例如,多个边缘计算节点中的其中一个边缘计算节点中的其中的一个功能组件通过位于该其中一个边缘节点中的对接插件向缓存插件传递的查询请求)而言,可以先在缓存插件中查找查询请求所需请求的类型的数据,若缓存插件中已缓存查询请求所需请求的类型的数据,则在缓存插件中可以查找到查询请求所需请求的类型的数据,然后就可以返回查询请求所需请求的类型的数据,查询请求的发起者就可以得到查询请求所需请求的类型的数据。如此,缓存插件可以不从中心服务端中实时获取查询请求所需请求的类型的数据,从而可以节省带宽,例如,可以节省边缘侧与中心侧之间的带宽等。
141.进一步地,在缓存插件中缓存有更新前的目标类型的数据的情况下,更新前的目标类型的数据往往不会再被功能组件使用,如此,还可以在缓存插件中删除更新前的目标类型的数据,以节省存储空间。
142.另外,在另一实施例中,有可能边缘侧断网,导致边缘侧与中心服务端之间断网,例如,缓存插件与中心服务端之间断网,各个边缘计算节点分别与中服务端之间断网。在这种情况下,缓存插件也无法从中心服务端中获取新的数据,无法在缓存插件中缓存新的数据。
143.但是,本技术引入缓存插件的读写分离的策略,虽然无法在缓存插件中写数据(缓存数据),但是不影响在缓存插件中读数据,从而使得缓存插件可以得到在缓存插件中缓存的更新后的目标类型的数据,并通过对接插件向第二功能组件提供缓存的更新后的目标类型的数据,如此,缓存插件可以不从中心服务端中实时获取更新后的目标类型的数据,从而可以节省带宽,例如,可以节省边缘侧与中心侧之间的带宽等。
144.由于边缘侧断网,中心服务端可以对中心服务端中的数据更新,缓存插件无法及时获取中心服务端中的更新后的数据,但是,在边缘侧通网之后,会随着针对监听请求监听的更新事件以及查询请求的主动获取数据的情况而逐渐得到更新后的数据,并在缓存插件中缓存更新后的数据,以使得中心服务端中的数据与缓存插件中的数据可以尽可能地保持一致。查询请求可以包括list请求等。
145.其中,在边缘侧断网期间,多个边缘计算节点中的功能组件均可以正常通过对接
插件向缓存插件提交监听请求以及查询请求。
146.针对监听请求,缓存插件可以缓存监听请求,在边缘侧通网之后,缓存插件针对之前接收到的各个监听请求可以分别建立缓存插件与中心服务端之间的各个监听请求分别所需要请求的类型的数据的监听长连接。
147.针对查询请求,如前所述,缓存插件可以在缓存插件中查找查询请求所需请求的类型的数据,在查找到缓存的查询请求所需请求的类型的数据的情况下,直接通过对接插件向查询请求的发起者传递查询请求所需请求的类型的数据。
148.如此可见,边缘侧断网不会引发边缘侧的边缘计算节点故障。
149.在本技术中,同一边缘计算节点中的不同的功能组件在工作时需要使用的数据的类型不全相同,且中心服务端中存储有各个边缘计算节点中的各个功能组件在工作时需要使用的各个类型的数据。
150.中心服务端中存储的各个类型的数据均可以在技术上适用本方案,也即,本方案在技术上不局限于适用目标类型的数据。如此,本技术的方案的适用范围更大。
151.当然,可以理解的是,根据实际需求,也可以指定一些特定的类型的数据不使用本方案等。
152.例如,在一个例子中,缓存插件缓存的数据是为了提供给多个边缘计算节点中的每一个边缘计算节点使用的,起到复用作用,以及,缓存插件建立的针对某一类型的数据的监听长连接是针对边缘计算节点中的每一个边缘计算节点针对该类型的数据的监听请求维持的,起到复用作用。
153.也即,对于缓存插件缓存的一个类型的数据,多个边缘计算节点中的每一个边缘计算节点往往都需要使用该类型数据,起到复用作用,以及,缓存插件建立的针对该类型的数据的监听长连接是对每一个边缘计算节点针对该类型的数据的监听请求复用的,起到复用作用。
154.然而,发明人发现,存在一种情况:对于任意一个边缘计算节点中的某一功能组件,该功能组件需要从中心服务端中获取某一类型的数据,但是该类型的数据只与该边缘计算节点相关,而与其他边缘计算节点无关,也即,只有该边缘计算节点中的该功能组件才会使用该类型的数据,而其他边缘计算节点中的功能组件并不会使用该类型的数据。
155.可见,一方面,在该边缘计算节点中的该功能组件通过缓存插件得到该类型的数据之后,若在缓存插件中缓存该类型的数据,则由于其他边缘计算节点中的功能组件并不会使用该类型的数据,进而其他边缘计算节点中的功能组件也不会主动从缓存插件中获取缓存的该类型的数据,可见,在缓存插件中缓存的该类型的数据起不到的复用的作用,还占用存储空间。
156.另一方面,若该边缘计算节点中的该功能组件向缓存插件发送了针对该类型的数据的监听请求,且缓存插件针对监听请求建立了缓存插件与中心服务端之间的针对该类型的数据的监听长连接,则由于其他边缘计算节点中的功能组件并不会使用该类型的数据,如此,也不会将其他边缘节点中的功能组件的监听请求与该监听长连接关联,可见,起不到的复用的作用,维持监听长连接还占用缓存插件的系统资源。
157.为此,针对该边缘计算节点中的该功能组件获取该类型的数据而言,可以不经过缓存插件。
158.在该边缘计算节点中的对接插件在接收到该边缘计算节点中的该功能组件提交的监听请求之后,该边缘计算节点中的对接插件可以直接建立该边缘计算节点中的对接插件与中心服务端之间的针对该类型的数据的监听长连接。
159.或者,在该边缘计算节点中的对接插件在接收到该边缘计算节点中的该功能组件提交的查询请求之后,该边缘计算节点中的对接插件可以直接与中心服务端交互,以从中心服务端中获取到该类型的数据,并向该边缘计算节点中的该功能组件传递该类型的数据。
160.如此,在本技术中,事先可以统计可以不通过缓存插件而可以直接从中心服务端中获取的数据的类型,并在各个边缘计算节点中的对接插件中的类型列表中分别记录统计的类型。
161.如此,在对接插件接收到边缘计算节点中的功能组件传递的监听请求(监听请求携带监听请求所针对的数据的类型,类型可以以字符串表示等)之后,可以确定监听请求所针对的数据的类型是否位于对接插件的类型列表中。在监听请求所针对的数据的类型不位于对接插件的类型列表中的情况下,再将监听请求路由至缓存插件,以交由缓存插件对监听请求处理。或者,在监听请求所针对的数据的类型位于对接插件的类型列表中的情况下,对接插件可以不将监听请求路由至缓存插件,而可以直接建立针对该类型的数据的对接插件与中心服务端之间的监听长连接。
162.在对接插件接收到边缘计算节点中的功能组件传递的查询请求(查询请求携带查询请求所针对的数据的类型,类型可以以字符串表示等)之后,可以确定查询请求所针对的数据的类型是否位于对接插件的类型列表中。在查询请求所针对的数据的类型不位于对接插件的类型列表中的情况下,再将查询请求路由至缓存插件,以交由缓存插件对查询请求处理。或者,在查询请求所针对的数据的类型位于对接插件的类型列表中的情况下,对接插件可以不将查询请求路由至缓存插件,而可以直接向中心服务端发送查询请求,以从中心服务端中直接得到该类型的数据。
163.在另一个实施例中,对于任意一个边缘计算节点,在该边缘计算节点中的多个功能组件中,需要获取该边缘计算节点中的对接插件中的类型列表中的类型对应的数据的功能组件也是特定的,如此,事先可以统计可以不通过缓存插件而可以直接从中心服务端中获取的数据的类型,并统计需要获取该类型对应的数据的功能组件的组件标识,以及在各个边缘计算节点中的对接插件中的标识列表中记录统计的组件标识。不同的功能组件的组件标识不同。
164.如此,在对接插件接收到边缘计算节点中的功能组件传递的监听请求(监听请求携带该功能组件的组件标识)之后,可以确定监听请求携带的该功能组件的组件标识是否位于对接插件的标识列表中。在监听请求携带的该功能组件的组件标识不位于对接插件的标识列表中的情况下,再将监听请求路由至缓存插件,以交由缓存插件对监听请求处理。或者,在监听请求携带的该功能组件的组件标识位于对接插件的标识列表中的情况下,对接插件可以不将监听请求路由至缓存插件,而可以直接建立针对监听请求需要请求的类型的数据的对接插件与中心服务端之间的监听长连接。
165.在对接插件接收到边缘计算节点中的功能组件传递的查询请求(查询请求携带该功能组件的组件标识)之后,可以确定查询请求携带的该功能组件的组件标识是否位于对
接插件的标识列表中。在查询请求携带的该功能组件的组件标识不位于对接插件的标识列表中的情况下,再将查询请求路由至缓存插件,以交由缓存插件对查询请求处理。或者,在查询请求携带的该功能组件的组件标识位于对接插件的标识列表中的情况下,对接插件可以不将查询请求路由至缓存插件,而可以直接向中心服务端发送查询请求,以从中心服务端中直接得到查询请求需要请求的类型的数据。
166.需要说明的是,对于方法实施例,为了简单描述,故将其都表述为一系列的动作组合,但是本领域技术人员应该知悉,本技术并不受所描述的动作顺序的限制,因为依据本技术,某些步骤可以采用其他顺序或者同时进行。其次,本领域技术人员也应该知悉,说明书中所描述的实施例均属于可选实施例,所涉及的动作并不一定是本技术所必须的。
167.参照图7,示出了本技术的一种基于数据处理系统的数据处理装置,数据处理系统至少包括中心服务端以及多个边缘计算节点,各个边缘计算节点中分别具有对接插件,至少一个边缘计算节点中部署有缓存插件或者在数据处理系统还包括的中间件中部署有缓存插件,对接插件与缓存插件之间对接,缓存插件与中心服务端之间对接;所述装置应用于缓存插件,所述装置包括:
168.第一接收模块11,用于接收对接插件路由的监听请求,所述监听请求用于监听更新中心服务端中的目标类型的数据的更新事件,所述监听请求是边缘计算节点中的第一功能组件向对接插件传递的;
169.第一确定模块12,用于确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接;
170.关联模块13,用于在存在针对目标类型的数据的监听长连接的情况下,关联所述监听请求与所述监听长连接;
171.第一传递模块14,用于在基于所述监听长连接监听到所述更新事件且通过所述监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据与所述监听长连接关联的所述监听请求向对接插件传递更新后的目标类型的数据,以使对接插件接收更新后的目标类型的数据,并向第一功能组件传递更新后的目标类型的数据。
172.在一个可选的实现方式中,所述装置还包括:
173.建立模块,用于在不存在针对目标类型的数据的监听长连接的情况下,针对所述监听请求建立缓存插件与中心服务端之间的针对目标类型的数据的监听长连接;
174.第二传递模块,用于在基于建立的监听长连接监听到所述更新事件且通过建立的监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据建立的监听长连接所针对的所述监听请求向对接插件传递更新后的目标类型的数据。
175.在一个可选的实现方式中,所述装置还包括:
176.缓存模块,用于在缓存插件中缓存更新后的目标类型的数据。
177.在一个可选的实现方式中,所述装置还包括:
178.删除模块,用于在缓存插件中缓存有更新前的目标类型的数据的情况下,在缓存插件中删除更新前的目标类型的数据。
179.在一个可选的实现方式中,所述关联模块包括:
180.存储单元,用于在缓存插件中存储所述监听请求的请求标识与针对目标类型的数据的监听长连接的连接标识之间的关联关系;
181.相应地;
182.所述第一传递模块包括:
183.获取单元,用于根据监听长连接的连接标识获取所述关联关系中的请求标识;
184.传递单元,用于根据所述关联关系中的请求标识所对应的所述监听请求向对接插件传递更新后的目标类型的数据。
185.在一个可选的实现方式中,所述第一确定模块包括:
186.查找单元,用于在缓存插件中的监听长连接的连接标识与监听长连接针对的类型之间的映射关系中,查找目标类型对应的连接标识;
187.第一确定单元,用于在映射关系中查找到目标类型对应的连接标识的情况下,确定缓存插件与中心服务端之间存在针对目标类型的数据的监听长连接;目标类型以及目标类型对应的连接标识是在之前建立缓存插件与中心服务端之间的针对目标类型的数据的监听长连接的情况下存储在所述映射关系中的;
188.或者,
189.第二确定单元,用于在所述映射关系中未查找到目标类型对应的连接标识的情况下,确定缓存插件与中心服务端之间不存在针对目标类型的数据的监听长连接。
190.在一个可选的实现方式中,所述监听请求还携带鉴权信息;
191.所述装置还包括:
192.提取模块,用于提取所述监听请求中携带的鉴权信息;
193.第二确定模块,用于根据所述鉴权信息确定所述监听请求是否为合法请求;
194.所述第一确定模块还用于:在所述监听请求为合法请求的情况下,确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接。
195.在一个可选的实现方式中,所述装置还包括:
196.第四接收模块,用于接收对接插件路由的查询请求;查询请求是边缘计算节点中的第二功能组件向对接插件传递的;查询请求携带目标类型,查询请求用于主动请求获取更新后的目标类型的数据;
197.查找模块,用于在缓存插件中查找更新后的目标类型的数据;
198.返回模块,用于根据查询请求向对接插件返回在缓存插件中查找到的、更新后的目标类型的数据,以使对接插件接收在缓存插件中查找到的、更新后的目标类型的数据,并向第二功能组件传递在缓存插件中查找到的、更新后的目标类型的数据。
199.在本技术中,对接节点接收边缘计算节点中的第一功能组件传递的监听请求,将监听请求路由至缓存插件。缓存插件接收对接插件路由的监听请求。监听请求用于监听更新中心服务端中的目标类型的数据的更新事件。缓存插件确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接。在存在针对目标类型的数据的监听长连接的情况下,就可以不针对监听请求实时建立缓存插件与中心服务端之间的针对目标类型的数据的新的监听长连接,可以关联监听请求与已存在的针对目标类型的数据的监听长连接,以使得监听请求可以复用已存在的针对目标类型的数据的监听长连接,从而避免增加缓存插件与中心服务端之间的针对目标类型的数据的监听长连接的数量,进而避免缓存插件与中心服务端之间的针对目标类型的数据的监听长连接的数量过多,进而避免由于监听长连接的数量过多,以避免各个监听长连接的带宽非常低,进而可以尽可能地降低监听长连接
被中心服务端断开的可能性。
200.另外,在基于监听长连接监听到更新事件且通过监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,可以根据与监听长连接关联的监听请求向对接插件传递更新后的目标类型的数据,以使对接插件向第一功能组件传递更新后的目标类型的数据,进而第一功能组件可以得到更新后的目标类型的数据,可以起到确保第一功能组件能够及时得到更新后的目标类型的数据的目的。
201.参照图8,示出了本技术的一种基于数据处理系统的数据处理装置,数据处理系统至少包括中心服务端以及多个边缘计算节点,各个边缘计算节点中分别具有对接插件,至少一个边缘计算节点中部署有缓存插件或者在数据处理系统还包括的中间件中部署有缓存插件,对接插件与缓存插件之间对接,缓存插件与中心服务端之间对接;所述装置应用于对接插件,所述装置包括:
202.第二接收模块21,用于接收边缘计算节点中的第一功能组件传递的监听请求;所述监听请求用于监听更新中心服务端中的目标类型的数据的更新事件。
203.路由模块22,用于将所述监听请求路由至缓存插件;以使缓存插件接收所述监听请求;确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接;在存在针对目标类型的数据的监听长连接的情况下,关联所述监听请求与所述监听长连接;在基于所述监听长连接监听到所述更新事件且通过所述监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据与所述监听长连接关联的所述监听请求向对接插件传递更新后的目标类型的数据;
204.第三接收模块23,用于接收更新后的目标类型的数据;
205.第三传递模块24,用于向第一功能组件传递更新后的目标类型的数据。
206.在本技术中,对接节点接收边缘计算节点中的第一功能组件传递的监听请求,将监听请求路由至缓存插件。缓存插件接收对接插件路由的监听请求。监听请求用于监听更新中心服务端中的目标类型的数据的更新事件。缓存插件确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接。在存在针对目标类型的数据的监听长连接的情况下,就可以不针对监听请求实时建立缓存插件与中心服务端之间的针对目标类型的数据的新的监听长连接,可以关联监听请求与已存在的针对目标类型的数据的监听长连接,以使得监听请求可以复用已存在的针对目标类型的数据的监听长连接,从而避免增加缓存插件与中心服务端之间的针对目标类型的数据的监听长连接的数量,进而避免缓存插件与中心服务端之间的针对目标类型的数据的监听长连接的数量过多,进而避免由于监听长连接的数量过多,以避免各个监听长连接的带宽非常低,进而可以尽可能地降低监听长连接被中心服务端断开的可能性。
207.另外,在基于监听长连接监听到更新事件且通过监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,可以根据与监听长连接关联的监听请求向对接插件传递更新后的目标类型的数据,以使对接插件向第一功能组件传递更新后的目标类型的数据,进而第一功能组件可以得到更新后的目标类型的数据,可以起到确保第一功能组件能够及时得到更新后的目标类型的数据的目的。
208.本技术实施例还提供了一种非易失性可读存储介质,该存储介质中存储有一个或多个模块(programs),该一个或多个模块被应用在设备时,可以使得该设备执行本技术实
施例中各方法步骤的指令(instructions)。
209.本技术实施例提供了一个或多个机器可读介质,其上存储有指令,当由一个或多个处理器执行时,使得电子设备执行如上述实施例中一个或多个的方法。本技术实施例中,电子设备包括服务器、网关、子设备等,子设备为物联网设备等设备。
210.本公开的实施例可被实现为使用任意适当的硬件,固件,软件,或及其任意组合进行想要的配置的装置,该装置可包括服务器(集群)、终端设备如iot设备等电子设备。
211.图9示意性地示出了可被用于实现本技术中的各个实施例的示例性装置1300。
212.对于一个实施例,图9示出了示例性装置1300,该装置具有一个或多个处理器1302、被耦合到(一个或多个)处理器1302中的至少一个的控制模块(芯片组)1304、被耦合到控制模块1304的存储器1306、被耦合到控制模块1304的非易失性存储器(nvm)/存储设备1308、被耦合到控制模块1304的一个或多个输入/输出设备1310,和被耦合到控制模块1304的网络接口1312。
213.处理器1302可包括一个或多个单核或多核处理器,处理器1302可包括通用处理器或专用处理器(例如图形处理器、应用处理器、基频处理器等)的任意组合。在一些实施例中,装置1300能够作为本技术实施例中网关等服务器设备。
214.在一些实施例中,装置1300可包括具有指令1314的一个或多个计算机可读介质(例如,存储器1306或nvm/存储设备1308)和与该一个或多个计算机可读介质相合并被配置为执行指令1314以实现模块从而执行本公开中的动作的一个或多个处理器1302。
215.对于一个实施例,控制模块1304可包括任意适当的接口控制器,以向(一个或多个)处理器1302中的至少一个和/或与控制模块1304通信的任意适当的设备或组件提供任意适当的接口。
216.控制模块1304可包括存储器控制器模块,以向存储器1306提供接口。存储器控制器模块可以是硬件模块、软件模块和/或固件模块。
217.存储器1306可被用于例如为装置1300加载和存储数据和/或指令1314。对于一个实施例,存储器1306可包括任意适当的易失性存储器,例如,适当的dram。在一些实施例中,存储器1306可包括双倍数据速率四同步动态随机存取存储器(ddr4sdram)。
218.对于一个实施例,控制模块1304可包括一个或多个输入/输出控制器,以向nvm/存储设备1308及(一个或多个)输入/输出设备1310提供接口。
219.例如,nvm/存储设备1308可被用于存储数据和/或指令1314。nvm/存储设备1308可包括任意适当的非易失性存储器(例如,闪存)和/或可包括任意适当的(一个或多个)非易失性存储设备(例如,一个或多个硬盘驱动器(hdd)、一个或多个光盘(cd)驱动器和/或一个或多个数字通用光盘(dvd)驱动器)。
220.nvm/存储设备1308可包括在物理上作为装置1300被安装在其上的设备的一部分的存储资源,或者其可被该设备访问可不必作为该设备的一部分。例如,nvm/存储设备1308可通过网络经由(一个或多个)输入/输出设备1310进行访问。
221.(一个或多个)输入/输出设备1310可为装置1300提供接口以与任意其他适当的设备通信,输入/输出设备1310可以包括通信组件、拼音组件、传感器组件等。网络接口1312可为装置1300提供接口以通过一个或多个网络通信,装置1300可根据一个或多个无线网络标准和/或协议中的任意标准和/或协议来与无线网络的一个或多个组件进行无线通信,例如
接入基于通信标准的无线网络,如wifi、2g、3g、4g、5g等,或它们的组合进行无线通信。
222.对于一个实施例,(一个或多个)处理器1302中的至少一个可与控制模块1304的一个或多个控制器(例如,存储器控制器模块)的逻辑封装在一起。对于一个实施例,(一个或多个)处理器1302中的至少一个可与控制模块1304的一个或多个控制器的逻辑封装在一起以形成系统级封装(sip)。对于一个实施例,(一个或多个)处理器1302中的至少一个可与控制模块1304的一个或多个控制器的逻辑集成在同一模具上。对于一个实施例,(一个或多个)处理器1302中的至少一个可与控制模块1304的一个或多个控制器的逻辑集成在同一模具上以形成片上系统(soc)。
223.在各个实施例中,装置1300可以但不限于是:服务器、台式计算设备或移动计算设备(例如,膝上型计算设备、手持计算设备、平板电脑、上网本等)等终端设备。在各个实施例中,装置1300可具有更多或更少的组件和/或不同的架构。例如,在一些实施例中,装置1300包括一个或多个摄像机、键盘、液晶显示器(lcd)屏幕(包括触屏显示器)、非易失性存储器端口、多个天线、图形芯片、专用集成电路(asic)和扬声器。
224.本技术实施例提供了一种电子设备,包括:一个或多个处理器;和,其上存储有指令的一个或多个机器可读介质,当由一个或多个处理器执行时,使得电子设备执行如本技术中一个或多个的方法。
225.对于装置实施例而言,由于其与方法实施例基本相似,所以描述的比较简单,相关之处参见方法实施例的部分说明即可。
226.本说明书中的各个实施例均采用递进的方式描述,每个实施例重点说明的都是与其他实施例的不同之处,各个实施例之间相同相似的部分互相参见即可。
227.本技术实施例是参照根据本技术实施例的方法、终端设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、和流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程信息处理终端设备的处理器以产生一个机器,使得通过计算机或其他可编程信息处理终端设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。
228.这些计算机程序指令也可存储在能引导计算机或其他可编程信息处理终端设备以特定方式工作的计算机可读存储器中,使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品,该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。
229.这些计算机程序指令也可装载到计算机或其他可编程信息处理终端设备上,使得在计算机或其他可编程终端设备上执行一系列操作步骤以产生计算机实现的处理,从而在计算机或其他可编程终端设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。
230.尽管已描述了本技术实施例的优选实施例,但本领域内的技术人员一旦得知了基本创造性概念,则可对这些实施例做出另外的变更和修改。所以,所附权利要求意欲解释为包括优选实施例和落入本技术实施例范围的所有变更和修改。
231.最后,还需要说明的是,在本文中,诸如第一和第二等之类的关系术语仅仅用来将
一个实体或者操作与另一个实体或操作区分开来,而不一定要求或者暗示这些实体或操作之间存在任何这种实际的关系或者顺序。而且,术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含,从而使得包括一系列要素的过程、方法、物品或者终端设备不仅包括那些要素,而且还包括没有明确列出的其他要素,或者是还包括为这种过程、方法、物品或者终端设备所固有的要素。在没有更多限制的情况下,由语句“包括一个
……”
限定的要素,并不排除在包括要素的过程、方法、物品或者终端设备中还存在另外的相同要素。
232.以上对本技术所提供的基于数据处理系统的数据处理方法及装置,进行了详细介绍,本文中应用了具体个例对本技术的原理及实施方式进行了阐述,以上实施例的说明只是用于帮助理解本技术的方法及其核心思想;同时,对于本领域的一般技术人员,依据本技术的思想,在具体实施方式及应用范围上均会有改变之处,综上,本说明书内容不应理解为对本技术的限制。

技术特征:
1.一种基于数据处理系统的数据处理方法,其特征在于,数据处理系统至少包括中心服务端以及多个边缘计算节点,各个边缘计算节点中分别具有对接插件,至少一个边缘计算节点中部署有缓存插件或者在数据处理系统还包括的中间件中部署有缓存插件,对接插件与缓存插件之间对接,缓存插件与中心服务端之间对接;所述方法应用于缓存插件,所述方法包括:接收对接插件路由的监听请求,所述监听请求用于监听更新中心服务端中的目标类型的数据的更新事件,所述监听请求是边缘计算节点中的第一功能组件向对接插件传递的;确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接;在存在针对目标类型的数据的监听长连接的情况下,关联所述监听请求与所述监听长连接;在基于所述监听长连接监听到所述更新事件且通过所述监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据与所述监听长连接关联的所述监听请求向对接插件传递更新后的目标类型的数据,以使对接插件接收更新后的目标类型的数据,并向第一功能组件传递更新后的目标类型的数据。2.根据权利要求1所述的方法,其特征在于,所述方法还包括:在不存在针对目标类型的数据的监听长连接的情况下,针对所述监听请求建立缓存插件与中心服务端之间的针对目标类型的数据的监听长连接;在基于建立的监听长连接监听到所述更新事件且通过建立的监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据建立的监听长连接所针对的所述监听请求向对接插件传递更新后的目标类型的数据。3.根据权利要求1或2所述的方法,其特征在于,所述方法还包括:在缓存插件中缓存更新后的目标类型的数据。4.根据权利要求3所述的方法,其特征在于,所述方法还包括:在缓存插件中缓存有更新前的目标类型的数据的情况下,在缓存插件中删除更新前的目标类型的数据。5.根据权利要求1所述的方法,其特征在于,所述关联所述监听请求与所述监听长连接,包括:在缓存插件中存储所述监听请求的请求标识与针对目标类型的数据的监听长连接的连接标识之间的关联关系;相应地;所述根据与所述监听长连接关联的所述监听请求向对接插件传递更新后的目标类型的数据,包括:根据监听长连接的连接标识获取所述关联关系中的请求标识;根据所述关联关系中的请求标识所对应的所述监听请求向对接插件传递更新后的目标类型的数据。6.根据权利要求1所述的方法,其特征在于,所述确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接,包括:在缓存插件中的监听长连接的连接标识与监听长连接针对的类型之间的映射关系中,查找目标类型对应的连接标识;
在映射关系中查找到目标类型对应的连接标识的情况下,确定缓存插件与中心服务端之间存在针对目标类型的数据的监听长连接;目标类型以及目标类型对应的连接标识是在之前建立缓存插件与中心服务端之间的针对目标类型的数据的监听长连接的情况下存储在所述映射关系中的;或者,在所述映射关系中未查找到目标类型对应的连接标识的情况下,确定缓存插件与中心服务端之间不存在针对目标类型的数据的监听长连接。7.根据权利要求1所述的方法,其特征在于,所述监听请求还携带鉴权信息;所述接收对接插件路由的监听请求之后,还包括:提取所述监听请求中携带的鉴权信息;根据所述鉴权信息确定所述监听请求是否为合法请求;在所述监听请求为合法请求的情况下,再确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接。8.根据权利要求3所述的方法,其特征在于,所述方法还包括:接收对接插件路由的查询请求;查询请求是边缘计算节点中的第二功能组件向对接插件传递的;查询请求携带目标类型,查询请求用于主动请求获取更新后的目标类型的数据;在缓存插件中查找更新后的目标类型的数据;根据查询请求向对接插件返回在缓存插件中查找到的、更新后的目标类型的数据,以使对接插件接收在缓存插件中查找到的、更新后的目标类型的数据,并向第二功能组件传递在缓存插件中查找到的、更新后的目标类型的数据。9.一种基于数据处理系统的数据处理方法,其特征在于,数据处理系统至少包括中心服务端以及多个边缘计算节点,各个边缘计算节点中分别具有对接插件,至少一个边缘计算节点中部署有缓存插件或者在数据处理系统还包括的中间件中部署有缓存插件,对接插件与缓存插件之间对接,缓存插件与中心服务端之间对接;所述方法应用于对接插件,所述方法包括:接收边缘计算节点中的第一功能组件传递的监听请求;所述监听请求用于监听更新中心服务端中的目标类型的数据的更新事件;将所述监听请求路由至缓存插件;以使缓存插件接收所述监听请求;确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接;在存在针对目标类型的数据的监听长连接的情况下,关联所述监听请求与所述监听长连接;在基于所述监听长连接监听到所述更新事件且通过所述监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据与所述监听长连接关联的所述监听请求向对接插件传递更新后的目标类型的数据;接收更新后的目标类型的数据;向第一功能组件传递更新后的目标类型的数据。10.一种数据处理系统,其特征在于,数据处理系统至少包括中心服务端以及多个边缘计算节点,各个边缘计算节点中分别具有对接插件,至少一个边缘计算节点中部署有缓存插件或者在数据处理系统还包括的中间件中部署有缓存插件,对接插件与缓存插件之间对接,缓存插件与中心服务端之间对接;
对接插件用于接收边缘计算节点中的第一功能组件传递的监听请求,向缓存插件路由监听请求;所述监听请求用于监听更新中心服务端中的目标类型的数据的更新事件;缓存插件用于接收对接插件路由的监听请求;确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接;在存在针对目标类型的数据的监听长连接的情况下,关联所述监听请求与所述监听长连接;在基于所述监听长连接监听到所述更新事件且通过所述监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据与所述监听长连接关联的所述监听请求向对接插件传递更新后的目标类型的数据;对接插件用于接收更新后的目标类型的数据,并向第一功能组件传递更新后的目标类型的数据。11.一种基于数据处理系统的数据处理装置,其特征在于,数据处理系统至少包括中心服务端以及多个边缘计算节点,各个边缘计算节点中分别具有对接插件,至少一个边缘计算节点中部署有缓存插件或者在数据处理系统还包括的中间件中部署有缓存插件,对接插件与缓存插件之间对接,缓存插件与中心服务端之间对接;所述装置应用于缓存插件,所述装置包括:第一接收模块,用于接收对接插件路由的监听请求,所述监听请求用于监听更新中心服务端中的目标类型的数据的更新事件,所述监听请求是边缘计算节点中的第一功能组件向对接插件传递的;第一确定模块,用于确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接;关联模块,用于在存在针对目标类型的数据的监听长连接的情况下,关联所述监听请求与所述监听长连接;第一传递模块,用于在基于所述监听长连接监听到所述更新事件且通过所述监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据与所述监听长连接关联的所述监听请求向对接插件传递更新后的目标类型的数据,以使对接插件接收更新后的目标类型的数据,并向第一功能组件传递更新后的目标类型的数据。12.一种基于数据处理系统的数据处理装置,其特征在于,数据处理系统至少包括中心服务端以及多个边缘计算节点,各个边缘计算节点中分别具有对接插件,至少一个边缘计算节点中部署有缓存插件或者在数据处理系统还包括的中间件中部署有缓存插件,对接插件与缓存插件之间对接,缓存插件与中心服务端之间对接;所述装置应用于对接插件,所述装置包括:第二接收模块,用于接收边缘计算节点中的第一功能组件传递的监听请求;所述监听请求用于监听更新中心服务端中的目标类型的数据的更新事件;路由模块,用于将所述监听请求路由至缓存插件;以使缓存插件接收所述监听请求;确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接;在存在针对目标类型的数据的监听长连接的情况下,关联所述监听请求与所述监听长连接;在基于所述监听长连接监听到所述更新事件且通过所述监听长连接从中心服务端中得到更新后的目标类型的数据的情况下,根据与所述监听长连接关联的所述监听请求向对接插件传递更新后的目标类型的数据;第三接收模块,用于接收更新后的目标类型的数据;
第三传递模块,用于向第一功能组件传递更新后的目标类型的数据。13.一种电子设备,包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序,其特征在于,处理器执行程序时实现如权利要求1至9中任一项的方法的步骤。14.一种计算机可读存储介质,其特征在于,计算机可读存储介质上存储有计算机程序,计算机程序被处理器执行时实现如权利要求1至9中任一项的方法的步骤。

技术总结
本申请提供了一种基于数据处理系统的数据处理方法及装置。接收对接插件路由的用于监听更新中心服务端中的目标类型的数据的更新事件的监听请求。确定缓存插件与中心服务端之间是否存在针对目标类型的数据的监听长连接。若是,可以关联监听请求与针对目标类型的数据的监听长连接,以使得监听请求可以复用已存在的针对目标类型的数据的监听长连接,从避免增加缓存插件与中心服务端之间的针对目标类型的数据的监听长连接,进而避免缓存插件与中心服务端之间的针对目标类型的数据的监听长连接的数量过多,进而避免由于监听长连接的数量过多而导致各个监听长连接的带宽非常低,进而可以尽可能地降低监听长连接被中心服务端断开的可能性。开的可能性。开的可能性。


技术研发人员:李志信
受保护的技术使用者:阿里巴巴(中国)有限公司
技术研发日:2023.03.20
技术公布日:2023/7/20
版权声明

本文仅代表作者观点,不代表航空之家立场。
本文系作者授权航家号发表,未经原创作者书面授权,任何单位或个人不得引用、复制、转载、摘编、链接或以其他任何方式复制发表。任何单位或个人在获得书面授权使用航空之家内容时,须注明作者及来源 “航空之家”。如非法使用航空之家的部分或全部内容的,航空之家将依法追究其法律责任。(航空之家官方QQ:2926969996)

飞行汽车 https://www.autovtol.com/

分享:

扫一扫在手机阅读、分享本文

相关推荐