异步消息处理方法、装置、电子设备和存储介质.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113626217A(43)申请公布日2021.11.09(21)申请号202110859560.2(22)申请日2021.07.28(71)申请人北京达佳互联信息技术有限公司地址100085北京市海淀区上地西路6号1幢1层101D1-7(72)发明人邵帅(74)专利代理机构北京清亦华知识产权代理事务所(普通合伙)11201代理人张梦瑶(51)Int.Cl.G06F9/54(2006.01)权利要求书2页说明书10页附图3页(54)发明名称异步消息处理方法、装置、电子设备和存储介质(57)摘要本公开提出一种异步消息处理方法、装置、电子设备和存储介质，其中，方法包括：获取待发送的异步消息，根据异步消息中设定字段所携带数据，确定异步消息对应的异步消息队列中的目标分区，将异步消息，存储至异步消息对应的目标分区，以使得和目标分区对应的消费方获取目标分区中存储的各异步消息。本公开中根据异步消息的设定字段所携带数据，确定对应的目标分区，实现了对应同一个数据的更新可以存储至同一个目标分区中，以确保目标分区对应的消费方从目标分区中处理消息时，避免旧数据覆盖新数据，确保消费方和发送方数据的一致性。CN113626217ACN113626217A权利要求书1/2页1.一种异步消息处理方法，其特征在于，包含：获取待发送的异步消息；根据所述异步消息中设定字段所携带数据，确定所述异步消息对应的异步消息队列中的目标分区；将所述异步消息，存储至所述异步消息对应的所述目标分区，以使得和所述目标分区对应的消费方处理所述目标分区中存储的各异步消息。2.如权利要求1所述的方法，其特征在于，所述根据所述异步消息中设定字段所携带数据，确定所述异步消息对应的异步消息队列中的目标分区，包括：根据所述设定字段所携带数据和所述异步消息队列中多个分区之间的映射关系，从所述多个分区中确定所述异步消息中所述设定字段的数据对应的目标分区。3.如权利要求2所述的方法，其特征在于，所述根据所述设定字段所携带数据和所述异步消息队列中多个分区之间的映射关系，从所述多个分区中确定所述异步消息中所述设定字段的数据对应的目标分区，包括：对所述设定字段所携带数据执行哈希运算，得到所述设定字段所携带数据的哈希值；根据所述哈希值和所述映射关系，从所述多个分区中确定所述异步消息中所述设定字段的数据对应的目标分区。4.如权利要求1‑3任一项所述的方法，其特征在于，所述方法还包括：将向所述异步消息对应的目标分区发送所述异步消息的时间和写入所述异步消息的时间，存储至所述异步消息对应的所述目标分区，以使得和所述目标分区对应的消费方，根据所述目标分区中存储的各异步消息对应的发送至所述目标分区的时间和写入所述目标分区的时间，处理所述目标分区中的各异步消息。5.一种异步消息处理方法，其特征在于，包括：获取存储在异步消息队列的目标分区中的异步消息，以及所述异步消息向所述目标分区发送的时间和写入所述目标分区的时间；获取亲缘性线程池中和所述目标分区的异步消息的设定字段对应的目标线程；利用所述目标线程，根据所述异步消息向所述目标分区发送的时间和写入所述目标分区的时间，处理所述异步消息。6.一种异步消息处理装置，其特征在于，包含：获取模块，被配置为执行获取待发送的异步消息；确定模块，被配置为执行根据所述异步消息中设定字段所携带数据，确定所述异步消息对应的异步消息队列中的目标分区；存储模块，被配置为将所述异步消息，存储至所述异步消息对应的所述目标分区，以使得和所述目标分区对应的消费方处理所述目标分区中存储的各异步消息。7.一种异步消息处理装置，其特征在于，包括：第一获取模块，被配置为执行获取存储在异步消息队列的目标分区中的异步消息，以及所述异步消息向所述目标分区发送的时间和写入所述目标分区的时间；第二获取模块，被配置为执行获取亲缘性线程池中和所述目标分区的异步消息的设定字段对应的目标线程；处理模块，被配置为执行利用所述目标线程，根据所述异步消息向所述目标分区发送2CN113626217A权利要求书2/2页的时间和写入所述目标分区的时间，处理所述异步消息。8.一种电子设备，其特征在于，包括：处理器；用于存储所述处理器可执行指令的存储器；其中，所述处理器被配置为执行所述指令，以实现如权利要求1至4中任一项所述的异步消息处理方法，或者是实现如权利要求5中所述的异步消息处理方法。9.一种计算机可读存储介质，其特征在于，当所述存储介质中的指令由电子设备中的处理器执行时，使得电子设备能够执行如权利要求1至4中任一项所述的异步消息处理方法，或者是执行如权利要求5中所述的异步消息处理方法。10.一种计算机程序产品，包括计算机程序，其特征在于，所述计算机程序在被处理器执行