FWQ
生产redisson延时队列不消费问题排查解决
生产redisson延时队列不消费问题排查解决 0浏览 收藏 IT行业相对于一般传统行业,发展更新速度更快,一旦停止了学习,很快就会被行业所淘汰。所以我们需要踏踏实实的不断学习,精进自己的技术,尤其是初学者。今天golang学习网给大家整理了《生产redisson延时队列不消费问题排查解决》,聊聊排查、redisson延时队列、不消费,我们一起来看看吧! 问题描述 项目使用redisson延时队列功能,实现直播的开播提醒,突然有一天业务爆出问题,未触发开播提醒。 初步排查 首先通过查询生产日志,发送端日志存在,没有消费日志,猜测消费端没有消费到延时消息,,在dba的协助下查询redis队列,消息也确实存在,但已经过了过期时间,由此证明redisson消费者出现问题。通过服务日志发现在最后一次设置自定义推送任务是在一次服务发布之前,服务发布后,之前设置的自定义推送消息均没有被客户端消费,由此猜想是由发布服务导致消费端失效。 排查过程 发送端代码 public void produce(String delayQueue, T t, long delay, TimeUnit timeUnit) { try { log.info("delay msg,delayQueue:{},key:{},delay:{}", delayQueue, t, delay);…