SpringCloudEureka服務(wù)注冊與取消方法是什么
本篇內(nèi)容主要講解“Spring Cloud Eureka服務(wù)注冊與取消方法是什么”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學(xué)習(xí)“Spring Cloud Eureka服務(wù)注冊與取消方法是什么”吧!
創(chuàng)新互聯(lián)主營召陵網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司,主營網(wǎng)站建設(shè)方案,成都App制作,召陵h5成都微信小程序搭建,召陵網(wǎng)站營銷推廣歡迎召陵等地區(qū)企業(yè)咨詢
關(guān)于服務(wù)注冊
開啟/關(guān)閉服務(wù)注冊配置：eureka.client.register-with-eureka = true （默認(rèn)）
什么時候注冊？
應(yīng)用第一次啟動時，初始化EurekaClient時，應(yīng)用狀態(tài)改變：從STARTING變?yōu)閁P會觸發(fā)這個Listener，調(diào)用instanceInfoReplicator.onDemandUpdate(); 可以推測出，實例狀態(tài)改變時，也會通過注冊接口更新實例狀態(tài)信息
statusChangeListener = new ApplicationInfoManager.StatusChangeListener() {
@Override
public String getId() {
return "statusChangeListener";
}
@Override
public void notify(StatusChangeEvent statusChangeEvent) {
if (InstanceStatus.DOWN == statusChangeEvent.getStatus() ||
InstanceStatus.DOWN == statusChangeEvent.getPreviousStatus()) {
// log at warn level if DOWN was involved
logger.warn("Saw local status change event {}", statusChangeEvent);
} else {
logger.info("Saw local status change event {}", statusChangeEvent);
}
instanceInfoReplicator.onDemandUpdate();
}
};定時任務(wù)，如果InstanceInfo發(fā)生改變，也會通過注冊接口更新信息
public void run() {
try {
discoveryClient.refreshInstanceInfo();
//如果實例信息發(fā)生改變，則需要調(diào)用register更新InstanceInfo
Long dirtyTimestamp = instanceInfo.isDirtyWithTime();
if (dirtyTimestamp != null) {
discoveryClient.register();
instanceInfo.unsetIsDirty(dirtyTimestamp);
}
} catch (Throwable t) {
logger.warn("There was a problem with the instance info replicator", t);
} finally {
Future next = scheduler.schedule(this, replicationIntervalSeconds, TimeUnit.SECONDS);
scheduledPeriodicRef.set(next);
}
}在定時renew時，如果renew接口返回404（代表這個實例在EurekaServer上面找不到），可能是之前注冊失敗或者注冊過期導(dǎo)致的。這時需要調(diào)用register重新注冊
boolean renew() {
EurekaHttpResponse<InstanceInfo> httpResponse;
try {
httpResponse = eurekaTransport.registrationClient.sendHeartBeat(instanceInfo.getAppName(), instanceInfo.getId(), instanceInfo, null);
logger.debug("{} - Heartbeat status: {}", PREFIX + appPathIdentifier, httpResponse.getStatusCode());
//如果renew接口返回404（代表這個實例在EurekaServer上面找不到），可能是之前注冊失敗或者注冊過期導(dǎo)致的
if (httpResponse.getStatusCode() == 404) {
REREGISTER_COUNTER.increment();
logger.info("{} - Re-registering apps/{}", PREFIX + appPathIdentifier, instanceInfo.getAppName());
long timestamp = instanceInfo.setIsDirtyWithTime();
boolean success = register();
if (success) {
instanceInfo.unsetIsDirty(timestamp);
}
return success;
}
return httpResponse.getStatusCode() == 200;
} catch (Throwable e) {
logger.error("{} - was unable to send heartbeat!", PREFIX + appPathIdentifier, e);
return false;
}
}向Eureka發(fā)送注冊請求EurekaServer發(fā)生了什么？
主要有兩個存儲，一個是之前提到過的registry，還有一個最近變化隊列，后面我們會知道，這個最近變化隊列里面就是客戶端獲取增量實例信息的內(nèi)容：
# 整體注冊信息緩存 private final ConcurrentHashMap<String, Map<String, Lease<InstanceInfo>>> registry = new ConcurrentHashMap<String, Map<String, Lease<InstanceInfo>>>(); # 最近變化隊列 private ConcurrentLinkedQueue<RecentlyChangedItem> recentlyChangedQueue = new ConcurrentLinkedQueue<RecentlyChangedItem>();
EurekaServer收到實例注冊主要分兩步：
調(diào)用父類方法注冊
同步到其他EurekaServer實例
public void register(InstanceInfo info, boolean isReplication) {
int leaseDuration = 90;
if (info.getLeaseInfo() != null && info.getLeaseInfo().getDurationInSecs() > 0) {
leaseDuration = info.getLeaseInfo().getDurationInSecs();
}
//調(diào)用父類方法注冊
super.register(info, leaseDuration, isReplication);
//同步到其他EurekaServer實例
this.replicateToPeers(PeerAwareInstanceRegistryImpl.Action.Register, info.getAppName(), info.getId(), info, (InstanceStatus)null, isReplication);
}我們先看同步到其他EurekaServer實例
其實就是，注冊到的EurekaServer再依次調(diào)用其他集群內(nèi)的EurekaServer的Register方法將實例信息同步過去
private void replicateToPeers(Action action, String appName, String id,
InstanceInfo info /* optional */,
InstanceStatus newStatus /* optional */, boolean isReplication) {
Stopwatch tracer = action.getTimer().start();
try {
if (isReplication) {
numberOfReplicationsLastMin.increment();
}
// If it is a replication already, do not replicate again as this will create a poison replication
if (peerEurekaNodes == Collections.EMPTY_LIST || isReplication) {
return;
}
for (final PeerEurekaNode node : peerEurekaNodes.getPeerEurekaNodes()) {
// If the url represents this host, do not replicate to yourself.
if (peerEurekaNodes.isThisMyUrl(node.getServiceUrl())) {
continue;
}
replicateInstanceActionsToPeers(action, appName, id, info, newStatus, node);
}
} finally {
tracer.stop();
}
}
private void replicateInstanceActionsToPeers(Action action, String appName,
String id, InstanceInfo info, InstanceStatus newStatus,
PeerEurekaNode node) {
try {
InstanceInfo infoFromRegistry = null;
CurrentRequestVersion.set(Version.V2);
switch (action) {
case Cancel:
node.cancel(appName, id);
break;
case Heartbeat:
InstanceStatus overriddenStatus = overriddenInstanceStatusMap.get(id);
infoFromRegistry = getInstanceByAppAndId(appName, id, false);
node.heartbeat(appName, id, infoFromRegistry, overriddenStatus, false);
break;
case Register:
node.register(info);
break;
case StatusUpdate:
infoFromRegistry = getInstanceByAppAndId(appName, id, false);
node.statusUpdate(appName, id, newStatus, infoFromRegistry);
break;
case DeleteStatusOverride:
infoFromRegistry = getInstanceByAppAndId(appName, id, false);
node.deleteStatusOverride(appName, id, infoFromRegistry);
break;
}
} catch (Throwable t) {
logger.error("Cannot replicate information to {} for action {}", node.getServiceUrl(), action.name(), t);
}
}然后看看調(diào)用父類方法注冊：
public void register(InstanceInfo registrant, int leaseDuration, boolean isReplication) {
try {
//register雖然看上去好像是修改，但是這里用的是讀鎖，后面會解釋
read.lock();
//從registry中查看這個app是否存在
Map<String, Lease<InstanceInfo>> gMap = registry.get(registrant.getAppName());
//不存在就創(chuàng)建
if (gMap == null) {
final ConcurrentHashMap<String, Lease<InstanceInfo>> gNewMap = new ConcurrentHashMap<String, Lease<InstanceInfo>>();
gMap = registry.putIfAbsent(registrant.getAppName(), gNewMap);
if (gMap == null) {
gMap = gNewMap;
}
}
//查看這個app的這個實例是否已存在
Lease<InstanceInfo> existingLease = gMap.get(registrant.getId());
if (existingLease != null && (existingLease.getHolder() != null)) {
//如果已存在，對比時間戳，保留比較新的實例信息......
} else {
// 如果不存在，證明是一個新的實例
//更新自我保護(hù)監(jiān)控變量的值的代碼.....
}
Lease<InstanceInfo> lease = new Lease<InstanceInfo>(registrant, leaseDuration);
if (existingLease != null) {
lease.setServiceUpTimestamp(existingLease.getServiceUpTimestamp());
}
//放入registry
gMap.put(registrant.getId(), lease);
//加入最近修改的記錄隊列
recentlyChangedQueue.add(new RecentlyChangedItem(lease));
//初始化狀態(tài)，記錄時間等相關(guān)代碼......
//主動讓Response緩存失效
invalidateCache(registrant.getAppName(), registrant.getVIPAddress(), registrant.getSecureVipAddress());
} finally {
read.unlock();
}
}總結(jié)起來，就是主要三件事：
1.將實例注冊信息放入或者更新registry
2.將實例注冊信息加入最近修改的記錄隊列
3.主動讓Response緩存失效
我們來類比下服務(wù)取消
服務(wù)取消CANCEL
protected boolean internalCancel(String appName, String id, boolean isReplication) {
try {
//cancel雖然看上去好像是修改，但是這里用的是讀鎖，后面會解釋
read.lock();
//從registry中剔除這個實例
Map<String, Lease<InstanceInfo>> gMap = registry.get(appName);
Lease<InstanceInfo> leaseToCancel = null;
if (gMap != null) {
leaseToCancel = gMap.remove(id);
}
if (leaseToCancel == null) {
logger.warn("DS: Registry: cancel failed because Lease is not registered for: {}/{}", appName, id);
return false;
} else {
//改變狀態(tài)，記錄狀態(tài)修改時間等相關(guān)代碼......
if (instanceInfo != null) {
instanceInfo.setActionType(ActionType.DELETED);
//加入最近修改的記錄隊列
recentlyChangedQueue.add(new RecentlyChangedItem(leaseToCancel));
}
//主動讓Response緩存失效
invalidateCache(appName, vip, svip);
logger.info("Cancelled instance {}/{} (replication={})", appName, id, isReplication);
return true;
}
} finally {
read.unlock();
}
}總結(jié)起來，也是主要三件事：
1.從registry中剔除這個實例
2.將實例注冊信息加入最近修改的記錄隊列
3.主動讓Response緩存失效
這里我們注意到了這個最近修改隊列，我們來詳細(xì)看看
最近修改隊列
這個最近修改隊列和消費者定時獲取服務(wù)實例列表有著密切的關(guān)系
private TimerTask getDeltaRetentionTask() {
return new TimerTask() {
@Override
public void run() {
Iterator<RecentlyChangedItem> it = recentlyChangedQueue.iterator();
while (it.hasNext()) {
if (it.next().getLastUpdateTime() <
System.currentTimeMillis() - serverConfig.getRetentionTimeInMSInDeltaQueue()) {
it.remove();
} else {
break;
}
}
}
};
}這個RetentionTimeInMSInDeltaQueue默認(rèn)是180s（配置是eureka.server.retention-time-in-m-s-in-delta-queue,默認(rèn)是180s，官網(wǎng)寫錯了），可以看出這個隊列是一個長度為180s的滑動窗口，保存最近180s以內(nèi)的應(yīng)用實例信息修改，后面我們會看到，客戶端調(diào)用獲取增量信息，實際上就是從這個queue中讀取，所以可能一段時間內(nèi)讀取到的信息都是一樣的。
到此，相信大家對“Spring Cloud Eureka服務(wù)注冊與取消方法是什么”有了更深的了解，不妨來實際操作一番吧！這里是創(chuàng)新互聯(lián)網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！
網(wǎng)頁名稱：SpringCloudEureka服務(wù)注冊與取消方法是什么
文章鏈接：http://bm7419.com/article20/jjshco.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供、App設(shè)計、響應(yīng)式網(wǎng)站、Google、微信公眾號、手機網(wǎng)站建設(shè)
聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)
- 沒有收錄的文章如何讓百度重新收錄? 2014-07-24
- SEO文章怎么寫容易收錄？ 2015-04-13
- 關(guān)于網(wǎng)站收錄的那些事 2023-04-20
- 怎么吸引蜘蛛收錄頁面？ 2013-10-09
- 提高網(wǎng)站收錄的五點定律 2017-03-01
- SEO優(yōu)化?中，網(wǎng)站不收錄的原因 2014-05-05
- 搜索引擎對新網(wǎng)站收錄問題探討 2013-12-17
- 網(wǎng)站文章每日都更新為什么還是不收錄新文章 2016-11-04
- 內(nèi)頁不收錄的原因是什么，如何解決？ 2014-02-12
- 如何讓網(wǎng)站被百度快速收錄？ 2013-04-28
- 網(wǎng)站做百度優(yōu)化過程中收錄急劇減少應(yīng)該怎么排查原因？ 2014-11-10
- SEO優(yōu)化中如何提高文章內(nèi)容收錄率? 2015-02-01