“ kafka实现延迟消息 ”

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

背景

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

kafka实现延时消息

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

标签:
kafka 分布式

每日一言

"<!doctype html> <html lang="Zh-cn"> <head> <meta http-equiv="Content-Type" content="text/html; charset=utf-8" /> <meta name="robots" content="noindex,nofollow"> <meta name="viewport" content="width=device-width, initial-scale=1.0, maximum-scale=1.0, user-scalable=no"/> <meta name="renderer" content="webkit"> <title>您请求的文件不存在!</title> <link type="text/css" rel="stylesheet" href="https://www.oick.cn/css/404.css" /> <link rel="shortcut icon" href="http://www.oick.cn/favicon.ico" type="image/x-icon" /> </head> <body> <div id="wrap"> <div> <img src="https://www.oick.cn/imgs/404.png" alt="404" /> </div> <div id="text"> <strong> <span></span> <a href="javascript:history.back()">返回上一页</a> </strong> </div> </div> <div class="animate below"></div> <div class="animate above"></div> </body> </html>"

...

站点统计

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