redis支持master-slave模式,可以设置一个master,多个slave;采用读写分离的策略,master负责写数据,多个slave负责读数据,slave的数据是复制master上的,所以多个slave之间的数据是可以保持一致的,即便down了之后,也会通过加载dump数据的方式,重新加载会原来的缓存数据。
Fail-Tolerance
当前项目需要保证一个client连接到slave服务上读取数据,如果slave down 了之后,可以在不影响应用的情况下,自动切换到另外一个可用的slave
因为jredis不支持设置多个slave服务器,所以写了一个小工具类,目的是为了探测如果的当前正在使用的slave没有heartbeat之后,立马可以切换到一个可用的slave;这样可以保证one of slave down掉之后,不用missing-load也可及时切换到另外一个slave上读数据。
public class RedisFailToleranceUtil {
private static JRedisService jredisService = null;
private static ConnectionSpec defaultConnectionSpec = null;
private static int current = 1;
private static HashMap<String,ConnectionSpec> serverPools = new HashMap<String,ConnectionSpec>();
static{
ConnectionSpec connectionSpec1 = DefaultConnectionSpec.newSpec("192.168.1.238", 6380, 0,null);
ConnectionSpec connectionSpec2 = DefaultConnectionSpec.newSpec("192.168.1.238", 6381, 0,null);
serverPools.put("1", connectionSpec1);
serverPools.put("2", connectionSpec2);
}
private String next(){
if(current>serverPools.size()){
current=1;
}
int nextIndex = current;
current++;
return nextIndex+"";
}
private ConnectionSpec getConnectionSpec(){
if(defaultConnectionSpec != null){
return defaultConnectionSpec;
}
jredisService = null;
/**
* we are working multiple servers
* try different servers,util we fetch the first available server pool
*/
HashMap<String,ConnectionSpec> tryServers = new HashMap<String,ConnectionSpec>(serverPools);
if(serverPools.size() == 1){
return (ConnectionSpec)serverPools.get("1");
}
while(!tryServers.isEmpty()){
ConnectionSpec connectionSpec = tryServers.get(this.next());
if(isConnect(connectionSpec)){
return connectionSpec;
}
tryServers.remove(connectionSpec);
if(tryServers.isEmpty()){
break;
}
}
return null;
}
/**
* try whether the server is available
* @param connectionSpec
* @return true or false
*/
private boolean isConnect(ConnectionSpec connectionSpec){
if(connectionSpec == null){
return false;
}
JRedis jredis = new JRedisClient(connectionSpec.getAddress().getHostAddress(), connectionSpec.getPort());
try{
jredis.ping();
jredis.quit();
}catch(Exception e){
return false;
}
return true;
}
public void initialize(){
defaultConnectionSpec = this.getConnectionSpec();
if(jredisService == null){
synchronized (RedisFailToleranceUtil.class) {
jredisService = new JRedisService(defaultConnectionSpec,100);
}
}
}
public String getS(String key){
this.initialize();
String value = null;
try {
value = DefaultCodec.toStr(jredisService.get(key));
} catch (Exception e) {
defaultConnectionSpec = null;
this.initialize();
}
return value;
}
public static void main(String args[]){
RedisFailToleranceUtil redis = new RedisFailToleranceUtil();
redis.getS("name");
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
redis.getS("name");
try {
Thread.sleep(30000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
redis.getS("name");
}
}
分享到:
相关推荐
Mechanical tolerance stackup and analysis(公差叠加及分析)
Tolerance机械公差查询工具
fault tolerance in computer system design
Tolerance是一款机械计算机辅助设计软件。该软件的宗旨是最大程度减轻机械设计工程师的工作强度。软件的开发目标是提供机械设计中各种机械公差的查询和综合、快速地相关设计计算,帮助设计人员提高设计质量和效率。
Mechanica_Tolerance_Stackup_And_Analysis
Software Fault Tolerance Techniques and Implementation
tolerance.pdf
Tolerance机械公差查询软件 用户手册 软硬件环境 1 软件环境 Windows 操作系统:Windows98/Me或Windows NT4.0/2000/XP/2003。 Solidworks:2001PLUS及以上版本。(仅在要求使用本软件的Solidworks辅助功能时)...
机械制造-Tolerance Manager公差分析及优化设计管理软件介绍.pdf
02公差累加分析Tolerance Stackup培训大纲 新
使用MATLAB进行电子电路的容差分析
MITCalc用于进行尺寸公差分析的模块,适用于Excel2013。
Security and Fault Tolerance in Internet of Things By 作者: Rajat Subhra Chakraborty ISBN-10 书号: 3030028062 ISBN-13 书号: 9783030028060 Edition 版本: 1st ed. 2019 出版日期: 2019-01-04 pages 页数: ...
Tolerance Analysis(公差分析)
非常好用的机械设计公差查询软件,减少经常翻工具书的苦恼
A Tutorial on Reed-Solomon Coding for Fault-Tolerance in RAID-like Systems
一个公差查询软件,可以查询形位公差、齿轮、轴承等公差,方便实用,建议下载
JMP应用-试验设计(DOE)之公差设计(Tolerance Design)应用教程.f4v
几何形位公差,GD&T,机械工程及汽车行业图纸解读
实现了多线程模型,采用主从式架构,通过REDO-Logging实现fault tolerance。