好湿?好紧?好多水好爽自慰,久久久噜久噜久久综合,成人做爰A片免费看黄冈,机机对机机30分钟无遮挡

主頁 > 知識庫 > Redis集群下過期key監聽的實現代碼

Redis集群下過期key監聽的實現代碼
熱門標簽：高碑店市地圖標注app 南京手機外呼系統廠家 臺灣電銷 地圖標注工廠入駐 四川穩定外呼系統軟件 廊坊外呼系統在哪買 b2b外呼系統 一個地圖標注多少錢 400電話辦理的口碑

1.　前言

在使用redis集群時，發現過期key始終監聽不到。網上也沒有現成的解決方案。于是想，既然不能監聽集群，那我可以建立多個redis連接，分別對每個redis的key過期進行監聽。以上做法可能不盡人意，目前也沒找到好的解決方案，如果有好的想法，請留言告知哦！不多說，直接貼我自己的代碼！

2.　代碼實現

關于Redis集群配置代碼此處不貼，直接貼配置監聽類代碼！

redis.host1: 10.113.56.68
redis.port1: 7030
redis.host2: 10.113.56.68
redis.port2: 7031
redis.host3: 10.113.56.68
redis.port3: 7032
redis.host4: 10.113.56.68
redis.port4: 7033
redis.host5: 10.113.56.68
redis.port5: 7034
redis.host6: 10.113.56.68
redis.port6: 7035
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cache.CacheManager;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.cache.RedisCacheManager;
import org.springframework.data.redis.connection.RedisClusterConfiguration;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPoolConfig;

import java.util.Arrays;

/**
 * @Author xiabing5
 * @Create 2019/8/6 14:46
 * @Desc  監聽redis中Key過期事件
 **/
@Configuration
public class RedisListenerConfig {

  @Value("${redis.host1}")
  private String host1;

  @Value("${redis.host2}")
  private String host2;

  @Value("${redis.host3}")
  private String host3;

  @Value("${redis.host4}")
  private String host4;

  @Value("${redis.host5}")
  private String host5;

  @Value("${redis.host6}")
  private String host6;

  @Value("${redis.port1}")
  private int port1;

  @Value("${redis.port2}")
  private int port2;

  @Value("${redis.port3}")
  private int port3;

  @Value("${redis.port4}")
  private int port4;

  @Value("${redis.port5}")
  private int port5;

  @Value("${redis.port6}")
  private int port6;

  @Bean
  JedisPoolConfig jedisPoolConfig(){
    JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
    jedisPoolConfig.setMaxIdle(100);
    jedisPoolConfig.setMaxWaitMillis(1000);
    return jedisPoolConfig;
  }

  // redis-cluster不支持key過期監聽，建立多個連接，對每個redis節點進行監聽
  @Bean
  RedisMessageListenerContainer redisContainer1() {
    final RedisMessageListenerContainer container = new RedisMessageListenerContainer();
    JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory();
    jedisConnectionFactory.setHostName(host1);
    jedisConnectionFactory.setPort(port1);
    jedisConnectionFactory.setPoolConfig(jedisPoolConfig());
    jedisConnectionFactory.afterPropertiesSet();
    container.setConnectionFactory(jedisConnectionFactory);
    return container;
  }

  @Bean
  RedisMessageListenerContainer redisContainer2() {
    final RedisMessageListenerContainer container = new RedisMessageListenerContainer();
    JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory();
    jedisConnectionFactory.setHostName(host2);
    jedisConnectionFactory.setPort(port2);
    jedisConnectionFactory.setPoolConfig(jedisPoolConfig());
    jedisConnectionFactory.afterPropertiesSet();
    container.setConnectionFactory(jedisConnectionFactory);
    return container;
  }

  @Bean
  RedisMessageListenerContainer redisContainer3() {
    final RedisMessageListenerContainer container = new RedisMessageListenerContainer();
    JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory();
    jedisConnectionFactory.setHostName(host3);
    jedisConnectionFactory.setPort(port3);
    jedisConnectionFactory.setPoolConfig(jedisPoolConfig());
    jedisConnectionFactory.afterPropertiesSet();
    container.setConnectionFactory(jedisConnectionFactory);
    return container;
  }

  @Bean
  RedisMessageListenerContainer redisContainer4() {
    final RedisMessageListenerContainer container = new RedisMessageListenerContainer();
    JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory();
    jedisConnectionFactory.setHostName(host4);
    jedisConnectionFactory.setPort(port4);
    jedisConnectionFactory.setPoolConfig(jedisPoolConfig());
    jedisConnectionFactory.afterPropertiesSet();
    container.setConnectionFactory(jedisConnectionFactory);
    return container;
  }

  @Bean
  RedisMessageListenerContainer redisContainer5() {
    final RedisMessageListenerContainer container = new RedisMessageListenerContainer();
    JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory();
    jedisConnectionFactory.setHostName(host5);
    jedisConnectionFactory.setPort(port5);
    jedisConnectionFactory.setPoolConfig(jedisPoolConfig());
    jedisConnectionFactory.afterPropertiesSet();
    container.setConnectionFactory(jedisConnectionFactory);
    return container;
  }

  @Bean
  RedisMessageListenerContainer redisContainer6() {
    final RedisMessageListenerContainer container = new RedisMessageListenerContainer();
    JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory();
    jedisConnectionFactory.setHostName(host6);
    jedisConnectionFactory.setPort(port6);
    jedisConnectionFactory.setPoolConfig(jedisPoolConfig());
    jedisConnectionFactory.afterPropertiesSet();
    container.setConnectionFactory(jedisConnectionFactory);
    return container;
  }

  @Bean
  RedisKeyExpirationListener redisKeyExpirationListener1() {
    return new RedisKeyExpirationListener(redisContainer1());
  }

  @Bean
  RedisKeyExpirationListener redisKeyExpirationListener2() {
    return new RedisKeyExpirationListener(redisContainer2());
  }

  @Bean
  RedisKeyExpirationListener redisKeyExpirationListener3() {
    return new RedisKeyExpirationListener(redisContainer3());
  }

  @Bean
  RedisKeyExpirationListener redisKeyExpirationListener4() {
    return new RedisKeyExpirationListener(redisContainer4());
  }

  @Bean
  RedisKeyExpirationListener redisKeyExpirationListener5() {
    return new RedisKeyExpirationListener(redisContainer5());
  }

  @Bean
  RedisKeyExpirationListener redisKeyExpirationListener6() {
    return new RedisKeyExpirationListener(redisContainer6());
  }

}
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import java.util.Date;

/**
 * @Author xiabing5
 * @Create 2019/9/4 9:47
 * @Desc  redis過期監聽
 **/
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
  @Autowired
  RedisUtil redisUtil;
  @Autowired
  LoginUserStatisticsMapper loginUserStatisticsMapper;
  public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
    super(listenerContainer);
  }
  @Override
  public void onMessage(Message message, byte[] pattern) {
    // 用戶做自己的業務處理即可,message.toString()可以獲取失效的key
    String mesg = message.toString();   
  }
}

3.　Redis防止過期key重復監聽

對于項目集群情況下，部署多個服務后，容易出現redis過期被多個服務同時監聽到，從而執行相同的業務邏輯，這不是我們期望的。單機部署下方法的同步可以采用synchronize關鍵字。但集群下，就得采用分布式鎖。在需要加鎖的地方，只要加鎖和解鎖即可。此處正好寫到Redis，那就貼一個自己用的redis分布式鎖。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import redis.clients.jedis.Jedis;
import java.util.Collections;
import java.util.UUID;
/**
 * @Author xiabing5
 * @Create 2019/9/6 15:54
 * @Desc  redis分布式鎖
 **/
@Component
public class RedisLock {
  @Autowired
  Jedis jedis;
  private static final String SET_IF_NOT_EXIST = "NX"; // NX表示如果不存在key就設置value
  private static final String SET_WITH_EXPIRE_TIME = "PX"; // PX表示毫秒
  // 加鎖
  public String tryLock(String key,Long acquireTimeout) {
    // 生成隨機value
    String identifierValue = UUID.randomUUID().toString();
    // 設置超時時間
    Long endTime = System.currentTimeMillis() + acquireTimeout;
    // 循環獲取鎖
    while (System.currentTimeMillis()  endTime) {
      String result = jedis.set(key,identifierValue, SET_IF_NOT_EXIST, SET_WITH_EXPIRE_TIME, acquireTimeout);
      if("OK".equals(result)) {
        return identifierValue;
      }
    }
    return null;
  }
  // 解鎖
//  public void delLock(String key,String identifierValue) {
//    // 判斷是否是同一把鎖
//    try{
//      if(jedis.get(key).equals(identifierValue)){
//        // 此處操作非原子性，容易造成釋放非自己的鎖
//        jedis.del(key);
//      }
//    }catch(Exception e) {
//      e.printStackTrace();
//    }
//  }
  // 使用Lua代碼解鎖
  public void delLock(String key,String identifierValue) {
    try{
      String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
      Long result = (Long) jedis.eval(script, Collections.singletonList(key), Collections.singletonList(identifierValue));
      if (1 == result) {
        System.out.println(result+"釋放鎖成功");
      } if (0 == result) {
        System.out.println(result+"釋放鎖失敗");
      }
    }catch (Exception e) {
      e.printStackTrace();
    }
  }
}

4.　總結

自己實現的一個小demo,廢話比較少。小白自己寫的配置類，理解有問題請留言！自己實現的方案感覺不妥，只是基本完成需求，還得繼續研究。

以上所述是小編給大家介紹的Redis集群下過期key監聽的實現代碼,希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復大家的。在此也非常感謝大家對腳本之家網站的支持！
如果你覺得本文對你有幫助，歡迎轉載，煩請注明出處，謝謝！

您可能感興趣的文章:
  • 基于docker搭建redis集群的方法
  • Docker 部署單機版 Pulsar 和集群架構 Redis(開發神器)的方法
  • Redis Cluster集群數據分片機制原理
  • springcloud微服務基于redis集群的單點登錄實現解析
  • springboot整合redis集群過程解析
  • Java調用Redis集群代碼及問題解決
  • Linux(Centos7)下redis5集群搭建和使用說明詳解
  • 基于docker搭建redis-sentinel集群的方法示例
  • 詳細分析Redis集群故障
  • 比較幾種Redis集群方案

標簽：拉薩 南寧 定州 河源 甘南 畢節 伊春 泰州

巨人網絡通訊聲明：本文標題《Redis集群下過期key監聽的實現代碼》，本文關鍵詞  Redis,集群,下,過期,key,監聽,；如發現本文內容存在版權問題，煩請提供相關信息告之我們，我們將及時溝通與處理。本站內容系統采集于網絡，涉及言論、版權與本站無關。
  • 相關文章
  • 下面列出與本文章《Redis集群下過期key監聽的實現代碼》相關的同類信息！
  • 本頁收集關于Redis集群下過期key監聽的實現代碼的相關信息資訊供網民參考！
    • 推薦文章
    主站蜘蛛池模板： 韩国色网站| bl纯肉yd饥渴受np快穿| 又污又爽的网站| 向涟苍士献上纯洁是第一季| 老司机福利成人精品app| 美国玩尿眼道videos| 强制被迫年下bl高H| 好看的电视剧大全免费观看| 白丝梦莉裸乳被爆?白浆的视频| 艳荡芦花湾小说| 国产91精品久久久久久| 色戒完整版未删减版| 日产乱码一二三区别免费| 不要了不要| 综合AV第一页| 日韩欧美电影在线| 成人区视频爽爽爽爽爽| 《年轻护士2》中文字幕 | 撅着屁股被客人sp光屁股罚站| 欧美男同志videos| 欧美无人区码AAAAA| 疯狂的浪寡妇| 《年轻护士2》中文字幕| 成年黄页免费大全网站| 肉宴h| 亚洲Av日韩综合A∨蜜月Av| 日日摸夜夜爽无码久久上司| 99久在线| 欧美tv xtime| 四季在线观看免费资源| 国产精品39P| 大胸的丰满老师HD| 欧美看片网站| 风间由美bd456高清在线| 97色伦影院中文字幕| 女人被躁到高潮嗷嗷叫游戏| A天V堂人妻熟女| 男女试看| 娇小枯瘦女需要巨大黑壮男| 国产最顶级国精产品| 久久青草免费91线频观看站街|