写文章
- @weixin_40270946
简介
该用户还未填写简介
擅长的技术栈
未填写擅长的技术栈
可提供的服务
暂无可提供的服务
用Kafka实现延迟消息
本篇参考了基于kafka实现延迟队列 - 知乎，实现了Rocket MQ 18级延迟消息队列的功能，并加入任意延迟时间的支持（通过多个延迟队列的转发实现）。1. Kafka操作工具类——KafkaManager本类实现了对Kafka的连接和基本操作。import org.apache.kafka.clients.admin.*;import org.apache.kafka.common.Topi
到底了