使用 Eureka 简单实现服务健康监控日志分析

spring:
  application:
    name: dcp-hellworld-service
eureka:
  client:
    serviceUrl:
      defaultZone: http://dcp-peer-eureka1:8000/eureka/,http://dcp-peer-eureka2:8000/eureka/,http://dcp-peer-eureka3:8000/eureka/
  instance:
    status-page-url-path: /info
    instance-id: ${spring.cloud.client.ipAddress}:${server.port}
    preferIpAddress: true
    registry-fetch-interval-seconds: 30
    lease-renewal-interval-in-seconds: 15
    lease-expiration-duration-in-seconds: 15

@Autowiredprivate
DiscoveryClient discoveryClient;

List<ServiceInstance> serviceInstances = discoveryClient.getInstances(serviceId);

@GetMapping("/test")
public String invoke() {
    return "invoke::" + UUID.randomUUID();
}

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-actuator</artifactId>
  <version>2.1.3.RELEASE</version>
</dependency>

@GetMapping("/service/{serviceId}/multinstances")
public R testMuitlIntancesInvoke(@PathVariable String serviceId) {        RestTemplate restTemplate = new RestTemplate();        // 获取服务的实例列表
        List<ServiceInstance> serviceInstances = discoveryClient.getInstances(serviceId);        if (CollectionUtils.isNotEmpty(serviceInstances)) {
            serviceInstances.forEach(s -> {                long s =  System.currentTimeMillis();                StringBuilder invokeURL = new StringBuilder();                invokeURL.append("http://").append(s.getHost()).append(":").append(s.getPort());
                invokeURL.append("api/v1/test");
                String invokeResult = restTemplate.getForObject(invokeURL.toString(), String.class);
                long e =  System.currentTimeMillis();               // 发送 kafka 消息
                kafkaClient.send(topicName, s , (e-s)/1000);
            });        
      }        
      return R.ok().data(serviceInstances.size());