Redis集群下过期key监听的实现代码

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();   
  }
}

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();
    }
  }
}