本文主要分享 应用实例的覆盖状态属性。
这里要注意下&＃xff0c;不是应用实例的状态( status )&＃xff0c;而是覆盖状态( overridestatus ) 。代码如下&＃xff1a;
public class InstanceInfo {private volatile InstanceStatus overriddenstatus &＃61; InstanceStatus.UNKNOWN;// ... 省略属性和方法}
调用 Eureka-Server HTTP Restful 接口 apps/${APP_NAME}/${INSTANCE_ID}/status 对应用实例覆盖状态的变更&＃xff0c;从而达到主动的、强制的变更应用实例状态。注意&＃xff0c;实际不会真的修改 Eureka-Client 应用实例的状态&＃xff0c;而是修改在 Eureka-Server 注册的应用实例的状态。
通过这样的方式&＃xff0c;Eureka-Client 在获取到注册信息时&＃xff0c;并且配置 eureka.shouldFilterOnlyUpInstances &＃61; true&＃xff0c;过滤掉非 InstanceStatus.UP 的应用实例&＃xff0c;从而避免调动该实例&＃xff0c;以达到应用实例的暂停服务( InstanceStatus.OUT_OF_SERVICE )&＃xff0c;而无需关闭应用实例。
因此&＃xff0c;大多数情况下&＃xff0c;调用该接口的目的&＃xff0c;将应用实例状态在 ( InstanceStatus.UP ) 和 ( InstanceStatus.OUT_OF_SERVICE ) 之间切换。引用官方代码上的注释如下&＃xff1a;
AbstractInstanceRegistry#statusUpdate方法注释
Updates the status of an instance.
Normally happens to put an instance between {&＃64;link InstanceStatus#OUT_OF_SERVICE} and {&＃64;link InstanceStatus#UP} to put the instance in and out of traffic.
推荐 Spring Cloud 书籍&＃xff1a;
接口 apps/${APP_NAME}/${INSTANCE_ID}/status 实际是两个&＃xff1a;
apps/${APP_NAME}/${INSTANCE_ID}/statusapps/${APP_NAME}/${INSTANCE_ID}/status下面&＃xff0c;我们逐节分享这两接口的代码实现。
2. 应用实例覆盖状态变更接口应用实例覆盖状态变更接口&＃xff0c;映射 InstanceResource#statusUpdate() 方法&＃xff0c;实现代码如下&＃xff1a;
&＃64;PUT
&＃64;Path("status")
public Response statusUpdate(&＃64;QueryParam("value") String newStatus,&＃64;HeaderParam(PeerEurekaNode.HEADER_REPLICATION) String isReplication,&＃64;QueryParam("lastDirtyTimestamp") String lastDirtyTimestamp) {try {// 应用实例不存在if (registry.getInstanceByAppAndId(app.getName(), id) &＃61;&＃61; null) {logger.warn("Instance not found: {}/{}", app.getName(), id);return Response.status(Status.NOT_FOUND).build();}// 覆盖状态更新boolean isSuccess &＃61; registry.statusUpdate(app.getName(), id,InstanceStatus.valueOf(newStatus), lastDirtyTimestamp,"true".equals(isReplication));// 返回结果if (isSuccess) {logger.info("Status updated: " &＃43; app.getName() &＃43; " - " &＃43; id&＃43; " - " &＃43; newStatus);return Response.ok().build();} else {logger.warn("Unable to update status: " &＃43; app.getName() &＃43; " - "&＃43; id &＃43; " - " &＃43; newStatus);return Response.serverError().build();}} catch (Throwable e) {logger.error("Error updating instance {} for status {}", id,newStatus);return Response.serverError().build();}
}
PeerAwareInstanceRegistryImpl#statusUpdate(...) 方法&＃xff0c;更新应用实例覆盖状态。实现代码如下&＃xff1a; &＃64;Override
public boolean statusUpdate(final String appName, final String id,final InstanceStatus newStatus, String lastDirtyTimestamp,final boolean isReplication) {if (super.statusUpdate(appName, id, newStatus, lastDirtyTimestamp, isReplication)) {// Eureka-Server 集群同步replicateToPeers(Action.StatusUpdate, appName, id, null, newStatus, isReplication);return true;}return false;
}
AbstractInstanceRegistry#statusUpdate(...) 方法&＃xff0c;更新应用实例覆盖状态。调用 AbstractInstanceRegistry#statusUpdate(...) 方法&＃xff0c;更新应用实例覆盖状态&＃xff0c;实现代码如下&＃xff1a;
1: &＃64;Override2: public boolean statusUpdate(String appName, String id,3: InstanceStatus newStatus, String lastDirtyTimestamp,4: boolean isReplication) {5: try {6: // 获取读锁7: read.lock();8: // 添加 覆盖状态变更次数 到 监控9: STATUS_UPDATE.increment(isReplication);
10: // 获得 租约
11: Map
12: Lease
13: if (gMap !&＃61; null) {
14: lease &＃61; gMap.get(id);
15: }
16: // 租约不存在
17: if (lease &＃61;&＃61; null) {
18: return false;
19: } else {
20: // 设置 租约最后更新时间&＃xff08;续租&＃xff09;
21: lease.renew();
22:
23: // 应用实例信息不存在( 防御型编程 )
24: InstanceInfo info &＃61; lease.getHolder();
25: // Lease is always created with its instance info object.
26: // This log statement is provided as a safeguard, in case this invariant is violated.
27: if (info &＃61;&＃61; null) {
28: logger.error("Found Lease without a holder for instance id {}", id);
29: }
30: //
31: if ((info !&＃61; null) && !(info.getStatus().equals(newStatus))) {
32: // 设置 租约的开始服务的时间戳&＃xff08;只有第一次有效&＃xff09;
33: // Mark service as UP if needed
34: if (InstanceStatus.UP.equals(newStatus)) {
35: lease.serviceUp();
36: }
37: // 添加到 应用实例覆盖状态映射
38: // This is NAC overridden status
39: overriddenInstanceStatusMap.put(id, newStatus);
40: // 设置 应用实例覆盖状态
41: // Set it for transfer of overridden status to replica on
42: // replica start up
43: info.setOverriddenStatus(newStatus);
44: // 设置 应用实例信息 数据不一致时间
45: long replicaDirtyTimestamp &＃61; 0;
46: // 设置 应用实例状态
47: info.setStatusWithoutDirty(newStatus);
48: if (lastDirtyTimestamp !&＃61; null) {
49: replicaDirtyTimestamp &＃61; Long.valueOf(lastDirtyTimestamp);
50: }
51: // If the replication&＃39;s dirty timestamp is more than the existing one, just update
52: // it to the replica&＃39;s.
53: if (replicaDirtyTimestamp > info.getLastDirtyTimestamp()) {
54: info.setLastDirtyTimestamp(replicaDirtyTimestamp);
55: }
56: // 添加到 最近租约变更记录队列
57: info.setActionType(ActionType.MODIFIED);
58: recentlyChangedQueue.add(new RecentlyChangedItem(lease));
59: // 设置 最后更新时间
60: info.setLastUpdatedTimestamp();
61: // 设置 响应缓存 过期
62: invalidateCache(appName, info.getVIPAddress(), info.getSecureVipAddress());
63: }
64: return true;
65: }
66: } finally {
67: // 释放锁
68: read.unlock();
69: }
70: }
第 6 至 7 行 &＃xff1a;获取读锁。在 《Eureka源码解析 —— 应用实例注册发现 &＃xff08;九&＃xff09;之岁月是把萌萌的读写锁》 详细解析。
第 8 至 9 行 &＃xff1a;添加覆盖状态变更次数到监控。配合 Netflix Servo 实现监控信息采集。
第 10 至 15 行 &＃xff1a;获得租约。
第 16 至 18 行 &＃xff1a;租约不存在&＃xff0c;返回更新失败。
第 20 至 21 行 &＃xff1a;设置租约最后更新时间( 续租 )。
第 23 至 29 行 &＃xff1a;持有租约的应用实例不存在&＃xff0c;理论来说不会出现&＃xff0c;防御性编程。
第 31 行 &＃xff1a;应用实例当前状态和覆该状态不一致时才更新覆盖状态。
第 32 至 36 行 &＃xff1a;当覆盖状态是 InstanceStatus.UP&＃xff0c;设置租约的开始服务的时间戳&＃xff08;只有第一次有效&＃xff09;。
第 37 至 39 行 &＃xff1a;添加到应用实例覆盖状态映射( overriddenInstanceStatusMap )。此处英文 "NAC" 可能是 "Network Access Control" 的缩写&＃xff0c;感兴趣的可以看看 《Network Access Control》 。overriddenInstanceStatusMap 属性代码如下&＃xff1a;
/**
* 应用实例覆盖状态映射
* key&＃xff1a;应用实例编号
*/
protected final ConcurrentMap
第 40 至 43 行 &＃xff1a;设置应用实例的覆盖状态。用于 Eureka-Server 集群同步。
第 46 至 47 行 &＃xff1a;设置应用实例状态。设置后&＃xff0c;Eureka-Client 拉取注册信息&＃xff0c;被更新覆盖状态的应用实例就是设置的状态。
第 48 至 55 行 &＃xff1a;设置应用实例的数据不一致时间。用于 Eureka-Server 集群同步。
第 56 至 58 行 &＃xff1a;添加应用实例到最近租约变更记录队列。
第 59 至 60 行 &＃xff1a;设置应用实例的最后更新时间( lastUpdatedTimestamp )。lastUpdatedTimestamp 主要用于记录最后更新时间&＃xff0c;无实际业务用途。
第 61 至 62 行 &＃xff1a;设置响应缓存过期。
第 64 行 &＃xff1a;返回更新成功。
第 68 行 &＃xff1a;释放读锁。
当我们不需要应用实例的覆盖状态时&＃xff0c;调度接口接口进行删除。关联官方 issue#89 &＃xff1a;Provide an API to remove all overridden status。
应用实例覆盖状态删除接口&＃xff0c;映射 InstanceResource#deleteStatusUpdate() 方法&＃xff0c;实现代码如下&＃xff1a;
&＃64;DELETE
&＃64;Path("status")
public Response deleteStatusUpdate(&＃64;HeaderParam(PeerEurekaNode.HEADER_REPLICATION) String isReplication,&＃64;QueryParam("value") String newStatusValue,&＃64;QueryParam("lastDirtyTimestamp") String lastDirtyTimestamp) {try {// 应用实例不存在if (registry.getInstanceByAppAndId(app.getName(), id) &＃61;&＃61; null) {logger.warn("Instance not found: {}/{}", app.getName(), id);return Response.status(Status.NOT_FOUND).build();}// 覆盖状态删除InstanceStatus newStatus &＃61; newStatusValue &＃61;&＃61; null ? InstanceStatus.UNKNOWN : InstanceStatus.valueOf(newStatusValue);boolean isSuccess &＃61; registry.deleteStatusOverride(app.getName(), id,newStatus, lastDirtyTimestamp, "true".equals(isReplication));// 返回结果if (isSuccess) {logger.info("Status override removed: " &＃43; app.getName() &＃43; " - " &＃43; id);return Response.ok().build();} else {logger.warn("Unable to remove status override: " &＃43; app.getName() &＃43; " - " &＃43; id);return Response.serverError().build();}} catch (Throwable e) {logger.error("Error removing instance&＃39;s {} status override", id);return Response.serverError().build();}
}
请求参数 newStatusValue &＃xff0c;设置应用实例的状态。大多数情况下&＃xff0c;newStatusValue 要和应用实例实际的状态一致&＃xff0c;因为该应用实例的 Eureka-Client 不会从 Eureka-Server 拉取到该应用状态 newStatusValue 。另外一种方式&＃xff0c;不传递该参数&＃xff0c;相当于 UNKNOWN 状态&＃xff0c;这样&＃xff0c;Eureka-Client 会主动向 Eureka-Server 再次发起注册&＃xff0c;具体原因在 [「4.3 续租场景」] 详细解析&＃xff0c;更加推荐的方式。
调用父类 AbstractInstanceRegistry#deleteStatusOverride(...) 方法&＃xff0c;删除应用实例覆盖状态。实现代码如下&＃xff1a;
&＃64;Override
public boolean deleteStatusOverride(String appName, String id,InstanceStatus newStatus,String lastDirtyTimestamp,boolean isReplication) {if (super.deleteStatusOverride(appName, id, newStatus, lastDirtyTimestamp, isReplication)) {// Eureka-Server 集群同步replicateToPeers(Action.DeleteStatusOverride, appName, id, null, null, isReplication);return true;}return false;
}
AbstractInstanceRegistry#deleteStatusOverride(...) 方法&＃xff0c;删除应用实例覆盖状态。调用父类 AbstractInstanceRegistry#deleteStatusOverride(...) 方法&＃xff0c;删除应用实例覆盖状态。实现代码如下&＃xff1a;
1: &＃64;Override2: public boolean deleteStatusOverride(String appName, String id,3: InstanceStatus newStatus,4: String lastDirtyTimestamp,5: boolean isReplication) {6: try {7: // 获取读锁8: read.lock();9: // 添加 覆盖状态删除次数 到 监控
10: STATUS_OVERRIDE_DELETE.increment(isReplication);
11: // 获得 租约
12: Map
13: Lease
14: if (gMap !&＃61; null) {
15: lease &＃61; gMap.get(id);
16: }
17: // 租约不存在
18: if (lease &＃61;&＃61; null) {
19: return false;
20: } else {
21: // 设置 租约最后更新时间&＃xff08;续租&＃xff09;
22: lease.renew();
23:
24: // 应用实例信息不存在( 防御型编程 )
25: InstanceInfo info &＃61; lease.getHolder();
26: // Lease is always created with its instance info object.
27: // This log statement is provided as a safeguard, in case this invariant is violated.
28: if (info &＃61;&＃61; null) {
29: logger.error("Found Lease without a holder for instance id {}", id);
30: }
31:
32: // 移除 应用实例覆盖状态
33: InstanceStatus currentOverride &＃61; overriddenInstanceStatusMap.remove(id);
34: if (currentOverride !&＃61; null && info !&＃61; null) {
35: // 设置 应用实例覆盖状态
36: info.setOverriddenStatus(InstanceStatus.UNKNOWN);
37: // 设置 应用实例状态
38: info.setStatusWithoutDirty(newStatus);
39: // 设置 应用实例信息 数据不一致时间
40: long replicaDirtyTimestamp &＃61; 0;
41: if (lastDirtyTimestamp !&＃61; null) {
42: replicaDirtyTimestamp &＃61; Long.valueOf(lastDirtyTimestamp);
43: }
44: // If the replication&＃39;s dirty timestamp is more than the existing one, just update
45: // it to the replica&＃39;s.
46: if (replicaDirtyTimestamp > info.getLastDirtyTimestamp()) {
47: info.setLastDirtyTimestamp(replicaDirtyTimestamp);
48: }
49: // 添加到 最近租约变更记录队列
50: info.setActionType(ActionType.MODIFIED);
51: recentlyChangedQueue.add(new RecentlyChangedItem(lease));
52: // 设置 最后更新时间
53: info.setLastUpdatedTimestamp();
54: // 设置 响应缓存 过期
55: invalidateCache(appName, info.getVIPAddress(), info.getSecureVipAddress());
56: }
57: return true;
58: }
59: } finally {
60: // 释放锁
61: read.unlock();
62: }
63: }
overriddenInstanceStatusMap )。newStatus。设置后&＃xff0c;Eureka-Client 拉取注册信息&＃xff0c;被更新覆盖状态的应用实例就是设置的状态。lastUpdatedTimestamp )。lastUpdatedTimestamp 主要用于记录最后更新时间&＃xff0c;无实际业务用途。虽然我们在上面代码&＃xff0c;使用覆盖状态( overridestatus )设置到应用实例的状态( status )&＃xff0c;实际调用 AbstractInstanceRegistry#getOverriddenInstanceStatus(...) 方法&＃xff0c;根据应用实例状态覆盖规则( InstanceStatusOverrideRule )进行计算最终应用实例的状态。实现代码如下&＃xff1a;
// AbstractInstanceRegistry.java
protected InstanceInfo.InstanceStatus getOverriddenInstanceStatus(InstanceInfo r,Lease
}protected abstract InstanceStatusOverrideRule getInstanceInfoOverrideRule();
#getInstanceInfoOverrideRule() 方法&＃xff0c;获取应用实例状态覆盖规则( InstanceStatusOverrideRule )。在 PeerAwareInstanceRegistryImpl 里该方法实现代码如下&＃xff1a; private final InstanceStatusOverrideRule instanceStatusOverrideRule;public PeerAwareInstanceRegistryImpl(EurekaServerConfig serverConfig,EurekaClientConfig clientConfig,ServerCodecs serverCodecs,EurekaClient eurekaClient) {// ... 省略其它方法this.instanceStatusOverrideRule &＃61; new FirstMatchWinsCompositeRule(new DownOrStartingRule(),new OverrideExistsRule(overriddenInstanceStatusMap), new LeaseExistsRule());
}&＃64;Override
protected InstanceStatusOverrideRule getInstanceInfoOverrideRule() {return this.instanceStatusOverrideRule;
}
com.netflix.eureka.registry.rule.InstanceStatusOverrideRule &＃xff0c;应用实例状态覆盖规则接口。接口代码如下&＃xff1a;
// InstanceStatusOverrideRule.java
public interface InstanceStatusOverrideRule {/*** Match this rule.** &＃64;param instanceInfo The instance info whose status we care about. 关注状态的应用实例对象* &＃64;param existingLease Does the instance have an existing lease already? If so let&＃39;s consider that. 已存在的租约* &＃64;param isReplication When overriding consider if we are under a replication mode from other servers. 是否是 Eureka-Server 发起的请求* &＃64;return A result with whether we matched and what we propose the status to be overriden to.*/StatusOverrideResult apply(final InstanceInfo instanceInfo,final Lease
public class StatusOverrideResult {public static StatusOverrideResult NO_MATCH &＃61; new StatusOverrideResult(false, null);public static StatusOverrideResult matchingStatus(InstanceInfo.InstanceStatus status) {return new StatusOverrideResult(true, status);}// Does the rule match?private final boolean matches;// The status computed by the rule.private final InstanceInfo.InstanceStatus status;private StatusOverrideResult(boolean matches, InstanceInfo.InstanceStatus status) {this.matches &＃61; matches;this.status &＃61; status;}public boolean matches() {return matches;}public InstanceInfo.InstanceStatus status() {return status;}
}
#apply(...) 方法参数 instanceInfo 代表的是关注状态的应用实例&＃xff0c;和方法参数 existingLease 里的应用实例不一定是同一个&＃xff0c;在 「4.1.6 总结」 详细解析。com.netflix.eureka.registry.rule.StatusOverrideResult &＃xff0c;状态覆盖结果。当匹配成功&＃xff0c;返回 matches &＃61; true &＃xff1b;否则&＃xff0c;返回 matches &＃61; false 。实现类关系如下&＃xff1a;
com.netflix.eureka.registry.rule.FirstMatchWinsCompositeRule &＃xff0c;复合规则&＃xff0c;以第一个匹配成功为准。实现代码如下&＃xff1a;
public class FirstMatchWinsCompositeRule implements InstanceStatusOverrideRule {/*** 复合规则集合*/private final InstanceStatusOverrideRule[] rules;/*** 默认规则*/private final InstanceStatusOverrideRule defaultRule;private final String compositeRuleName;public FirstMatchWinsCompositeRule(InstanceStatusOverrideRule... rules) {this.rules &＃61; rules;this.defaultRule &＃61; new AlwaysMatchInstanceStatusRule();// Let&＃39;s build up and "cache" the rule name to be used by toString();List
rules 属性&＃xff0c;复合规则集合。在 PeerAwareInstanceRegistryImpl 里&＃xff0c;我们可以看到该属性为 [ DownOrStartingRule , OverrideExistsRule , LeaseExistsRule ] 。defaultRule 属性&＃xff0c;默认规则&＃xff0c;值为 AlwaysMatchInstanceStatusRule 。#apply() 方法&＃xff0c;优先使用复合规则( rules )&＃xff0c;顺序匹配&＃xff0c;直到匹配成功 。当未匹配成功&＃xff0c;使用默认规则( defaultRule ) 。com.netflix.eureka.registry.rule.DownOrStartingRule &＃xff0c;匹配 InstanceInfo.InstanceStatus.DOWN 或者 InstanceInfo.InstanceStatus.STARTING 状态。实现 #apply(...) 代码如下&＃xff1a;
&＃64;Override
public StatusOverrideResult apply(InstanceInfo instanceInfo,Lease
}
instanceInfo 。com.netflix.eureka.registry.rule.OverrideExistsRule &＃xff0c;匹配应用实例覆盖状态映射( statusOverrides ) 。实现 #apply(...) 代码如下&＃xff1a;
public class OverrideExistsRule implements InstanceStatusOverrideRule {private Map
statusOverrides 属性&＃xff0c;应用实例覆盖状态映射。在 PeerAwareInstanceRegistryImpl 里&＃xff0c;使用 AbstractInstanceRegistry.overriddenInstanceStatusMap 属性赋值。AbstractInstanceRegistry.overriddenInstanceStatusMap 每次访问刷新有效期&＃xff0c;如果调用到 OverrideExistsRule &＃xff0c;则会不断刷新。从 DownOrStartingRule 看到&＃xff0c;instanceInfo 处于 InstanceInfo.InstanceStatus.DOWN 或者 InstanceInfo.InstanceStatus.STARTING 才不会继续调用 OverrideExistsRule 匹配&＃xff0c;AbstractInstanceRegistry.overriddenInstanceStatusMap 才有可能过期。com.netflix.eureka.registry.rule.LeaseExistsRule &＃xff0c;匹配已存在租约的应用实例的 nstanceStatus.OUT_OF_SERVICE 或者 InstanceInfo.InstanceStatus.UP 状态。实现 #apply(...) 代码如下&＃xff1a;
public StatusOverrideResult apply(InstanceInfo instanceInfo,Lease
}
existingLease &＃xff0c;并且非 Eureka-Server 请求。com.netflix.eureka.registry.rule.AlwaysMatchInstanceStatusRule &＃xff0c;总是匹配关注状态的实例对象( instanceInfo )的状态。实现 #apply(...) 代码如下&＃xff1a;
&＃64;Override
public StatusOverrideResult apply(InstanceInfo instanceInfo,Lease
}
instanceInfo 。我们将 PeerAwareInstanceRegistryImpl 的应用实例覆盖状态规则梳理如下&＃xff1a;
instanceInfo 处于 STARTING 或者 DOWN 状态&＃xff0c;应用实例可能不适合提供服务( 被请求 )&＃xff0c;考虑可信赖&＃xff0c;返回 instanceInfo 的状态。statusoverrides ) &＃xff0c;使用该状态&＃xff0c;比较好理解。UP 或则 OUT_OF_SERVICE &＃xff0c;保留当前状态。原因&＃xff0c;禁止 Eureka-Client 主动在这两个状态之间切换。如果要切换&＃xff0c;使用应用实例覆盖状态变更与删除接口。instanceInfo 的状态返回&＃xff0c;以保证能匹配到状态。#getOverriddenInstanceStatus() 方法会在注册和续租使用到。结合上图&＃xff0c;我们在 「4.2 注册场景」 和 「4.3 续租场景」 也会详细解析。#getOverriddenInstanceStatus() 方法会在注册和续租使用到&＃xff0c;方法参数 instanceInfo 情况如下&＃xff1a; instanceInfo &＃xff0c;和 existingLease 的应用实例属性不相等( 如果考虑 Eureka-Server 的 LastDirtyTimestamp 更大的情况&＃xff0c;则类似 续租时的情况 ) 。existingLease 的应用实例&＃xff0c;两者相等。instanceInfo 理解成请求方的状态。// AbstractInstanceRegistry.java1: public void register(InstanceInfo registrant, int leaseDuration, boolean isReplication) {2: try {3: // &＃xff08;(省略代码) &＃xff09;获取锁4: Map
existingLease ) 。lease )。overridestatus )&＃xff0c;避免注册应用实例后&＃xff0c;丢失覆盖状态。registrant 和 existingLease 的应用实例不是同一个对象。// AbstractInstanceRegistry.java1: public boolean renew(String appName, String id, boolean isReplication) {2: // &＃xff08;省略代码&＃xff09;增加 续租次数 到 监控3: // 获得 租约4: Map
UNKNOWN&＃xff0c;无法续约 。返回 false 后&＃xff0c;请求方( Eureka-Client 或者 Eureka-Server 集群其他节点 )会发起注册&＃xff0c;在 《Eureka 源码解析 —— 应用实例注册发现&＃xff08;二&＃xff09;之续租》 有详细解析。为什么会是 UNKNOWN 呢&＃xff1f;在 「3. 应用实例覆盖状态删除接口」 传递应用实例状态为 UNKNOWN 。#renew(...) 和 #statusUpdate(...) 可以无锁&＃xff0c;并行执行&＃xff0c;如果 #renew(...) 执行完第 16 行代码&＃xff0c;获取到 overriddenInstanceStatus 后&＃xff0c;恰巧 #statusUpdate(...) 执行完更新应用实例状态 newStatus&＃xff0c;又恰好两者不相等&＃xff0c;使用 overriddenInstanceStatus 覆盖掉应用实例的 newStatus 状态。overriddenstatus )反倒被覆盖&＃xff1f;&＃xff1f;&＃xff1f;不会&＃xff0c;在下一次心跳&＃xff0c;应用实例的状态会被修正回来。当然&＃xff0c;如果应用实例状态如果为 UP 或者 STARTING 不会被修正&＃xff0c;也不应该被修正。// AbstractInstanceRegistry.java
protected boolean internalCancel(String appName, String id, boolean isReplication) {// ... 省略无关代码// 移除 应用实例覆盖状态映射InstanceStatus instanceStatus &＃61; overriddenInstanceStatusMap.remove(id);if (instanceStatus !&＃61; null) {logger.debug("Removed instance id {} from the overridden map which has value {}", id, instanceStatus.name());}}
同 「4.4 下线场景」 相同。
5. 客户端调用接口对应用实例覆盖状态的变更和删除接口调用&＃xff0c;点击如下方法查看&＃xff0c;非常易懂&＃xff0c;本文就不啰嗦了&＃xff1a;
AbstractJerseyEurekaHttpClient#statusUpdate(...)AbstractJerseyEurekaHttpClient#deleteStatusOverride(...)
京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有