在读写操作比较均匀且实时性要求较高,可以用下图的分布式模式：
在读操作远远多于写操作时,可以用下图的分布式模式：
package?com.jd.redis.client;
import?java.util.ArrayList;
import?java.util.List;
import?redis.clients.jedis.JedisPoolConfig;
import?redis.clients.jedis.JedisShardInfo;
import?redis.clients.jedis.ShardedJedis;
import?redis.clients.jedis.ShardedJedisPool;
import?redis.clients.util.Hashing;
import?redis.clients.util.Sharded;
publicclass?RedisShardPoolTest {
static?ShardedJedisPoolpool;
static{
JedisPoolConfig config =new?JedisPoolConfig();//Jedis池配置
config.setMaxWait(1000 * 10);//获取对象时最大等待时间
config.setTestOnBorrow(true);
JedisShardInfo infoA =?new?JedisShardInfo(hostA, portA);
JedisShardInfo infoB =?new?JedisShardInfo(hostB, portB);
jdsInfoList.add(infoA);
jdsInfoList.add(infoB);
pool?=new?ShardedJedisPool(config, jdsInfoList, Hashing.MURMUR_HASH,
Sharded.DEFAULT_KEY_TAG_PATTERN);
}
/**
*?@param?args
*/
publicstaticvoid?main(String[] args) {
for(int?i=0; i<100; i++){
String key =generateKey();
ShardedJedis jds =null;
try?{
jds =pool.getResource();
}catch?(Exception e) {
e.printStackTrace();
finally{
pool.returnResource(jds);
privatestaticintindex?= 1;
publicstatic?String generateKey(){
从运行结果中可以看到,不同的key被分配到不同的Redis-Server上去了.
（如果亲还是不信的话,可以将上面程序中的?jdsInfoList在add的时候,先add第二个,在add第一个,绝对取不出数据,原因很简单,第一次set值的时候,是按list下标来hash计算出一个服务器的,所以取值的时候,list顺序不能变动）
实际上,上面的集群模式还存在两个问题：
①? 扩容问题：
A.? 在新的物理机上运行Redis-Server；
B.?? 该Redis-Server从属于(slaveof)分片列表中的某一Redis-Server（假设叫RedisA）；
D.? 停止RedisA.
这样相当于将某一Redis-Server转移到了一台新机器上.Prd-Sharding实际上是一种在线扩容的办法,但还是很依赖Redis本身的复制功能的,如果主库快照数据文件过大,这个复制的过程也会很久,同时会给主库带来压力.所以做这个拆分的过程最好选择为业务访问低峰时段进行.
以上就是土嘎嘎小编为大家整理的redis 集群以及扩容方面的内容相关主题介绍,如果您觉得小编更新的文章只要能对粉丝们有用,就是我们最大的鼓励和动力,不要忘记讲本站分享给您身边的朋友哦！！