SpringCloud Ribbon（三）之IPing机制

一、IPing机制

IPing是一个主动探测服务节点存活的机制，通过判断服务节点的当前状态，设置节点的可用状态。只有当节点为可用时候才会作为负载均衡器的选取节点。

IPing有以下几种模式:

DummyPing：默认返回true，即认为所有节点都可用，这也是单独使用Ribbon时的默认模式
NIWSDiscoveryPing：借助Eureka服务发现机制获取节点状态。节点状态是UP，则认为是可用状态
PingUrl：主动向服务节点发起一次http调用，对方有响应则认为节点是可用状态
NoOpPing：返回true
PingConstant：返回设置的常量值

二、IPing配置

（1）application.yaml配置

#单个服务设置
[service-name]: ribbon: NFLoadBalancerPingClassName: com.netflix.loadbalancer.DummyPing

（2）代码配置

public class MicroRibbonConfig {@Beanpublic IPing microIPing(){return new DummyPing();}
}@RibbonClient(name = "micro-service", configuration = MicroRibbonConfig.class)
public class RibbonClientConfig {}

三、IPing模式实现

（1）DummyPing

public class DummyPing extends AbstractLoadBalancerPing {public DummyPing() {}public boolean isAlive(Server server) {return true;}@Overridepublic void initWithNiwsConfig(IClientConfig clientConfig) {}
}public abstract class AbstractLoadBalancerPing implements IPing, IClientConfigAware{AbstractLoadBalancer lb;@Overridepublic boolean isAlive(Server server) {return true;}public void setLoadBalancer(AbstractLoadBalancer lb){this.lb = lb;}public AbstractLoadBalancer getLoadBalancer(){return lb;}}

（2）PingUrl

public class PingUrl implements IPing {private static final Logger LOGGER = LoggerFactory.getLogger(PingUrl.class);String pingAppendString = "";boolean isSecure = false;String expectedContent = null;/*** Send one ping only.** Well, send what you need to determine whether or not the* server is still alive.  Should return within a "reasonable"* time.*/public PingUrl() {}public PingUrl(boolean isSecure, String pingAppendString) {this.isSecure = isSecure;this.pingAppendString = (pingAppendString != null) ? pingAppendString : "";}public void setPingAppendString(String pingAppendString) {this.pingAppendString = (pingAppendString != null) ? pingAppendString : "";}public String getPingAppendString() {return pingAppendString;}public boolean isSecure() {return isSecure;}/*** Should the Secure protocol be used to Ping* @param isSecure*/public void setSecure(boolean isSecure) {this.isSecure = isSecure;}public String getExpectedContent() {return expectedContent;}/*** Is there a particular content you are hoping to see?* If so -set this here.* for e.g. the WCS server sets the content body to be 'true'* Please be advised that this content should match the actual * content exactly for this to work. Else yo may get false status.* @param expectedContent*/public void setExpectedContent(String expectedContent) {this.expectedContent = expectedContent;}public boolean isAlive(Server server) {String urlStr   = "";if (isSecure){urlStr = "https://";}else{urlStr = "http://";}urlStr += server.getId();urlStr += getPingAppendString();boolean isAlive = false;HttpClient httpClient = new DefaultHttpClient();HttpUriRequest getRequest = new HttpGet(urlStr);String content=null;try {HttpResponse response = httpClient.execute(getRequest);content = EntityUtils.toString(response.getEntity());isAlive = (response.getStatusLine().getStatusCode() == 200);if (getExpectedContent()!=null){LOGGER.debug("content:" + content);if (content == null){isAlive = false;}else{if (content.equals(getExpectedContent())){isAlive = true;}else{isAlive = false;}}}} catch (IOException e) {e.printStackTrace();}finally{// Release the connection.getRequest.abort();}return isAlive;}public static void main(String[] args){PingUrl p = new PingUrl(false,"/cs/hostRunning");p.setExpectedContent("true");Server s = new Server("ec2-75-101-231-85.compute-1.amazonaws.com", 7101);boolean isAlive = p.isAlive(s);System.out.println("isAlive:" + isAlive);}
}

（3）PingConstant

public class PingConstant implements IPing {boolean constant = true;public void setConstant(String constantStr) {constant = (constantStr != null) && (constantStr.toLowerCase().equals("true"));}public void setConstant(boolean constant) {this.constant = constant;}public boolean getConstant() {return constant;}public boolean isAlive(Server server) {return constant;}
}

（4）NoOpPing

public class NoOpPing implements IPing {@Overridepublic boolean isAlive(Server server) {return true;}}

SpringCloud Ribbon（三）之IPing机制相关推荐

SpringCloud进阶-Hystrix的熔断机制+Hystrix的工作流程
提示:本文主要对SpringCloud中的Hystrix的熔断机制和工作流程进行总结文章目录前言一.简介 1.熔断是什么二.实操 1.实现 2.测试三.总结 1.大神结论 2.熔断类型 3. ...
JDK/Dubbo/Spring 三种 SPI 机制，谁更好？
点击关注公众号,Java干货及时送达来源:juejin.cn/post/6950266942875779108 SPI 全称为 Service Provider Interface,是一种服务发现机 ...
java同步异步调用_详解java 三种调用机制（同步、回调、异步）
1:同步调用:一种阻塞式调用,调用方要等待对方执行完毕才返回,jsPwwCe它是一种单向调用 2:回调:一种双向调用模式,也就是说,被调用方在接口被调用时也会调用对方的接口: 3:异步调用:一种类似消 ...
JDK/Dubbo/Spring 三种 SPI 机制，谁更好呢？
JDK/Dubbo/Spring 三种 SPI 机制,谁更好? SPI 全称为 Service Provider Interface,是一种服务发现机制.SPI 的本质是将接口实现类的全限定名配置在文 ...
flink 三种时间机制_Flink1.10入门：时间机制简介
一.概述上篇文章介绍了Window窗口机制的相关知识,这里我们介绍下Flink的另外一个核心概念"Event Time机制",本篇文章只介绍相关概念不讲实战,实战会结合Windo ...
Yarn的三种资源调度机制
在企业中并不是只有一个人来执行MapReduce程序单独使用Yarn的资源,实际开发中,会有很多人一起使用Yarn这个资源,如果每个人都提交了job,这个时候Yarn就需要进行调度去分配资源给job, ...
Android Glide图片加载框架（三）缓存机制
文章目录一.缓存简介二.缓存用法内存缓存方式磁盘缓存方式三.缓存KEY 四.内存缓存内存缓存流程五.磁盘缓存磁盘缓存流程 Android Glide图片加载框架系列文章 Android ...
【JVM】第三章垃圾收集机制
第三章垃圾收集机制文章目录第三章垃圾收集机制一.垃圾标记算法 1.引用计数算法 2.根可达性分析算法二.垃圾收集算法 1.标记 - 清除算法 2.复制算法 3.标记 - 压缩算法 4.对比 ...
Application应用框架思考(三) 之[插件机制]
Application应用框架思考(三) 之[插件机制] /// <summary> /// 单例类 /// //为子功能提供主框架信息接口类 /// </summary> ...

SpringCloud Ribbon（三）之IPing机制

一、IPing机制

二、IPing配置

三、IPing模式实现

SpringCloud Ribbon（三）之IPing机制相关推荐

最新文章

热门文章