消息处理方法、系统、电子设备、存储介质和程序产品与流程

本申请涉及计算机，尤其涉及一种消息处理方法、系统、电子设备、存储介质和程序产品。

背景技术：

1、在云服务场景中，基于云资源进行的数据处理会触发生成对应的事件消息，这些事件消息通过消息通知服务器流转至下游多个应用进行后续处理。在实际场景中，由于下游应用的数量较多，每条事件消息都重复分发，会导致消息总量成倍放大，下游应用需要额外对无用消息进行过滤和丢弃，从而增加系统负担。因此，需要在消息流转过程中进行消息过滤，减少无用消息的流转。

2、相关技术中，消息通知服务器对接收到的事件消息进行过滤处理，对于高流量场景中包含的大量无效事件消息，需要额外的机器资源来处理过滤逻辑，计算压力大且资源成本高。

技术实现思路

1、本申请实施例提供一种消息处理方法、系统、电子设备、存储介质和程序产品，以缓解或解决现有技术中存在的一项或多项技术问题。

2、第一方面，本申请实施例提供了一种消息处理方法，应用于消息处理客户端，该方法包括：接收云服务端发送的各事件消息，所述各事件消息为用户终端基于预定云资源进行数据处理所触发的；获取来自消息处理服务端的消息过滤规则，所述消息过滤规则与所述用户终端提交的规则构建需求相匹配，所述规则构建需求用于指示所述用户终端指定的与所述预定云资源相关的数据对象；基于所述消息过滤规则对所述各事件消息进行过滤。

3、第二方面，本申请实施例提供了一种消息处理方法，应用于消息处理服务端，该方法包括：获取用户终端提交的规则构建需求，所述规则构建需求用于指示所述用户终端指定的与预定云资源相关的数据对象；将所述数据对象与规则模板库中的规则模板进行匹配，生成与所述规则构建需求相匹配的消息过滤规则；发送所述消息过滤规则至消息处理客户端，所述消息过滤规则用于使所述消息处理客户端对各事件消息进行过滤，所述各事件消息是所述用户终端基于所述预定云资源进行数据处理触发的。

4、第三方面，本申请实施例提供了一种消息处理系统，包括：云服务端、消息处理服务端和消息处理客户端；所述云服务端，用于将用户终端基于预定云资源进行数据处理触发的各事件消息发送至所述消息处理客户端；所述消息处理服务端，用于获取所述用户终端提交的规则构建需求，所述规则构建需求用于指示所述用户终端指定的与所述预定云资源相关的数据对象；将所述数据对象与规则模板库中的规则模板进行匹配，生成与所述规则构建需求相匹配的消息过滤规则；发送所述消息过滤规则至消息处理客户端；所述消息处理客户端，用于接收所述各事件消息，获取所述消息过滤规则，基于所述消息过滤规则对所述各事件消息进行过滤。

5、第四方面，本申请实施例提供了一种电子设备，包括存储器、处理器及存储在存储器上的计算机程序，处理器在执行计算机程序时实现本申请实施例任一项的方法。

6、第五方面，本申请实施例提供了一种计算机可读存储介质，计算机可读存储介质内存储有计算机程序，计算机程序被处理器执行时实现本申请实施例任一项的方法。

7、第六方面，本申请实施例提供了一种计算机程序产品，包括计算机程序，计算机程序在被处理器执行时实现本申请实施例任一项的方法。

8、根据本申请实施例的方法，消息处理客户端可以接收来自云服务端的各事件消息，这些事件消息是用户终端基于预定云资源进行数据处理时触发的。基于来自消息处理服务端的消息过滤规则对这些事件消息进行过滤，消息过滤规则与用户终端提交的规则构建需求相匹配，可以明确指示用户终端指定的与预定云资源相关的数据对象。通过获取的消息过滤规则对事件消息进行过滤，有利于得到满足消息过滤需求的事件消息。并且，在消息处理客户端对各事件消息执行消息过滤，有利于将消息过滤的处理逻辑与消息处理服务端解耦，从而可以有效降低消息处理服务端的资源压力和资源成本，提升系统的整体稳定性和可靠性。

9、上述说明仅是本申请技术方案的概述，为了能够更清楚了解本申请的技术手段，可依照说明书的内容予以实施，并且为了让本申请的上述和其他目的、特征和优点能够更明显易懂，以下特举本申请的具体实施方式。

1.一种消息处理方法，应用于消息处理客户端，包括：

2.根据权利要求1所述的方法，其中，所述基于所述消息过滤规则对所述各事件消息进行过滤，包括：

3.根据权利要求2所述的方法，其中，所述从缓存中获取所述消息过滤规则的规则对象之前，还包括：

4.根据权利要求3所述的方法，其中，所述根据所述消息过滤规则构建所述规则对象，包括：

5.根据权利要求3所述的方法，其中，所述将所述规则对象懒加载至所述缓存中之后，还包括：

6.根据权利要求1所述的方法，其中，所述基于所述消息过滤规则对所述各事件消息进行过滤，包括：

7.根据权利要求5所述的方法，其中，还包括：

8.根据权利要求1所述的方法，其中，所述获取来自消息处理服务端的消息过滤规则之前，还包括：

9.根据权利要求1-8中任一项所述的方法，其中，还包括：

10.一种消息处理方法，应用于消息处理服务端，包括：

11.根据权利要求10所述的方法，其中，所述将所述数据对象与规则模板库中的规则模板进行匹配，包括：

12.根据权利要求10所述的方法，其中，所述生成与所述规则构建需求相匹配的消息过滤规则之后，还包括：

13.根据权利要求12所述的方法，其中，所述将符合所述校验通过条件的消息过滤规则存储至预定数据库，包括：

14.根据权利要求10所述方法，其中，所述发送所述消息过滤规则至消息处理客户端，包括：

15.根据权利要求14所述的方法，其中，所述基于分布式缓存中存在所述消息过滤规则，将从所述分布式缓存中提取的所述消息过滤规则发送至所述消息处理客户端之前，还包括：

16.根据权利要求12所述的方法，其中，所述将符合所述校验通过条件的消息过滤规则存储至预定数据库之后，还包括：

17.根据权利要求10-16中任一项所述的方法，其中，所述发送所述消息过滤规则至消息处理客户端之后，还包括：

18.一种消息处理系统，包括：云服务端、消息处理服务端和消息处理客户端；

19.一种电子设备，包括存储器、处理器及存储在存储器上的计算机程序，所述处理器在执行所述计算机程序时实现权利要求1至9中任一项、或权利要求10-17中任一项所述的方法。

20.一种计算机可读存储介质，所述计算机可读存储介质内存储有计算机程序，所述计算机程序被处理器执行时实现权利要求1至9中任一项、或权利要求10-17中任一项所述的方法。

21.一种计算机程序产品，包括计算机程序，所述计算机程序在被处理器执行时实现根据权利要求1至9中任一项、或权利要求10-17中任一项所述的方法。