springboot 2.x集成redis+lua脚本

springboot 2.x集成redis+lua脚本

文章目录

• 一、springboot集成redis
• • 1、引Pom
  • 2、配置，我用的是cluster（当然集群不支持事物-我后面一些多命令会用Lua）
  • 3、redis数据类型序列化，这里我重命名了一下redisTemplateMy ，你也可以保持原名redisTemplate
  • 4 、搞一个工具类,大多数简单 *** 作的都比较适用
• 二、原子 *** 作-lua脚本
• • 1、lua一些常见语法
  • 2、集成lua用法
  • 3、注意项

一、springboot集成redis 1、引Pom

        
            org.springframework.boot
            spring-boot-starter-data-redis
        

        
            org.apache.commons
            commons-pool2
        

2、配置，我用的是cluster（当然集群不支持事物-我后面一些多命令会用Lua）

spring.redis.timeout = 10000ms
spring.redis.database = 0
spring.redis.password = jc_redis_xyz
spring.redis.cluster.nodes = ip1:7000,ip1:7001,ip2:7000,ip2:7001,ip3:7000,ip3:7001
spring.redis.cluster.max-redirects = 2
spring.redis.lettuce.pool.max-active = 1000
spring.redis.lettuce.pool.max-idle = 10
spring.redis.lettuce.pool.min-idle = 3
spring.redis.lettuce.pool.max-wait = 6000ms

本地或测试环境是单机的话，直接换成这个，你配置成哪种，springboot集成的redis自动装配会帮你切换使用哪种连接。所以只改配置就行了，用法不变：

spring.redis.host=127.0.0.1
#Redis服务器连接端口
spring.redis.port=6379
#Redis服务器连接密码（默认为空）
spring.redis.password=
#连接池最大连接数（使用负值表示没有限制）
spring.redis.pool.max-active=8
#连接池最大阻塞等待时间（使用负值表示没有限制）
spring.redis.pool.max-wait=-1
#连接池中的最大空闲连接
spring.redis.pool.max-idle=8
#连接池中的最小空闲连接
spring.redis.pool.min-idle=0
#连接超时时间（毫秒）
spring.redis.timeout=30000

3、redis数据类型序列化，这里我重命名了一下redisTemplateMy ，你也可以保持原名redisTemplate

@Configuration
@AutoConfigureAfter(RedisAutoConfiguration.class)
public class RedisConfig {

    //redisConnectionFactory配置信息由yml控制

    @Bean
    @ConditionalOnMissingBean
    public RedisTemplate redisTemplateMy (LettuceConnectionFactory redisConnectionFactory) {
        RedisTemplate template = new RedisTemplate();
        //配置序列化器
        template.setKeySerializer(new StringRedisSerializer());
        template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
        template.setHashKeySerializer(new StringRedisSerializer());
        template.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
        template.setConnectionFactory(redisConnectionFactory);
        return template;
    }

}

4 、搞一个工具类,大多数简单 *** 作的都比较适用

package com.epay.cu.upcc.ccc.provider.controller.test.redis.util;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisCallback;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ZSetOperations.TypedTuple;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;

import java.util.*;
import java.util.concurrent.TimeUnit;


@Component
public class RedisUtil {

  @Autowired
  private RedisTemplate redisTemplate;

  
  public boolean hasKey(String key) {
    try {
      return redisTemplate.hasKey(key);
    } catch (Exception e) {
      e.printStackTrace();
      return false;
    }
  }

  
  @SuppressWarnings("unchecked")
  public void del(String... key) {
    if (key != null && key.length > 0) {
      if (key.length == 1) {
        redisTemplate.delete(key[0]);
      } else {
        redisTemplate.delete(CollectionUtils.arrayToList(key));
      }
    }
  }
  // ================================Map=================================

  
  public Object hget(String key, String item) {
    return redisTemplate.opsForHash().get(key, item);
  }

  
  public boolean hmset(String key, Map map, long time) {
    try {
      redisTemplate.opsForHash().putAll(key, map);
      if (time > 0) {
        expire(key, time);
      }
      return true;
    } catch (Exception e) {
      e.printStackTrace();
      return false;
    }
  }
  
  public Map hmget(String key) {
    return redisTemplate.opsForHash().entries(key);
  }

  
  public boolean hmset(String key, Map map) {
    try {
      redisTemplate.opsForHash().putAll(key, map);
      return true;
    } catch (Exception e) {
      e.printStackTrace();
      return false;
    }
  }

  
  public boolean hset(String key, String item, Object value) {
    try {
      redisTemplate.opsForHash().put(key, item, value);
      return true;
    } catch (Exception e) {
      e.printStackTrace();
      return false;
    }
  }

  
  public boolean hset(String key, String item, Object value, long time) {
    try {
      redisTemplate.opsForHash().put(key, item, value);
      if (time > 0) {
        expire(key, time);
      }
      return true;
    } catch (Exception e) {
      e.printStackTrace();
      return false;
    }
  }

  
  public void hdel(String key, Object... item) {
    redisTemplate.opsForHash().delete(key, item);
  }

  
  public boolean hHasKey(String key, String item) {
    return redisTemplate.opsForHash().hasKey(key, item);
  }

  // ============================set=============================

  
  public Set