一种基于GRPC的多方信息传递及状态同步方法、系统及介质转让专利

申请号 : CN202311197887.3

文献号 : CN116938999B

文献日 :

基本信息:

PDF:

法律信息:

相似专利:

发明人 : 杨超潘光明张浩王震张李军李刚

申请人 : 翼方健数(北京)信息科技有限公司翼健(上海)信息科技有限公司

摘要 :

本申请提供了一种基于GRPC的多方信息传递及状态同步方法、系统及介质。该方法包括:对meta数据进行分类,将类标签存储到一级节点中,将meta数据存储到相应的二级节点中,根节点对客户端发出的请求验证指令进行身份验证后生成验证码,客户端将验证码以及请求调用指令进行随机排列组合后,生成标准调用指令,并与一级节点进行匹配后传输至二级节点进行相似度对比,以确定发生响应的二级节点,同时触发回调函数,将响应数据传输至一级节点再传输至根节点最后发送至客户端。本申请可实现对meta数据的存储以及精确、快速调用的功能,并可以对数据修改事件进行批量实时监听,具有较好的时效性。

权利要求 :

1.一种基于GRPC的多方信息传递及状态同步方法,其特征在于,包括以下步骤:获取网站的meta数据;

对所述meta数据进行特征提取获得特征数据,根据特征数据对所述meta数据进行分类生成不同类别的meta数据集,并对meta数据集标注类标签;

将所述类标签分别存储到不同的一级节点中,将所述类标签对应的所述meta数据集的子数据分别存储到一级节点对应分支的二级节点中;

客户端向根节点发出请求验证指令,根节点对请求验证指令进行身份验证,生成验证码,并将验证码发送至客户端;

所述客户端产生请求调用指令,并将所述验证码以及请求调用指令进行随机排列组合后,生成标准调用指令,发送至所述根节点,所述根节点将标准调用指令传输至所述一级节点;

将所述一级节点内存储的所述类标签分别与所述标准调用指令进行匹配,根据匹配结果确定作为中间传输节点的一级节点,再由中间传输节点传输至所述二级节点;

向所有节点注册回调函数,将所述二级节点内存储的所述子数据与所述标准调用指令分别进行相似度对比,根据相似度对比结果确定发生响应的所述二级节点,并获得响应数据,同时触发所述回调函数;

所述回调函数将所述响应数据由所述二级节点传输至所述一级节点,再由所述一级节点传输至所述根节点,最后由所述根节点发送至所述客户端。

2.根据权利要求1所述的基于GRPC的多方信息传递及状态同步方法,其特征在于,所述对所述meta数据进行特征提取获得特征数据,根据特征数据对所述meta数据进行分类生成不同类别的meta数据集,并对meta数据集标注类标签,具体包括:将所述meta数据输入预设特征分析模型进行分析处理获得特征数据;

根据所述特征数据对所述meta数据进行分类,获得分类结果;

根据所述分类结果对所述meta数据进行集合获得不同类别的meta数据集,并对meta数据集标注类标签。

3.根据权利要求2所述的基于GRPC的多方信息传递及状态同步方法,其特征在于,所述客户端向根节点发出请求验证指令,根节点对请求验证指令进行身份验证,生成验证码,并将验证码发送至客户端,具体包括:客户端向根节点发出请求验证指令;

所述根节点将所述请求验证指令输入预设身份验证模型进行分析处理,获得验证码,并将验证码发送至所述客户端。

4.根据权利要求3所述的基于GRPC的多方信息传递及状态同步方法,其特征在于,所述客户端产生请求调用指令,并将所述验证码以及请求调用指令进行随机排列组合后,生成标准调用指令,发送至所述根节点,所述根节点将标准调用指令传输至所述一级节点,具体包括:所述客户端产生请求调用指令,并将所述验证码以及请求调用指令进行随机排列组合后,生成标准调用指令;

所述客户端将所述标准调用指令发送至所述根节点;

所述根节点将所述标准调用指令传输至所述一级节点。

5.根据权利要求4所述的基于GRPC的多方信息传递及状态同步方法,其特征在于,所述将所述一级节点内存储的所述类标签分别与所述标准调用指令进行匹配,根据匹配结果确定作为中间传输节点的一级节点,再由中间传输节点传输至所述二级节点,具体包括:将所述标准调用指令进行关键词提取,获得关键词数据;

将所述关键词数据与所述一级节点内存储的所述类标签分别进行匹配获得相应匹配度值;

选取匹配度值最高的类标签对应的所述一级节点作为中间传输节点;

所述中间传输节点将所述标准调用指令传输至所述二级节点。

6.根据权利要求5所述的基于GRPC的多方信息传递及状态同步方法,其特征在于,所述向所有节点注册回调函数,将所述二级节点内存储的所述子数据与所述标准调用指令分别进行相似度对比,根据相似度对比结果确定发生响应的所述二级节点,并获得响应数据,同时触发所述回调函数,具体包括:向所有节点注册回调函数;

将所述二级节点内存储的所述子数据与所述标准调用指令分别进行相似度对比,获得相似度对比结果;

将所述相似度对比结果按照从高到低的顺序进行排序,选取相似度最高的子数据对应的所述二级节点作为响应二级节点;

获得所述响应二级节点的响应数据,同时触发所述回调函数。

7.根据权利要求6所述的基于GRPC的多方信息传递及状态同步方法,其特征在于,还包括:向所有的所述一级节点注册监视函数;

若所述二级节点内存储的所述子数据产生变化值,则自动对所述二级节点进行标记,并触发所述回调函数以及所述监视函数,同时对未被标记的所述二级节点进行自动询问;

若未被标记的所述二级节点产生变化值,则所述回调函数将所述响应数据由所述二级节点传输至所述一级节点,再由所述一级节点传输至所述根节点,最后由所述根节点发送至所述客户端;

若未被标记的所述二级节点未产生变化值,则只对标记的所述二级节点产生的变化值进行传输。

8.一种基于GRPC的多方信息传递及状态同步系统,其特征在于,包括存储器和处理器,所述存储器中包括基于GRPC的多方信息传递及状态同步方法程序,所述基于GRPC的多方信息传递及状态同步方法程序被所述处理器执行时实现如下步骤:获取网站的meta数据;

对所述meta数据进行特征提取获得特征数据,根据特征数据对所述meta数据进行分类生成不同类别的meta数据集,并对meta数据集标注类标签;

将所述类标签分别存储到不同的一级节点中,将所述类标签对应的所述meta数据集的子数据分别存储到一级节点对应分支的二级节点中;

客户端向根节点发出请求验证指令,根节点对请求验证指令进行身份验证,生成验证码,并将验证码发送至客户端;

所述客户端产生请求调用指令,并将所述验证码以及请求调用指令进行随机排列组合后,生成标准调用指令,发送至所述根节点,所述根节点将标准调用指令传输至所述一级节点;

将所述一级节点内存储的所述类标签分别与所述标准调用指令进行匹配,根据匹配结果确定作为中间传输节点的一级节点,再由中间传输节点传输至所述二级节点;

向所有节点注册回调函数,将所述二级节点内存储的所述子数据与所述标准调用指令分别进行相似度对比,根据相似度对比结果确定发生响应的所述二级节点,并获得响应数据,同时触发所述回调函数;

所述回调函数将所述响应数据由所述二级节点传输至所述一级节点,再由所述一级节点传输至所述根节点,最后由所述根节点发送至所述客户端。

9.根据权利要求8所述的基于GRPC的多方信息传递及状态同步系统,其特征在于,所述对所述meta数据进行特征提取获得特征数据,根据特征数据对所述meta数据进行分类生成不同类别的meta数据集,并对meta数据集标注类标签,具体包括:将所述meta数据输入预设特征分析模型进行分析处理获得特征数据;

根据所述特征数据对所述meta数据进行分类,获得分类结果;

根据所述分类结果对所述meta数据进行集合获得不同类别的meta数据集,并对meta数据集标注类标签。

10.计算机可读存储介质,其特征在于,所述计算机可读存储介质中包括基于GRPC的多方信息传递及状态同步方法程序,所述基于GRPC的多方信息传递及状态同步方法程序被处理器执行时,实现如权利要求1至7中任一项所述的基于GRPC的多方信息传递及状态同步方法的步骤。

说明书 :

一种基于GRPC的多方信息传递及状态同步方法、系统及介质

技术领域

[0001] 本申请涉及大数据及计算机应用技术领域,具体而言,涉及一种基于GRPC的多方信息传递及状态同步方法、系统及介质。

背景技术

[0002] GRPC(Google Remote Procedure Calls, 谷歌远程过程调用)是 Google 公司开发的一个高性能、跨语言的、通用的远程过程调用开源软件框架,它可以使得通信双方聚焦在业务,无需关注由 GRPC 软件框架实现的底层通信,可以实现客户端与服务器端之间的通信。目前,在信息传递过程中,现有的技术方案多采用zookeeper、etcd等服务,虽然提供了的meta数据存储、监听功能,但是采用了复杂的一致性协议,运行过程复杂,而且多采用数据库作为中间存储,采用主动轮询机制,具有一定的时间间隔,因此数据时效性较差。
[0003] 针对上述问题,目前亟待有效的技术解决方案。

发明内容

[0004] 本申请的目的在于提供一种基于GRPC的多方信息传递及状态同步方法、系统及介质,首先对meta数据进行分类,将类标签存储到一级节点中,将meta数据存储到相应的二级节点中,根节点对客户端发出的请求验证指令进行身份验证后生成验证码,客户端将验证码以及请求调用指令进行随机排列组合后,生成标准调用指令,并与一级节点进行匹配后传输至二级节点进行相似度对比,以确定发生响应的二级节点,同时触发回调函数,将响应数据传输至一级节点再传输至根节点最后发送至客户端。本申请基于GRPC 软件框架,通过客户端与服务器端的直接通信,可实现对meta数据的精确、快速调用的功能,并可以对数据修改事件进行批量实时监听,具有较好的时效性。
[0005] 本申请还提供了基于GRPC的多方信息传递及状态同步方法,包括以下步骤:
[0006] 获取网站的meta数据;
[0007] 对所述meta数据进行特征提取获得特征数据,根据特征数据对所述meta数据进行分类生成不同类别的meta数据集,并对meta数据集标注类标签;
[0008] 将所述类标签分别存储到不同的一级节点中,将所述类标签对应的所述meta数据集的子数据分别存储到一级节点对应分支的二级节点中;
[0009] 客户端向根节点发出请求验证指令,根节点对请求验证指令进行身份验证,生成验证码,并将验证码发送至客户端;
[0010] 所述客户端产生请求调用指令,并将所述验证码以及请求调用指令进行随机排列组合后,生成标准调用指令,发送至所述根节点,所述根节点将标准调用指令传输至所述一级节点;
[0011] 将所述一级节点内存储的所述类标签分别与所述标准调用指令进行匹配,根据匹配结果确定作为中间传输节点的一级节点,再由中间传输节点传输至所述二级节点;
[0012] 向所有节点注册回调函数,将所述二级节点内存储的所述子数据与所述标准调用指令分别进行相似度对比,根据相似度对比结果确定发生响应的所述二级节点,并获得响应数据,同时触发所述回调函数;
[0013] 所述回调函数将所述响应数据由所述二级节点传输至所述一级节点,再由所述一级节点传输至所述根节点,最后由所述根节点发送至所述客户端。
[0014] 可选地,在本申请所述的基于GRPC的多方信息传递及状态同步方法中,所述对所述meta数据进行特征提取获得特征数据,根据特征数据对所述meta数据进行分类生成不同类别的meta数据集,并对meta数据集标注类标签,具体包括:
[0015] 将所述meta数据输入预设特征分析模型进行分析处理获得特征数据;
[0016] 根据所述特征数据对所述meta数据进行分类,获得分类结果;
[0017] 根据所述分类结果对所述meta数据进行集合获得不同类别的meta数据集,并对meta数据集标注类标签。
[0018] 可选地,在本申请所述的基于GRPC的多方信息传递及状态同步方法中,所述客户端向根节点发出请求验证指令,根节点对请求验证指令进行身份验证,生成验证码,并将验证码发送至客户端,具体包括:
[0019] 客户端向根节点发出请求验证指令;
[0020] 所述根节点将所述请求验证指令输入预设身份验证模型进行分析处理,获得验证码,并将验证码发送至所述客户端。
[0021] 可选地,在本申请所述的基于GRPC的多方信息传递及状态同步方法中,所述客户端产生请求调用指令,并将所述验证码以及请求调用指令进行随机排列组合后,生成标准调用指令,发送至所述根节点,所述根节点将标准调用指令传输至所述一级节点,具体包括:
[0022] 所述客户端产生请求调用指令,并将所述验证码以及请求调用指令进行随机排列组合后,生成标准调用指令;
[0023] 所述客户端将所述标准调用指令发送至所述根节点;
[0024] 所述根节点将所述标准调用指令传输至所述一级节点。
[0025] 可选地,在本申请所述的基于GRPC的多方信息传递及状态同步方法中,所述将所述一级节点内存储的所述类标签分别与所述标准调用指令进行匹配,根据匹配结果确定作为中间传输节点的一级节点,再由中间传输节点传输至所述二级节点,具体包括:
[0026] 将所述标准调用指令进行关键词提取,获得关键词数据;
[0027] 将所述关键词数据与所述一级节点内存储的所述类标签分别进行匹配获得相应匹配度值;
[0028] 选取匹配度值最高的类标签对应的所述一级节点作为中间传输节点;
[0029] 所述中间传输节点将所述标准调用指令传输至所述二级节点。
[0030] 可选地,在本申请所述的基于GRPC的多方信息传递及状态同步方法中,所述向所有节点注册回调函数,将所述二级节点内存储的所述子数据与所述标准调用指令分别进行相似度对比,根据相似度对比结果确定发生响应的所述二级节点,并获得响应数据,同时触发所述回调函数,具体包括:
[0031] 向所有节点注册回调函数;
[0032] 将所述二级节点内存储的所述子数据与所述标准调用指令分别进行相似度对比,获得相似度对比结果;
[0033] 将所述相似度对比结果按照从高到低的顺序进行排序,选取相似度最高的子数据对应的所述二级节点作为响应二级节点;
[0034] 获得所述响应二级节点的响应数据,同时触发所述回调函数。
[0035] 可选地,在本申请所述的基于GRPC的多方信息传递及状态同步方法中,还包括:
[0036] 向所有的所述一级节点注册监视函数;
[0037] 若所述二级节点内存储的所述子数据产生变化值,则自动对所述二级节点进行标记,并触发所述回调函数以及所述监视函数,同时对未被标记的所述二级节点进行自动询问;
[0038] 若未被标记的所述二级节点产生变化值,则所述回调函数将所述响应数据由所述二级节点传输至所述一级节点,再由所述一级节点传输至所述根节点,最后由所述根节点发送至所述客户端;
[0039] 若未被标记的所述二级节点未产生变化值,则只对标记的所述二级节点产生的变化值进行传输。
[0040] 第二方面,本申请提供了基于GRPC的多方信息传递及状态同步系统,该系统包括:存储器及处理器,所述存储器中包括基于GRPC的多方信息传递及状态同步方法的程序,所述基于GRPC的多方信息传递及状态同步方法的程序被所述处理器执行时实现以下步骤:
[0041] 获取网站的meta数据;
[0042] 对所述meta数据进行特征提取获得特征数据,根据特征数据对所述meta数据进行分类生成不同类别的meta数据集,并对meta数据集标注类标签;
[0043] 将所述类标签分别存储到不同的一级节点中,将所述类标签对应的所述meta数据集的子数据分别存储到一级节点对应分支的二级节点中;
[0044] 客户端向根节点发出请求验证指令,根节点对请求验证指令进行身份验证,生成验证码,并将验证码发送至客户端;
[0045] 所述客户端产生请求调用指令,并将所述验证码以及请求调用指令进行随机排列组合后,生成标准调用指令,发送至所述根节点,所述根节点将标准调用指令传输至所述一级节点;
[0046] 将所述一级节点内存储的所述类标签分别与所述标准调用指令进行匹配,根据匹配结果确定作为中间传输节点的一级节点,再由中间传输节点传输至所述二级节点;
[0047] 向所有节点注册回调函数,将所述二级节点内存储的所述子数据与所述标准调用指令分别进行相似度对比,根据相似度对比结果确定发生响应的所述二级节点,并获得响应数据,同时触发所述回调函数;
[0048] 所述回调函数将所述响应数据由所述二级节点传输至所述一级节点,再由所述一级节点传输至所述根节点,最后由所述根节点发送至所述客户端。
[0049] 可选地,在本申请所述的基于GRPC的多方信息传递及状态同步系统中,所述对所述meta数据进行特征提取获得特征数据,根据特征数据对所述meta数据进行分类生成不同类别的meta数据集,并对meta数据集标注类标签,具体包括:
[0050] 将所述meta数据输入预设特征分析模型进行分析处理获得特征数据;
[0051] 根据所述特征数据对所述meta数据进行分类,获得分类结果;
[0052] 根据所述分类结果对所述meta数据进行集合获得不同类别的meta数据集,并对meta数据集标注类标签。
[0053] 第三方面,本申请还提供了一种计算机可读存储介质,所述计算机可读存储介质中包括基于GRPC的多方信息传递及状态同步方法程序,所述基于GRPC的多方信息传递及状态同步方法程序被处理器执行时,实现如上述任一项所述的基于GRPC的多方信息传递及状态同步方法的步骤。
[0054] 由上可知,本申请实施例提供的一种基于GRPC的多方信息传递及状态同步方法、系统及介质,首先对meta数据进行分类,将类标签存储到一级节点中,将meta数据存储到相应的二级节点中,根节点对客户端发出的请求验证指令进行身份验证后生成验证码,客户端将验证码以及请求调用指令进行随机排列组合后,生成标准调用指令,并与一级节点进行匹配后传输至二级节点进行相似度对比,以确定发生响应的二级节点,同时触发回调函数,将响应数据传输至一级节点再传输至根节点最后发送至客户端。本申请基于GRPC 软件框架,通过客户端与服务器端的直接通信,可实现对meta数据的精确、快速调用的功能,并可以对数据修改事件进行批量实时监听,具有较好的时效性。
[0055] 本申请的其他特征和优点将在随后的说明书阐述,并且,部分地从说明书中变得显而易见,或者通过实施本申请实施例了解。本申请的目的和其他优点可通过在所写的说明书、权利要求书、以及附图中所特别指出的结构来实现和获得。

附图说明

[0056] 为了更清楚地说明本申请实施例的技术方案,下面将对本申请实施例中所需要使用的附图作简单地介绍,应当理解,以下附图仅示出了本申请的某些实施例,因此不应被看作是对范围的限定,对于本领域普通技术人员来讲,在不付出创造性劳动的前提下,还可以根据这些附图获得其他相关的附图。
[0057] 图1为本申请实施例提供的基于GRPC的多方信息传递及状态同步方法的流程图;
[0058] 图2为本申请实施例提供的基于GRPC的多方信息传递及状态同步方法的生成不同类别的meta数据集并标注类标签的流程图;
[0059] 图3为本申请实施例提供的基于GRPC的多方信息传递及状态同步方法的生成验证码并发送至客户端的流程图;
[0060] 图4为本申请实施例提供的基于GRPC的多方信息传递及状态同步系统的一种结构示意图。

具体实施方式

[0061] 下面将结合本申请实施例中附图,对本申请实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例仅仅是本申请一部分实施例,而不是全部的实施例。通常在此处附图中描述和示出的本申请实施例的组件可以以各种不同的配置来布置和设计。因此,以下对在附图中提供的本申请的实施例的详细描述并非旨在限制要求保护的本申请的范围,而是仅仅表示本申请的选定实施例。基于本申请的实施例,本领域技术人员在没有做出创造性劳动的前提下所获得的所有其他实施例,都属于本申请保护的范围。
[0062] 应注意到,相似的标号和字母在下面的附图中表示类似项,因此,一旦某一项在一个附图中被定义,则在随后的附图中不需要对其进行进一步定义和解释。同时,在本申请的描述中,术语“第一”、“第二”等仅用于区分描述,而不能理解为指示或暗示相对重要性。
[0063] 请参照图1,图1是本申请一些实施例中的基于GRPC的多方信息传递及状态同步方法的流程图。该基于GRPC的多方信息传递及状态同步方法用于终端设备中,例如电脑、手机终端等。该基于GRPC的多方信息传递及状态同步方法,包括以下步骤:
[0064] S101、获取网站的meta数据;
[0065] S102、对所述meta数据进行特征提取获得特征数据,根据特征数据对所述meta数据进行分类生成不同类别的meta数据集,并对meta数据集标注类标签;
[0066] S103、将所述类标签分别存储到不同的一级节点中,将所述类标签对应的所述meta数据集的子数据分别存储到一级节点对应分支的二级节点中;
[0067] S104、客户端向根节点发出请求验证指令,根节点对请求验证指令进行身份验证,生成验证码,并将验证码发送至客户端;
[0068] S105、所述客户端产生请求调用指令,并将所述验证码以及请求调用指令进行随机排列组合后,生成标准调用指令,发送至所述根节点,所述根节点将标准调用指令传输至所述一级节点;
[0069] S106、将所述一级节点内存储的所述类标签分别与所述标准调用指令进行匹配,根据匹配结果确定作为中间传输节点的一级节点,再由中间传输节点传输至所述二级节点;
[0070] S107、向所有节点注册回调函数,将所述二级节点内存储的所述子数据与所述标准调用指令分别进行相似度对比,根据相似度对比结果确定发生响应的所述二级节点,并获得响应数据,同时触发所述回调函数;
[0071] S108、所述回调函数将所述响应数据由所述二级节点传输至所述一级节点,再由所述一级节点传输至所述根节点,最后由所述根节点发送至所述客户端。
[0072] 需要说明的是,为了实现对meta数据的存储以及快速、精确调用功能,即通过将meta数据按照其特征不同分类存储到树形结构的不同节点中,当客户端向服务器发出调用指令之前服务器先对客户端进行身份验证,当发出调用指令时,服务器数据存储节点通过进行自动匹配以及相似度对比的方式以实现对调用指令的精确响应,首先获取网站的meta数据,meta数据即元数据,在互联网领域是指用于描述网页的标题、编码方式和关键词等元信息的数据,对meta数据进行特征提取获得特征数据,根据特征数据对meta数据进行分类生成不同类别的meta数据集,并对meta数据集标注类标签,将类标签分别存储到不同的一级节点中,将类标签对应的meta数据集的子数据分别存储到一级节点对应分支的二级节点中,客户端向根节点发出请求验证指令,根节点对请求验证指令进行身份验证,生成验证码,并将验证码发送至客户端,当客户端产生请求调用指令时,将验证码以及请求调用指令进行随机排列组合后,生成标准调用指令,发送至根节点,根节点将标准调用指令传输至一级节点,将一级节点内存储的类标签分别与标准调用指令进行匹配,根据匹配结果确定作为中间传输节点的一级节点,再由中间传输节点传输至二级节点,向所有节点注册回调函数,将二级节点内存储的子数据与标准调用指令分别进行相似度对比,根据相似度对比结果确定发生响应的二级节点,并获得响应数据,同时触发回调函数,回调函数将响应数据由二级节点传输至一级节点,再由一级节点传输至根节点,最后由根节点发送至客户端。
[0073] 请参照图2,图2是本申请一些实施例中的基于GRPC的多方信息传递及状态同步方法的生成不同类别的meta数据集并标注类标签的流程图。根据本发明实施例,所述对所述meta数据进行特征提取获得特征数据,根据特征数据对所述meta数据进行分类生成不同类别的meta数据集,并对meta数据集标注类标签,具体为:
[0074] S201、将所述meta数据输入预设特征分析模型进行分析处理获得特征数据;
[0075] S202、根据所述特征数据对所述meta数据进行分类,获得分类结果;
[0076] S203、根据所述分类结果对所述meta数据进行集合获得不同类别的meta数据集,并对meta数据集标注类标签。
[0077] 需要说明的是,为了将meta数据进行特征分类,进而以便于后续根据分类结果将数据存储到树形结构的不同节点中,首先将meta数据输入预设特征分析模型进行分析处理获得特征数据,再根据特征数据对meta数据进行分类,获得分类结果,根据分类结果对meta数据进行集合获得不同类别的meta数据集,并对meta数据集标注类标签,该特征分析模型是通过获取大量历史样本的meta数据以及特征数据进行训练获得的模型,可通过输入相关信息进行处理获得对应输出的特征数据。
[0078] 请参照图3,图3是本申请一些实施例中的基于GRPC的多方信息传递及状态同步方法的生成验证码并发送至客户端的流程图。根据本发明实施例,所述客户端向根节点发出请求验证指令,根节点对请求验证指令进行身份验证,生成验证码,并将验证码发送至客户端,具体为:
[0079] S301、客户端向根节点发出请求验证指令;
[0080] S302、所述根节点将所述请求验证指令输入预设身份验证模型进行分析处理,获得验证码,并将验证码发送至所述客户端。
[0081] 需要说明的是,客户端在向服务器发送调用指令之前,服务器要先对客户端的身份进行验证,具体为:客户端向根节点发出请求验证指令,根节点将请求验证指令输入预设身份验证模型进行分析处理,获得验证码,并将验证码发送至客户端,该预设身份验证模型是通过获取大量历史样本的请求验证指令以及验证码进行训练获得的模型,可通过输入相关信息进行处理获得对应输出的验证码。
[0082] 根据本发明实施例,所述客户端产生请求调用指令,并将所述验证码以及请求调用指令进行随机排列组合后,生成标准调用指令,发送至所述根节点,所述根节点将标准调用指令传输至所述一级节点,具体为:
[0083] 所述客户端产生请求调用指令,并将所述验证码以及请求调用指令进行随机排列组合后,生成标准调用指令;
[0084] 所述客户端将所述标准调用指令发送至所述根节点;
[0085] 所述根节点将所述标准调用指令传输至所述一级节点。
[0086] 需要说明的是,客户端在获得身份验证码后,向服务器发送调用指令时,将获得的验证码以及请求调用指令进行随机排列组合后,生成标准调用指令,然后将标准调用指令发送至根节点,再由根节点传输至一级节点。
[0087] 根据本发明实施例,所述将所述一级节点内存储的所述类标签分别与所述标准调用指令进行匹配,根据匹配结果确定作为中间传输节点的一级节点,再由中间传输节点传输至所述二级节点,具体为:
[0088] 将所述标准调用指令进行关键词提取,获得关键词数据;
[0089] 将所述关键词数据与所述一级节点内存储的所述类标签分别进行匹配获得相应匹配度值;
[0090] 选取匹配度值最高的类标签对应的所述一级节点作为中间传输节点;
[0091] 所述中间传输节点将所述标准调用指令传输至所述二级节点。
[0092] 需要说明的是,当调用指令传输至一级节点时,一级节点内存储的类标签分别与标准调用指令进行匹配,根据匹配结果确定作为中间传输节点的一级节点,再由中间传输节点传输至二级节点。
[0093] 根据本发明实施例,所述向所有节点注册回调函数,将所述二级节点内存储的所述子数据与所述标准调用指令分别进行相似度对比,根据相似度对比结果确定发生响应的所述二级节点,并获得响应数据,同时触发所述回调函数,具体为:
[0094] 向所有节点注册回调函数;
[0095] 将所述二级节点内存储的所述子数据与所述标准调用指令分别进行相似度对比,获得相似度对比结果;
[0096] 将所述相似度对比结果按照从高到低的顺序进行排序,选取相似度最高的子数据对应的所述二级节点作为响应二级节点;
[0097] 获得所述响应二级节点的响应数据,同时触发所述回调函数。
[0098] 需要说明的是,为了对调用指令进行精确的响应,向所有节点注册回调函数以便于将响应数据进行回传,将二级节点内存储的子数据与标准调用指令分别进行相似度对比,将相似度对比结果按照从高到低的顺序进行排序,选取相似度最高的子数据对应的二级节点作为响应二级节点,获得响应二级节点的响应数据,同时触发回调函数进行工作,以便将响应数据由二级节点传输至一级节点再传输至根节点,最后由根节点发送至客户端。
[0099] 根据本发明实施例,还包括:
[0100] 向所有的所述一级节点注册监视函数;
[0101] 若所述二级节点内存储的所述子数据产生变化值,则自动对所述二级节点进行标记,并触发所述回调函数以及所述监视函数,同时对未被标记的所述二级节点进行自动询问;
[0102] 若未被标记的所述二级节点产生变化值,则所述回调函数将所述响应数据由所述二级节点传输至所述一级节点,再由所述一级节点传输至所述根节点,最后由所述根节点发送至所述客户端;
[0103] 若未被标记的所述二级节点未产生变化值,则只对标记的所述二级节点产生的变化值进行传输。
[0104] 需要说明的是,为了实现对数据修改事件的批量实时监听,首先向所有的一级节点注册监视函数,若二级节点内存储的子数据产生变化值,则自动对二级节点进行标记,并触发回调函数以及监视函数,同时对未被标记的二级节点进行自动询问,若未被标记的二级节点产生变化值,则回调函数将响应数据由二级节点传输至一级节点,再由一级节点传输至根节点,最后由根节点发送至客户端,若未被标记的二级节点未产生变化值,则只对标记的二级节点产生的变化值进行传输。
[0105] 如图4所示,本发明还公开了基于GRPC的多方信息传递及状态同步系统4,包括存储器41和处理器42,所述存储器中包括基于GRPC的多方信息传递及状态同步方法程序,所述基于GRPC的多方信息传递及状态同步方法程序被所述处理器执行时实现如下步骤:
[0106] 获取网站的meta数据;
[0107] 对所述meta数据进行特征提取获得特征数据,根据特征数据对所述meta数据进行分类生成不同类别的meta数据集,并对meta数据集标注类标签;
[0108] 将所述类标签分别存储到不同的一级节点中,将所述类标签对应的所述meta数据集的子数据分别存储到一级节点对应分支的二级节点中;
[0109] 客户端向根节点发出请求验证指令,根节点对请求验证指令进行身份验证,生成验证码,并将验证码发送至客户端;
[0110] 所述客户端产生请求调用指令,并将所述验证码以及请求调用指令进行随机排列组合后,生成标准调用指令,发送至所述根节点,所述根节点将标准调用指令传输至所述一级节点;
[0111] 将所述一级节点内存储的所述类标签分别与所述标准调用指令进行匹配,根据匹配结果确定作为中间传输节点的一级节点,再由中间传输节点传输至所述二级节点;
[0112] 向所有节点注册回调函数,将所述二级节点内存储的所述子数据与所述标准调用指令分别进行相似度对比,根据相似度对比结果确定发生响应的所述二级节点,并获得响应数据,同时触发所述回调函数;
[0113] 所述回调函数将所述响应数据由所述二级节点传输至所述一级节点,再由所述一级节点传输至所述根节点,最后由所述根节点发送至所述客户端。
[0114] 需要说明的是,为了实现对meta数据的存储以及快速、精确调用功能,即通过将meta数据按照其特征不同分类存储到树形结构的不同节点中,当客户端向服务器发出调用指令之前服务器先对客户端进行身份验证,当发出调用指令时,服务器数据存储节点通过进行自动匹配以及相似度对比的方式以实现对调用指令的精确响应,首先获取网站的meta数据,meta数据即元数据,在互联网领域是指用于描述网页的标题、编码方式和关键词等元信息的数据,对meta数据进行特征提取获得特征数据,根据特征数据对meta数据进行分类生成不同类别的meta数据集,并对meta数据集标注类标签,将类标签分别存储到不同的一级节点中,将类标签对应的meta数据集的子数据分别存储到一级节点对应分支的二级节点中,客户端向根节点发出请求验证指令,根节点对请求验证指令进行身份验证,生成验证码,并将验证码发送至客户端,当客户端产生请求调用指令时,将验证码以及请求调用指令进行随机排列组合后,生成标准调用指令,发送至根节点,根节点将标准调用指令传输至一级节点,将一级节点内存储的类标签分别与标准调用指令进行匹配,根据匹配结果确定作为中间传输节点的一级节点,再由中间传输节点传输至二级节点,向所有节点注册回调函数,将二级节点内存储的子数据与标准调用指令分别进行相似度对比,根据相似度对比结果确定发生响应的二级节点,并获得响应数据,同时触发回调函数,回调函数将响应数据由二级节点传输至一级节点,再由一级节点传输至根节点,最后由根节点发送至客户端。
[0115] 根据本发明实施例,所述对所述meta数据进行特征提取获得特征数据,根据特征数据对所述meta数据进行分类生成不同类别的meta数据集,并对meta数据集标注类标签,具体为:
[0116] 将所述meta数据输入预设特征分析模型进行分析处理获得特征数据;
[0117] 根据所述特征数据对所述meta数据进行分类,获得分类结果;
[0118] 根据所述分类结果对所述meta数据进行集合获得不同类别的meta数据集,并对meta数据集标注类标签。
[0119] 需要说明的是,为了将meta数据进行特征分类,进而以便于后续根据分类结果将数据存储到树形结构的不同节点中,首先将meta数据输入预设特征分析模型进行分析处理获得特征数据,再根据特征数据对meta数据进行分类,获得分类结果,根据分类结果对meta数据进行集合获得不同类别的meta数据集,并对meta数据集标注类标签,该特征分析模型是通过获取大量历史样本的meta数据以及特征数据进行训练获得的模型,可通过输入相关信息进行处理获得对应输出的特征数据。
[0120] 根据本发明实施例,所述客户端向根节点发出请求验证指令,根节点对请求验证指令进行身份验证,生成验证码,并将验证码发送至客户端,具体为:
[0121] 客户端向根节点发出请求验证指令;
[0122] 所述根节点将所述请求验证指令输入预设身份验证模型进行分析处理,获得验证码,并将验证码发送至所述客户端。
[0123] 需要说明的是,客户端在向服务器发送调用指令之前,服务器要先对客户端的身份进行验证,具体为:客户端向根节点发出请求验证指令,根节点将请求验证指令输入预设身份验证模型进行分析处理,获得验证码,并将验证码发送至客户端,该预设身份验证模型是通过获取大量历史样本的请求验证指令以及验证码进行训练获得的模型,可通过输入相关信息进行处理获得对应输出的验证码。
[0124] 根据本发明实施例,所述客户端产生请求调用指令,并将所述验证码以及请求调用指令进行随机排列组合后,生成标准调用指令,发送至所述根节点,所述根节点将标准调用指令传输至所述一级节点,具体为:
[0125] 所述客户端产生请求调用指令,并将所述验证码以及请求调用指令进行随机排列组合后,生成标准调用指令;
[0126] 所述客户端将所述标准调用指令发送至所述根节点;
[0127] 所述根节点将所述标准调用指令传输至所述一级节点。
[0128] 需要说明的是,客户端在获得身份验证码后,向服务器发送调用指令时,将获得的验证码以及请求调用指令进行随机排列组合后,生成标准调用指令,然后将标准调用指令发送至根节点,再由根节点传输至一级节点。
[0129] 根据本发明实施例,所述将所述一级节点内存储的所述类标签分别与所述标准调用指令进行匹配,根据匹配结果确定作为中间传输节点的一级节点,再由中间传输节点传输至所述二级节点,具体为:
[0130] 将所述标准调用指令进行关键词提取,获得关键词数据;
[0131] 将所述关键词数据与所述一级节点内存储的所述类标签分别进行匹配获得相应匹配度值;
[0132] 选取匹配度值最高的类标签对应的所述一级节点作为中间传输节点;
[0133] 所述中间传输节点将所述标准调用指令传输至所述二级节点。
[0134] 需要说明的是,当调用指令传输至一级节点时,一级节点内存储的类标签分别与标准调用指令进行匹配,根据匹配结果确定作为中间传输节点的一级节点,再由中间传输节点传输至二级节点。
[0135] 根据本发明实施例,所述向所有节点注册回调函数,将所述二级节点内存储的所述子数据与所述标准调用指令分别进行相似度对比,根据相似度对比结果确定发生响应的所述二级节点,并获得响应数据,同时触发所述回调函数,具体为:
[0136] 向所有节点注册回调函数;
[0137] 将所述二级节点内存储的所述子数据与所述标准调用指令分别进行相似度对比,获得相似度对比结果;
[0138] 将所述相似度对比结果按照从高到低的顺序进行排序,选取相似度最高的子数据对应的所述二级节点作为响应二级节点;
[0139] 获得所述响应二级节点的响应数据,同时触发所述回调函数。
[0140] 需要说明的是,为了对调用指令进行精确的响应,向所有节点注册回调函数以便于将响应数据进行回传,将二级节点内存储的子数据与标准调用指令分别进行相似度对比,将相似度对比结果按照从高到低的顺序进行排序,选取相似度最高的子数据对应的二级节点作为响应二级节点,获得响应二级节点的响应数据,同时触发回调函数进行工作,以便将响应数据由二级节点传输至一级节点再传输至根节点,最后由根节点发送至客户端。
[0141] 根据本发明实施例,还包括:
[0142] 向所有的所述一级节点注册监视函数;
[0143] 若所述二级节点内存储的所述子数据产生变化值,则自动对所述二级节点进行标记,并触发所述回调函数以及所述监视函数,同时对未被标记的所述二级节点进行自动询问;
[0144] 若未被标记的所述二级节点产生变化值,则所述回调函数将所述响应数据由所述二级节点传输至所述一级节点,再由所述一级节点传输至所述根节点,最后由所述根节点发送至所述客户端;
[0145] 若未被标记的所述二级节点未产生变化值,则只对标记的所述二级节点产生的变化值进行传输。
[0146] 需要说明的是,为了实现对数据修改事件的批量实时监听,首先向所有的一级节点注册监视函数,若二级节点内存储的子数据产生变化值,则自动对二级节点进行标记,并触发回调函数以及监视函数,同时对未被标记的二级节点进行自动询问,若未被标记的二级节点产生变化值,则回调函数将响应数据由二级节点传输至一级节点,再由一级节点传输至根节点,最后由根节点发送至客户端,若未被标记的二级节点未产生变化值,则只对标记的二级节点产生的变化值进行传输。
[0147] 本发明第三方面提供了一种可读存储介质,所述可读存储介质中包括基于GRPC的多方信息传递及状态同步方法程序,所述基于GRPC的多方信息传递及状态同步方法程序被处理器执行时,实现如上述任一项所述的基于GRPC的多方信息传递及状态同步方法的步骤。
[0148] 本发明公开的基于GRPC的多方信息传递及状态同步方法、系统和介质,首先对meta数据进行分类,将类标签存储到一级节点中,将meta数据存储到相应的二级节点中,根节点对客户端发出的请求验证指令进行身份验证后生成验证码,客户端将验证码以及请求调用指令进行随机排列组合后,生成标准调用指令,并与一级节点进行匹配后传输至二级节点进行相似度对比,以确定发生响应的二级节点,同时触发回调函数,将响应数据传输至一级节点再传输至根节点最后发送至客户端。本申请基于GRPC 软件框架,通过客户端与服务器端的直接通信,可实现对meta数据的精确、快速调用的功能,并可以对数据修改事件进行批量实时监听,具有较好的时效性。
[0149] 在本申请所提供的几个实施例中,应该理解到,所揭露的设备和方法,可以通过其它的方式实现。以上所描述的设备实施例仅仅是示意性的,例如,所述单元的划分,仅仅为一种逻辑功能划分,实际实现时可以有另外的划分方式,如:多个单元或组件可以结合,或可以集成到另一个系统,或一些特征可以忽略,或不执行。另外,所显示或讨论的各组成部分相互之间的耦合、或直接耦合、或通信连接可以是通过一些接口,设备或单元的间接耦合或通信连接,可以是电性的、机械的或其它形式的。
[0150] 上述作为分离部件说明的单元可以是、或也可以不是物理上分开的,作为单元显示的部件可以是、或也可以不是物理单元;既可以位于一个地方,也可以分布到多个网络单元上;可以根据实际的需要选择其中的部分或全部单元来实现本实施例方案的目的。
[0151] 另外,在本发明各实施例中的各功能单元可以全部集成在一个处理单元中,也可以是各单元分别单独作为一个单元,也可以两个或两个以上单元集成在一个单元中;上述集成的单元既可以采用硬件的形式实现,也可以采用硬件加软件功能单元的形式实现。
[0152] 本领域普通技术人员可以理解:实现上述方法实施例的全部或部分步骤可以通过程序指令相关的硬件来完成,前述的程序可以存储于可读取存储介质中,该程序在执行时,执行包括上述方法实施例的步骤;而前述的存储介质包括:移动存储设备、只读存储器(ROM,Read‑Only Memory)、随机存取存储器(RAM,Random Access Memory)、磁碟或者光盘等各种可以存储程序代码的介质。
[0153] 或者,本发明上述集成的单元如果以软件功能模块的形式实现并作为独立的产品销售或使用时,也可以存储在一个可读取存储介质中。基于这样的理解,本发明实施例的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来,该软件产品存储在一个存储介质中,包括若干指令用以使得一台计算机设备(可以是个人计算机、服务器、或者网络设备等)执行本发明各个实施例所述方法的全部或部分。而前述的存储介质包括:移动存储设备、ROM、RAM、磁碟或者光盘等各种可以存储程序代码的介质。