主键生成方式-白红宇

主键生成方式

阅读量：6304 次

发布时间：2019-06-22

本文共 6245 字，大约阅读时间需要 20 分钟。

一.COMB生成方式

COMB数据类型的基本设计思路是这样的：既然GUID数据因毫无规律可言造成索引效率低下，影响了系统的性能，那么能不能通过组合的方式，保留GUID的10个字节。

用另6个字节表示GUID生成的时间（DateTime），这样我们将时间信息与GUID组合起来，在保留GUID的唯一性的同时增加了有序性，以此来提高索引效率。

private Guid GenerateComb()  {      byte[] guidArray = Guid.NewGuid().ToByteArray();         DateTime baseDate = new DateTime(1900, 1, 1);      DateTime now = DateTime.Now;         // Get the days and milliseconds which will be used to build         //the byte string          TimeSpan days = new TimeSpan(now.Ticks - baseDate.Ticks);      TimeSpan msecs = now.TimeOfDay;         // Convert to a byte array              // Note that SQL Server is accurate to 1/300th of a         // millisecond so we divide by 3.333333          byte[] daysArray = BitConverter.GetBytes(days.Days);      byte[] msecsArray = BitConverter.GetBytes((long)        (msecs.TotalMilliseconds / 3.333333));         // Reverse the bytes to match SQL Servers ordering         Array.Reverse(daysArray);      Array.Reverse(msecsArray);         // Copy the bytes into the guid          Array.Copy(daysArray, daysArray.Length - 2, guidArray,        guidArray.Length - 6, 2);      Array.Copy(msecsArray, msecsArray.Length - 4, guidArray,        guidArray.Length - 4, 4);         return new Guid(guidArray);  }

结论：适合大型应用。即保留GUID的唯一性的同时增加了GUID有序性，提高了索引效率；解决了关联表业务问题；生成的Id不够友好；占据了32位。（强烈推荐）

二.twitter的SnowflakeIdWorker算法

该方式比较适合分布式项目

/** * Twitter_Snowflake
 * SnowFlake的结构如下(每部分用-分开):
 * 0 - 0000000000 0000000000 0000000000 0000000000 0 - 00000 - 00000 - 000000000000 
 * 1位标识，由于long基本类型在Java中是带符号的，最高位是符号位，正数是0，负数是1，所以id一般是正数，最高位是0
 * 41位时间截(毫秒级)，注意，41位时间截不是存储当前时间的时间截，而是存储时间截的差值（当前时间截 - 开始时间截) * 得到的值），这里的的开始时间截，一般是我们的id生成器开始使用的时间，由我们程序来指定的（如下下面程序IdWorker类的startTime属性）。41位的时间截，可以使用69年，年T = (1L << 41) / (1000L * 60 * 60 * 24 * 365) = 69
 * 10位的数据机器位，可以部署在1024个节点，包括5位datacenterId和5位workerId
 * 12位序列，毫秒内的计数，12位的计数顺序号支持每个节点每毫秒(同一机器，同一时间截)产生4096个ID序号
 * 加起来刚好64位，为一个Long型。
 * SnowFlake的优点是，整体上按照时间自增排序，并且整个分布式系统内不会产生ID碰撞(由数据中心ID和机器ID作区分)，并且效率较高，经测试，SnowFlake每秒能够产生26万ID左右。 */public class SnowflakeIdWorker {    // ==============================Fields===========================================    /**     * 开始时间截 (2015-01-01)     */    private final long twepoch = 1420041600000L;    /**     * 机器id所占的位数     */    private final long workerIdBits = 5L;    /**     * 数据标识id所占的位数     */    private final long datacenterIdBits = 5L;    /**     * 支持的最大机器id，结果是31 (这个移位算法可以很快的计算出几位二进制数所能表示的最大十进制数)     */    private final long maxWorkerId = -1L ^ (-1L << workerIdBits);    /**     * 支持的最大数据标识id，结果是31     */    private final long maxDatacenterId = -1L ^ (-1L << datacenterIdBits);    /**     * 序列在id中占的位数     */    private final long sequenceBits = 12L;    /**     * 机器ID向左移12位     */    private final long workerIdShift = sequenceBits;    /**     * 数据标识id向左移17位(12+5)     */    private final long datacenterIdShift = sequenceBits + workerIdBits;    /**     * 时间截向左移22位(5+5+12)     *     */    private final long timestampLeftShift = sequenceBits + workerIdBits + datacenterIdBits;    /**     * 生成序列的掩码，这里为4095 (0b111111111111=0xfff=4095)     */    private final long sequenceMask = -1L ^ (-1L << sequenceBits);    /**     * 工作机器ID(0~31)     */    private long workerId;    /**     * 数据中心ID(0~31)     */    private long datacenterId;    /**     * 毫秒内序列(0~4095)     */    private long sequence = 0L;    /**     * 上次生成ID的时间截     */    private long lastTimestamp = -1L;    //==============================Constructors=====================================    /**     * 构造函数     *     * @param workerId     工作ID (0~31)     * @param datacenterId 数据中心ID (0~31)     */    public SnowflakeIdWorker(long workerId, long datacenterId) {        if (workerId > maxWorkerId || workerId < 0) {            throw new IllegalArgumentException(String.format("worker Id can't be greater than %d or less than 0", maxWorkerId));        }        if (datacenterId > maxDatacenterId || datacenterId < 0) {            throw new IllegalArgumentException(String.format("datacenter Id can't be greater than %d or less than 0", maxDatacenterId));        }        this.workerId = workerId;        this.datacenterId = datacenterId;    }    // ==============================Methods==========================================    /**     * 获得下一个ID (该方法是线程安全的)     *     * @return SnowflakeId     */    public synchronized long nextId() {        long timestamp = timeGen();        //如果当前时间小于上一次ID生成的时间戳，说明系统时钟回退过这个时候应当抛出异常        if (timestamp < lastTimestamp) {            throw new RuntimeException(                    String.format("Clock moved backwards.  Refusing to generate id for %d milliseconds", lastTimestamp - timestamp));        }        //如果是同一时间生成的，则进行毫秒内序列        if (lastTimestamp == timestamp) {            sequence = (sequence + 1) & sequenceMask;            //毫秒内序列溢出            if (sequence == 0) {                //阻塞到下一个毫秒,获得新的时间戳                timestamp = tilNextMillis(lastTimestamp);            }        }        //时间戳改变，毫秒内序列重置        else {            sequence = 0L;        }        //上次生成ID的时间截        lastTimestamp = timestamp;        //移位并通过或运算拼到一起组成64位的ID        return ((timestamp - twepoch) << timestampLeftShift) //                | (datacenterId << datacenterIdShift) //                | (workerId << workerIdShift) //                | sequence;    }    /**     * 阻塞到下一个毫秒，直到获得新的时间戳     *     * @param lastTimestamp 上次生成ID的时间截     * @return 当前时间戳     */    protected long tilNextMillis(long lastTimestamp) {        long timestamp = timeGen();        while (timestamp <= lastTimestamp) {            timestamp = timeGen();        }        return timestamp;    }    /**     * 返回以毫秒为单位的当前时间     *     * @return 当前时间(毫秒)     */    protected long timeGen() {        return System.currentTimeMillis();    }    //==============================Test=============================================    /**     * 测试     */    public static void main(String[] args) {        SnowflakeIdWorker idWorker = new SnowflakeIdWorker(0, 0);        for (int i = 0; i < 100; i++) {            Integer id = (int)idWorker.nextId();//            System.out.println(Long.toBinaryString(id));            System.out.println(id);        }        System.out.println(System.currentTimeMillis());    }}