如何实现pubsub消息的1分钟延迟发布功能？

原生Pub/Sub服务普遍没有直接的延迟发布API，你可以通过以下几种成熟方案实现需求：

方案1：基于死信队列+重试机制的原生实现（无需额外组件） #

• 原理：利用Pub/Sub服务自带的消费重试和死信队列能力实现延迟。先将消息发送到专门的延迟中转主题，给该主题绑定的订阅配置60秒的消费重试间隔，同时设置最大重试次数为1次、死信队列指向你实际需要投递的目标主题。
• 实现步骤：
  1. 创建中转主题和对应订阅，关闭订阅的自动确认配置
  2. 给订阅配置死信规则，指定死信队列为实际业务使用的目标主题
  3. 编写中转订阅的消费逻辑，所有消息消费时直接返回NACK（消费失败），触发重试规则
  4. 60秒后消息重试次数耗尽，会自动投递到死信队列（即目标主题），完成延迟发布
• 适用场景：仅需要固定时长延迟、不想引入额外中间件的场景，注意确认你使用的Pub/Sub服务支持自定义重试间隔配置。

方案2：引入外部定时存储实现（灵活性更高） #

如果你的Pub/Sub服务不支持自定义重试间隔，可以通过外部存储加定时扫描的方式实现：

• Redis ZSET实现：将消息序列化为value，当前时间戳+60秒作为score写入ZSET，启动独立的定时扫描进程，每隔1秒拉取score小于等于当前时间戳的消息，发送到目标Pub/Sub主题后删除ZSET中的对应记录即可。
• 关系型数据库实现：新建专门的延迟消息表，字段包含消息内容、计划发送时间、发送状态，写入消息时计划发送时间填当前时间加1分钟，定时任务每秒扫描状态为「待发送」且计划发送时间小于等于当前时间的记录，发送完成后更新状态为「已发送」。
• 适用场景：延迟时间不固定、后续有扩展延迟时长需求的场景，需要做好定时进程的高可用部署，避免单点故障。

方案3：切换支持原生延迟消息的消息队列 #

如果业务允许调整消息队列选型，很多主流MQ原生支持延迟消息能力，无需额外开发：

• RocketMQ：发送消息时指定delayTimeLevel参数，对应1分钟的等级即可直接实现延迟
• RabbitMQ：安装延迟消息插件后，发送消息时指定x-delay参数为60000（单位毫秒）即可
• 各类云托管MQ：阿里云RocketMQ、腾讯云CMQ等都原生支持延迟消息参数，发送时直接传入延迟时间即可。

注意：所有方案都需要做好消息幂等性校验，避免消息重复投递导致业务异常；如果消息重要性较高，需要配合消息落盘、消费确认机制避免消息丢失。

内容的提问来源于stack exchange，提问作者Jaward Sally