技术摘要：
本发明涉及一种实现自动化实时消息推送运营的系统，包括客户数据采集模块，用于通过分布式定时任务调度采集、汇总、存储客户数据；批量事件处理模块，用于接入行情变化事件和定时触发事件；个人事件处理模块，用于接入个人操作事件；批量推送计算模块，完成人群交集计  全部
背景技术：
消息推送是一种互联网环境下对客户进行消息触达的沟通方式，即消息运营方通 过移动应用消息、桌面应用消息、短信、微信、邮件等沟通方式将包含特定信息的消息在特 定的条件下在特定的时间点推送给特定的客户群体。 传统的消息推送一般具有触达对象不精准、消息触发条件、消息触达内容不可灵 活配置、不支持实时客户事件触发消息、消息推送吞吐量小、消息推送支持人群小等特点。 触达对象不精准会给客户带来不必要的骚扰，影响消息推送的体验与效能，增加运营方的 运营成本。消息触发条件、消息触达内容不可灵活配置会影响消息推送的易用性与及时性， 增加消息推送运营者的工作难度和工作强度。消息推送不支持实时客户事件触发会影响消 息推送的时效性，降低消息推送的效能。消息推送吞吐量小，影响消息的推送及时性及消息 的可用种类和数目。消息推送支持人群小，影响消息的触达面和消息运营带来的收益。
技术实现要素：
本发明的目的是克服了上述现有技术的缺点，提供了一种满足时效性好、易用性 好、及时性好的实现自动化实时消息推送运营的系统及其方法。 为了实现上述目的，本发明的实现自动化实时消息推送运营的系统及其方法如 下： 该实现自动化实时消息推送运营的系统，其主要特点是，所述的系统包括： 客户数据采集模块，用于通过分布式定时任务调度采集、汇总、存储客户数据； 批量事件处理模块，用于接入行情变化事件和定时触发事件，并按配置事件条件 计算是否满足批量消息推送触发要求； 个人事件处理模块，用于接入个人操作事件，并按配置事件条件计算是否满足个 人消息推送触发要求； 批量推送计算模块，与客户数据采集模块和批量事件处理模块相连接，用于完成 人群交集计算、消息模板占位符替换、消息分页发送以及消息发送统计信息记录； 个人推送计算模块，与客户数据采集模块和个人事件处理模块相连接，用于完成 个人消息模板占位符替换、消息发送以及个人发送统计信息记录。 较佳地，所述的系统还包括消息推送运营管理模块，与批量事件处理模块、个人事 件处理模块、批量推送计算模块和个人推送计算模块相连接，用于设置、删除运营策略，激 活、失活运营策略所配置的事件处理计算及人群计算，并提供相应的统计信息查询功能。 较佳地，所述的系统还包括消息推送记录及日志管理模块，与批量事件处理模块、 个人事件处理模块、批量推送计算模块和个人推送计算模块相连接，用于查询事件的处理 4 CN 111552885 A 说　明　书 2/11 页 状态、消息的推送状态、消息的推送内容和时间。 较佳地，所述的客户数据采集模块包含多个数据采集方式，数据采集方式包含数 据文件导入和实时数据接入。 较佳地，所述的批量事件处理模块包含实时行情事件、定时触发事件的处理功能， 并支持使用布尔表达式灵活配置触发的条件。 较佳地，所述的个人事件处理模块包含客户个人实时事件的处理功能，并支持使 用布尔表达式灵活配置客户事件的触发条件。 较佳地，所述的个人推送计算模块包含推送消息内容可根据个人事件处理模块的 计算结果进行占位符替换、个人消息推送的统计信息计算记录功能。 较佳地，所述的个人事件处理模块采用消息队列接收各类型客户实时操作事件。 较佳地，所述的个人事件处理模块通过条件表达式计算引擎支持动态条件表达式 配置。 较佳地，所述的批量推送计算模块通过配置指明不同人群类型如何关联，使用分 布式并行计算数据库不同节点、不同分区下的数据，并采用分布式NoSQL数据库记录每个消 息配置的触发情况，进行次数控制和时间间隔控制。 该利用上述系统实现自动化实时消息推送运营控制的方法，其主要特点是，所述 的方法包括以下步骤： (1)客户数据采集模块通过分布式任务调度方式接收静态数据、消息队列实时数 据，并按固定散列规则将客户的相关数据散列到分布式关系型数据库的特定节点的特定分 区，并存储至特定的表中； (2)消息推送运营管理模块进行消息推送设置； (3)消息推送记录及日志管理模块接收上述消息设置实时触发效果并汇总统计提 供给消息推送记录及日志管理模块查询接口。 较佳地，所述的步骤(1)具体包括以下步骤： (1 .1)分布式批量处理通过SQL批量插入方式导入静态数据，同一批SQL插入数据 属于同一个数据库节点的同一数据分区； (1 .2)分布式批量流处理通过SQL批量插入方式导入实时数据，且同一批SQL插入 数据属于同一个数据库节点的同一数据分区； (1 .3)分布式关系型数据库采用开源分布式关系型数据库，不同类型的客户数据 采用不同的数据表进行存储，同个客户不同维度的数据存储在分布式关系型数据库的同一 个节点的同一个分区内。 较佳地，所述的步骤(2)进行消息推送设置包含进行批量人群事件消息推送设置 的步骤和进行个人事件消息推送设置的步骤，其中进行批量人群事件消息推送设置的步骤 包括以下处理过程： (1-2.1)选择触发消息的推送平台； (1-2.2)设置消息推送的格式、标题、摘要和内容，设置多套消息模板循环触发； (1-2.3)选择消息触达的人群选择及人群参数选择； (1-2.4)选择消息触发的条件，并填写条件参数，组成布尔条件表达式； (1-2.5)选择触发的日期类型、每次触发的次数、每次触发的时间间隔的事件限定 5 CN 111552885 A 说　明　书 3/11 页 参数。 较佳地，所述的步骤(2)进行消息推送设置包含进行批量人群事件消息推送设置 的步骤和进行个人事件消息推送设置的步骤，其中进行个人事件消息推送设置的步骤包括 以下处理过程： (2-2.1)选择触发消息的推送平台； (2-2.2)设置消息推送的格式、标题、摘要、内容，设置多套消息模板，循环触发； (2-2.3)选择消息触达的人群选择及人群参数选择，通过开源分布式缓存技术缓 存分布式关系型数据库中存储的客户信息； (2-2.4)选择消息触发的事件，设置事件下可选的触发条件，并组成布尔表达式； (2-2.5)选择触发的日期类型、每次触发的次数、每次触发的时间间隔的事件限定 参数。 采用了本发明的实现自动化实时消息推送运营的系统及其方法，满足生产环境下 面对大数据量级客户的触发事件条件、发送消息内容、发送目标人群都灵活可配置的要求， 并且生产环境下由于广泛采用了分布式技术，无瓶颈节点，满足高可用的前提下具备高吞 吐量、低时延特性。同时通过支持触发条件灵活可配、支持指定触发人群乃至不同人群关联 具备精准推送特性，克服了传统消息推送触达对象不精准、消息触发条件、消息触达内容不 可灵活配置、不支持实时客户事件触发消息、消息推送吞吐量小、消息推送支持人群小等缺 点，具备技术上的独创性。 附图说明 图1为本发明的实现自动化实时消息推送运营的系统的整体框架图。 图2为本发明的实现自动化实时消息推送运营控制的方法的实施例的高可用部署 示例方案图。 图3为本发明的实现自动化实时消息推送运营控制的方法的时序图。