<dependency>
	<artifactId>free-bsf-redis</artifactId>
	<groupId>com.free.bsf</groupId>
	<version>1.7.1-SNAPSHOT</version>
</dependency>

#bsf redis是否开启支持
bsf.redis.enabled = false

    #key支持spel表达式,timeout 单位为秒
    @RedisCache(key = "'user-'+#userId", timeout = 60)
    public User callComplex(long userId) {
        return new User(userId, "hello: " + System.currentTimeMillis(), Arrays.asList(new User.Job(userId + "001", "haha")));
    }

    public List<User> callback(long userId) {
        List<User> list = redisProvider.cache("user-" + userId, 60, () -> Arrays.asList(new User(userId, "hello: " + userId, Arrays.asList(new User.Job(userId + "001", "haha")))), new TypeReference<List<User>>() {
        }.getType());
        System.out.println(list);
        return list;
    }

     //加锁,如果冲突,则一直等待
     redisProvider.lock(key, () -> {
        try {
            callable.call();
        } catch (Exception e) {
            e.printStackTrace();
        }
     });
     //尝试加锁,不行直接放弃
     boolean result = redisProvider.tryLock(key, () -> {
        try {
            callable.call();
        } catch (Exception e) {
            e.printStackTrace();
        }
     });

    RedisLeaderElection leaderElection = new RedisLeaderElection();
    //异步通知进行选举
    leaderElection.doElection(task);
    //异步监听器
    leaderElection.getListeners().add((name,isMaster)->{
        if(isMaster){
            System.out.println(threadName+ "【主节点】:" + isMaster);
        }else{
            System.out.println(threadName+ "【从节点】:" + isMaster);
        }
    });
    //退出选举
    leaderElection.exitElection();
    //当前是否是主节点
    leaderElection.isMaster();

  val redis = ContextUtils.getBean(RedisProvider.class,false);
  if (redis.limit("测试限流", 1, 10,RedisLimitType.Count)) {
        //正常访问
  } else {
        //已限流
  }

  val jRedis = new Jedis({IP},6379);
  val redis = RedisLimitFactory.create(jRedis,RedisLimitType.Slide);
  if (redis.visit("测试限流", 1, 10)) {
        //正常访问
  } else {
        //已限流
  }

	@Autowired
	private RedisProvider redisProvider;

	/**
	* 获取值
	*/
	public String get(String key) {
		return redisProvider.get(key);
	}

	/**
	* 设置键值
	*/
	public void set(String key, String value, int timeout) {
		redisProvider.set(key, value, timeout);
	}

#集群模式客户端
val client = (JedisCluster)RedisProvider.getClient();
#单机模式客户端
val client = (Jedis)RedisProvider.getClient();