RQSay 的技术小站
  • Dublin
  • °C ~ °C

“ kafka实现延迟消息 ”

发布时间：2023-12-29
今日阅读：0
来源：CSDN
作者：lixia0417mul2
...

背景

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

kafka实现延时消息

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

标签:
kafka 分布式

推荐阅读

♦ SpringCloud-RabbitMQ消息模型
(0)
♦ kafka和rabbitmq区别面试题，十年Java编程开发生涯
(0)

每日一言

""男人单身叫单身狗，女的单身叫狗不理。""

最近发布

热门标签

json(1) linux(1) python(1) shell(1) SublimeText(1) zsh(1) 分布式(1) 快捷键(1) 运维(1) 问题排查(1) 限流(1) mac(2) mysql(2)
...

站点统计

本周更新文章: 0 篇
文章总数: 59110 篇
今日访问量: 38277 次
访问总量: 149600 次