詳解SpringCloud eureka服務狀態(tài)監(jiān)聽

更新時間：2018年07月19日 10:06:58 作者：時光沉舊了少年

這篇文章主要介紹了詳解SpringCloud eureka服務狀態(tài)監(jiān)聽，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧

一.前言

近期由于公司不同平臺項目之間的業(yè)務整合,需要做到相互訪問! 每個平臺均有自己的注冊中心和服務,且注冊中心相互之間并沒有相互注冊!

借助spring的事件監(jiān)聽,在eureka-server端監(jiān)聽服務注冊,將所有服務的ip和port存放至redis庫,然后讓其他平臺服務通過redis庫獲取ip和端口號,進而進行http調(diào)用.結(jié)構(gòu)圖如下:

二.事件解析

事件列表

在org.springframework.cloud.netflix.eureka.server.event包下會發(fā)現(xiàn)如下類:

EurekaInstanceCanceledEvent: 服務下線事件
EurekaInstanceRegisteredEvent: 服務注冊事件
EurekaInstanceRenewedEvent: 服務續(xù)約事件
EurekaRegistryAvailableEvent: eureka注冊中心啟動事件
EurekaServerStartedEvent: eureka server啟動時間

源碼分析

打開org.springframework.cloud.netflix.eureka.server.InstanceRegistry類,會發(fā)現(xiàn)當eureka服務續(xù)約、注冊、取消等時,spring會publish不同的事件,對應的事件類就是上面的列表.

續(xù)約事件

 @Override
 public boolean renew(final String appName, final String serverId,
   boolean isReplication) {
  log("renew " + appName + " serverId " + serverId + ", isReplication {}"
    + isReplication);
  List<Application> applications = getSortedApplications();
  for (Application input : applications) {
   if (input.getName().equals(appName)) {
    InstanceInfo instance = null;
    for (InstanceInfo info : input.getInstances()) {
     if (info.getId().equals(serverId)) {
      instance = info;
      break;
     }
    }
    // 發(fā)布續(xù)約事件
    publishEvent(new EurekaInstanceRenewedEvent(this, appName, serverId,
      instance, isReplication));
    break;
   }
  }
  return super.renew(appName, serverId, isReplication);
 }

注冊事件

 @Override
 public void register(InstanceInfo info, int leaseDuration, boolean isReplication) {
  handleRegistration(info, leaseDuration, isReplication);
  super.register(info, leaseDuration, isReplication);
 }
 
  private void handleRegistration(InstanceInfo info, int leaseDuration,
   boolean isReplication) {
  log("register " + info.getAppName() + ", vip " + info.getVIPAddress()
    + ", leaseDuration " + leaseDuration + ", isReplication "
    + isReplication);
  // 發(fā)布注冊事件
  publishEvent(new EurekaInstanceRegisteredEvent(this, info, leaseDuration,
    isReplication));
 }

事件監(jiān)聽

通過上面的源碼追溯,我們已經(jīng)得到對應的事件類了,所以現(xiàn)在要做的僅僅是監(jiān)聽對應的事件即可,至此已經(jīng)完成了我們所需要對事件監(jiān)聽后的業(yè)務處理!

@Component
public class EurekaStateChangeListener {

 @Value("${iptable.platform}")
 private String platform;
 
 @Autowired
 private RedisTemplate<String, String> redisTemplate;

 private static Logger logger = LoggerFactory.getLogger(EurekaStateChangeListener.class);
 private static final String COLON = ":";

 @EventListener//(condition = "#event.replication==false")
 public void listen(EurekaInstanceCanceledEvent eurekaInstanceCanceledEvent) {
  // 服務斷線事件
  String appName = eurekaInstanceCanceledEvent.getAppName();
  String serverId = eurekaInstanceCanceledEvent.getServerId();
  Objects.requireNonNull(appName, "服務名不能為空!");

  SetOperations<String, String> opsForSet = redisTemplate.opsForSet();
  opsForSet.remove((platform + appName).toLowerCase(), serverId);
  logger.info(">>>>>>> 失效服務:{},已被剔除!", serverId);
 }

 @EventListener//(condition = "#event.replication==false")
 public void listen(EurekaInstanceRegisteredEvent event) {
  // 服務注冊
  InstanceInfo instanceInfo = event.getInstanceInfo();
  String appName = instanceInfo.getAppName();
  Objects.requireNonNull(appName, "服務名不能為空!");

  SetOperations<String, String> opsForSet = redisTemplate.opsForSet();
  opsForSet.add((platform + appName).toLowerCase(), instanceInfo.getIPAddr() + COLON + instanceInfo.getPort());
  logger.info(">>>>>>> 服務名:{},端口號:{},已緩存至redis", appName, instanceInfo.getPort());
 }

 @EventListener//(condition = "#event.replication==false")
 public void listen(EurekaInstanceRenewedEvent event) {
  // 服務續(xù)約
  logger.info(">>>>>>>>>>>>>>>Server續(xù)約:" + event.getServerId());
 }

 @EventListener
 public void listen(EurekaRegistryAvailableEvent event) {
  // 注冊中心啟動
  logger.info(">>>>>>>>>>>>>>>Server注冊中心:" + event);
 }

 @EventListener
 public void listen(EurekaServerStartedEvent event) {
  // Server啟動
  logger.info(">>>>>>>>>>>>>>>Server啟動:" + event);
 }
}

注意事項

[ ] 版本問題:

當時項目組用的SpringCloud版本是Brixton.RELEASE,該版本有一個問題就是服務注冊和下線并不會出發(fā)對應的事件,所以導致一直監(jiān)聽不到.解決的辦法也很簡單,只要升級版本即可,我已經(jīng)升級到最新版本Finchley.RELEASE.

傳送門,點我

[ ] 重復監(jiān)聽:

例如,在續(xù)約的時候,eureka會發(fā)出2條EurekaInstanceRenewedEvent事件,但是2條事件的屬性卻不一樣!一個事件的屬性replication為true,另外一個為false.如果我們只想處理replication=true的事件,如下配置即可:

 @EventListener(condition = "#event.replication==false")
 public void listen(EurekaInstanceRenewedEvent event) {
  // 服務續(xù)約
  logger.info(">>>>>>>>>>>>>>>Server續(xù)約:" + event.getServerId());
 }

GitHub代碼,點我

以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: