做pc端网站讯息,wordpress post提交表单,网页设计与网站建设电话,visual c 网站开发背景
我们知道消息中间件mq是支持延迟消息的发送功能的#xff0c;但是kafka不支持这种直接的用法#xff0c;所以我们需要独立实现这个功能#xff0c;以下是在kafka中实现消息延时投递功能的一种方案
kafka实现延时消息
主要的思路是增加一个检测服务#xff0c;这个检…背景
我们知道消息中间件mq是支持延迟消息的发送功能的但是kafka不支持这种直接的用法所以我们需要独立实现这个功能以下是在kafka中实现消息延时投递功能的一种方案
kafka实现延时消息
主要的思路是增加一个检测服务这个检测服务会每分钟定时从延时队列中获取消息然后判断这些延迟消息是否到期如果到期那么就把这条消息发送到正常的队列中如果还没到期继续放到延时队列里面,这样就可以实现延时队列的功能了.
