Spring Cloud微服务实战-服务治理（Spring Cloud Eureka）

 1 spring.application.name=eureka-server
 2 server.port=8761
 3 
 4 eureka.instance.hostname=localhost
 5 
 6 # 代表不向注册中心注册自己
 7 eureka.client.register-with-eureka=false
 8 
 9 # 不去检索服务
10 eureka.client.fetch-registry=false
11 eureka.client.service-url.defaultZone=http://${eureka.instance.hostname}:${server.port}/eureka

 1 package com.suns.eurekaserver;
 2 
 3 
 4 import org.springframework.boot.SpringApplication;
 5 import org.springframework.boot.autoconfigure.SpringBootApplication;
 6 import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
 7 
 8 @EnableEurekaServer
 9 @SpringBootApplication
10 public class EurekaServerApplication {
11 
12     public static void main(String[] args) {
13         SpringApplication.run(EurekaServerApplication.class, args);
14     }
15 }

 1 package com.suns.eurekaservice;
 2 
 3 import org.springframework.boot.SpringApplication;
 4 import org.springframework.boot.autoconfigure.SpringBootApplication;
 5 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
 6 
 7 @EnableDiscoveryClient
 8 @SpringBootApplication
 9 public class EurekaServiceApplication {
10 
11     public static void main(String[] args) {
12         SpringApplication.run(EurekaServiceApplication.class, args);
13     }
14 }

 1 package com.suns.eurekaservice.api;
 2 
 3 import org.apache.log4j.Logger;
 4 import org.springframework.beans.factory.annotation.Autowired;
 5 import org.springframework.cloud.client.ServiceInstance;
 6 import org.springframework.cloud.client.discovery.DiscoveryClient;
 7 import org.springframework.web.bind.annotation.RequestMapping;
 8 import org.springframework.web.bind.annotation.RequestMethod;
 9 import org.springframework.web.bind.annotation.RestController;
10 
11 
12 @RestController
13 public class HelloController {
14 
15     private final Logger logger = Logger.getLogger(getClass());
16 
17     @Autowired
18     private DiscoveryClient client;
19 
20     @RequestMapping(value = "/hello", method = RequestMethod.GET)
21     public String index() {
22         ServiceInstance instance = client.getLocalServiceInstance();
23         logger.info("/hello, host: " + instance.getHost() + ", service_id: " + instance.getServiceId());
24         return "Hello World";
25     }
26 }

2020-02-10 07:33:01.234  INFO 4036 --- [nio-8762-exec-9] c.s.eurekaservice.api.HelloController    : /hello, host: DCNA7245.APAC.Local, service_id: eureka-service

127.0.0.1    server1
127.0.0.1    server2

---
spring:
  profiles: server1                                 # 指定profile=server1
  application:
    name: eureka-high-avai-server
server:
  port: 8761
eureka:
  instance:
    hostname: server1                               # 指定当profile=server1时，主机名
  client:
    serviceUrl:
      defaultZone: http://server2:8762/eureka/      # 将自己注册到server2这个Eureka上面去
  server:
    enableSelfPreservation: false                   # 关掉Eureka的自我保护机制

---
spring:
  profiles: server2
  application:
    name: eureka-high-avai-server
server:
  port: 8762
eureka:
  instance:
    hostname: server2
  client:
    serviceUrl:
      defaultZone: http://server1:8761/eureka/
  server:
    enable-self-preservation: false

 1 package com.suns.eurekahighavaiserver;
 2 
 3 import org.springframework.boot.SpringApplication;
 4 import org.springframework.boot.autoconfigure.SpringBootApplication;
 5 import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
 6 
 7 @EnableEurekaServer
 8 @SpringBootApplication
 9 public class EurekaHighAvaiServerApplication {
10 
11     public static void main(String[] args) {
12         SpringApplication.run(EurekaHighAvaiServerApplication.class, args);
13     }
14 }

 1 ---
 2 spring:
 3   profiles: service1
 4   application:
 5     name: eureka-high-avai-service
 6 server:
 7   port: 8763
 8 eureka:
 9   client:
10     serviceUrl:
11       defaultZone: http://server1:8761/eureka/,http://server2:8762/eureka/
12 
13 ---
14 spring:
15   profiles: service2
16   application:
17     name: eureka-high-avai-service
18 server:
19   port: 8764
20 eureka:
21   client:
22     serviceUrl:
23       defaultZone: http://server1:8761/eureka/,http://server2:8762/eureka/

 1 package com.suns.eurekahighavaiservice;
 2 
 3 import org.springframework.boot.SpringApplication;
 4 import org.springframework.boot.autoconfigure.SpringBootApplication;
 5 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
 6 
 7 @EnableDiscoveryClient
 8 @SpringBootApplication
 9 public class EurekaHighAvaiServiceApplication {
10 
11     public static void main(String[] args) {
12         SpringApplication.run(EurekaHighAvaiServiceApplication.class, args);
13     }
14 }

 1 package com.suns.eurekahighavaiservice.api;
 2 
 3 import org.apache.log4j.Logger;
 4 import org.springframework.beans.factory.annotation.Autowired;
 5 import org.springframework.beans.factory.annotation.Value;
 6 import org.springframework.cloud.client.ServiceInstance;
 7 import org.springframework.cloud.client.discovery.DiscoveryClient;
 8 import org.springframework.web.bind.annotation.RequestMapping;
 9 import org.springframework.web.bind.annotation.RequestMethod;
10 import org.springframework.web.bind.annotation.RestController;
11 
12 
13 @RestController
14 public class HelloController {
15 
16     private final Logger logger = Logger.getLogger(getClass());
17 
18     @Autowired
19     private DiscoveryClient client;
20 
21     @Value("${server.port}")
22     String port;
23 
24     @RequestMapping(value = "/hello", method = RequestMethod.GET)
25     public String index() {
26         ServiceInstance instance = client.getLocalServiceInstance();
27         logger.info("/hello, host: " + instance.getHost() + ", service_id: " + instance.getServiceId() + ", port:" + port);
28         return "/hello, host: " + instance.getHost() + ", service_id: " + instance.getServiceId() + ", port:" + port;
29     }
30 }

1 spring.application.name=eureka-client
2 server.port=8765
3 
4 eureka.client.service-url.defaultZone=http://server1:8761/eureka/,http://server2:8762/eureka/

 1 package com.suns.eurekahighavaiclient;
 2 
 3 import org.springframework.boot.SpringApplication;
 4 import org.springframework.boot.autoconfigure.SpringBootApplication;
 5 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
 6 import org.springframework.cloud.client.loadbalancer.LoadBalanced;
 7 import org.springframework.context.annotation.Bean;
 8 import org.springframework.web.client.RestTemplate;
 9 
10 @EnableDiscoveryClient
11 @SpringBootApplication
12 public class EurekaHighAvaiClientApplication {
13 
14     @Bean
15     @LoadBalanced
16     RestTemplate restTemplate() {
17         return new RestTemplate();
18     }
19 
20     public static void main(String[] args) {
21         SpringApplication.run(EurekaHighAvaiClientApplication.class, args);
22     }
23 }

 1 package com.suns.eurekahighavaiclient.api;
 2 
 3 import org.springframework.beans.factory.annotation.Autowired;
 4 import org.springframework.web.bind.annotation.RequestMapping;
 5 import org.springframework.web.bind.annotation.RequestMethod;
 6 import org.springframework.web.bind.annotation.RestController;
 7 import org.springframework.web.client.RestTemplate;
 8 
 9 @RestController
10 public class ConsumerController {
11 
12     @Autowired
13     RestTemplate restTemplate;
14 
15     @RequestMapping(value = "/ribbon-consumer", method = RequestMethod.GET)
16     public String helloConsumer() {
17         return restTemplate.getForEntity("http://EUREKA-HIGH-AVAI-SERVICE/hello", String.class).getBody();
18     }
19 }

/hello, host: DESKTOP-1BVDM6L, service_id: eureka-high-avai-service, port:8763
/hello, host: DESKTOP-1BVDM6L, service_id: eureka-high-avai-service, port:8764

1 eureka:
2     instance:
3         leaseRenewalIntervalInSeconds: 1 #心跳间隔时间1s
4         leaseExpirationDurationInSeconds: 2 #连续2s未响应时将服务注销                        

1 eureka:
2     server:
3         enable-self-preservation: false    

1 management.context-path=/hello
2  
3 eureka.instance.statusPageUrlPath=${management.context-path}/info
4 eureka.instance.healthCheckUrlPath=${management.context-path}/health