[大数据] Redis实现过期监听类似消息队列

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> 大数据 -> Redis实现过期监听类似消息队列 -> 正文阅读

[大数据]Redis实现过期监听类似消息队列

使用Redis实现过期监听,类似消息队列,实现消息到期提醒,工单超时等功能
RedisTimeoutConfiguration配置类

@Configuration
public class RedisTimeoutConfiguration {
 
    @Autowired
    private RedisConnectionFactory redisConnectionFactory;
 
    @Bean
    public RedisMessageListenerContainer redisMessageListenerContainer() {
        RedisMessageListenerContainer redisMessageListenerContainer = new RedisMessageListenerContainer();
        redisMessageListenerContainer.setConnectionFactory(redisConnectionFactory);
        return redisMessageListenerContainer;
    }
 
    @Bean
    public KeyExpiredListener keyExpiredListener() {
        return new KeyExpiredListener(this.redisMessageListenerContainer());
    }
}

redisKey过期监听KeyExpiredListener类

/** @author christ */
@Slf4j
public class KeyExpiredListener extends KeyExpirationEventMessageListener {

  @Autowired private RedisCache redisCache;
  @Autowired private ISysMessageService sysMessageService;
  @Autowired private JdbcTemplate jdbcTemplate;

  private String sql = "update sys_message set status=? where id=?";

  public KeyExpiredListener(RedisMessageListenerContainer listenerContainer) {
    super(listenerContainer);
  }

  @Override
  public void onMessage(Message message, byte[] pattern) {
    String channel = new String(message.getChannel(), StandardCharsets.UTF_8);
    // 过期的key
    String key = new String(message.getBody(), StandardCharsets.UTF_8);
    System.out.println(message.toString());
    log.info("redis key 过期：pattern={},channel={},key={}", new String(pattern), channel, key);

    // 已过拜访时间
    if (key.contains(TransferConstant.VISIT_RECORD_READY)) {
      String[] split = key.split("-");
      updateMsgStatus(Long.parseLong(split[1]), 1);
      // 提前二十四小时提醒时间,
    } else if (key.contains(TransferConstant.VISIT_RECORD_WILL)) {
      String[] split = key.split("-");
      updateMsgStatus(Long.parseLong(split[1]), 0);
      // 获取当前消息记录
      SysMessage byId = sysMessageService.getById(Long.parseLong(split[1]));
      // 存入redis,准备24小时后过期
      redisCache.setCacheObject(
          TransferConstant.VISIT_RECORD_READY + "-" + byId.getId(),
          byId.getId(),
          Integer.parseInt(String.valueOf(byId.getVisitId() - System.currentTimeMillis())),
          TimeUnit.MILLISECONDS);
    }
  }