Java集群环境下全局唯一流水ID生成方法之一

package com.pfq.deal.risk.util;

import java.net.InetAddress;
import java.net.UnknownHostException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashSet;
import java.util.List;
import java.util.Random;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * 生成30位唯一数: yyyyMMddHHmmssSSS+服务器IP后5位+3位递增序号+5位随机数
 * 如果将系统部署到集群上面，情况有会有不同了，不同的服务器集群生成的这个数字，是有重合的概率的，
 * 因此，一般情况是，将集群中的每个机器进行IP编码，然后将机器编码放在这个标识中以示区分
 * 
 * @author Dabria_ly 2017年8月24日
 */
public class Uidutil {
	private static final Logger LOG = LoggerFactory.getLogger(Uidutil.class);
	private static String no = "0";
	private static String dateValue = "";//默认精确到毫秒的比对时间
	private static Random rand = new Random();


	public static synchronized String next() throws UnknownHostException {
		String ipStr = InetAddress.getLocalHost().getHostAddress();// 获取本机IP
		ipStr = ipStr.substring(ipStr.indexOf("." + 2)).replace(".", "");
		if(ipStr.length() > 5){
			ipStr = ipStr.substring(0, 5);
		}
		String dateStr = new SimpleDateFormat("yyyyMMddHHmmssSSS").format(new Date());
		String num = new StringBuilder().append(dateStr)
				                        .append(ipStr).toString();
		if (!(String.valueOf(dateStr)).equals(dateValue)) {//不是同一个时段，从0开始递增序号
			no = "0";
			dateValue = dateStr;
		}
		num += getNo(no, num);
		return num;
	}


	/**
	 * 返回当前序号+1
	 */
	public static String getNo(String noCount, String num) {
		long i = Long.parseLong(noCount);
		i += 1;
		noCount = "" + i;
		for (int j = noCount.length(); j < 25 - num.length(); j++) {
			noCount = "0" + noCount;
		}
		no = noCount;
		return noCount;
	}


	/**
	 * 利用Set中不允许有重复的元素的特性，来判断集合元素中是否有重复元素
	 * 
	 * @param list:被判断的集合
	 * @return false:有重复元素或list为null; true:没有重复元素
	 */
	private static boolean hasSame(List<? extends Object> list) {
		if (null == list)
			return false;
		return list.size() == new HashSet<Object>(list).size();
	}
	
	/**
	 * next()+5位随机数
	 * @return
	 * @throws UnknownHostException
	 */
	public static String getTransactionId() throws UnknownHostException{
		return new StringBuilder().append(next())
		.append(String.valueOf(rand.nextInt(99999 - 10000 + 1) + 10000)).toString();
	}


	public static void main(String[] args) {
		final List<String> guidList = new ArrayList<String>();
		for (int i = 0; i < 10; i++) {// 开启10个线程
			new Thread(new Runnable() {
				@Override
				public void run() {
					for (int j = 0; j < 10000; j++) {// 每个线程循环1w条数据
						try {
							String guid = getTransactionId();
							System.out.println("guid="+guid+",length="+guid.length());
							guidList.add(guid);
						} catch (UnknownHostException e) {
							LOG.error("未知主机IP错误-->【{}】", e);
						}
					}


				}


			}).start();
		}


		try {
			Thread.sleep(30000);// sleep 30秒
			LOG.info("集合个数-->【{}】", guidList.size());
			LOG.info("没有重复元素-->【{}】", hasSame(guidList));
		} catch (InterruptedException e) {
			LOG.error("sleep error-->【{}】", e);
		}
	}
}