`
zysnba
  • 浏览: 183807 次
  • 性别: Icon_minigender_1
  • 来自: 北京
文章分类
社区版块
存档分类
最新评论

订单号唯一性

阅读更多
package com.test.util;

import java.util.HashSet;
import java.util.Set;

/**
* Twitter_Snowflake<br>
* SnowFlake的结构如下(每部分用-分开):<br>
* 0 - 0000000000 0000000000 0000000000 0000000000 0 - 00000 - 00000 - 000000000000 <br>
* 1位标识,由于long基本类型在Java中是带符号的,最高位是符号位,正数是0,负数是1,所以id一般是正数,最高位是0<br>
* 41位时间截(毫秒级),注意,41位时间截不是存储当前时间的时间截,而是存储时间截的差值(当前时间截 - 开始时间截)
* 得到的值),这里的的开始时间截,一般是我们的id生成器开始使用的时间,由我们程序来指定的(如下下面程序IdWorker类的startTime属性)。41位的时间截,可以使用69年,年T = (1L << 41) / (1000L * 60 * 60 * 24 * 365) = 69<br>
* 10位的数据机器位,可以部署在1024个节点,包括5位datacenterId和5位workerId<br>
* 12位序列,毫秒内的计数,12位的计数顺序号支持每个节点每毫秒(同一机器,同一时间截)产生4096个ID序号<br>
* 加起来刚好64位,为一个Long型。<br>
* 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();
    }

   
    public static String getOrderNumber(){
    SnowflakeIdWorker idWorker = new SnowflakeIdWorker(0, 0);
             long id = idWorker.nextId();
             return String.valueOf(id);
    }
    //==============================Test=============================================
    /** 测试 */
//    public static void main(String[] args) {
//        SnowflakeIdWorker idWorker = new SnowflakeIdWorker(0, 0);
//        Set<String> set= new HashSet<String>();
//        for (int i = 0; i < 1000000; i++) {
//            long id = idWorker.nextId();
////            System.out.println(Long.toBinaryString(id));
//            set.add(String.valueOf(id));
//            System.out.println(id);
//        }
//        System.out.println(set.size());
//    }
}
分享到:
评论

相关推荐

    银联订单号永远不会重复的生成算法分析与示例20170224

    ### 银联订单号永不重复的生成算法分析 ...尤其是在大型交易系统中,这种算法能够很好地满足订单号唯一性的需求。未来随着业务规模的扩大和技术的发展,对于订单号生成机制的研究也将不断深入和完善。

    订单号生成工具类

    订单号生成工具类是软件开发中的一个重要组成部分,特别是在电商、金融等业务中,订单号的唯一性和可追溯性是至关重要的。一个良好的订单号生成机制能够确保每笔交易的唯一标识,便于数据跟踪和管理。下面我们将深入...

    JAVA生成订单号(日期+流水号)

    4. **递增性与唯一性**:为了保证订单号的递增性,需要在生成新订单号时确保上一次生成的订单号已被正确记录和更新。如果是在数据库中存储订单号,每次生成新的订单号之前,需要查询最新的订单号并在此基础上增加。...

    magento插件-将订单号改为日期流水号

    在电子商务运营中,订单号的隐私性和唯一性是至关重要的。"magento插件-将订单号改为日期流水号"这个插件就是为了满足这一需求而设计的。 首先,我们来了解一下Magento的默认订单号系统。在Magento中,每个订单都会...

    订单号的生成redis中获取

    在IT行业中,订单号的生成是一项关键任务,它确保了交易的唯一性和可追溯性。在给定的标题“订单号的生成redis中获取”中,我们可以推断这是一个关于利用Redis来生成订单号的实践。Redis是一个高性能的键值存储系统...

    银联订单号永远不会重复的生成算法分析与示例

    银联订单号生成算法是为了确保在高并发环境下生成的订单号具有唯一性,同时考虑到16位数字的限制。在设计此类算法时,主要需要解决以下几个问题:避免数据库同步问题、时间精度与位数限制、数据库自增字段的并发压力...

    并发生成重复订单号1

    并发生成重复订单号是一个典型的多线程同步问题,特别是在高并发的电商系统中,确保订单号的唯一性至关重要。以下是对相关知识点的详细说明: 1. **订单号生成策略**: - 订单号通常由日期和序列号组成,如`"yyyy-...

    c#后台生成不重复的订单号及后台存储过程

    根据提供的标题、描述、标签以及部分内容...通过这两种不同的方法,我们可以生成多种格式的订单号,满足业务需求的同时确保数据的唯一性和准确性。此外,使用枚举类型、存储过程等方式可以提高代码的可维护性和扩展性。

    订单号随机生成器

    日期和时间戳确保了每个订单号的唯一性,因为它们反映了订单创建的时间。序列号则是在同一时间间隔内区分不同订单的额外标识,可以是纯数字或包含字母,以增加可读性和防止冲突。 在生成随机订单号的过程中,开发者...

    PHP生成唯一订单号

    一个良好的订单号生成策略可以保证订单的唯一性,避免因为订单号重复造成的数据错误和管理混乱。 在提供的文件中,介绍了两种生成唯一订单号的方法。这两种方法都使用了日期、时间戳、微秒数和随机数等元素来构建一...

    java web在高并发和分布式下实现订单号生成唯一的解决方案

    这个方案可以保证订单号的唯一性,并且能够适应高并发和分布式环境。 方案三:使用 Redis 的原子递增 在高并发和分布式环境下,我们可以使用 Redis 的原子递增来生成唯一的订单号。这个方案可以保证订单号的唯一性...

    淘气支付系统商户接入手册1

    - **订单号唯一性**:`shop_order_no`必须确保全局唯一,防止重复充值。 - **回调处理**:收到回调后,务必正确响应,避免重复处理订单。 - **跳转判断**:不要仅依赖用户跳转判断支付成功,应结合服务器端的订单...

    magento订单号的修改

    其中,订单号的管理是电商运营中的一个重要环节,它不仅涉及到数据的唯一性、连续性和可追溯性,还可能与企业的业务流程、财务系统以及客户体验紧密相关。本文将深入探讨如何在Magento中实现订单号的自由修改,特别...

    java中的zookeeper

    `04_多线程生成订单号.docx`虽然名字中没有明确提到ZooKeeper,但考虑到上下文,可能是使用ZooKeeper实现多线程环境下的订单号唯一性,通过分布式锁保证在高并发场景下不会生成重复订单号。 综上所述,Java中的...

    C#如何生成唯一订单号

    在C#编程中,生成唯一的订单号是许多业务系统中的常见需求,这通常涉及到数据库操作、并发控制以及数据完整性。本文将深入探讨如何在C#中实现这一功能,特别是使用提供的代码实例。 首先,让我们理解生成唯一订单号...

    PHP生成唯一订单号的方法汇总_.docx

    它将当前日期转换为字符串,然后将随机数填充到字符串中,以保证订单号码的唯一性。 代码如下: ```php return date('Ymd') . str_pad(mt_rand(1, 99999), 5, '0', STR_PAD_LEFT); ``` 第二种方法:使用唯一标识符 ...

    java写的网上定餐系统

    在处理支付回调时,需注意防止重复支付问题,这通常通过订单号唯一性和交易状态双重校验来实现。 安全性方面,系统应具备防止SQL注入、XSS攻击的能力,这可以通过使用预编译SQL、参数化查询以及过滤用户输入来实现...

    支付宝接口(ASP)

    例如,通过订单号唯一性、支付状态校验等手段确保交易安全。 9. **页面跳转与回调处理**: 用户支付成功后,支付宝会将用户重定向回商家设定的页面。开发者需要在ASP中处理这个跳转,展示合适的页面信息。 10. **...

    Android-给集群环境下生产一定命名规范下的id如订单号等

    在Android开发中,特别是在大型分布式系统环境中,生成具有特定命名规范的唯一ID,例如订单号,是一项关键任务。这样的ID不仅需要确保全局唯一性,还要符合业务规则,以便于跟踪和管理。在这种背景下,"Android-给...

Global site tag (gtag.js) - Google Analytics