本文是基于jedis的一致性環(huán)哈希來修改的，.net選的是servicestack.redis組件來修改

無奈兩個(gè)組件都有各自的一致性環(huán)哈希算法，不兼容，那就選一個(gè)作為標(biāo)準(zhǔn)，修改另一個(gè)咯。本文選擇jedis的一致性環(huán)哈希作為標(biāo)準(zhǔn)，進(jìn)而修改.net來適應(yīng)jedis

jedis的邏輯是給每個(gè)redis節(jié)點(diǎn)構(gòu)造160個(gè)虛擬節(jié)點(diǎn)，放入一顆二叉樹中(key/value：key是一個(gè)long值，根據(jù)哈希算法算出來的一個(gè)long、value是節(jié)點(diǎn)id，是個(gè)string)。

OK，邏輯清楚了，那就簡單了，給c#端寫個(gè)一模一樣的一致性環(huán)哈希算法。

public?class?Sharded

{????????private?object?nodes_lock?=?new?object();????????private?RedBlackTreeMap?nodes?=?new?RedBlackTreeMap();????????private?IHash?hashAlgo?=?new?MD5_LongSUM_Multiply_Hash();

public?void?AddTarget(int?index,?string?shard)

{????????????lock?(nodes_lock)

{????????????????for?(int?n?=?0;?n?

{????????????????????var?hashKey?=?"SHARD-"?+?index?+?"-NODE-"?+?n;????????????????????long?hashValue?=?this.hashAlgo.Hash(hashKey);

nodes.SetOrAddValue(hashValue,?shard);

}

}

}????????public?string?GetShardInfo(string?key)

{????????????long?searchHashKey?=?this.hashAlgo.Hash(key);????????????long?nearestKey;????????????string?shard;????????????lock?(nodes_lock)

{????????????????if?(this.nodes.NearestGreater(searchHashKey,?out?nearestKey))

{

shard?=?this.nodes.GetValue(nearestKey);????????????????????return?shard;

}????????????????if?(this.nodes.Least(out?searchHashKey,?out?shard))????????????????????return?shard;

}????????????throw?new?Exception("GetShardInfo?exception");

}

}

其中RedBlackTreeMap這個(gè)是TreeLib中的組件，需要在nuget上引用。

MD5_LongSUM_Multiply_Hash，這是個(gè)MD5算法，輸入為string，輸出為long。

此處由于考慮到輸出不是string，因此自己又改了改，讓他輸出long

public?class?MD5_LongSUM_Multiply_Hash?:?IHash

{????????public?long?Hash(string?key)

{????????????var?md5=?Md5Hash(key);????????????if?(string.IsNullOrEmpty(md5))

Log.GetLog().Info("Hash,?md5?is?null?or?empty");????????????var?convertedKeyBytes?=?Encoding.UTF8.GetBytes(md5);

long?value?=?1;????????????foreach(var?b?in?convertedKeyBytes)

value?*=?b*-1;????????????return?value;

}????????private?string?Md5Hash(string?input)

{

MD5CryptoServiceProvider?md5Hasher?=?new?MD5CryptoServiceProvider();????????????if?(string.IsNullOrEmpty(input))

Log.GetLog().Info("Md5Hash,?input?is?null?or?empty");????????????byte[]?data?=?md5Hasher.ComputeHash(Encoding.Default.GetBytes(input));

StringBuilder?sBuilder?=?new?StringBuilder();????????????for?(int?i?=?0;?i?

{

sBuilder.Append(data[i].ToString("x2"));

}????????????return?sBuilder.ToString();

}

}

剩下的就是java端的這個(gè)輸入string，輸出long的算法，需要和.net的輸入輸出一致了。

那就也寫一個(gè)哈希算法，讓他輸入string，輸出long，和.net的一致，這里只要java/.net用同一種md5算法，后續(xù)的md5變成long就很容易了。

import?org.springframework.security.authentication.encoding.MessageDigestPasswordEncoder;import?redis.clients.util.Hashing;import?redis.clients.util.SafeEncoder;import?java.io.UnsupportedEncodingException;/**

*?Created?by?z?on?2017/4/12.?*/public?class?MD5_SUM_Hash?implements?Hashing?{

MessageDigestPasswordEncoder?encoder=new?MessageDigestPasswordEncoder("MD5");????public?long?hash(String?key)?{????????return?this.hash(SafeEncoder.encode(key));

}????public?long?hash(byte[]?bytes)?{

String?converted_str=?null;????????try?{

converted_str?=?new?String(bytes,?"UTF8");

}?catch?(UnsupportedEncodingException?e)?{

e.printStackTrace();

}

String?result=encoder.encodePassword(converted_str,?null);????????try?{

bytes=result.getBytes("UTF8");

}?catch?(UnsupportedEncodingException?e)?{

e.printStackTrace();

}????????long?value?=?1;????????for(byte?b?:?bytes)

value?*=?b*-1;????????return?value;

}

}

org.springframework.security

spring-security-core

總結(jié)

以上是生活随笔為你收集整理的java .net 互通redis_C# servicestack.redis 互通 java jedis的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。