一种基于Redis的轻量级消息队列处理方法及装置.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113918364A(43)申请公布日2022.01.11(21)申请号202111193293.6(22)申请日2021.10.13(71)申请人上海中通吉网络技术有限公司地址201799上海市青浦区华志路1685号5幢(72)发明人林毕成(74)专利代理机构北京细软智谷知识产权代理有限责任公司11471代理人涂凤琴(51)Int.Cl.G06F9/54(2006.01)权利要求书1页说明书9页附图3页(54)发明名称一种基于Redis的轻量级消息队列处理方法及装置(57)摘要本申属于计算机技术领域。具体涉及一种基于Redis的轻量级消息队列处理方法、装置及计算机，包括：接收生产者发送的待处理的消息队列数据，待处理的消息队列数据包括ID号；将待处理的消息队列数据按照时间顺序以及预设存储格式存储在目标存储区及备份存储区；根据ID号，判断待处理的消息队列数据ID号与已处理的消息队列数据ID号是否相同，得到判断结果；若判断结果为待处理的消息队列数据ID号与已处理的消息数ID号不同，则从消息队列中读取生产者写入的消息队列数据，将待处理的消息发送给消费者；若判断结果为待处理的消息队列数据ID号与已处理的消息队列数据ID号是相同，则放弃读取消息队列数据。避免了重复消息的处理并保证了消息的可靠性。CN113918364ACN113918364A权利要求书1/1页1.一种基于Redis的轻量级消息队列处理方法，其特征在于，所述方法包括：接收生产者发送的待处理的消息队列数据，所述待处理的消息队列数据包括ID号；将所述待处理的消息队列数据按照时间顺序以及预设存储格式存储在目标存储区及备份存储区；根据所述ID号，判断所述待处理的消息队列数据ID号与已处理的消息队列数据ID号是否相同，得到判断结果；若所述判断结果为所述待处理的消息队列数据ID号与已处理的消息数ID号不同，则从消息队列中读取所述生产者写入的消息队列数据，将所述待处理的消息发送给消费者；若所述判断结果为所述待处理的消息队列数据ID号与已处理的消息队列数据ID号是相同，则放弃读取所述消息队列数据。2.根据权利要求1所述的方法，其特征在于，所述接收生产者发送的待处理的消息队列数据，所述待处理的消息队列数据包括ID号，包括：按照时间顺序接收生产者发送的待处理的消息队列数据，所述待处理的消息队列数据包括ID号。3.根据权利要求1所述的方法，其特征在于，所述待处理的消息队列数据包括ID号为所述待处理的消息队列数据包括全局唯一ID号。4.根据权利要求1所述的方法，其特征在于，将所述待处理的消息队列数据按照时间顺序以及JSON文件格式存储在目标存储区及备份存储区。5.根据权利要求1所述的方法，其特征在于，还包括：当未在所述目标存储区读取到所述待处理的消息队列数据时，则从所述备份存储区读取所述待处理消息队列数据。6.一种基于Redis的轻量级消息队列处理装置，其特征在于，所述装置包括：接收模块，用于接收生产者发送的待处理的消息队列数据，所述待处理的消息队列数据包括ID号；存储模块，用于将所述待处理的消息队列数据按照时间顺序以及预设存储格式存储在目标存储区；判断模块，用于根据所述ID号，判断所述待处理的消息队列数据ID号与已处理的消息队列数据ID号是否相同，得到判断结果；处理模块，用于若所述判断结果为所述待处理的消息队列数据ID号与已处理的消息数ID号不同，则从消息队列中读取所述生产者写入的消息队列数据；放弃处理模块，用于若所述判断结果为所述待处理的消息队列数据ID号与已处理的消息队列数据ID号是相同，则放弃读取所述消息队列数据。7.一种计算机，其特征在于，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，其特征在于，所述处理器执行所述计算机程序时实现权利要求1至5任一项所述的方法。2CN113918364A说明书1/9页一种基于Redis的轻量级消息队列处理方法及装置技术领域[0001]本申请属于计算机技术领域，具体涉及一种基于Redis的轻量级消息队列处理方法及装置。背景技术[0002]我们在处理消息队列在存取消息时，需要满足以下三个需求，分别是消息保序、处理重复的消息和保证消息可靠性。虽然消费者是异步处理消息，但是，消费者仍然需要按照生产者发送消息的顺序来处理消息，避免后发送的消息被先处理了。对于要求消息保序的场景来说，一旦出现这种消息被乱序处理的情况，就可能会导致业务逻辑被错误执行，从而给业务方造成损失。消费者从消息队列读取消息时，有时会因为网络堵塞而出现消息重传的情况。此时，消费者可能会收到多条重复的消息。对于重复的消息，消费者如果多次处理的话，就可能造成一个业务逻辑被多次执行，如果业务逻辑正好是要修