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

 更新时间:2023年12月07日 09:58:43   作者:留守的小柯基  
这篇文章主要介绍了使用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.创建序列号的表,存储序列值,通过添加版本号字段或加锁控制写入 优点:准确 缺点:效率低

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

相关文章

  • redis发布订阅_动力节点Java学院整理

    redis发布订阅_动力节点Java学院整理

    这篇文章主要介绍了redis发布订阅,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-08-08
  • Redis教程(一):Redis简介

    Redis教程(一):Redis简介

    这篇文章主要介绍了Redis教程(一):Redis简介,本文是系列文章的第一篇,欢迎大家跟随本教程学习Redis数据库,需要的朋友可以参考下
    2015-04-04
  • Redis分布式锁的正确实现方法总结

    Redis分布式锁的正确实现方法总结

    在本篇文章里小编给大家整理的是关于Redis分布式锁的正确实现方式介绍,有兴趣的朋友们可以学习下。
    2020-02-02
  • redis如何取hash的值

    redis如何取hash的值

    这篇文章主要介绍了redis如何取hash的值问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-01-01
  • redis发布订阅模式的实现

    redis发布订阅模式的实现

    本文主要介绍了redis发布订阅模式,Redis 的 SUBSCRIBE 命令可以让客户端订阅任意数量的频道,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起学习学习吧
    2024-04-04
  • Redis队列和阻塞队列的实现

    Redis队列和阻塞队列的实现

    本文主要介绍了Redis队列和阻塞队列的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2023-11-11
  • Redis Lua同步锁实现源码解析

    Redis Lua同步锁实现源码解析

    这篇文章主要为大家介绍了Redis Lua同步锁实现源码解析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-05-05
  • Redis缓存-序列化对象存储乱码问题的解决

    Redis缓存-序列化对象存储乱码问题的解决

    这篇文章主要介绍了Redis缓存-序列化对象存储乱码问题的解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-06-06
  • Redis3.2开启远程访问详细步骤

    Redis3.2开启远程访问详细步骤

    redis默认只允许本地访问,要使redis可以远程访问可以修改redis.conf
    2018-03-03
  • Redis序列化存储及日期格式的问题处理

    Redis序列化存储及日期格式的问题处理

    这篇文章主要介绍了Redis序列化存储及其日期格式的问题处理方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-12-12

最新评论