java如何根據(jù)時(shí)間戳生成有序ID

更新時(shí)間：2024年04月15日 10:01:57 作者：紫金丨小飛俠

這篇文章主要介紹了java如何根據(jù)時(shí)間戳生成有序ID問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

引言

我們常用的主鍵有這么幾種

1. 數(shù)據(jù)庫(kù)自增主鍵，比如mysql的autoincrement，這種插入快，但是識(shí)別度不高

2. uuid 這個(gè)號(hào)稱是全球唯一的，但是無(wú)序，沒(méi)有實(shí)際意義，只能保證唯一

3. 時(shí)間戳，這種在分布式的場(chǎng)景下就需要考慮更多種情況

4. 雪花算法 snow flake ，分布式全局唯一主鍵，很牛，但是我覺(jué)得用起來(lái)也挺麻煩哈哈哈

所以在并發(fā)情況沒(méi)那么大的時(shí)候用一個(gè)工具類(lèi)搞定，我就是這么懶

工具類(lèi)

@Slf4j
public class NumUtil {

    private static long tmpID = 0;
    private static final long LOCK_TIME = 1;
    private static final long INCREASE_STEP = 1;
    private static SimpleDateFormat sdf = new SimpleDateFormat("yyMMddHHmmssSSS");
    private static final Lock LOCK = new ReentrantLock();


    public static long nextPkId() throws InterruptedException {
        //當(dāng)前：（年、月、日、時(shí)、分、秒、毫秒）
        long timeCount;
        if (LOCK.tryLock(LOCK_TIME, TimeUnit.SECONDS)) {
            timeCount = Long.parseLong(sdf.format(new Date()));
            try {
                if (tmpID < timeCount) {
                    tmpID = timeCount;
                } else {
                    tmpID += INCREASE_STEP;
                    timeCount = tmpID;
                }
                return timeCount;
            } finally {
                LOCK.unlock();
            }
        } else {
            log.error("lock failed");
            return nextPkId();

        }
    }
}

貼上代碼，這里用了當(dāng)前時(shí)間，精確到毫秒級(jí)，如果有需要的話可以在實(shí)例化timeCount的時(shí)候乘以10或者100 1000之類(lèi)的，這個(gè)看大家，然后加上鎖，防止線程不安全的情況，加鎖失敗的時(shí)候遞歸，再來(lái)一次。

也可以使用synchronized做成同步方法，當(dāng)中的區(qū)別下次再討論。

有評(píng)論說(shuō)宕機(jī)會(huì)導(dǎo)致tmpID歸0導(dǎo)致已經(jīng)使用過(guò)超出當(dāng)前時(shí)間的ID，所以持久化這個(gè)tmpID也是可以的。

但這也就是在并發(fā)沒(méi)那么高的情況下才使用這種方法，一般并發(fā)場(chǎng)景下還是分布式鎖+推特的雪花算法解決。

測(cè)試

public static void numTest() {
        ExecutorService executorService = Executors.newCachedThreadPool();
        int n = 10000;
        List<Long> list = new ArrayList<>();
        CountDownLatch latch = new CountDownLatch(n);
        for (int i = 0; i < n; i++) {
            executorService.execute(() -> {
                //執(zhí)行業(yè)務(wù)請(qǐng)求
                try {
                    list.add(NumUtil.nextPkId());
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                latch.countDown();
            });
        }
        try {
            // 一定記得加上timeout時(shí)間，防止阻塞主線程
            latch.await(3000, TimeUnit.MILLISECONDS);
        } catch (InterruptedException e) {
            log.error(e.getMessage());
        }
        //4.等待所有子任務(wù)完成，組裝內(nèi)容
        while (list.size() < n) {
            log.info("集合長(zhǎng)度 >>> {}",list.size());
        }
        //5.關(guān)閉線程池
        executorService.shutdown();

        for (Long aLong : list) {
            System.out.println(aLong);
        }
    }

然后噼里啪啦打印了一萬(wàn)個(gè)ID，沒(méi)有重復(fù)的，一秒以內(nèi)生成