首页/ 北京商越网络科技有限公司/ 专利详情

实现分布式系统中延时消息的方法和装置、设备及存储介质

基本信息

申请号 CN202110803441.5 申请日 -
公开（公告）号 CN113268365A 公开（公告）日 2021-08-17
申请公布号 CN113268365A 申请公布日 2021-08-17
分类号 G06F9/54 分类 计算；推算；计数;
发明人 石玉军 申请（专利权）人 北京商越网络科技有限公司
代理机构 北京市鼎立东审知识产权代理有限公司 代理人 朱慧娟;陈佳妹
地址 100000 北京市海淀区农大南路1号院8号楼4层401-1001
法律状态 -

摘要

摘要 本申请涉及一种实现分布式系统中延时消息的方法和装置、设备及存储介质，其中方法包括：在服务启动时，拉取ZooKeeper中存储的所有延时消息，并将拉取到的所有延时消息存放到延时队列中；基于延时队列中各延时消息的投递时间执行相应的消费逻辑。通过以ZooKeeper作为服务端，进行所有延时消息的存储，从而在进行延时消息的实现时，可以直接调用ZooKeeper中相应的线程。并且，由于在各项订单项目中本身就使用了ZooKeeper，因此不需要再额外引用新的中间件。这就有效简化了延时消息实现的系统架构。