CN113779149B 消息处理方法、装置、电子设备及可读存储介质 （北京知道创宇信息技术股份有限公司）

根据第一待处理消息中的第一当前偏移量及第如此，可利用偏移量确定消息是否为已消费消2根据所述第一待处理消息中的第一当前偏移量及第一目标偏移量在所述第一判断结果为所述第一待处理消息是已消费消息的情在所述第一判断结果为所述第一待处理消息不是已消费消息的当前偏移量对所述第一目标偏移量进行更新，并对所述第一待处理消息进行处理及保存，所述第一判断结果用于表示所述第一待处理消息是否已经被进行预设处理并保存到所述根据所述第二待处理消息中的第二当前偏移量及第二目标偏移量在所述第二判断结果为所述第二待处理消息是已消费消息的情在所述第二判断结果为所述第二待处理消息不是已消费消息的情在所述第一当前偏移量不大于所述第一目标偏移量的情况下，在所述第一当前偏移量大于所述第一目标偏移量的情况在所述第二当前偏移量不大于所述第二目标偏移量的情况下，在所述第二当前偏移量大于所述第二目标偏移量的情况3将本次批量存入所述数据库的处理结果中的最大偏移量保存为第三目标偏移量，其将至少一个处理节点的节点信息保存到日志文档中，其中，所处理模块，用于在所述第一判断结果为所述第一待处理消息是已消费消息的情况下，所述处理模块，还用于在所述第一判断结果为所述第一待处理消息被进行预设处理并保存到所述第一缓冲区中；从所述第一缓冲区中获得第二待处理消息；存入的消息的偏移量；在所述第二判断结果为所述第二待处理消息是已消费消息的情况理器执行的机器可执行指令，所述处理器可执行所述机器可执行指令以实现权利要求1-64执行时实现如权利要求1-6中任意一项所5[0002]消息队列这一概念的诞生是为了减少请求响应时间和解偶，而Kafka是一个高并[0003]Kafka的消息数据的消费状态是由消费者Consumer自己维护，这样可以除去服务[0014]判断模块，用于根据所述第一待处理消息中的第一当前偏移量及第一目标偏移6算机程序被处理器执行时实现如前述实施方式78[0039]针对以上方案所存在的缺陷，均是发明人在经过实践并只读存储器(ProgrammableRead-OnlyMemory，PROM)，可擦除只读存储器(ErasableProgrammableRead-OnlyMemory，EPROM)，电可擦除只读存储器(ElectricErasable存储器110中存储有消息处理装置200，所述消息处理装置200包括至少一个可以软件或固9[0048]通信单元130用于通过网络建立所述电子设备100与其它通信终端之间的通信连[0055]步骤S130，在所述第一判断结果为所述第一待处理消息[0057]步骤S140，在所述第一判断结果为所述第一待处理消息不是已消费消息的情况判断第一待处理消息是否为已消费消息，可以理解为判断第一待处理消息之前已经被从[0080]子步骤S143，根据所述第二待处理消息中的第二当前偏所述第二当前偏移量及第二目标偏移量，判断该第二待处理消息是否已存入第二缓冲区。是否已经将该第二待处理消息放入过第二缓冲区。通过该判断可以避免重复入库的情况。判断所述第二当前偏移量是否大于所述第二目标偏移量。也即判断以下公式是否成立：[0090]子步骤S144，在所述第二判断结果为所述第二待处理消息是已消费消息的情况[0093]可选地，在所述第二判断结果为所述第二待处理消息不第二待处理消息保存到第二缓冲区后，在异步进行将消息队列中的消息存入第一缓冲区、存入该第二缓冲区中的该第二待处理消息保存到数可利用同步方式完成过对一条第二待处理消变，则会触发rebalance的现象。rebalance时候，Kaf[0113]本申请实施例通过仔细分析Kafka信息消费的过程，针对每种可能出现出现的消[0116]所述判断模块220，用于根据所述第一待处理消息中的第一当前偏移量及第一目一目标偏移量为消费者上一次消费的第一待处理消[0117]所述处理模块230，用于在所述第一判断结果为所述第一待处理消息是已消费消[0118]所述处理模块230，还用于在所述第一判断结果为所述第一待处理消息不是已消述处理模块230还用于：将本次批量存入所述数据库的处理结果中的最大偏移量保存为第质，根据消息队列中获得的第一待处理消息中的第一当前偏移量及存储的第一目标偏移显示了根据本申请的多个实施例的装置、方法和计算机程序产品的可能实现的体系架构、[0129]另外，在本申请各个实施例中的各功能模块可以集成在一起形成一个独立的部算机软件产品存储在一个存储介质中，包括若干指令用以使得一台计算机设备(可以是个