一种消息处理方法和装置.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN111510469A(43)申请公布日2020.08.07(21)申请号201910098148.6(22)申请日2019.01.31(71)申请人上海哔哩哔哩科技有限公司地址200092上海市杨浦区四平路1945号1641室(72)发明人刘国栋邱亮曹铮铮(74)专利代理机构上海百一领御专利代理事务所(普通合伙)31243代理人王奎宇(51)Int.Cl.H04L29/08(2006.01)H04L12/875(2013.01)权利要求书1页说明书7页附图3页(54)发明名称一种消息处理方法和装置(57)摘要本发明公开了一种消息处理方法和装置，该消息处理方法，包括：接收消息投放请求后，将接收到的消息存储至消息存储集群；轮询消息存储集群中已过期消息，按照约定策略进行消息的处理投递；消息投递后接受方未按照约定答复，则延迟指定的时间再次投递消息；多次同时批量获取消息，如果其中一个所述的消息已经被消费标记，则当前消费时间根据返回的内容不进行处理，处理未标记的消息id；对已经被消费标记的消息设定固定过期时间，当超过设定的固定过期时间后，对该消息进行投放处理。本发明针对支付系统或电商系统中存在大量的稍后重试或错误失败重试场景，对于每条消息投放提供可变时的延时通知配置以及对应的下游服务配置。CN111510469ACN111510469A权利要求书1/1页1.一种消息处理方法，其特征在于，包括：接收消息投放请求后，将接收到的消息存储至消息存储集群；轮询消息存储集群中已过期消息，按照约定策略进行消息的处理投递。2.如权利要求1所述的消息处理方法，其特征在于，所述的消息以序列化串方式存储，并按照“关键字-值”形式存储于消息存储集群中，所述的关键字为消息id，值为消息体。3.如权利要求2所述的消息处理方法，其特征在于，所述的消息体包括：用户投递的消息内容、消息到期时间戳和消息回调地址。4.如权利要求3所述的消息处理方法，其特征在于，所述的消息体还包括消息重试策略，则所述的按照约定策略进行消息的处理投递进一步包括：消息投递后若未收到按照约定的答复，则延迟指定的时间再次投递消息。5.如权利要求1所述的消息处理方法，其特征在于，所述的方法进一步包括：存储消息过期时间序列，所述存储消息过期时间序列包括：采用rediszset结构组织消息，并从rediszset中跟进时间戳范围获取到期的所有消息id，根据消息id获取消息id对应消息体投放，其中存放消息过期时间序列的zset为过期序列zset。6.如权利要求5所述的消息处理方法，其特征在于，所述rediszset对应存储一个时间片序列，所述的方法进一步包括：获取当前时间片zset的位置，根据分布存储值并结合过期序列zset找到当前时间到期的所有消息id，再次进行获取当前时间到期的所有消息id。7.如权利要求1所述的消息处理方法，其特征在于，还包括：多次同时批量获取消息，如果其中一个所述的消息已经被消费标记，则当前消费时间根据返回的内容不进行处理，处理未标记的消息id。8.如权利要求7所述的消息处理方法，其特征在于，所述的处理未标记的消息id后进一步包括：对已经被消费标记的消息设定固定过期时间，当该消息被消费占用时间超过设定的固定过期时间后，对该消息进行投放处理。9.如权利要求6所述的消息处理方法，其特征在于，进一步包括：当消息投放失败后，删除时间序列zset和过期序列zset的指定值，并根据重试策略设定新的过期时间。10.一种消息处理装置，包括处理器、存储器以及存储在所述存储器中且被配置为由所述处理器执行的计算机程序，其特征在于，所述的处理器执行所述计算机程序时实现如权利要求1-9任一项所述的消息处理方法。2CN111510469A说明书1/7页一种消息处理方法和装置技术领域[0001]本发明涉及计算机技术领域，特别涉及一种消息处理方法和装置。背景技术[0002]支付系统存在大量的异步通知场景，如支付完成通知商户发货，支付后查询第三方获得支付结果，此时消息在通知过程中可能因为商户或者下游系统未准备好需要再次通知。[0003]异步消息是消息中间件中的概念，存放在消息队列中，通常用于同步操作异步化与业务逻辑解耦。比如生产者发送特定结构的消息到队列中之后，消费者订阅消息队列，获取消息并消费。例如现在的支付和服务分发业务，普遍存在交易结果通知回调，而且要求要做到最大努力通知，现在的支付和服务分发业务及审计日志业务，都要求尽量做成异步的，不要影响主业务。[0004]然而，本专利申请发明人发现，现有技术至少存在如下问题：[0005]1、常规的异步通知处理可能会因为下游状态不稳定，从而导致下游不能正确收到被通知的消息。[0006]2、遇到高并发