消息处理方法、服务器、终端、系统及存储介质

授权

摘要

本发明实施例公开了一种消息处理方法，应用于通信技术领域，包括：服务器接收第一客户端发送的全量消息，将全量消息写入总Kafka集群，按照主题分类，将总Kafka集群中的全量消息分别写入各子Kafka集群，得到按不同主题分类的各子Kafka集群，以使获取到第二客户端发送的数据获取请求时，读取与该数据获取请求对应的子Kafka集群中的用户行为数据，并发送该用户行为数据至第二客户端。本发明实施例还公开了一种消息处理方法、服务器、终端、系统及存储介质，通过将消息分别写入各子Kafka集群，读取消息时，从相应的子Kafka集群中进行读取，使总Kafka集群只负责消息的写入，在不丢失数据时效性同时，减缓总Kafka集群压力。

基本信息

专利标题：

消息处理方法、服务器、终端、系统及存储介质

专利标题（英）：

暂无

公开（公告）号：

CN110875885A

申请号：

CN201811016853.9

公开（公告）日：

2020-03-10

申请日：

2018-08-31

授权号：

CN110875885B

授权日：

2022-04-12

发明人：

肖源

申请人：

武汉斗鱼网络科技有限公司

申请人地址：

湖北省武汉市武汉东湖开发区软件园东路1号软件产业4.1期B1栋11楼

代理机构：

中科专利商标代理有限责任公司

代理人：

周天宇

优先权：

CN201811016853.9

主分类号：

H04L12/803

IPC分类号：

H04L12/803 H04L12/815 H04L12/851 H04L29/08