Source Code Cross Referenced for PKGenerator.java in  » J2EE » jfox » org » jfox » entity » dao » Java Source Code / Java DocumentationJava Source Code and Java Documentation

001:        /*
002:         * JFox - The most lightweight Java EE Application Server!
003:         * more details please visit http://www.huihoo.org/jfox or http://www.jfox.org.cn.
004:         *
005:         * JFox is licenced and re-distributable under GNU LGPL.
006:         */
007:        package org.jfox.entity.dao;
008:
009:        import java.text.SimpleDateFormat;
010:        import java.util.concurrent.locks.Lock;
011:        import java.util.concurrent.locks.ReentrantLock;
012:        import java.util.Date;
013:        import java.util.Map;
014:        import java.util.HashMap;
015:
016:        /**
017:         * 用�生�唯一的PK
018:         * 该 PK 生�器生� 19 �的唯一 long 值，精确到万分之一秒，
019:         * 最�一�为尾数，用�在集群环境下��PK的唯一性。
020:         *
021:         * 该PK生�虽然�赖于时间，但是在�行过程中改�时间�会影�PK，
022:         * 但是如果将系统时间�调，然��新�动，有�能造�PK��。
023:         *
024:         * 该 PK 生�器��赖于数�库，相比�赖数�表的PK生�器，速度快，而且值�读
025:         *
026:         * @author <a href="mailto:jfox.young@gmail.com">Young Yang</a>
027:         */
028:        public class PKGenerator {
029:            /**
030:             * PK生��，用��定�一时刻�有一个线程进入PK生�计算
031:             */
032:            private final Lock LOCK = new ReentrantLock();
033:
034:            /**
035:             * �始化时的毫秒数，因为该时间会�系统时间的改�而改�，
036:             * 所以计算方法为该时间加上通过 nanoTime 计算出�的时间差
037:             */
038:            private final static Long startMilli = System.currentTimeMillis();
039:
040:            /**
041:             * �始化时的纳秒数，用�计�时间差，nanoTime�会��系统时间的修改而改�
042:             */
043:            private final static long startNano = System.nanoTime();
044:
045:            /**
046:             * 记录上一次生� 的 PK，如果新生�的PK和上次相等，则需��次生�
047:             */
048:            private volatile long lastPK = -1;
049:
050:            private final static SimpleDateFormat dateFormat = new SimpleDateFormat(
051:                    "yyyyMMddHHmmssSSS");
052:
053:            /**
054:             * 返回的long PK的尾数，尾数�以用�在集群环境中判断该PK由哪一个节点产生
055:             * 尾数通过�置设定
056:             */
057:            private int suffix = 0;
058:
059:            private static final Map<Integer, PKGenerator> instanceMap = new HashMap<Integer, PKGenerator>();
060:
061:            //å¿…é¡»æ??供正确的å?‚数，以ä¿?è¯? suffix 在机群环境的唯一性
062:            private PKGenerator(int suffix) {
063:                this .suffix = suffix;
064:            }
065:
066:            public synchronized static PKGenerator getInstance() {
067:                return getInstance(0);
068:            }
069:
070:            /**
071:             * �机环境下，应该��用相�的 suffix
072:             *
073:             * 在集群环境中，ä¸?å?Œçš„机器必须æ??ä¾›ä¸?å?Œçš„ suffix æ?¥ä¿?è¯?生æˆ?çš„ID的唯一性
074:             *
075:             * @param suffix 唯一标识好
076:             */
077:            public synchronized static PKGenerator getInstance(int suffix) {
078:                PKGenerator pkgen;
079:                if (!instanceMap.containsKey(suffix)) {
080:                    pkgen = new PKGenerator(suffix);
081:                    instanceMap.put(suffix, pkgen);
082:                } else {
083:                    pkgen = instanceMap.get(suffix);
084:                }
085:                return pkgen;
086:            }
087:
088:            /**
089:             * 返回下一个 long 型 PK, format: 2006111423361344491 <br>
090:             * yyyyMMddHHmmssSSS + Macro Seconds + suffix
091:             *
092:             * @return long PK
093:             */
094:            public long nextPK() {
095:                LOCK.lock();
096:                try {
097:                    long newPK;
098:                    do {
099:                        long pastNano = System.nanoTime() - startNano; // 纳秒时间差
100:                        long milliTime = pastNano / 1000000; // �得毫秒差
101:                        long macroTime = (pastNano / 100000) % 10; // �得微秒第一�，
102:                        // 计算出�的long PK，精度到万分之一秒（百微妙），加上尾数，一共19�，这是 Long.MAX_VALUE的最大�数了
103:                        newPK = Long.parseLong(dateFormat.format(new Date(
104:                                startMilli + milliTime))
105:                                + macroTime + suffix);
106:                    } while (lastPK == newPK); // 如果生�的相�，则�次计算
107:                    lastPK = newPK; // 设置 lastPK
108:                    return newPK;
109:                } finally {
110:                    LOCK.unlock();
111:                }
112:            }
113:
114:            public static void main(String[] args) throws Exception {
115:                PKGenerator pkg = getInstance(0);
116:                int i = 0;
117:                long now = System.currentTimeMillis();
118:                while (i++ < 1000) {
119:                    System.out.println(pkg.nextPK());
120:                }
121:                System.out.println("Time: "
122:                        + (System.currentTimeMillis() - now));
123:            }
124:        }