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