<dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-lang3</artifactId>
            <version>3.1</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
            <version>${spring.boot.version}</version>
        </dependency>

server.port=9091
server.servlet.context-path=/

spring.redis.host=127.0.0.1
spring.redis.port=6379
#spring.redis.password=1234
spring.redis.database=0

package com.xiaochun.service;

import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.support.atomic.RedisAtomicLong;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;

@Service
public class SequenceService {

    private static Logger logger = LoggerFactory.getLogger(SequenceService.class);

    @Resource
    private RedisTemplate redisTemplate;

    //用作存放redis中的key
    private static String ORDER_KEY = "order_key";
    
    //生成特定的業(yè)務(wù)編號，prefix為特定的業(yè)務(wù)代碼
    public String getOrderNo(String prefix){
         return getSeqNo(ORDER_KEY, prefix);
    }
    
    //SequenceService類中公用部分，傳入制定的key和prefix
    private String getSeqNo(String key, String prefix)
    {
        Calendar calendar = Calendar.getInstance();
        calendar.set(Calendar.HOUR_OF_DAY, 23);
        calendar.set(Calendar.MINUTE, 59);
        calendar.set(Calendar.SECOND, 59);
        calendar.set(Calendar.MILLISECOND, 999);
        //設(shè)置過期時間，這里設(shè)置為當(dāng)天的23:59:59
        Date expireDate = calendar.getTime();
        //返回當(dāng)前redis中的key的最大值
        Long seq = generate(redisTemplate, key, expireDate);
        //獲取當(dāng)天的日期，格式為yyyyMMdd
        String date = new SimpleDateFormat("yyyyMMdd").format(expireDate);
        //生成八為的序列號，如果seq不夠八位，seq前面補(bǔ)0，
        //如果seq位數(shù)超過了八位，那么無需補(bǔ)0直接返回當(dāng)前的seq
        String sequence = StringUtils.leftPad(seq.toString(), 8, "0");
        if (prefix == null)
        {
            prefix = "";
        }
        //拼接業(yè)務(wù)編號
        String seqNo = prefix + date + sequence;
        logger.info("KEY:{}, 序列號生成:{}, 過期時間:{}", key, seqNo, String.format("%tF %tT ", expireDate, expireDate));
        return seqNo;
    }

    /**
     * @param key
     * @param expireTime <i>過期時間</i>
     * @return
     */
    public static long generate(RedisTemplate<?,?> redisTemplate,String key,Date expireTime) {
        //RedisAtomicLong為原子類，根據(jù)傳入的key和redis鏈接工廠創(chuàng)建原子類
        RedisAtomicLong counter = new RedisAtomicLong(key,redisTemplate.getConnectionFactory());
        //設(shè)置過期時間
        counter.expireAt(expireTime);
        //返回redis中key的值，內(nèi)部實現(xiàn)下面詳細(xì)說明
        return counter.incrementAndGet();
    }

}

public class RedisAtomicLong extends Number implements Serializable, BoundKeyOperations<String> {
    private static final long serialVersionUID = 1L;
    //redis中的key，用volatile修飾，獲得原子性
    private volatile String key;
    //當(dāng)前的key-value對象，根據(jù)傳入的key獲取value值
    private ValueOperations<String, Long> operations;
    //傳入當(dāng)前redisTemplate對象，為RedisTemplate對象的頂級接口
    private RedisOperations<String, Long> generalOps;

    public RedisAtomicLong(String redisCounter, RedisConnectionFactory factory) {
        this(redisCounter, (RedisConnectionFactory)factory, (Long)null);
    }
    private RedisAtomicLong(String redisCounter, RedisConnectionFactory factory, Long initialValue) {
        Assert.hasText(redisCounter, "a valid counter name is required");
        Assert.notNull(factory, "a valid factory is required");
        //初始化一個RedisTemplate對象
        RedisTemplate<String, Long> redisTemplate = new RedisTemplate();
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setValueSerializer(new GenericToStringSerializer(Long.class));
        redisTemplate.setExposeConnection(true);
        //設(shè)置當(dāng)前的redis連接工廠
        redisTemplate.setConnectionFactory(factory);
        redisTemplate.afterPropertiesSet();
        //設(shè)置傳入的key
        this.key = redisCounter;
        //設(shè)置當(dāng)前的redisTemplate
        this.generalOps = redisTemplate;
        //獲取當(dāng)前的key-value集合
        this.operations = this.generalOps.opsForValue();
        //設(shè)置默認(rèn)值，如果傳入為null，則key獲取operations中的value，如果value為空，設(shè)置默認(rèn)值為0
        if (initialValue == null) {
            if (this.operations.get(redisCounter) == null) {
                this.set(0L);
            }
        //不為空則設(shè)置為傳入的值
        } else {
            this.set(initialValue);
        }
    }
    //將傳入key的value+1并返回
    public long incrementAndGet() {
        return this.operations.increment(this.key, 1L);
    }