一种千万级用户消息快速推送方法、装置及设备与流程

1.本发明涉及数据推送技术领域，尤其涉及一种千万级用户消息快速推送方法、装置及设备。


背景技术：

2.常规的消息推送技术通常包括电子邮件推送、短信推送和应用程序推送这几种。电子邮件推送是一种基于互联网的传统消息推送技术，它可以向一个或多个收件人发送消息；短信推送是一种基于移动通信网络的消息推送技术，它可以向移动设备发送简短的文本消息；应用程序推送是一种基于移动应用程序的消息推送技术，它可以向用户的移动设备发送通知消息。
3.然而，上述几种推送技术存在以下几个缺点：（1）传输速度慢：传统的消息推送方式速度都比较慢，需要一定时间才能到达接收方；（2）无法精准定位目标用户：传统的消息推送方式无法精准定位到目标用户，只能采用全覆盖推送，费时费力；（3）灵活性差：传统的消息推送方式无法灵活地根据不同的需求和情况进行调整和优化，如消息推送形式都相同，无法给不同用户推送个性化消息。


技术实现要素：

4.本发明提供了一种千万级用户消息快速推送方法、装置及设备，解决了现有消息推送技术存在传输速度慢、无法精准定位目标用户及灵活性差的缺陷的技术问题。
5.本发明第一方面提供一种千万级用户消息快速推送方法，包括：获取目标推送任务对应的推送消息和用户属性关键词；根据所述用户属性关键词确定目标用户推送列表；所述目标用户推送列表包括至少一个用户的标识及对应的个性化消息通知格式；基于所述目标用户推送列表将所述推送消息转换为对应个性化消息通知格式的目标推送消息，并将所述目标推送消息存储至分布式消息队列；采用多节点并行推送方式，配合所述目标用户推送列表将每条所述目标推送消息推送至对应的用户。
6.根据本发明第一方面的一种能够实现的方式，所述根据所述用户属性关键词确定目标用户推送列表，包括：根据所述用户属性关键词从第一预置数据库中匹配相应的用户属性标签作为目标用户属性标签；所述第一预置数据库存储有用户属性关键词与用户属性标签的对应关系；根据所述目标用户属性标签从第二预置数据库中匹配相应的用户推送列表作为目标用户推送列表；所述第二预置数据库存储有用户属性标签与目标用户推送列表的对应
关系。
7.根据本发明第一方面的一种能够实现的方式，所述方法还包括：获取用户阅读消息的历史记录；根据所述历史记录确定对应用户的喜好矩阵；所述喜好矩阵内的值为用户对相应类消息的阅读次数；根据所述喜好矩阵计算相应用户对各类消息的喜好程度，筛选喜好程度大于预置喜好程度阈值的消息类型作为目标消息类型；根据所述目标消息类型确定对应用户所关联的用户属性标签；将关联同一用户属性标签的用户的相关信息归入同一列表，以生成相应的用户推送列表；所述相关信息包括用户的标识及个性化消息通知格式。
8.根据本发明第一方面的一种能够实现的方式，所述个性化消息通知格式包括消息推送模式，所述基于所述目标用户推送列表将所述推送消息转换为对应个性化消息通知格式的目标推送消息，包括：基于所述目标用户推送列表将所述推送消息转换为对应消息推送模式的目标推送消息；所述消息推送模式包括语音推送模式、动画推送模式和/或文字推送模式。
9.根据本发明第一方面的一种能够实现的方式，所述个性化消息通知格式包括消息发送位置，所述配合所述目标用户推送列表将每条所述目标推送消息推送至对应的用户，包括：配合所述目标用户推送列表，将所述目标推送消息推送至对应用户的相应消息发送位置。
10.根据本发明第一方面的一种能够实现的方式，在配合所述目标用户推送列表将每条所述目标推送消息推送至对应的用户之前，所述方法还包括：对各所述目标推送消息进行预处理；所述预处理包括：对各所述目标推送消息进行推送优先级配置，基于优先级队列模式对各所述目标推送消息进行处理；和/或，对各所述目标推送消息进行过滤操作。
11.根据本发明第一方面的一种能够实现的方式，所述个性化消息通知格式包括消息发送时间范围，所述目标用户推送列表还包括表中各用户的初始推送优先级，所述对各所述目标推送消息进行推送优先级配置，包括：根据所述消息发送时间范围对各所述目标推送消息进行分组，并对得到的目标推送消息分组按照从早到晚的顺序进行排序，得到第一排序结果；确定所述目标用户推送列表中的各用户在预置时间段内对目标已推送消息的累计阅读次数；所述目标已推送消息为与所述目标推送任务对应的推送消息所属消息类型相同的已推送信息；根据所述累计阅读次数和所述初始推送优先级计算相应用户的目标推送优先级；按照目标推送优先级由大到小的顺序对各所述目标推送消息分组内的各目标推送消息进行排序，得到第二排序结果；基于所述第一排序结果和所述第二排序结果确定各所述目标推送消息的排序优先级；以确定的排序优先级作为推送优先级对各所述目标推送消息进行推送优先级配
置。
12.本发明第二方面提供一种千万级用户消息快速推送装置，包括：第一获取模块，用于获取目标推送任务对应的推送消息和用户属性关键词；第一确定模块，用于根据所述用户属性关键词确定目标用户推送列表；所述目标用户推送列表包括至少一个用户的标识及对应的个性化消息通知格式；转换处理模块，用于基于所述目标用户推送列表将所述推送消息转换为对应个性化消息通知格式的目标推送消息，并将所述目标推送消息存储至分布式消息队列；推送模块，用于采用多节点并行推送方式，配合所述目标用户推送列表将每条所述目标推送消息推送至对应的用户。
13.根据本发明第二方面的一种能够实现的方式，所述确定模块包括：第一匹配单元，用于根据所述用户属性关键词从第一预置数据库中匹配相应的用户属性标签作为目标用户属性标签；所述第一预置数据库存储有用户属性关键词与用户属性标签的对应关系；第二匹配单元，用于根据所述目标用户属性标签从第二预置数据库中匹配相应的用户推送列表作为目标用户推送列表；所述第二预置数据库存储有用户属性标签与目标用户推送列表的对应关系。
14.根据本发明第二方面的一种能够实现的方式，所述装置还包括：第二获取模块，用于获取用户阅读消息的历史记录；第二确定模块，用于根据所述历史记录确定对应用户的喜好矩阵；所述喜好矩阵内的值为用户对相应类消息的阅读次数；筛选模块，用于根据所述喜好矩阵计算相应用户对各类消息的喜好程度，筛选喜好程度大于预置喜好程度阈值的消息类型作为目标消息类型；第三确定模块，用于根据所述目标消息类型确定对应用户所关联的用户属性标签；生成模块，用于将关联同一用户属性标签的用户的相关信息归入同一列表，以生成相应的用户推送列表；所述相关信息包括用户的标识及个性化消息通知格式。
15.根据本发明第二方面的一种能够实现的方式，所述个性化消息通知格式包括消息推送模式，所述转换处理模块包括：转换单元，用于基于所述目标用户推送列表将所述推送消息转换为对应消息推送模式的目标推送消息；所述消息推送模式包括语音推送模式、动画推送模式和/或文字推送模式。
16.根据本发明第二方面的一种能够实现的方式，所述个性化消息通知格式包括消息发送位置，所述推送模块包括：推送单元，用于配合所述目标用户推送列表，将所述目标推送消息推送至对应用户的相应消息发送位置。
17.根据本发明第二方面的一种能够实现的方式，在配合所述目标用户推送列表将每条所述目标推送消息推送至对应的用户之前，所述装置还包括：预处理模块，用于对各所述目标推送消息进行预处理；所述预处理包括：对各所述目标推送消息进行推送优先级配置，基于优先级队列模式对各所述目标推送消息进行处
理；和/或，对各所述目标推送消息进行过滤操作。
18.根据本发明第二方面的一种能够实现的方式，所述个性化消息通知格式包括消息发送时间范围，所述目标用户推送列表还包括表中各用户的初始推送优先级，所述预处理模块对各所述目标推送消息进行推送优先级配置时，具体用于：根据所述消息发送时间范围对各所述目标推送消息进行分组，并对得到的目标推送消息分组按照从早到晚的顺序进行排序，得到第一排序结果；确定所述目标用户推送列表中的各用户在预置时间段内对目标已推送消息的累计阅读次数；所述目标已推送消息为与所述目标推送任务对应的推送消息所属消息类型相同的已推送信息；根据所述累计阅读次数和所述初始推送优先级计算相应用户的目标推送优先级；按照目标推送优先级由大到小的顺序对各所述目标推送消息分组内的各目标推送消息进行排序，得到第二排序结果；基于所述第一排序结果和所述第二排序结果确定各所述目标推送消息的排序优先级；以确定的排序优先级作为推送优先级对各所述目标推送消息进行推送优先级配置。
19.本发明第三方面提供了一种千万级用户消息快速推送装置，包括：存储器，用于存储指令；其中，所述指令用于实现如上任意一项能够实现的方式所述的千万级用户消息快速推送方法；处理器，用于执行所述存储器中的指令。
20.本发明第四方面一种计算机可读存储介质，所述计算机可读存储介质上存储有计算机程序，所述计算机程序被处理器执行时实现如上任意一项能够实现的方式所述的千万级用户消息快速推送方法。
21.从以上技术方案可以看出，本发明具有以下优点：本发明获取目标推送任务对应的推送消息和用户属性关键词；根据所述用户属性关键词确定目标用户推送列表；所述目标用户推送列表包括至少一个用户的标识及对应的个性化消息通知格式；基于所述目标用户推送列表将所述推送消息转换为对应个性化消息通知格式的目标推送消息，并将所述目标推送消息存储至分布式消息队列；采用多节点并行推送方式，配合所述目标用户推送列表将每条所述目标推送消息推送至对应的用户；本发明基于目标用户推送列表进行消息推送，可以精准定位目标用户；本发明采用基于消息队列的异步推送方式，可以将消息发送到消息队列中后立即返回，多个推送节点并行消费和推送，大大提高了消息推送的传输速度；本发明可以将目标推送任务对应的推送消息转换为对应个性化消息通知格式的目标推送消息推送至对应的用户，有效提高了推送的灵活性。
附图说明
22.为了更清楚地说明本发明实施例或现有技术中的技术方案，下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以
根据这些附图获得其它的附图。
23.图1为本发明一个可选实施例提供的一种千万级用户消息快速推送方法的流程图；图2为本发明另一个可选实施例提供的一种千万级用户消息快速推送方法的流程图；图3为本发明又一个可选实施例提供的一种千万级用户消息快速推送方法的流程图；图4为本发明一个可选实施例提供的一种千万级用户消息快速推送装置的结构连接框图；图5为本发明另一个可选实施例提供的一种千万级用户消息快速推送装置的结构连接框图；图6为本发明又一个可选实施例提供的一种千万级用户消息快速推送装置的结构连接框图。
24.附图标记：1-第一获取模块；2-第一确定模块；3-转换处理模块；4-推送模块；5-第二获取模块；6-第二确定模块；7-筛选模块；8-第三确定模块；9-生成模块；10-预处理模块。
具体实施方式
25.本发明实施例提供了一种千万级用户消息快速推送方法、装置及设备，用于解决现有消息推送技术存在传输速度慢、无法精准定位目标用户及灵活性差的缺陷的技术问题。
26.为使得本发明的发明目的、特征、优点能够更加的明显和易懂，下面将结合本发明实施例中的附图，对本发明实施例中的技术方案进行清楚、完整地描述，显然，下面所描述的实施例仅仅是本发明一部分实施例，而非全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其它实施例，都属于本发明保护的范围。
27.本发明提供了一种千万级用户消息快速推送方法。
28.请参阅图1，图1示出了本发明实施例提供的一种千万级用户消息快速推送方法的流程图。
29.本发明实施例提供的一种千万级用户消息快速推送方法，包括步骤s1-s4。
30.步骤s1，获取目标推送任务对应的推送消息和用户属性关键词。
31.其中，用户属性关键词用于表征所需推送用户的基本特征，例如年龄范围、性别、电话号码归属地、推送消息需求等。
32.在一种能够实现的方式中，目标推送任务和用户属性关键词可以由消息发布者进行指定，进而基于目标推送任务确定需要推送的消息。
33.作为一种实施方式，可以根据实际业务案例训练生成消息生成器/模型，通过消息生成器/模型基于目标推送任务得到需要推送的消息。具体的训练方法可以参照现有技术，本实施例中，对此不做限定。
34.作为另一种实施方式，可以设置存储有目标推送任务和需要推送的消息的对应关
系的列表，进而通过匹配的方式实现目标推送任务对应的推送消息的获取。
35.在其他能够实现的方式中，目标推送任务对应的推送消息和用户属性关键词可以由消息发布者直接进行指定。
36.步骤s2，根据所述用户属性关键词确定目标用户推送列表；所述目标用户推送列表包括至少一个用户的标识及对应的个性化消息通知格式。
37.其中，个性化消息通知格式可以由消息接收者根据自己的需求进行指定，进而由消息发布者进行采集得到。
38.在一种能够实现的方式中，所述根据所述用户属性关键词确定目标用户推送列表，包括：根据所述用户属性关键词从第一预置数据库中匹配相应的用户属性标签作为目标用户属性标签；所述第一预置数据库存储有用户属性关键词与用户属性标签的对应关系；根据所述目标用户属性标签从第二预置数据库中匹配相应的用户推送列表作为目标用户推送列表；所述第二预置数据库存储有用户属性标签与目标用户推送列表的对应关系。
39.本发明上述实施例，通过列表分级匹配的方式确定目标用户推送列表，方法简单便捷。
40.在其他能够实现的方式中，可以基于训练好的用户推送列表生成模型，以用户属性关键词作为输入，输出目标用户推送列表。
41.需要说明的是，用户推送列表生成模型的具体训练方法可以参照现有技术，本实施例中，对此不做限定。
42.在一种能够实现的方式中，在图1所示方法的基础上，如图2所示，所述方法还包括：步骤s10，获取用户阅读消息的历史记录；步骤s20，根据所述历史记录确定对应用户的喜好矩阵；所述喜好矩阵内的值为用户对相应类消息的阅读次数；步骤s30，根据所述喜好矩阵计算相应用户对各类消息的喜好程度，筛选喜好程度大于预置喜好程度阈值的消息类型作为目标消息类型；步骤s40，根据所述目标消息类型确定对应用户所关联的用户属性标签；步骤s50，将关联同一用户属性标签的用户的相关信息归入同一列表，以生成相应的用户推送列表；所述相关信息包括用户的标识及个性化消息通知格式。
43.作为一种实施方式，根据所述喜好矩阵计算相应用户对各类消息的喜好程度时，可以按照下式进行计算：，式中，表示相应用户对类消息的喜好程度，表示相应用户对类消息的阅读次数，表示消息类型的数量。
44.本发明实施例中，用户属性标签表征了用户的消息推送需求/兴趣，从而可以根据历史数据确定用户的喜好程度大于预置喜好程度阈值的消息类型作为目标消息类型，从而
根据目标消息类型确定用户属性标签。
45.本发明上述实施例中，可以实现用户推送列表数据的生成，从而为第二预置数据库提供所存储的数据，从而便于根据所述目标用户属性标签从第二预置数据库中匹配相应的用户推送列表作为目标用户推送列表。
46.步骤s3，基于所述目标用户推送列表将所述推送消息转换为对应个性化消息通知格式的目标推送消息，并将所述目标推送消息存储至分布式消息队列。
47.消息队列，用来保存消息直到发送给消费者。它是消息的容器，也是消息的终点。一个消息可投入一个或多个队列。消息一直在队列里面，等待消费者连接到这个队列将其取走。分布式消息队列可以视为将这种数据结构部署到独立的服务器上，通过远程访问接口使用分布式消息队列，进行消息存储操作，进而实现分布式的异步调用。当消息到达消息队列，消费者就可以从消息队列中取出消息，消费者跟消息队列建立起连接，为了节省资源，在每一条tcp连接开辟多个信道，数据通过信道传输给消费者。
48.本发明实施例中，将所述推送消息转换为对应个性化消息通知格式的目标推送消息，实现了推送消息的个性化设置，有效提高了消息推送的灵活性；采用基于消息队列的异步推送方式，可以将消息发送到消息队列中后立即返回，多个推送节点并行消费和推送，大大提高了消息推送的效率和速度。
49.在一种能够实现的方式中，所述个性化消息通知格式包括消息推送模式，所述基于所述目标用户推送列表将所述推送消息转换为对应个性化消息通知格式的目标推送消息，包括：基于所述目标用户推送列表将所述推送消息转换为对应消息推送模式的目标推送消息；所述消息推送模式包括语音推送模式、动画推送模式和/或文字推送模式。
50.本发明实施例中，实现了消息推送模式的个性化，能够增强用户体验，提高消息推送的灵活性。
51.需要说明的是，具体将消息的原格式转换为对应消息推送模式的方法可以参照现有技术，本实施例中，对此不做限定。
52.步骤s4，采用多节点并行推送方式，配合所述目标用户推送列表将每条所述目标推送消息推送至对应的用户。
53.本发明实施例中，采用多节点并行推送，可以提高推送效率和并发能力。
54.需要说明的是，具体的多节点并行推送过程属于现有技术，本实施例中，对此不做限定。
55.在一种能够实现的方式中，所述个性化消息通知格式包括消息发送位置，所述配合所述目标用户推送列表将每条所述目标推送消息推送至对应的用户，包括：配合所述目标用户推送列表，将所述目标推送消息推送至对应用户的相应消息发送位置。
56.本发明实施例中，实现了消息发送位置的个性化设置，有效提高了消息推送的灵活性。
57.在一种能够实现的方式中，在图2所示方法的基础上，如图3所示，在配合所述目标用户推送列表将每条所述目标推送消息推送至对应的用户之前，所述方法还包括：步骤s100，对各所述目标推送消息进行预处理；所述预处理包括：对各所述目标推
送消息进行推送优先级配置，基于优先级队列模式对各所述目标推送消息进行处理；和/或，对各所述目标推送消息进行过滤操作。
58.优先级队列模式提供了一种确保特定消息先于其他消息传递的机制，本发明实施例中，对各所述目标推送消息进行推送优先级配置，基于优先级队列模式对各所述目标推送消息进行处理，可以实现根据不同的业务需求和场景灵活配置消息推送策略，提高消息推送的灵活性。
59.对消息的过滤操作可以提高消息推送的稳定性和可靠性。对消息的过滤操作可以例如是，对重复消息进行删除，将格式错误的消息或需要访问不可用资源任务的消息删除等。
60.在一种能够实现的方式中，所述个性化消息通知格式包括消息发送时间范围，所述目标用户推送列表还包括表中各用户的初始推送优先级，所述对各所述目标推送消息进行推送优先级配置，包括：根据所述消息发送时间范围对各所述目标推送消息进行分组，并对得到的目标推送消息分组按照从早到晚的顺序进行排序，得到第一排序结果；确定所述目标用户推送列表中的各用户在预置时间段内对目标已推送消息的累计阅读次数；所述目标已推送消息为与所述目标推送任务对应的推送消息所属消息类型相同的已推送信息；根据所述累计阅读次数和所述初始推送优先级计算相应用户的目标推送优先级；按照目标推送优先级由大到小的顺序对各所述目标推送消息分组内的各目标推送消息进行排序，得到第二排序结果；基于所述第一排序结果和所述第二排序结果确定各所述目标推送消息的排序优先级；以确定的排序优先级作为推送优先级对各所述目标推送消息进行推送优先级配置。
61.作为一种实施方式，根据所述累计阅读次数和所述初始推送优先级计算相应用户的目标推送优先级，包括：根据累计阅读次数从预置优先级列表中匹配相应的推送优先级；所述预置优先级列表存储有累计阅读次数范围与推送优先级的对应关系；根据确定的推送优先级和所述初始推送优先级计算相应用户的目标推送优先级。
62.其中，可以根据实际情况设置根据确定的推送优先级和所述初始推送优先级计算相应用户的目标推送优先级的计算规则。例如，可以以确定的推送优先级和所述初始推送优先级的均值作为相应用户的目标推送优先级。
63.作为另一种实施方式，根据所述累计阅读次数和所述初始推送优先级计算相应用户的目标推送优先级，包括：根据所述累计阅读次数所属的累计阅读次数范围确定推送优先级的增加值；计算所确定的增加值和初始推送优先级的和作为目标推送优先级。
64.其中，根据所述累计阅读次数所属的累计阅读次数范围确定推送优先级的增加值的确定规则可以根据实际情况进行设置。
65.作为又一种实施方式，根据所述累计阅读次数和所述初始推送优先级计算相应用
户的目标推送优先级，包括：当累计阅读次数低于预置的次数阈值时，将初始推送优先级减1得到目标推送优先级；当累计阅读次数不低于预置的次数阈值时，将初始推送优先级作为目标推送优先级。
66.本发明上述实施例中，根据上述实施方式对各所述目标推送消息进行推送优先级配置，能够使得消息推送能够在满足用户需求的同时提高推送信息被阅读的概率，从而提高消息推送的灵活性和成功率。
67.本发明还提供了一种千万级用户消息快速推送装置，该装置可用于执行本发明上述任一项实施例所述的千万级用户消息快速推送方法。
68.请参阅图4，图4示出了本发明实施例提供的一种千万级用户消息快速推送装置的结构连接框图。
69.本发明实施例提供的一种千万级用户消息快速推送装置，包括：第一获取模块1，用于获取目标推送任务对应的推送消息和用户属性关键词；第一确定模块2，用于根据所述用户属性关键词确定目标用户推送列表；所述目标用户推送列表包括至少一个用户的标识及对应的个性化消息通知格式；转换处理模块3，用于基于所述目标用户推送列表将所述推送消息转换为对应个性化消息通知格式的目标推送消息，并将所述目标推送消息存储至分布式消息队列；推送模块4，用于采用多节点并行推送方式，配合所述目标用户推送列表将每条所述目标推送消息推送至对应的用户。
70.在一种能够实现的方式中，所述确定模块包括：第一匹配单元，用于根据所述用户属性关键词从第一预置数据库中匹配相应的用户属性标签作为目标用户属性标签；所述第一预置数据库存储有用户属性关键词与用户属性标签的对应关系；第二匹配单元，用于根据所述目标用户属性标签从第二预置数据库中匹配相应的用户推送列表作为目标用户推送列表；所述第二预置数据库存储有用户属性标签与目标用户推送列表的对应关系。
71.在一种能够实现的方式中，在图4所示装置的基础上，如图5所示，所述装置还包括：第二获取模块5，用于获取用户阅读消息的历史记录；第二确定模块6，用于根据所述历史记录确定对应用户的喜好矩阵；所述喜好矩阵内的值为用户对相应类消息的阅读次数；筛选模块7，用于根据所述喜好矩阵计算相应用户对各类消息的喜好程度，筛选喜好程度大于预置喜好程度阈值的消息类型作为目标消息类型；第三确定模块8，用于根据所述目标消息类型确定对应用户所关联的用户属性标签；生成模块9，用于将关联同一用户属性标签的用户的相关信息归入同一列表，以生成相应的用户推送列表；所述相关信息包括用户的标识及个性化消息通知格式。
72.在一种能够实现的方式中，所述个性化消息通知格式包括消息推送模式，所述转
换处理模块3包括：转换单元，用于基于所述目标用户推送列表将所述推送消息转换为对应消息推送模式的目标推送消息；所述消息推送模式包括语音推送模式、动画推送模式和/或文字推送模式。
73.在一种能够实现的方式中，所述个性化消息通知格式包括消息发送位置，所述推送模块4包括：推送单元，用于配合所述目标用户推送列表，将所述目标推送消息推送至对应用户的相应消息发送位置。
74.在一种能够实现的方式中，在图5所示装置的基础上，如图6所示，在配合所述目标用户推送列表将每条所述目标推送消息推送至对应的用户之前，所述装置还包括：预处理模块10，用于对各所述目标推送消息进行预处理；所述预处理包括：对各所述目标推送消息进行推送优先级配置，基于优先级队列模式对各所述目标推送消息进行处理；和/或，对各所述目标推送消息进行过滤操作。
75.在一种能够实现的方式中，所述个性化消息通知格式包括消息发送时间范围，所述目标用户推送列表还包括表中各用户的初始推送优先级，所述预处理模块10对各所述目标推送消息进行推送优先级配置时，具体用于：根据所述消息发送时间范围对各所述目标推送消息进行分组，并对得到的目标推送消息分组按照从早到晚的顺序进行排序，得到第一排序结果；确定所述目标用户推送列表中的各用户在预置时间段内对目标已推送消息的累计阅读次数；所述目标已推送消息为与所述目标推送任务对应的推送消息所属消息类型相同的已推送信息；根据所述累计阅读次数和所述初始推送优先级计算相应用户的目标推送优先级；按照目标推送优先级由大到小的顺序对各所述目标推送消息分组内的各目标推送消息进行排序，得到第二排序结果；基于所述第一排序结果和所述第二排序结果确定各所述目标推送消息的排序优先级；以确定的排序优先级作为推送优先级对各所述目标推送消息进行推送优先级配置。
76.本发明还提供了一种千万级用户消息快速推送设备，包括：存储器，用于存储指令；其中，所述指令用于实现如上任意一项实施例所述的千万级用户消息快速推送方法；处理器，用于执行所述存储器中的指令。
77.本发明还提供了一种计算机可读存储介质，所述计算机可读存储介质上存储有计算机程序，所述计算机程序被处理器执行时实现如上任意一项实施例所述的千万级用户消息快速推送方法。
78.所属领域的技术人员可以清楚地了解到，为描述的方便和简洁，上述描述的装置、设备、模块和单元的具体工作过程，可以参考前述方法实施例中的对应过程，上述描述的装置、设备、模块和单元的具体有益效果，可以参考前述方法实施例中的对应有益效果，在此不再赘述。
79.在本技术所提供的几个实施例中，应该理解到，所揭露的装置、设备和方法，可以通过其它的方式实现。例如，以上所描述的装置实施例仅仅是示意性的，例如，所述模块的划分，仅仅为一种逻辑功能划分，实际实现时可以有另外的划分方式，例如多个模块或组件可以结合或者可以集成到另一个装置，或一些特征可以忽略，或不执行。另一点，所显示或讨论的相互之间的耦合或直接耦合或通信连接可以是通过一些接口，装置或模块的间接耦合或通信连接，可以是电性，机械或其它的形式。
80.所述作为分离部件说明的模块可以是或者也可以不是物理上分开的，作为模块显示的部件可以是或者也可以不是物理模块，即可以位于一个地方，或者也可以分布到多个网络模块上。可以根据实际的需要选择其中的部分或者全部模块来实现本实施例方案的目的。
81.另外，在本发明各个实施例中的各功能模块可以集成在一个处理模块中，也可以是各个模块单独物理存在，也可以两个或两个以上模块集成在一个模块中。上述集成的模块既可以采用硬件的形式实现，也可以采用软件功能模块的形式实现。
82.所述集成的模块如果以软件功能模块的形式实现并作为独立的产品销售或使用时，可以存储在一个计算机可读取存储介质中。基于这样的理解，本发明的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的全部或部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质中，包括若干指令用以使得一台计算机设备（可以是个人计算机，服务器，或者网络设备等）执行本发明各个实施例所述方法的全部或部分步骤。而前述的存储介质包括：u盘、移动硬盘、只读存储器（rom，read-only memory）、随机存取存储器（ram，random access memory）、磁碟或者光盘等各种可以存储程序代码的介质。
83.以上所述，以上实施例仅用以说明本发明的技术方案，而非对其限制；尽管参照前述实施例对本发明进行了详细的说明，本领域的普通技术人员应当理解：其依然可以对前述各实施例所记载的技术方案进行修改，或者对其中部分技术特征进行等同替换；而这些修改或者替换，并不使相应技术方案的本质脱离本发明各实施例技术方案的精神和范围。

技术特征：
1.一种千万级用户消息快速推送方法，其特征在于，包括：获取目标推送任务对应的推送消息和用户属性关键词；根据所述用户属性关键词确定目标用户推送列表；所述目标用户推送列表包括至少一个用户的标识及对应的个性化消息通知格式；基于所述目标用户推送列表将所述推送消息转换为对应个性化消息通知格式的目标推送消息，并将所述目标推送消息存储至分布式消息队列；采用多节点并行推送方式，配合所述目标用户推送列表将每条所述目标推送消息推送至对应的用户。2.根据权利要求1所述的千万级用户消息快速推送方法，其特征在于，所述根据所述用户属性关键词确定目标用户推送列表，包括：根据所述用户属性关键词从第一预置数据库中匹配相应的用户属性标签作为目标用户属性标签；所述第一预置数据库存储有用户属性关键词与用户属性标签的对应关系；根据所述目标用户属性标签从第二预置数据库中匹配相应的用户推送列表作为目标用户推送列表；所述第二预置数据库存储有用户属性标签与目标用户推送列表的对应关系。3.根据权利要求2所述的千万级用户消息快速推送方法，其特征在于，所述方法还包括：获取用户阅读消息的历史记录；根据所述历史记录确定对应用户的喜好矩阵；所述喜好矩阵内的值为用户对相应类消息的阅读次数；根据所述喜好矩阵计算相应用户对各类消息的喜好程度，筛选喜好程度大于预置喜好程度阈值的消息类型作为目标消息类型；根据所述目标消息类型确定对应用户所关联的用户属性标签；将关联同一用户属性标签的用户的相关信息归入同一列表，以生成相应的用户推送列表；所述相关信息包括用户的标识及个性化消息通知格式。4.根据权利要求1所述的千万级用户消息快速推送方法，其特征在于，所述个性化消息通知格式包括消息推送模式，所述基于所述目标用户推送列表将所述推送消息转换为对应个性化消息通知格式的目标推送消息，包括：基于所述目标用户推送列表将所述推送消息转换为对应消息推送模式的目标推送消息；所述消息推送模式包括语音推送模式、动画推送模式和/或文字推送模式。5.根据权利要求1所述的千万级用户消息快速推送方法，其特征在于，所述个性化消息通知格式包括消息发送位置，所述配合所述目标用户推送列表将每条所述目标推送消息推送至对应的用户，包括：配合所述目标用户推送列表，将所述目标推送消息推送至对应用户的相应消息发送位置。6.根据权利要求1所述的千万级用户消息快速推送方法，其特征在于，在配合所述目标用户推送列表将每条所述目标推送消息推送至对应的用户之前，所述方法还包括：对各所述目标推送消息进行预处理；所述预处理包括：对各所述目标推送消息进行推送优先级配置，基于优先级队列模式对各所述目标推送消息进行处理；和/或，对各所述目
标推送消息进行过滤操作。7.根据权利要求6所述的千万级用户消息快速推送方法，其特征在于，所述个性化消息通知格式包括消息发送时间范围，所述目标用户推送列表还包括表中各用户的初始推送优先级，所述对各所述目标推送消息进行推送优先级配置，包括：根据所述消息发送时间范围对各所述目标推送消息进行分组，并对得到的目标推送消息分组按照从早到晚的顺序进行排序，得到第一排序结果；确定所述目标用户推送列表中的各用户在预置时间段内对目标已推送消息的累计阅读次数；所述目标已推送消息为与所述目标推送任务对应的推送消息所属消息类型相同的已推送信息；根据所述累计阅读次数和所述初始推送优先级计算相应用户的目标推送优先级；按照目标推送优先级由大到小的顺序对各所述目标推送消息分组内的各目标推送消息进行排序，得到第二排序结果；基于所述第一排序结果和所述第二排序结果确定各所述目标推送消息的排序优先级；以确定的排序优先级作为推送优先级对各所述目标推送消息进行推送优先级配置。8.一种千万级用户消息快速推送装置，其特征在于，包括：第一获取模块，用于获取目标推送任务对应的推送消息和用户属性关键词；第一确定模块，用于根据所述用户属性关键词确定目标用户推送列表；所述目标用户推送列表包括至少一个用户的标识及对应的个性化消息通知格式；转换处理模块，用于基于所述目标用户推送列表将所述推送消息转换为对应个性化消息通知格式的目标推送消息，并将所述目标推送消息存储至分布式消息队列；推送模块，用于采用多节点并行推送方式，配合所述目标用户推送列表将每条所述目标推送消息推送至对应的用户。9.一种千万级用户消息快速推送设备，其特征在于，包括：存储器，用于存储指令；其中，所述指令用于实现如权利要求1-7任意一项所述的千万级用户消息快速推送方法；处理器，用于执行所述存储器中的指令。10.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质上存储有计算机程序，所述计算机程序被处理器执行时实现如权利要求1-7任意一项所述的千万级用户消息快速推送方法。

技术总结
本发明涉及数据推送技术领域，公开了一种千万级用户消息快速推送方法、装置及设备。本发明获取目标推送任务对应的推送消息和用户属性关键词；根据用户属性关键词确定目标用户推送列表；所述目标用户推送列表包括至少一个用户的标识及对应的个性化消息通知格式；基于目标用户推送列表将所述推送消息转换为对应个性化消息通知格式的目标推送消息，并将目标推送消息存储至分布式消息队列；采用多节点并行推送方式，配合目标用户推送列表将每条目标推送消息推送至对应的用户。本发明可以精准定位目标用户，有效提高消息推送的传输速度和灵活性。活性。活性。


技术研发人员：徐宝祥 许海青 王浈广
受保护的技术使用者：苏州盈天地资讯科技有限公司
技术研发日：2023.08.30
技术公布日：2023/10/8