基于分布式发布订阅消息系统的数据处理方法及装置

摘要

本发明公开一种基于分布式发布订阅消息系统的数据处理方法及装置，所述数据处理方法包括如下步骤：接收到消费信息获取请求时，控制消费线程从分布式发布订阅消息系统中拉取消费信息，并将拉取到的消费信息发送至处理线程进行处理；当拉取到的消费信息的数量大于或等于预设的数量时，将消费线程挂起；当到达分布式发布订阅消息系统的最大心跳间隔时间时，向分布式发布订阅消息系统发送心跳包。本发明的技术方案，有效避免了由于分布式发布订阅消息系统进行自我重新判定而导致的线程退出与程序停止的技术问题。