技术摘要：
本发明实施例提供了一种消费进度的重置方法、装置、设备及可读存储介质，其中，方法可以包括接收待重置时间信息，待重置时间信息是待需要对消费进度进行重置时发送至分布式消息系统的；获得消息位置和时间信息的对应关系，对应关系以索引格式存储，对应关系指示各个消  全部
背景技术：
目前互联网公司，分布式消息系统使用非常广泛，是分布式系统中实现消息发送 以及接收的基本软件。分布式消息系统可利用高效、可靠的消息传递机制进行平台无关的 数据交流，并基于数据通信来进行分布式系统的集成。分布式消息系统通过提供消息传递 和消息排队模型，可以在分布式环境下扩展进程间的通信。利用分布式消息系统，应用程序 或组件之间可以进行可靠的异步通讯，从而降低系统之间的耦合度，提高系统的可扩展性 和可用性等。分布式消息系统利用分布式特性，其高吞吐的、高可用的性能尤为突出，受到 广泛应用。 分布式消息系统实现消息传递的过程中包括消费组消费消息的过程，消费组可以 与具体的业务相对应。而当消费组消费消息时，有可能需要对消费进度进行重置，比如消费 组2小时内的处理逻辑可能出现了问题，想回溯到2小时前的消息位置进行重新消费。现有 技术中通过估计2小时前的消息位置，进而消费组回溯到该估计的消息位置进行重新消费。 但是，估计的消息位置的准确性较低，使得根据该消息位置进行消费进度的重置的准确性 较低。
技术实现要素：
本发明实施例的目的在于提供一种消费进度的重置方法、装置、设备及可读存储 介质，以提高消费进度重置的准确性。具体技术方案如下： 在本发明实施的第一方面，首先提供了一种消费进度的重置方法，包括： 接收待重置时间信息，所述待重置时间信息是待需要对消费进度进行重置时发送 至分布式消息系统的； 获得消息位置和时间信息的对应关系，所述对应关系以索引格式存储，所述对应 关系指示各个消息位置以及各个消息位置分别对应的时间信息；针对各个消息位置，所述 消息位置对应的时间信息是所述消息位置存储的消息所对应的时间信息； 基于所述待重置时间信息，查询所述对应关系，得到所述待重置时间信息对应的 目标消息位置； 根据所述目标消息位置对消费进度进行重置。 可选的，在所述获得消息位置和时间信息的对应关系之前，所述方法还包括： 针对各个消息位置，确定所述消息位置存储的消息所对应的时间信息； 建立所述消息位置和所述时间信息的对应关系； 将所述对应关系以索引形式进行存储。 可选的，所述基于所述待重置时间信息，查询所述对应关系，得到所述待重置时间 4 CN 111597188 A 说　明　书 2/15 页 信息对应的目标消息位置，包括： 将所述待重置时间信息与所述对应关系所指示的各个消息位置对应的时间信息 进行比较，确定各个消息位置对应的时间信息中与所述待重置时间信息距离最近的时间信 息； 将与所述待重置时间信息距离最近的时间信息所对应的消息位置，作为所述目标 消息位置。 可选的，所述根据所述目标消息位置对消费进度进行重置，包括： 调用预设接口，将消费组的消费位置移动至所述目标消息位置，所述消费位置用 于指示所述消费组从所述消费位置开始消费。 可选的，在所述接收待重置时间信息之前，所述方法还包括： 提供用户操作界面，所述用户操作界面包括能够输入秒级时间的时间选项，所述 秒级时间为时间单位是秒的时间； 所述接收待重置时间信息，包括： 接收用户通过所述用户操作界面中所述时间选项输入的所述待重置时间信息，所 述待重置时间信息为秒级时间。 可选的，所述接收用户通过所述用户操作界面中所述时间选项输入的所述待重置 时间信息，包括： 接收所述用户通过所述用户操作界面中所述时间选项输入的初始时间； 反馈所述初始时间对应的消息相关信息，所述消息相关信息用于指示所述用户判 断所述初始时间对应的消息，是否是目标重置消费进度所对应的消息； 接收所述用户基于所述消息相关信息而对所述初始时间调整后的时间，所述调整 后的时间是所述用户在判断所述初始时间对应的消息，不是目标重置消费进度所对应的消 息时通过所述用户操作界面输入的。 可选的，所述用户操作界面包括消息通道选项和消费组选项；所述消息通道选项 用于输入消费所针对的消息通道的消息通道信息；所述消费组选项用于输入针对所述消息 通道消费的消费组的消费组信息； 所述接收用户通过所述用户操作界面中所述时间选项输入的所述待重置时间信 息，包括： 接收所述用户通过所述用户操作界面中所述时间选项输入的，所述消费组消费所 述消息通道中的消息时所对应的待重置时间信息。 在本发明实施的第二方面，还提供了一种消费进度的重置装置，包括： 接收模块，用于接收待重置时间信息，所述待重置时间信息是待需要对消费进度 进行重置时发送至分布式消息系统的； 获得模块，用于获得消息位置和时间信息的对应关系，所述对应关系以索引格式 存储，所述对应关系指示各个消息位置以及各个消息位置分别对应的时间信息；针对各个 消息位置，所述消息位置对应的时间信息是所述消息位置存储的消息所对应的时间信息； 查询模块，用于基于所述待重置时间信息，查询所述对应关系，得到所述待重置时 间信息对应的目标消息位置； 重置模块，用于根据所述目标消息位置对消费进度进行重置。 5 CN 111597188 A 说　明　书 3/15 页 可选的，所述装置还包括： 确定模块，用于针对各个消息位置，确定所述消息位置存储的消息所对应的时间 信息； 建立模块，用于建立所述消息位置和所述时间信息的对应关系； 存储模块，用于将所述对应关系以索引形式进行存储。 可选的，所述查询模块，具体用于将所述待重置时间信息与所述对应关系所指示 的各个消息位置对应的时间信息进行比较，确定各个消息位置对应的时间信息中与所述待 重置时间信息距离最近的时间信息；将与所述待重置时间信息距离最近的时间信息所对应 的消息位置，作为所述目标消息位置。 可选的，所述重置模块，具体用于调用预设接口，将消费组的消费位置移动至所述 目标消息位置，所述消费位置用于指示所述消费组从所述消费位置开始消费。 可选的，所述装置还包括： 提供模块，用于提供用户操作界面，所述用户操作界面包括能够输入秒级时间的 时间选项，所述秒级时间为时间单位是秒的时间； 所述接收模块，具体用于接收用户通过所述用户操作界面中所述时间选项输入的 所述待重置时间信息，所述待重置时间信息为秒级时间。 可选的，所述接收模块，具体用于接收所述用户通过所述用户操作界面中所述时 间选项输入的初始时间；反馈所述初始时间对应的消息相关信息，所述消息相关信息用于 指示所述用户判断所述初始时间对应的消息，是否是目标重置消费进度所对应的消息；接 收所述用户基于所述消息相关信息而对所述初始时间调整后的时间，所述调整后的时间是 所述用户在判断所述初始时间对应的消息，不是目标重置消费进度所对应的消息时通过所 述用户操作界面输入的。 可选的，所述用户操作界面包括消息通道选项和消费组选项；所述消息通道选项 用于输入消费所针对的消息通道的消息通道信息；所述消费组选项用于输入针对所述消息 通道消费的消费组的消费组信息； 所述接收模块，具体用于接收所述用户通过所述用户操作界面中所述时间选项输 入的，所述消费组消费所述消息通道中的消息时所对应的待重置时间信息。 在本发明实施的第三方面，还提供了一种电子设备，包括处理器、通信接口、存储 器和通信总线，其中，处理器，通信接口，存储器通过通信总线完成相互间的通信； 存储器，用于存放计算机程序； 处理器，用于执行存储器上所存放的程序时，实现上述第一方面所述的方法步骤。 在本发明实施的又一方面，还提供了一种计算机可读存储介质，所述计算机可读 存储介质中存储有指令，当其在计算机上运行时，使得计算机执行上述第一方面所述的方 法步骤。 在本发明实施的又一方面，还提供了一种包含指令的计算机程序产品，当其在计 算机上运行时，使得计算机执行上述第一方面所述的方法步骤。 本发明实施例提供的消费进度的重置方法、装置、设备及可读存储介质，通过接收 待重置时间信息，待重置时间信息是待需要对消费进度进行重置时发送至分布式消息系统 的；获得消息位置和时间信息的对应关系，对应关系以索引格式存储，对应关系指示各个消 6 CN 111597188 A 说　明　书 4/15 页 息位置以及各个消息位置分别对应的时间信息；针对各个消息位置，消息位置对应的时间 信息是消息位置存储的消息所对应的时间信息；基于待重置时间信息，查询对应关系，得到 待重置时间信息对应的目标消息位置；根据目标消息位置对消费进度进行重置。本发明实 施例中，对应关系包括各个消息位置和各个消息位置分别对应的时间信息，且针对各个消 息位置，消息位置对应的时间信息是消息位置存储的消息所对应的时间信息，每个消息位 置可以定位出确定的消息，而每个消息有其对应的时间信息，即通过时间信息可以准确地 确定出对应的消息位置，则相比较于现有的估计的消息位置，本发明实施例中根据待重置 时间信息以及消息位置和时间信息的对应关系确定待重置的消息位置更准确，如此，能够 使得根据目标消息位置对消费进度进行重置更准确。即能够实现基于时间进行消费进度的 重置，提高消费进度重置的准确性。 附图说明 为了更清楚地说明本发明实施例或现有技术中的技术方案，下面将对实施例或现 有技术描述中所需要使用的附图作简单地介绍。 图1为本发明实施例提供的消费进度的重置方法的一种流程图； 图2为本发明实施例中得到待重置时间信息对应的目标消息位置的流程示意图； 图3为本发明实施例中消费进度重置方法的另一种流程图； 图4为本发明实施例中接收待重置时间信息的流程示意图； 图5为本发明实施例提供的用户操作界面的示意图； 图6为本发明实施例中消息位置的示意图； 图7为本发明实施例提供的消费进度的重置的一种结构示意图； 图8为本发明实施例提供的消费进度的重置的另一种结构示意图； 图9为本发明实施例提供的消费进度的重置的又一种结构示意图； 图10为本发明实施例提供的电子设备的结构示意图。