一种消息幂等处理、生成和消费方法、装置和计算机设备

摘要

本文提供了一种消息幂等处理、生成和消费方法、装置和计算机设备，涉及大数据数据分析技术领域，其中消息幂等处理方法包括接收消费者对消息的消费请求；解析消费请求，获得消息的唯一标识符和业务版本号；根据唯一标识符，查询redis缓存中预先存储的与消息相对应的目标版本号；判断业务版本号与目标版本号是否一致；当一致时，确定消息为未消费并反馈给消费者，以使消费者获取消息的业务代码并消费消息；并将目标版本号由初值改为终值。本文利用消息的版本号来表征消息的消费状态，能够避免状态流转失败甚至状态逆流转的问题，从而避免了消息不幂等的情况；采用redis缓存能够在高并发场景下，降低系统I/O，提高系统吞吐量。