kafka实现延迟消息

背景

我们知道消息中间件mq是支持延迟消息的发送功能的,但是kafka不支持这种直接的用法,所以我们需要独立实现这个功能,以下是在kafka中实现消息延时投递功能的一种方案

kafka实现延时消息

主要的思路是增加一个检测服务,这个检测服务会每分钟定时从延时队列中获取消息,然后判断这些延迟消息是否到期,如果到期,那么就把这条消息发送到正常的队列中,如果还没到期,继续放到延时队列里面,这样就可以实现延时队列的功能了.
在这里插入图片描述

相关推荐

  1. kafka实现延迟队列

    2023-12-30 09:40:01       26 阅读
  2. RabbitMQ如何实现延迟消息

    2023-12-30 09:40:01       19 阅读
  3. RabbitMQ延迟消息(通过死信交换机实现

    2023-12-30 09:40:01       6 阅读

最近更新

  1. TCP协议是安全的吗?

    2023-12-30 09:40:01       19 阅读
  2. 阿里云服务器执行yum,一直下载docker-ce-stable失败

    2023-12-30 09:40:01       19 阅读
  3. 【Python教程】压缩PDF文件大小

    2023-12-30 09:40:01       19 阅读
  4. 通过文章id递归查询所有评论(xml)

    2023-12-30 09:40:01       20 阅读

热门阅读

  1. TCP/UDP协议

    2023-12-30 09:40:01       36 阅读
  2. 百度地图再vue中的引入方式

    2023-12-30 09:40:01       44 阅读
  3. 《基于 Vue 组件库 的 Webpack5 配置》- 总结

    2023-12-30 09:40:01       36 阅读
  4. FreeRTOS学习--61讲 内存管理

    2023-12-30 09:40:01       36 阅读
  5. 【蓝桥杯】比赛大纲整理

    2023-12-30 09:40:01       31 阅读
  6. 前端使用a标签下载非同源文件(备选方案)

    2023-12-30 09:40:01       44 阅读