Redis

关注公众号 jb51net

关闭
首页 > 数据库 > Redis > redis获取自增序列号

使用redis获取自增序列号实现方式

作者:留守的小柯基

这篇文章主要介绍了使用redis获取自增序列号实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

前言

Redis作为时下热门的缓存数据库,由于单线程、直接存取与内存中,所以速度很快很高效。redis的使用场景也非常多样化,常见的是作为优秀的缓存中间件,减轻数据库压力。

近期在项目中使用了redis获取有序的序列号,作为业务单号,非常常见,手里的项目有springBoot也有SpringMvc ,所以在此做下总结

项目实例

1.SpringBoot

1.pom文件引入

springBoot有对redis的封装插件,直接按以下引入即可:

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>

2.yml或者properties配置redis连接的相关信息

#redis
spring.redis.host=127.0.0.1
spring.redis.port=6379
spring.redis.timeout=3000
spring.redis.password=shit

3.添加redis配置类,可以实例化redisTemplate,设置缓存失效时间等,以及redis连接池等,这里从简了

@Configuration
public class RedisConfig {
	 
	 @Bean
	 public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory) {
		  StringRedisTemplate template = new StringRedisTemplate(factory);
		  //序列化方式 
		  Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
		  ObjectMapper objectMapper = new ObjectMapper();
		  objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
		  objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
		  jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
		  template.setValueSerializer(jackson2JsonRedisSerializer);
		  template.afterPropertiesSet();
		  return template;
	 }
	 
	 
}

4.按照key获取递增的序列号

@Configuration
public class RedisConfig {
	 
	 @Bean
	 public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory) {
		  StringRedisTemplate template = new StringRedisTemplate(factory);
		  //序列化方式 
		  Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
		  ObjectMapper objectMapper = new ObjectMapper();
		  objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
		  objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
		  jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
		  template.setValueSerializer(jackson2JsonRedisSerializer);
		  template.afterPropertiesSet();
		  return template;
	 }
	 
	 
}

2.springMVC

springMVC通常引入jedis包来进行redis相关的操作,和上诉spring-boot-starter-data-redis相比,jedis封装度更低,更加原生态,操作方式和一些方法更接近于redis命令操作。

1.pom文件引入

        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>2.2.1</version>
        </dependency>

2.redis连接配置

redis.host=127.0.0.1
redis.port=6379
redis.maxWait=1000000
redis.password=shit
redis.maxIdle=300
redis.maxTotal=60000

3.在spring配置文件中实例化对象

    <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
        <property name="maxIdle" value="${redis.maxIdle}"/> 
        <property name="maxActive" value="${redis.maxTotal}"/> 
        <property name="testOnBorrow" value="true"/> 
    </bean>

    <bean id="jedisPool" class="redis.clients.jedis.JedisPool">
        <constructor-arg name="poolConfig" ref="jedisPoolConfig"/>
        <constructor-arg name="host" value="${redis.host}"/>
        <constructor-arg name="port" value="${redis.port}" type="int"/>
        <constructor-arg name="timeout" value="${redis.maxWait}"/>
        <constructor-arg name="password" value="${redis.password}"/>
    </bean>

4.编写一个redis操作的工具类,

@Component
public class JedisUtil {
	 protected final static Logger logger = Logger.getLogger(JedisUtil.class);
	 
	 private static JedisPool jedisPool;
	 
	 @Autowired(required = true)
	 public void setJedisPool(JedisPool jedisPool) {
		  JedisUtil.jedisPool = jedisPool;
	 }
	
     /**
	  * 获取自增的序列号
	  *
	  * @param key redis主键
	  * @return
	  */
	 public static String getIncreNum(String key) {
		  
		  String value = null;
		  Jedis jedis = null;
		  try {
			   jedis = jedisPool.getResource();
			   value = jedis.incrBy(key, 1).toString();
		  } catch (Exception e) {
			   logger.warn("getList " + key + " = " + value);
		  } finally {
			   jedisPool.returnResource(jedis);
		  }
		  return value;
	 }
}

总结

以上未考虑到redis集群的情况,常规生成序列号是够用了,每次获取序列号的时间也在1毫秒左右,非常高效,同时列出其他生成连续号段的方法。

1.取mysql自增主键id,每次插入前查询当前库max(id) ,优点:简单,缺点:增加数据库查询次数,高并发考虑maxid与实际值不一致情况

2.创建序列号的表,存储序列值,通过添加版本号字段或加锁控制写入 优点:准确 缺点:效率低

好了,这些仅为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

您可能感兴趣的文章:
阅读全文