CN113064740B 一种消息处理方法和装置 （北京京东拓先科技有限公司）

及计算机技术领域。该方法的具体实施方式包述多个定时器分别指示了所述多个消息处理时2根据所述待处理消息以及多个定时器，构建所述待处理消息对据所述待处理消息，分别生成所述一个或多个待处理消息分别对应的一个或多个第二任根据所述消息处理时间，执行所述第一任务，以将所述第一预先配置多组定时器，每一组定时器包括多个定时器，且不同组根据确定出的所述定时器组中的多个定时器，生成所述第二任务对应的多个第一任通过所述kafka集群的第二线程，根据预设周期，从所述第一队列中提取所述第二任确定所述第一任务和所述第二任务中，是否存在与所述当理消息存储至第二队列；3针对同一消息处理时间对应的所述至少两个定时器设置锁，使得同一消息处理时间设置多个定时器，每一个定时器对应一个消息处理时间；根据所述待预先配置多组定时器，每一组定时器包括多个定时器，且不同组所述任务构建模块还用于：根据所述第二任务所对应的待处理消所述业务端向所述消息处理端发送一个或多根据所述待处理消息以及多个定时器，构建所述待处理消息对据所述待处理消息，分别生成所述一个或多个待处理消息分别对应的一个或多个第二任所述消息处理端还根据所述消息处理时间，执行所述第一任务，以4所述消息处理端还根据所述第二任务所对应的待处理消息的类56待处理消息存储至第二队列；7构架和redis队列组合构建独立的消息处理系统的技术手段，所以克服了多方后端交互可[0054]上述的非惯用的可选方式所具有的进一步效果将在下文中结合具体实施方式加[0056]图1是适于应用于本发明实施例的消息处理方法或消息处理装置的示例性系统架[0061]图5是适于用来实现本发明实施例的终端设备或服务器的计算机系统的结构示意[0063]图1示出了适于应用于本发明实施例的消息处理方法或消息处理装置的示例性系8[0076]通过kafka集群的第二线程，预先配置多组定时器，每一组定时器包括多个定时9应一个定时器，针对同一消息处理时间的多个相同的第一任务的多个定时器设置分布锁，储至第一队列。一任务，并将第一任务的处理结果发送给订阅与多个第一任务对应的待处理消息的订阅[0085]如果接收到的订阅者反馈的与待处理消息对应的多个第一任务中的最后一个目业务端发送关于处理失败的消息，接收业务端发送的关于重新执行所述待处理消息的消过本发明的消息处理方法，所述接收模块301通过MQ集群接收业务端发送的一个或多个待[0091]所述接收模块301接收到业务端发送的一个或多个待处理消息后，针对每一个待多个消息处理时间。所述任务构建模块302根据每一个待处理消息及其对应的多个消息处[0098]消息处理端在接收业务端发送的一个或多个待处理消息时，通过kafka集群第一[0100]通过kafka集群第二线程中的consumer通过其中的timer定时扫描message[0101]在构建第一任务后，timer将多个第一任务放入第一队列中，并记录本次扫描的offset(比如，业务标识+时间戳)；其中，第一队列可以是基于redis的list服务的ready待处理消息的业务标识删除mongodb中对应的待处理消息的集合数据；如果反馈结果为负存储部分508加载到随机访问存储器(RAM)503中的程序而执行各种适当的动作和处理。在的计算机程序根据需要被安装入存储部分5发明中，计算机可读的信号介质可以包括在基带中或者作为载波一部分传播的数据信号，