詳解SpringCloudeureka服務(wù)狀態(tài)監(jiān)聽

 @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));
 }

@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) {
  // 服務(wù)斷線事件
  String appName = eurekaInstanceCanceledEvent.getAppName();
  String serverId = eurekaInstanceCanceledEvent.getServerId();
  Objects.requireNonNull(appName, "服務(wù)名不能為空!");

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

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

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

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

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

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

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