利索能及
我要发布
收藏
专利号: 2018110168539
申请人: 武汉斗鱼网络科技有限公司
专利类型:发明专利
专利状态:已下证
更新日期:2025-05-17
缴费截止日期: 暂无
联系人

摘要:

权利要求书:

1.一种消息处理方法,应用于服务器,其特征在于,所述方法包括:接收第一客户端发送的全量消息,所述全量消息包括所述第一客户端中的至少一种用户行为数据;

将所述全量消息写入总Kafka集群,所述总Kafka集群包括至少一个子Kafka集群;

对所述全量消息中的至少一种用户行为数据进行主题分类,以将不同主题的用户行为数据写入不同的子Kafka集群;

获取第二客户端发送的数据获取请求,读取与所述数据获取请求对应的子Kafka集群中的用户行为数据,并发送所述用户行为数据至所述第二客户端。

2.根据权利要求1所述的方法,其特征在于,若所述主题还包括二级主题,则所述对所述全量消息中的至少一种用户行为数据进行主题分类,以将不同主题的用户行为数据写入不同的子Kafka集群之后,还包括:按照所述二级主题分类,将按所述主题分类的子Kafka集群中的消息分别写入各二级子Kafka集群,得到所述主题分类下的按所述二级主题分类的各二级子Kafka集群。

3.一种消息处理方法,应用于第一客户端,其特征在于,所述方法包括:发送全量消息给服务器,以使所述服务器将所述全量消息写入总Kafka集群,并对所述全量消息中的至少一种用户行为数据进行主题分类,以将不同主题的用户行为数据写入不同的子Kafka集群,获取第二客户端发送的数据获取请求,读取与所述数据获取请求对应的子Kafka集群中的用户行为数据,并发送所述用户行为数据至所述第二客户端,所述全量消息包括第一客户端中的至少一种用户行为数据,所述总Kafka集群包括至少一个子Kafka集群。

4.一种消息处理方法,应用于第二客户端,其特征在于,所述方法包括:发送数据获取请求给服务器,以使所述服务器读取与所述数据获取请求对应的子Kafka集群中的用户行为数据,并发送所述用户行为数据至第二客户端,其中,所述服务器接收第一客户端发送的全量消息,将所述全量消息写入总Kafka集群,并对所述全量消息中的至少一种用户行为数据进行主题分类,以将不同主题的用户行为数据写入不同的子Kafka集群,所述全量消息包括所述第一客户端中的至少一种用户行为数据,所述总Kafka集群包括至少一个子Kafka集群。

5.根据权利要求4所述的方法,其特征在于,若所述主题还包括二级主题,则所述对所述全量消息中的至少一种用户行为数据进行主题分类,以将不同主题的用户行为数据写入不同的子Kafka集群之后,还包括:按照所述二级主题分类,将按所述主题分类的子Kafka集群中的消息分别写入各二级子Kafka集群,得到所述主题分类下的按所述二级主题分类的各二级子Kafka集群。

6.一种服务器,其特征在于,包括:接收模块,用于接收第一客户端发送的全量消息,所述全量消息包括所述第一客户端中的至少一种用户行为数据;

写入模块,用于将所述全量消息写入总Kafka集群,所述总Kafka集群包括至少一个子Kafka集群;

分类模块,用于对所述全量消息中的至少一种用户行为数据进行主题分类,以将不同主题的用户行为数据写入不同的子Kafka集群;

获取模块,用于获取第二客户端发送的数据获取请求;

读取模块,用于与所述数据获取请求对应的子Kafka集群中的用户行为数据;

发送模块,用于发送所述用户行为数据至所述第二客户端。

7.一种第一终端,其特征在于,包括:发送模块,用于通过内置的客户端发送全量消息给服务器,以使所述服务器将所述全量消息写入总Kafka集群,并对所述全量消息中的至少一种用户行为数据进行主题分类,以将不同主题的用户行为数据写入不同的子Kafka集群,获取第二客户端发送的数据获取请求,读取与所述数据获取请求对应的子Kafka集群中的用户行为数据,并发送所述用户行为数据至所述第二客户端,所述全量消息包括第一客户端中的至少一种用户行为数据,所述总Kafka集群包括至少一个子Kafka集群。

8.一种第二终端,其特征在于,包括:发送模块,用于通过内置的客户端发送数据获取请求给服务器,以使所述服务器读取与所述数据获取请求对应的子Kafka集群中的用户行为数据,并发送所述用户行为数据至第二客户端,其中,所述服务器接收第一客户端发送的全量消息,将所述全量消息写入总Kafka集群,并对所述全量消息中的至少一种用户行为数据进行主题分类,以将不同主题的用户行为数据写入不同的子Kafka集群,所述全量消息包括所述第一客户端中的至少一种用户行为数据,所述总Kafka集群包括至少一个子Kafka集群。

9.一种消息处理系统,其特征在于,所述系统包括根据权利要求 6所述的服务器、根据权利要求 7所述的第一终端和根据权利要求 8所述的第二终端。

10.一种计算机可读存储介质,其上存储有计算机程序,其特征在于,所述计算机程序被处理器执行时实现权利要求1或2任一项所述的消息处理方法。