日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

?大家好，我是不才陳某~

創(chuàng)新互聯(lián)公司從2013年創(chuàng)立，是專業(yè)互聯(lián)網(wǎng)技術(shù)服務(wù)公司，擁有項目網(wǎng)站設(shè)計、網(wǎng)站制作網(wǎng)站策劃，項目實施與項目整合能力。我們以讓每一個夢想脫穎而出為使命，1280元大興做網(wǎng)站,已為上家服務(wù),為大興各地企業(yè)和個人服務(wù),聯(lián)系電話:18980820575

最近知識星球的球友在學(xué)習(xí)星球中的《精盡Spring Cloud Alibaba》專欄提到一個問題，相信也有很多人在線上環(huán)境遇到過，或許也因此被批過：一個集群中有某個服務(wù)突然下線，但是網(wǎng)關(guān)還是會去請求這個實例，所以線上就報錯了，報錯信息如下圖：

究其原因到底為何呢？有沒有一種靠譜的解決方案呢？別著急，往下看

產(chǎn)生原因

Gateway中有個緩存 CachingRouteLocator ，而網(wǎng)關(guān)服務(wù)使用的是lb模式，服務(wù)在上線或者下線之后，未能及時刷新這個緩存，相應(yīng)的源碼如下：

public class CachingRouteLocator implements Ordered, RouteLocator,
  ApplicationListener, ApplicationEventPublisherAware {

 private static final Log log = LogFactory.getLog(CachingRouteLocator.class);

 private static final String CACHE_KEY = "routes";

 private final RouteLocator delegate;

 private final Flux routes;

 private final Map cache = new ConcurrentHashMap<>();

 private ApplicationEventPublisher applicationEventPublisher;

 public CachingRouteLocator(RouteLocator delegate) {
  this.delegate = delegate;
  routes = CacheFlux.lookup(cache, CACHE_KEY, Route.class)
    .onCacheMissResume(this::fetch);
 }

 private Flux fetch() {
  return this.delegate.getRoutes().sort(AnnotationAwareOrderComparator.INSTANCE);
 }

 @Override
 public Flux getRoutes() {
  return this.routes;
 }

 /**
  * Clears the routes cache.
  * @return routes flux
  */
 public Flux refresh() {
  this.cache.clear();
  return this.routes;
 }

 @Override
 public void onApplicationEvent(RefreshRoutesEvent event) {
  try {
   fetch().collect(Collectors.toList()).subscribe(list -> Flux.fromIterable(list)
     .materialize().collect(Collectors.toList()).subscribe(signals -> {
      applicationEventPublisher
        .publishEvent(new RefreshRoutesResultEvent(this));
      cache.put(CACHE_KEY, signals);
     }, throwable -> handleRefreshError(throwable)));
  }
  catch (Throwable e) {
   handleRefreshError(e);
  }
 }

 private void handleRefreshError(Throwable throwable) {
  if (log.isErrorEnabled()) {
   log.error("Refresh routes error !!!", throwable);
  }
  applicationEventPublisher
    .publishEvent(new RefreshRoutesResultEvent(this, throwable));
 }

 @Deprecated
 /* for testing */ void handleRefresh() {
  refresh();
 }

 @Override
 public int getOrder() {
  return 0;
 }

 @Override
 public void setApplicationEventPublisher(
   ApplicationEventPublisher applicationEventPublisher) {
  this.applicationEventPublisher = applicationEventPublisher;
 }
}

那么解決方案就自然能夠想出來，只需要在服務(wù)下線時能夠去實時的刷新這個緩存自然就解決了

解決方案

這里通過去監(jiān)聽 Nacos 實例刷新事件，一旦出現(xiàn)實例發(fā)生變化馬上刪除緩存。在刪除負(fù)載均衡緩存后，Spring Cloud Gateway 在處理請求時發(fā)現(xiàn)沒有緩存會重新拉取一遍服務(wù)列表，這樣之后都是用的是最新的服務(wù)列表了，也就達到了我們動態(tài)感知上下線的目的。

代碼如下：

@Component
@Slf4j
public  class NacosInstancesChangeEventListener extends Subscriber {
    @Resource
    private CacheManager defaultLoadBalancerCacheManager;

    @Override
    public void onEvent(InstancesChangeEvent event) {
        log.info("Spring Gateway 接收實例刷新事件：{}, 開始刷新緩存", JacksonUtils.toJson(event));
        Cache cache = defaultLoadBalancerCacheManager.getCache(SERVICE_INSTANCE_CACHE_NAME);
        if (cache != null) {
            cache.evict(event.getServiceName());
        }
        log.info("Spring Gateway 實例刷新完成");
    }

    @Override
    public Class subscribeType() {
        return InstancesChangeEvent.class;
    }
}

這里通過繼承的方式監(jiān)聽 Nacos 的 InstancesChangeEvent?，在 onEvent 接收到實例刷新的信息后直接刪除對應(yīng)服務(wù)的負(fù)載均衡緩存，緩存的名字是定義在 Spring Gateway 的相關(guān)代碼中的，直接引入即可，Cache 則是繼承自 Spring Cache 接口，負(fù)載均衡緩存也繼承了 Cache 接口，有了 Cache 接口就可以直接使用其接口定義的 evict 方法即可，而緩存的 key 名就則就是服務(wù)名，在 InstancesChangeEvent 中，通過 getServiceName 就可以得到服務(wù)名。

這里就不演示了，有興趣的小伙伴可以測試一下

網(wǎng)站名稱：Spring Cloud Gateway + Nacos 實現(xiàn)服務(wù)上下線無縫切換
轉(zhuǎn)載注明：http://m.5511xx.com/article/ccoipdc.html