Merge pull request #1 from MyCATApache/master

拉取官方代码

src/main/java/io/mycat/route/function/PartitionByMurmurHash.java

@@ -56,8 +56,6 @@ public class PartitionByMurmurHash extends AbstractPartitionAlgorithm implements
 	private int seed;
 	private int count;
 	private int virtualBucketTimes=DEFAULT_VIRTUAL_BUCKET_TIMES;
-	private Map<Integer,Integer> weightMap=new HashMap<>();
-//	private String bucketMapPath;
 
 	private HashFunction hash;
 
@@ -66,18 +64,7 @@ public class PartitionByMurmurHash extends AbstractPartitionAlgorithm implements
 	public void init()  {
 		try{
 			bucketMap=new TreeMap<>();
-//			boolean serializableBucketMap=bucketMapPath!=null && bucketMapPath.length()>0;
-//			if(serializableBucketMap){
-//				File bucketMapFile=new File(bucketMapPath);
-//				if(bucketMapFile.exists() && bucketMapFile.length()>0){
-//					loadBucketMapFile();
-//					return;
-//				}
-//			}
 			generateBucketMap();
-//			if(serializableBucketMap){
-//				storeBucketMap();
-//			}
 		}catch(Exception e){
 			throw new MurmurHashException(e);
 		}
@@ -87,43 +74,10 @@ private void generateBucketMap(){
 		hash=Hashing.murmur3_32(seed);//计算一致性哈希的对象
 		for(int i=0;i<count;i++){//构造一致性哈希环，用TreeMap表示
 			StringBuilder hashName=new StringBuilder("SHARD-").append(i);
-			for(int n=0,shard=virtualBucketTimes*getWeight(i);n<shard;n++){
+			for(int n=0,shard=virtualBucketTimes;n<shard;n++){
 				bucketMap.put(hash.hashUnencodedChars(hashName.append("-NODE-").append(n)).asInt(),i);
 			}
 		}
-		weightMap=null;
-	}
-//	private void storeBucketMap() throws IOException{
-//		try(OutputStream store=new FileOutputStream(bucketMapPath)){
-//			Properties props=new Properties();
-//			for(Map.Entry entry:bucketMap.entrySet()){
-//				props.setProperty(entry.getKey().toString(), entry.getValue().toString());
-//			}
-//			props.store(store,null);
-//		}
-//	}
-//	private void loadBucketMapFile() throws FileNotFoundException, IOException{
-//		try(InputStream in=new FileInputStream(bucketMapPath)){
-//			Properties props=new Properties();
-//			props.load(in);
-//			for(Map.Entry entry:props.entrySet()){
-//				bucketMap.put(Integer.parseInt(entry.getKey().toString()), Integer.parseInt(entry.getValue().toString()));
-//			}
-//		}
-//	}
-	/**
-	 * 得到桶的权重，桶就是实际存储数据的DB实例
-	 * 从0开始的桶编号为key，权重为值，权重默认为1。
-	 * 键值必须都是整数
-	 * @param bucket
-	 * @return
-	 */
-	private int getWeight(int bucket){
-		Integer w=weightMap.get(bucket);
-		if(w==null){
-			w=DEFAULT_WEIGHT;
-		}
-		return w;
 	}
 	/**
 	 * 创建murmur_hash对象的种子，默认0
@@ -146,34 +100,6 @@ public void setCount(int count) {
 	public void setVirtualBucketTimes(int virtualBucketTimes){
 		this.virtualBucketTimes=virtualBucketTimes;
 	}
-	/**
-	 * 节点的权重，没有指定权重的节点默认是1。以properties文件的格式填写，以从0开始到count-1的整数值也就是节点索引为key，以节点权重值为值。
-	 * 所有权重值必须是正整数，否则以1代替
-	 * @param weightMapPath
-	 * @throws IOException
-	 * @throws
-	 */
-	public void setWeightMapFile(String weightMapPath) throws IOException{
-		Properties props=new Properties();
-		try(BufferedReader reader=new BufferedReader(new InputStreamReader(this.getClass().getClassLoader().getResourceAsStream(weightMapPath), DEFAULT_CHARSET))){
-			props.load(reader);
-			for(Map.Entry entry:props.entrySet()){
-				int weight=Integer.parseInt(entry.getValue().toString());
-				weightMap.put(Integer.parseInt(entry.getKey().toString()), weight>0?weight:1);
-			}
-		}
-	}
-//	/**
-//	 * 保存一致性hash的虚拟节点文件路径。
-//	 * 如果这个文件不存在或是空文件就按照指定的count, weightMapFile等构造新的MurmurHash数据结构并保存到这个路径的文件里。
-//	 * 如果这个文件已存在且不是空文件就加载这个文件里的内容作为MurmurHash数据结构，此时其它参数都忽略。
-//	 * 除第一次以外在之后增加节点时可以直接修改这个文件，不过不推荐这么做。如果节点数量变化了，推荐删除这个文件。
-//	 * 可以不指定这个路径，不指定路径时不会保存murmur hash
-//	 * @param bucketMapPath
-//	 */
-//	public void setBucketMapPath(String bucketMapPath){
-//		this.bucketMapPath=bucketMapPath;
-//	}
 	@Override
 	public Integer calculate(String columnValue) {
 		SortedMap<Integer, Integer> tail = bucketMap.tailMap(hash.hashUnencodedChars(columnValue).asInt());