分布式业务处理方法、装置及电子设备与流程

阅读：评论：0

1.本发明涉及数据处理技术领域，具体而言，涉及一种分布式业务处理方法、装置及电子设备。

背景技术：

2.规则引擎是一种嵌入式组件，在不重启服务的情况下可随时对业务规则进行扩展和维护，使得复杂的业务规则变的简单，减少了硬编码规则的成本和风险。在安全风险识别、银行风控、推广活动营销等领域应用十分广泛，通过实现业务逻辑与应用逻辑的分离，可以大大提高企业对市场变化的反应速度。规则直接由业务人员进行配置，同时更便捷的修改生效，使得业务人员可以快速的调整规则策略，降低公司的业务风险，从而提高应对不同场景的能力。
3.随着大数据技术的广泛应用，产生的数据量不断攀升、数据结构的多样性日益丰富，传统规则引擎性其管理的规则集存放在单台服务器上，处理业务的能力取决于单台机器的性能，存在单机的局限性。当处理大量数据及规则数量繁多且复杂时，业务数据处理的效率较低。

技术实现要素：

4.本发明实施例提供了一种分布式业务处理方法、装置及电子设备，以至少解决相关技术中将规则引擎配置在单个服务器上导致业务处理效率较低的技术问题。
5.根据本发明实施例的一个方面，提供了一种分布式业务处理方法，包括：获取待处理的业务数据，所述业务数据携带有业务请求参数；根据所述业务请求参数从预设规则集合中筛选出目标规则集合；根据目标规则集合将所述业务数据转发至多个目标节点服务器，以使所述多个目标节点服务器执行所述业务数据得到多个执行结果；其中，所述目标节点服务器分布在由多个节点服务器组成的服务器集中；将每个目标节点服务器返回的执行结果进行逻辑比对，得到决策结果。
6.根据本发明实施例的另一方面，还提供了一种分布式业务处理装置，包括：获取单元，用于获取待处理的业务数据，所述业务数据携带有业务请求参数；筛选单元，用于根据所述业务请求参数从预设规则集合中筛选出目标规则集合；转发执行单元，用于根据目标规则集合将所述业务数据转发至多个目标节点服务器，以使所述多个目标节点服务器执行所述业务数据得到多个执行结果；其中，所述目标节点服务器分布在由多个节点服务器组成的服务器集中；比对单元，用于将每个目标节点服务器返回的执行结果进行逻辑比对，得到决策结果。
7.根据本发明实施例的又一方面，还提供了一种电子设备，包括存储器和处理器，上述存储器中存储有计算机程序，上述处理器被设置为通过上述计算机程序执行上述的分布式业务处理方法。
8.根据本发明实施例的又一方面，还提供了一种计算机可读的存储介质，该计算机
可读的存储介质中存储有计算机程序，其中，该计算机程序被设置为运行时执行上述分布式业务处理方法。
9.在本发明实施例中，采用了获取待处理的业务数据，所述业务数据携带有业务请求参数；根据所述业务请求参数从预设规则集合中筛选出目标规则集合；根据目标规则集合将所述业务数据转发至多个目标节点服务器，以使所述多个目标节点服务器执行所述业务数据得到多个执行结果；其中，所述目标节点服务器分布在由多个节点服务器组成的服务器集中；将每个目标节点服务器返回的执行结果进行逻辑比对，得到决策结果的方法，在上述方法中，由于通过将业务数据转发到服务器集中进行处理，提升业务数据处理的效率，进而解决了相关技术中将规则引擎配置在单个服务器上导致业务处理效率较低的技术问题。
附图说明
10.此处所说明的附图用来提供对本发明的进一步理解，构成本技术的一部分，本发明的示意性实施例及其说明用于解释本发明，并不构成对本发明的不当限定。在附图中：
11.图1是根据本发明实施例的一种可选的分布式业务处理方法的应用环境的示意图；
12.图2是根据本发明实施例的另一种可选的分布式业务处理方法的应用环境的示意图；
13.图3是根据本发明实施例的一种可选的分布式业务处理方法的流程示意图；
14.图4是根据相关技术中的另一种可选的分布式业务处理方法的流程示意图；
15.图5是根据本发明实施例的一种可选的分布式业务处理装置的结构示意图；
16.图6是根据本发明实施例的一种可选的电子设备的结构示意图。
具体实施方式
17.为了使本技术领域的人员更好地理解本发明方案，下面将结合本发明实施例中的附图，对本发明实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅仅是本发明一部分的实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都应当属于本发明保护的范围。
18.需要说明的是，本发明的说明书和权利要求书及上述附图中的术语“第一”、“第二”等是用于区别类似的对象，而不必用于描述特定的顺序或先后次序。应该理解这样使用的数据在适当情况下可以互换，以便这里描述的本发明的实施例能够以除了在这里图示或描述的那些以外的顺序实施。此外，术语“包括”和“具有”以及他们的任何变形，意图在于覆盖不排他的包含，例如，包含了一系列步骤或单元的过程、方法、系统、产品或设备不必限于清楚地列出的那些步骤或单元，而是可包括没有清楚地列出的或对于这些过程、方法、产品或设备固有的其它步骤或单元。
19.根据本发明实施例的一个方面，提供了一种分布式业务处理方法，可选地，作为一种可选地实施方式，上述分布式业务处理方法可以但不限于应用于如图1所示的应用环境中。该应用环境中包括：与用户进行人机交互的终端设备102、网络104、服务器106。用户108
与终端设备102之间可以进行人机交互，终端设备102中运行有分布式业务处理应用程序。上述终端设备102中包括人机交互屏幕1022，处理器1024及存储器1026。人机交互屏幕1022用于显示待处理的业务数据；处理器1024用于获取当前待处理的业务数据。存储器1026用于存储上述待处理的业务数据。
20.此外，服务器106位于服务器集中，服务器106中包括数据库1062及处理引擎1064，数据库1062中用于存储待处理的业务数据。处理引擎1064用于获取待处理的业务数据，所述业务数据携带有业务请求参数；根据所述业务请求参数从预设规则集合中筛选出目标规则集合；根据目标规则集合将所述业务数据转发至多个目标节点服务器，以使所述多个目标节点服务器执行所述业务数据得到多个执行结果；其中，所述目标节点服务器分布在由多个节点服务器组成的服务器集中；将每个目标节点服务器返回的执行结果进行逻辑比对，得到决策结果；在上述终端设备102的客户端显示决策结果。
21.在一个或多个实施例中，本技术上述分布式业务处理方法可以应用于图2所示的应用环境中。如图2所示，用户202与用户设备204之间可以进行人机交互。用户设备204中包含有存储器206和处理器208。本实施例中用户设备204可以但不限于参考执行上述终端设备102所执行的操作，获取决策结果。
22.可选地，上述终端设备102和用户设备204包括但不限于为手机、机顶盒、电视、平板电脑、笔记本电脑、pc机，车载电子设备，可穿戴设备等终端，上述网络104可以包括但不限于无线网络或有线网络。其中，该无线网络包括：wifi及其他实现无线通信的网络。上述有线网络可以包括但不限于：广域网、城域网、局域网。上述服务器106可以包括但不限于任何可以进行计算的硬件设备。上述服务器可以是单一服务器，也可以是由多个服务器组成的服务器集，或者是云服务器。上述仅是一种示例，本实施例中对此不作任何限定。
23.相关技术中随着大数据技术的广泛应用，产生的数据量不断攀升、数据结构的多样性日益丰富，传统规则引擎性其管理的规则集存放在单台服务器上，处理业务的能力取决于单台机器的性能，存在单机的局限性。当处理大量数据及规则数量繁多且复杂时，业务数据处理的效率较低。
24.为了解决上述技术问题，作为一种可选地实施方式，如图3所示，本发明实施例提供了一种分布式业务处理方法，包括如下步骤：
25.s302，获取待处理的业务数据，所述业务数据携带有业务请求参数。
26.在本发明实施例中，上述业务数据例如包括但不限于登录服务的业务数据，注册服务的业务数据；业务请求参数例如可以为登录请求参数，注册请求参数等。
27.s304，根据所述业务请求参数从预设规则集合中筛选出目标规则集合。
28.例如，请求参数req中，包括checkpointcode等于cp-sign(登录标识)，即获取用户登录时需要校验的规则集a，checkpointcode等于cp-register注册标识，即获取用户注册时所需校验的规则集b，那么规则集合为{规则集a，规则集b}。需要说明的是，上述规则集合中的每个规则可以分布不同的服务器上。
29.s306，根据目标规则集合将所述业务数据转发至多个目标节点服务器，以使所述多个目标节点服务器执行所述业务数据得到多个执行结果；其中，所述目标节点服务器分布在由多个节点服务器组成的服务器集中。
30.这里，上述的服务器集包括但不限于为多个节点服务器组成的环形结构的服务
器集，或者，由多个节点服务器按顺序首尾相接应的服务器集。
31.s308，将每个目标节点服务器返回的执行结果进行逻辑比对，得到决策结果。
32.具体地，例如，第一目标节点服务器执行结果为通过pass，第二目标节点服务器执行结果同样为通过pass，第三目标节点服务器执行结果校验verify且人脸识别needface，进行逻辑比对后得到决策结果为该用户登录需要进行人脸认证校验。
33.在本发明实施例中，采用了获取待处理的业务数据，所述业务数据携带有业务请求参数；根据所述业务请求参数从预设规则集合中筛选出目标规则集合；根据目标规则集合将所述业务数据转发至多个目标节点服务器，以使所述多个目标节点服务器执行所述业务数据得到多个执行结果；其中，所述目标节点服务器分布在由多个节点服务器组成的服务器集中；将每个目标节点服务器返回的执行结果进行逻辑比对，得到决策结果的方法，在上述方法中，由于通过将业务数据转发到服务器集中进行处理，提升业务数据处理的效率，进而解决了相关技术中将规则引擎配置在单个服务器上导致业务处理效率较低的技术问题。
34.在一个或多个实施例中，所述根据所述业务请求参数从预设规则集合中筛选出目标规则集合，包括：业务调度节点根据所述业务请求参数从预设规则集合中筛选出目标规则集合。
35.具体地，本发明实施例中包括3个独立的实体jobtracker(执行作业运行前的预处理工作)、tasktracker(处理作业划分后的任务)，collecttracker(收集每个任务处理的结果)，上述三个实体分布在不同的服务器；业务调度节点jobtracker收到业务请求参数req，根据req携带的标识，获取即将执行的规则集(func.1、func.2、func.3
……
)。例如req中的携带的标识checkpointcode等于cp-sign(登录标识)，即获取用户登录时需要校验的规则集，checkpointcode为cp-register注册标识，即获取用户注册时所需校验的规则集。
36.所述根据目标规则集合将所述业务数据转发至多个目标节点服务器，包括：
37.所述业务调度节点根据将所述业务数据转发至多个任务处理节点；其中，所述业务调度节点和所述任务处理节点位于不同的目标节点服务器。
38.具体地，业务调度节点jobtracker根据将所述业务数据转发至多个任务处理节点tasktracker。
39.在一个或多个实施例中，所述业务调度节点根据所述业务请求参数从预设规则集合中筛选出目标规则集合，包括：
40.业务调度节点根据所述业务请求参数获取规则标识；
41.所述业务调度节点从预设规则集合中筛选出与所述规则标识匹配的目标规则集合。
42.具体地，规则标识包括cp-sign和cp-register，业务调度节点jobtracker从预设规则集合中筛选出与cp-sign和cp-register匹配的目标规则集合，即获取包括用户登录时需要校验的规则集a，以及用户注册时所需校验的规则集b的规则集合{规则集a，规则集b}。
43.在一个或多个实施例中，所述分布式业务处理方法，还包括：
44.将多个任务处理节点配置为环形结构，所述多个任务处理节点中的每个任务处理节点所在的节点服务器均不同；
45.将所述业务数据中的令牌按照顺时针或逆时针方向在所述多个任务处理节点之
间传递；其中，收到令牌的任务处理节点按预设规则对应处理所述业务数据。
46.具体地，例如如图4所示，将多个任务处理节点tasktracker1至tasktracker5配置为环形结构，然后将所述业务数据中的令牌按照顺时针方向在所述多个任务处理节点之间传递，收到令牌的tasktracker有权限访问数据库的数据资源。
47.在一个或多个实施例中，所述将所述业务数据中的令牌按照顺时针或逆时针方向在所述多个任务处理节点之间传递，包括：
48.在初始任务处理节点中设置默认令牌；
49.在接收到所述初始任务处理节点的处理业务的指令时，将所述默认令牌发送至所述初始任务处理节点的下一任务处理节点。
50.具体地，如图4所示，例如在初始任务处理节点tasktracker1中设置默认令牌，在接收到所述初始任务处理节点的处理业务的指令时，将所述默认令牌发送至所述初始任务处理节点的下一任务处理节点tasktracker2。
51.在一个或多个实施例中，所述以使所述多个目标节点服务器执行所述业务数据得到多个执行结果之后，还包括：
52.在当前任务处理节点所在服务器出现故障时，将所述令牌传递给所述当前任务处理节点的下一任务处理节点。
53.通过上述技术手段，可以在单个服务器节点出现故障时跳过对应的执行程序，从而很好的解决单点故障问题，提高系统的健壮性，提高系统的高可用性。
54.在一个或多个实施例中，所述将每个目标节点服务器返回的执行结果进行逻辑比对，得到决策结果，包括：
55.将每个目标节点服务器返回的执行结果与预设逻辑运算标识相匹配；
56.根据匹配结果得到待执行的业务操作；其中，所述决策结果包括所述待执行的业务操作。
57.将每个目标节点服务器返回的执行结果，例如pass、reject或verify等，将上述执行结果与预设逻辑运算标识(如包括pass、reject或verify等逻辑运算标识的逻辑运算标识集合)相匹配，得到匹配结果为，业务1通过，业务2拒绝，业务3待校验，待执行的业务操作为业务3待校验。
58.在一实施例中，将异常信息存储至日志记录库中，发送告警邮件、短信通知，并提供页面异常图表展示，便于日后分析。
59.在一些实施例中，随着大数据技术的广泛应用，产生的数据量不断攀升、数据结构的多样性日益丰富，传统规则引擎性能上的缺陷逐渐显露出来。当前主流的规则引擎系统，其管理的规则集存放在单台服务器上，虽然可以通过引入计算机集技术，从而支持高规模的请求吞吐量，表面看似解决了上述技术问题，但还是不能避免将业务数据进行路由转发后，业务数据集中在某一个节点上处理，全量的规则在一台机器上执行，这样集的性能无法得到充分发挥，最终也只取决于单台机器的性能，存在单机的局限性。当处理大量数据及规则数量繁多且复杂时，以及部分规则对计算机软/硬件有特殊依赖时(比如依赖特定gpu，大内存等)，传统规则引擎无法解决上述技术问题。
60.为了解决上述技术问题，在一些实施例中，通过令牌环行设计(将令牌依次在服务器之间进行传递)，在不同的服务器节点上执行(不同的服务器组成环形结构)，并且汇总各
个节点返回的执行结果，进行逻辑比对，得到最终的规则输出结果，做出业务决策。在一实施例中，通过构建一个多节点的，分布式的并行计算执行环境，执行环境里可以按业务需求植入不同软/硬件配置的计算机资源，以满足各类规则对不同软硬件资源的要求。
61.如图4所示，在一应用实施例中，上述分布式业务处理方法还包括如下内容：
62.1、分布式业务处理工作过程，包含3个独立的实体(分布在不同的服务器)，即jobtracker(执行作业运行前的预处理工作)、tasktracker(处理作业划分后的任务)，collecttracker(收集每个任务处理的结果)。
63.2、jobtracker收到请求参数req，根据req携带的特殊标识，获取即将执行的规则集(func.1、func.2、func.3
…
)。例如请求参数req中，checkpointcode等于cp-sign(登录标识)，即获取用户登录时需要校验的规则集，checkpointcode等于cp-register注册标识，即获取用户注册时所需校验的规则集。
64.3、所有的tasktracker构成一个环形结构，令牌按照顺时针(或逆时针)方向在程序之间传递，收到令牌的tasktracker有权限访问数据库资源(得到令牌的服务器才有权限访问)，对规则执行及处理。当tasktracker接受访问后将令牌传递给下一个tasktracker。
65.4、设置默认令牌tasktracker1上(可配置)，即将执行的func.1在令牌在tasktracker1执行，此时令牌传递给tasktracker2，因此func.2在tasktracker2执行规则，以此类推，实现分布式规则运算。
66.5、在令牌环中，若某一个程序出现故障，则直接将令牌传递给故障程序的下一个程序(或环形服务器集中的下一服务器)，从而很好的解决单点故障问题，提高系统的健壮性，带来更好的可用性。
67.6、collecttracker汇总每个规则的执行结果，完成逻辑比对，从而完成本次规则集的执行，并最终做出业务决策。比对逻辑可配置，例：登录配置风险等级优先，tasktracker1执行结果通过pass，tasktracker2执行结果也是通过pass，tasktracker3执行结果校验verify且人脸识别needface，则最终结果为该用户登录需要进行人脸认证校验。
68.7、规则执行过程发生的异常按事先配置好的运行报错默认处理的方式，直接返回pass、拒绝reject或verify，并将异常信息入库，发送告警邮件、短信通知，并提供页面异常图表展示，便于日后分析。
69.本发明实施例还具备如下有益的技术效果：
70.1、性能方面，与传统规则引擎的扩容集不同，将全量的规则分割细化分配给不同的集机器执行并汇总，充分利用集优势，空间换时间，性能效率得到了显著提升。
71.2、智能化方面，收集执行过程中的程序的运行情况，动态调整服务器集执行规则的调用链路。
72.3、异常捕获方面，实时收集规则运行中的异常，告警邮件、短信通知，并提供页面数据图表展示，便于问题分析。
73.4、拓展性方面，支持水平拓展。根据业务及性能需要，适当增加单节点处理服务器集的机器数量，从而提升规则引擎的整体系统性能。
74.需要说明的是，对于前述的各方法实施例，为了简单描述，故将其都表述为一系列的动作组合，但是本领域技术人员应该知悉，本发明并不受所描述的动作顺序的限制，因为
依据本发明，某些步骤可以采用其他顺序或者同时进行。其次，本领域技术人员也应该知悉，说明书中所描述的实施例均属于优选实施例，所涉及的动作和模块并不一定是本发明所必须的。
75.根据本发明实施例的另一个方面，还提供了一种用于实施上述分布式业务处理方法的分布式业务处理装置。如图5所示，该装置包括：
76.获取单元502，用于获取待处理的业务数据，所述业务数据携带有业务请求参数；
77.筛选单元504，用于根据所述业务请求参数从预设规则集合中筛选出目标规则集合；
78.转发执行单元506，用于根据目标规则集合将所述业务数据转发至多个目标节点服务器，以使所述多个目标节点服务器执行所述业务数据得到多个执行结果；其中，所述目标节点服务器分布在由多个节点服务器组成的服务器集中；
79.比对单元508，用于将每个目标节点服务器返回的执行结果进行逻辑比对，得到决策结果。
80.在本发明实施例中，采用了获取待处理的业务数据，所述业务数据携带有业务请求参数；根据所述业务请求参数从预设规则集合中筛选出目标规则集合；根据目标规则集合将所述业务数据转发至多个目标节点服务器，以使所述多个目标节点服务器执行所述业务数据得到多个执行结果；其中，所述目标节点服务器分布在由多个节点服务器组成的服务器集中；将每个目标节点服务器返回的执行结果进行逻辑比对，得到决策结果的方法，在上述方法中，由于通过将业务数据转发到服务器集中进行处理，提升业务数据处理的效率，进而解决了相关技术中将规则引擎配置在单个服务器上导致业务处理效率较低的技术问题。
81.在一个或多个实施例中，上述筛选单元504，包括：
82.筛选模块，用于使业务调度节点根据所述业务请求参数从预设规则集合中筛选出目标规则集合；
83.转发执行单元506，包括：
84.转发执行模块，用于使所述业务调度节点根据将所述业务数据转发至多个任务处理节点；其中，所述业务调度节点和所述任务处理节点位于不同的目标节点服务器。
85.在一个或多个实施例中，所述筛选模块，包括：
86.获取子单元，用于使业务调度节点根据所述业务请求参数获取规则标识；
87.筛选子单元，用于使所述业务调度节点从预设规则集合中筛选出与所述规则标识匹配的目标规则集合。
88.在一个或多个实施例中，所述分布式业务处理装置还包括：
89.配置单元，用于将多个任务处理节点配置为环形结构，所述多个任务处理节点中的每个任务处理节点所在的节点服务器均不同；
90.传递单元，用于将所述业务数据中的令牌按照顺时针或逆时针方向在所述多个任务处理节点之间传递；其中，收到令牌的任务处理节点按预设规则对应处理所述业务数据。
91.在一个或多个实施例中，所述传递单元，包括：
92.设置模块，用于在初始任务处理节点中设置默认令牌；
93.发送模块，用于在接收到所述初始任务处理节点的处理业务的指令时，将所述默
认令牌发送至所述初始任务处理节点的下一任务处理节点。
94.在一个或多个实施例中，所述分布式业务处理装置还包括：
95.故障处理单元，用于在当前任务处理节点所在服务器出现故障时，将所述令牌传递给所述当前任务处理节点的下一任务处理节点。
96.在一个或多个实施例中，所述比对单元508，包括：
97.匹配模块，用于将每个目标节点服务器返回的执行结果与预设逻辑运算标识相匹配；
98.确定模块，用于根据匹配结果得到待执行的业务操作；其中，所述决策结果包括所述待执行的业务操作。
99.根据本技术实施例的又一个方面，还提供了一种用于实施上述分布式业务处理方法的电子设备，该电子设备可以是图1所示的终端设备或服务器。本实施例以该电子设备为服务器为例来说明。如图6所示，该电子设备包括存储器602和处理器604，该存储器602中存储有计算机程序，该处理器604被设置为通过计算机程序执行上述任一项方法实施例中的步骤。
100.可选地，在本实施例中，上述电子设备可以位于计算机网络的多个网络设备中的至少一个网络设备。
101.可选地，在本实施例中，上述处理器可以被设置为通过计算机程序执行以下步骤：
102.s1，获取待处理的业务数据，所述业务数据携带有业务请求参数；
103.s2，根据所述业务请求参数从预设规则集合中筛选出目标规则集合；
104.s3，根据目标规则集合将所述业务数据转发至多个目标节点服务器，以使所述多个目标节点服务器执行所述业务数据得到多个执行结果；其中，所述目标节点服务器分布在由多个节点服务器组成的服务器集中；
105.s4，将每个目标节点服务器返回的执行结果进行逻辑比对，得到决策结果。
106.可选地，本领域普通技术人员可以理解，图6所示的结构仅为示意，电子装置电子设备也可以是智能手机(如android手机、ios手机等)、平板电脑、掌上电脑以及移动互联网设备(mobile internet devices，mid)、pad等终端设备。图6其并不对上述电子装置电子设备的结构造成限定。例如，电子装置电子设备还可包括比图6中所示更多或者更少的组件(如网络接口等)，或者具有与图6所示不同的配置。
107.其中，存储器602可用于存储软件程序以及模块，如本技术实施例中的分布式业务处理方法和装置对应的程序指令/模块，处理器604通过运行存储在存储器602内的软件程序以及模块，从而执行各种功能应用以及数据处理，即实现上述的分布式业务处理方法。存储器602可包括高速随机存储器，还可以包括非易失性存储器，如一个或者多个磁性存储装置、闪存、或者其他非易失性固态存储器。在一些实例中，存储器602可进一步包括相对于处理器604远程设置的存储器，这些远程存储器可以通过网络连接至终端。上述网络的实例包括但不限于互联网、企业内部网、局域网、移动通信网及其组合。其中，存储器602具体可以但不限于用于存储业务请求参数信息。作为一种示例，如图6所示，上述存储器602中可以但不限于包括上述分布式业务处理装置中的获取单元502、筛选单元504、转发执行单元506和比对单元508。此外，还可以包括但不限于上述分布式业务处理装置中的其他模块单元，本示例中不再赘述。
108.可选地，上述的传输装置606用于经由一个网络接收或者发送数据。上述的网络具体实例可包括有线网络及无线网络。在一个实例中，传输装置606包括一个网络适配器(network interface controller，nic)，其可通过网线与其他网络设备与路由器相连从而可与互联网或局域网进行通讯。在一个实例中，传输装置606为射频(radio frequency，rf)模块，其用于通过无线方式与互联网进行通讯。
109.此外，上述电子设备还包括：显示器608，用于显示业务处理结果；和连接总线610，用于连接上述电子设备中的各个模块部件。
110.在其他实施例中，上述终端设备或者服务器可以是一个分布式系统中的一个节点，其中，该分布式系统可以为区块链系统，该区块链系统可以是由该多个节点通过网络通信的形式连接形成的分布式系统。其中，节点之间可以组成点对点(p2p，peer to peer)网络，任意形式的计算设备，比如服务器、终端等电子设备都可以通过加入该点对点网络而成为该区块链系统中的一个节点。
111.在一个或多个实施例中，本技术还提供了一种计算机程序产品或计算机程序，该计算机程序产品或计算机程序包括计算机指令，该计算机指令存储在计算机可读存储介质中。计算机设备的处理器从计算机可读存储介质读取该计算机指令，处理器执行该计算机指令，使得该计算机设备执行上述分布式业务处理方法。其中，该计算机程序被设置为运行时执行上述任一项方法实施例中的步骤。
112.可选地，在本实施例中，上述计算机可读的存储介质可以被设置为存储用于执行以下步骤的计算机程序：
113.s1，获取待处理的业务数据，所述业务数据携带有业务请求参数；
114.s2，根据所述业务请求参数从预设规则集合中筛选出目标规则集合；
115.s3，根据目标规则集合将所述业务数据转发至多个目标节点服务器，以使所述多个目标节点服务器执行所述业务数据得到多个执行结果；其中，所述目标节点服务器分布在由多个节点服务器组成的服务器集中；
116.s4，将每个目标节点服务器返回的执行结果进行逻辑比对，得到决策结果。
117.可选地，在本实施例中，本领域普通技术人员可以理解上述实施例的各种方法中的全部或部分步骤是可以通过程序来指令终端设备相关的硬件来完成，该程序可以存储于一计算机可读存储介质中，存储介质可以包括：闪存盘、只读存储器(read-only memory，rom)、随机存取器(random access memory，ram)、磁盘或光盘等。
118.上述本发明实施例序号仅仅为了描述，不代表实施例的优劣。
119.上述实施例中的集成的单元如果以软件功能单元的形式实现并作为独立的产品销售或使用时，可以存储在上述计算机可读取的存储介质中。基于这样的理解，本发明的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的全部或部分可以以软件产品的形式体现出来，该计算机软件产品存储在存储介质中，包括若干指令用以使得一台或多台计算机设备(可为个人计算机、服务器或者网络设备等)执行本发明各个实施例方法的全部或部分步骤。
120.在本发明的上述实施例中，对各个实施例的描述都各有侧重，某个实施例中没有详述的部分，可以参见其他实施例的相关描述。
121.在本技术所提供的几个实施例中，应该理解到，所揭露的客户端，可通过其它的方
式实现。其中，以上所描述的装置实施例仅仅是示意性的，例如单元的划分，仅仅为一种逻辑功能划分，实际实现时可以有另外的划分方式，例如多个单元或组件可以结合或者可以集成到另一个系统，或一些特征可以忽略，或不执行。另一点，所显示或讨论的相互之间的耦合或直接耦合或通信连接可以是通过一些接口，单元或模块的间接耦合或通信连接，可以是电性或其它的形式。
122.作为分离部件说明的单元可以是或者也可以不是物理上分开的，作为单元显示的部件可以是或者也可以不是物理单元，即可以位于一个地方，或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部单元来实现本实施例方案的目的。
123.另外，在本发明各个实施例中的各功能单元可以集成在一个处理单元中，也可以是各个单元单独物理存在，也可以两个或两个以上单元集成在一个单元中。上述集成的单元既可以采用硬件的形式实现，也可以采用软件功能单元的形式实现。
124.以上仅是本发明的优选实施方式，应当指出，对于本技术领域的普通技术人员来说，在不脱离本发明原理的前提下，还可以做出若干改进和润饰，这些改进和润饰也应视为本发明的保护范围。

技术特征：

1.一种分布式业务处理方法，其特征在于，包括：获取待处理的业务数据，所述业务数据携带有业务请求参数；根据所述业务请求参数从预设规则集合中筛选出目标规则集合；根据目标规则集合将所述业务数据转发至多个目标节点服务器，以使所述多个目标节点服务器执行所述业务数据得到多个执行结果；其中，所述目标节点服务器分布在由多个节点服务器组成的服务器集中；将每个目标节点服务器返回的执行结果进行逻辑比对，得到决策结果。2.根据权利要求1所述的方法，其特征在于，所述根据所述业务请求参数从预设规则集合中筛选出目标规则集合，包括：业务调度节点根据所述业务请求参数从预设规则集合中筛选出目标规则集合；所述根据目标规则集合将所述业务数据转发至多个目标节点服务器，包括：所述业务调度节点根据将所述业务数据转发至多个任务处理节点；其中，所述业务调度节点和所述任务处理节点位于不同的目标节点服务器。3.根据权利要求2所述的方法，其特征在于，所述业务调度节点根据所述业务请求参数从预设规则集合中筛选出目标规则集合，包括：业务调度节点根据所述业务请求参数获取规则标识；所述业务调度节点从预设规则集合中筛选出与所述规则标识匹配的目标规则集合。4.根据权利要求2所述的方法，其特征在于，所述方法还包括：将多个任务处理节点配置为环形结构，所述多个任务处理节点中的每个任务处理节点所在的节点服务器均不同；将所述业务数据中的令牌按照顺时针或逆时针方向在所述多个任务处理节点之间传递；其中，收到令牌的任务处理节点按预设规则对应处理所述业务数据。5.根据权利要求4所述的方法，其特征在于，所述将所述业务数据中的令牌按照顺时针或逆时针方向在所述多个任务处理节点之间传递，包括：在初始任务处理节点中设置默认令牌；在接收到所述初始任务处理节点的处理业务的指令时，将所述默认令牌发送至所述初始任务处理节点的下一任务处理节点。6.根据权利要求4所述的方法，其特征在于，所述以使所述多个目标节点服务器执行所述业务数据得到多个执行结果之后，还包括：在当前任务处理节点所在服务器出现故障时，将所述令牌传递给所述当前任务处理节点的下一任务处理节点。7.根据权利要求1所述的方法，其特征在于，所述将每个目标节点服务器返回的执行结果进行逻辑比对，得到决策结果，包括：将每个目标节点服务器返回的执行结果与预设逻辑运算标识相匹配；根据匹配结果得到待执行的业务操作；其中，所述决策结果包括所述待执行的业务操作。8.一种分布式业务处理装置，其特征在于，包括：获取单元，用于获取待处理的业务数据，所述业务数据携带有业务请求参数；筛选单元，用于根据所述业务请求参数从预设规则集合中筛选出目标规则集合；
转发执行单元，用于根据目标规则集合将所述业务数据转发至多个目标节点服务器，以使所述多个目标节点服务器执行所述业务数据得到多个执行结果；其中，所述目标节点服务器分布在由多个节点服务器组成的服务器集中；比对单元，用于将每个目标节点服务器返回的执行结果进行逻辑比对，得到决策结果。9.一种计算机可读的存储介质，其特征在于，所述计算机可读的存储介质包括存储的程序，其中，所述程序运行时执行所述权利要求1至7任一项中所述的方法。10.一种电子设备，包括存储器和处理器，其特征在于，所述存储器中存储有计算机程序，所述处理器被设置为通过所述计算机程序执行所述权利要求1至7任一项中所述的方法。

技术总结

本发明公开了一种分布式业务处理方法、装置及电子设备。其中，上述方法包括：获取待处理的业务数据，所述业务数据携带有业务请求参数；根据所述业务请求参数从预设规则集合中筛选出目标规则集合；根据目标规则集合将所述业务数据转发至多个目标节点服务器，以使所述多个目标节点服务器执行所述业务数据得到多个执行结果；其中，所述目标节点服务器分布在由多个节点服务器组成的服务器集中；将每个目标节点服务器返回的执行结果进行逻辑比对，得到决策结果。本发明解决了相关技术中将规则引擎配置在单个服务器上导致业务处理效率较低的技术问题。的技术问题。的技术问题。