فهرست منبع

注册中心监听服务加入

gaodm 6 سال پیش
والد
کامیت
56f633b56d

+ 2 - 0
config-server/src/main/resources/application.yml

@@ -28,6 +28,8 @@ server:
 
 eureka:
   instance:
+    prefer-ip-address: true #使用IP注册
+    instance-id: ${spring.cloud.client.ip-address}:${server.port}
     leaseRenewalIntervalInSeconds: 10
     health-check-url-path: /actuator/health #2.0后actuator的地址发生了变化
   client:

+ 2 - 0
config-server/src/main/resources/shared/application-dev.yml

@@ -12,6 +12,8 @@
 
 eureka:
   instance:
+    prefer-ip-address: true #使用IP注册
+    instance-id: ${spring.cloud.client.ip-address}:${server.port}
     leaseRenewalIntervalInSeconds: 10
     health-check-url-path: /actuator/health #2.0后actuator的地址发生了变化
   client:

+ 2 - 0
config-server/src/main/resources/shared/application-local.yml

@@ -12,6 +12,8 @@
 
 eureka:
   instance:
+    prefer-ip-address: true #使用IP注册
+    instance-id: ${spring.cloud.client.ip-address}:${server.port}
     leaseRenewalIntervalInSeconds: 10
     health-check-url-path: /actuator/health #2.0后actuator的地址发生了变化
   client:

+ 22 - 0
eureka-server/src/main/java/com/diagbot/listener/InstanceCancelListener.java

@@ -0,0 +1,22 @@
+package com.diagbot.listener;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.cloud.netflix.eureka.server.event.EurekaInstanceCanceledEvent;
+import org.springframework.context.ApplicationListener;
+import org.springframework.context.annotation.Configuration;
+
+
+/**
+ * @Description: 服务挂掉监听
+ * @author: gaodm
+ * @time: 2018/8/21 15:40
+ */
+@Configuration
+public class InstanceCancelListener implements ApplicationListener<EurekaInstanceCanceledEvent> {
+    private static final Logger logger = LoggerFactory.getLogger(InstanceCancelListener.class);
+    @Override
+    public void onApplicationEvent(EurekaInstanceCanceledEvent event) {
+        logger.info("服务:{}挂了",event.getAppName());
+    }
+}

+ 21 - 0
eureka-server/src/main/java/com/diagbot/listener/InstanceRegisterListener.java

@@ -0,0 +1,21 @@
+package com.diagbot.listener;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.cloud.netflix.eureka.server.event.EurekaInstanceRegisteredEvent;
+import org.springframework.context.ApplicationListener;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @Description: 服务注册监听
+ * @author: gaodm
+ * @time: 2018/8/21 15:41
+ */
+@Configuration
+public class InstanceRegisterListener implements ApplicationListener<EurekaInstanceRegisteredEvent> {
+    private static final Logger logger = LoggerFactory.getLogger(InstanceRegisterListener.class);
+    @Override
+    public void onApplicationEvent(EurekaInstanceRegisteredEvent eurekaInstanceRegisteredEvent) {
+        logger.info("服务:{},注册成功了",eurekaInstanceRegisteredEvent.getInstanceInfo().getAppName());
+    }
+}

+ 21 - 0
eureka-server/src/main/java/com/diagbot/listener/InstanceRenewListener.java

@@ -0,0 +1,21 @@
+package com.diagbot.listener;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.cloud.netflix.eureka.server.event.EurekaInstanceRenewedEvent;
+import org.springframework.context.ApplicationListener;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @Description: 心跳检测服务监听
+ * @author: gaodm
+ * @time: 2018/8/21 15:41
+ */
+@Configuration
+public class InstanceRenewListener implements ApplicationListener<EurekaInstanceRenewedEvent> {
+    private static final Logger logger = LoggerFactory.getLogger(InstanceRenewListener.class);
+    @Override
+    public void onApplicationEvent(EurekaInstanceRenewedEvent event) {
+        logger.info("心跳检测服务:{}" ,event.getInstanceInfo().getAppName());
+    }
+}