Redis increment 函数处理并发序列号案例

目录

• 1. 创建Spring Boot项目
• 2. 配置application.yml
• 3. 创建缓存配置类
• 4. 创建服务类
• 5. 创建控制器
• 6. 启动类

1. 创建Spring Boot项目

首先，创建一个新的Spring Boot项目。你可以使用Spring Initializr（https://start.spring.io/）来生成项目结构。选择以下依赖：

• Spring Web
• Spring Data Redis
• Lombok（可选，用于简化代码）

2. 配置application.yml

在你的 ​application.yml​文件中添加Redis配置：

spring:
  cache:
    type: GENERIC
  redis:
    host: ${sy.redis.ip}
    password:
    port: ${sy.redis.port}
    database: ${sy.redis.database}

3. 创建缓存配置类

创建一个配置类来手动配置基于Redis的缓存管理器：

import org.springframework.cache.CacheManager;
import org.springframework.context.annotation.Bean;
imGpgAJRVport org.springframework.context.annotation.phpConfiguration;
import org.springframework.data.redis.cache.RedisCacheConfiguration;
import org.springframework.data.redis.cache.RedisCacheManager;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.serializer.GenericJackson2jsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializationContext;
import Java.time.Duration;
@Configuration
public class CacheConfig {
    @Bean
    public CacheManager cacheManager(RedisConnectionFactory redisConnectionFactory) {
        RedisCacheConfiguration cacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
                .entryTtl(Duration.ofMinutes(10)) // 设置缓存过期时间
                .disableCachingNullValues()
                .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new GenericJackson2JsonRedisSerializer()));
        return RedisCacheManager.builder(redisConnectionFactory)
                .cacheDefaults(cacheConfiguration)
                .build();
    }
}

4. 创建服务类

创建一个服务类来使用Redis的 ​INCR​方法生成每天的序号

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;
import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
@Service
public class SequenceService {
    @Autowired
    private StringRedisTemplate redisjavascriptTemplate;
    public long getDailySequence() {
        String dateStr = DateUtils.format(new Date(), "yyyy-MM-dd");
        String key = "dailySequence_" + dateStr;
        // 执行 increment 操作
        Long applicantNumber = redisTemplate.opsForValue().increment(key);
        // 设置过期时间为2天，不设置默认永久
        redisTemplate.expire(key, 2, TimeUnit.DAYS);
        //redisTemplate.expire(key) // 查询key的过期时间。
        //-1: 表示键存在但没有设置过期时间。
        //-2: 表示键不存在。
        //返回秒：如上面返回值是 172780，这意味着该键将在大约 172780 秒（约 48 小时）后过期。
        return applicantNumber;
    }
}

5. 创建控制器

创建一个控制器来暴露获取每天序号的API：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class SequenceController {
    @Autowired
    private SequenceService sequenceService;
    @GetMapping("/daily-sequence")
    public String getDailySequence() {
        long sequence = sequenceService.getDailySequence();
        return "Daily sequence: " + sequence;
    编程客栈}
}

6. 启动类

确保你的启动类包含 ​@EnableCaching​注解以启用缓存功能：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cache.annotation.EnableCaching;
@SpringBootApplication
@EnableCaching
public class RedisIncrApplication {
    public static void main(String[] args) {
        SpringApplication.run(RedisIncrApplication.class, args);
    }
}

到此这篇关于Redis increment 函数处理并发序列号的编程文章就介绍到这了,更多相关Redis increment 序列号内容请搜索编程客栈(www.devze.com)以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程客栈(www.devze.com)！