【SpringCloud】服務提供者集群與服務發現Discovery（三）

　　閱讀本章，請先閱讀【SpringCloud】快速入門（一）

　　本章使用Demo，是在SpringCloud單機版的基礎上，擴充的。

服務提供者集群

　　既然SpringCloud的是微服務結構，那么對於同一種服務，當然不可能只有一個節點，需要部署多個節點

　　架構圖如下：

　　

　　由上可以看出存在多個同一種服務提供者（Service Provider）

　　搭建服務提供者集群

　　1、參考：【SpringCloud】SpringCloud 快速入門（一）搭建單機版的：Eureka Server、Service Provider、Service Consumer

　　2、根據支付模塊服務提供者（test-springcloud-provider-payment8001），在父工程中，同樣新建一個支付模塊的服務提供者（test-springcloud-provider-payment8002）

　　　　服務8001與8002的配置中，除端口外，其他都相同，且spring.application.name應用名稱必須相同，表明2個服務是同一種服務

　　　　服務8002配置文件如下：

# 端口
server:
  port: 8002

spring:
  application:
    name: cloud-payment-service
  #   數據源基本配置
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/test_springcloud?allowPublicKeyRetrieval=true&useSSL=true
    username: admin
    password: 123456

eureka:
  client:
    # 表示將自己注冊進Eureka Server默認為true
    register-with-eureka: true
    # 是否從Eureka Server抓去已有的注冊信息，默認是true
    fetch-registry: true
    # 設置與Eureka Server交互的地址查詢服務和注冊服務都需要依賴這個地址
    service-url:
      defaultZone: http://localhost:8761/eureka

mybatis:
  mapperLocations: classpath:mapper/*Mapper.xml
  # 所有entity別名類所在的包
  type-aliases-pachage: com.test.springcloud.entities

 

　　3、重新啟動項目，打開Eureka查看，發現有2個支付服務

　　　　

　　4、使用訂單模塊消費者調用支付服務

　　　　消費者部分代碼模塊如下：

@Configuration
public class AppConfig {

    /**
     * 注入restTemplate，請用請求rest接口
     * @return
     */
    @Bean
    // 標注此注解后，RestTemplate就具有了客戶端負載均衡能力
    // 負載均衡技術依賴於的是Ribbon組件~
    // RestTemplate都塞入一個loadBalancerInterceptor 讓其具備有負載均衡的能力
    @LoadBalanced
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
}


@RestController
@Slf4j
public class OrderController {

    public static final String PAYMENT_URL = "http://CLOUD-PAYMENT-SERVICE";

    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/consumer/payment/get/{id}")
    public CommonResult<Payment> getPayment(@PathVariable("id") Long id){
        return restTemplate.getForObject(PAYMENT_URL + "/payment/get/" + id, CommonResult.class);
    }

    ...
}

　　　　由上可以，通過配置向容器中注入了RestTemplate對象，而RestTemplate又被標注此@LoadBalanced注解后，RestTemplate就具有了客戶端負載均衡能力，也就是說RestTemplate會輪流調用服務的各個節點，到達均衡的目的

　　5、測試調用，啟動項目，使用地址：http://localhost:8000/consumer/payment/get/1，進行訪問，可以看到已到達負載均衡的目的

　　　　

服務發現Discovery

　　服務發現就是對於注冊進eureka里面的微服務，可以通過服務發現獲得該服務的信息

　　案例如下：

　　1、在微服務中使用@EnableDiscoveryClient注解，啟用服務發現

// Eureka客戶端
@EnableEurekaClient
// 啟用服務發現
@EnableDiscoveryClient
@SpringBootApplication
public class PaymentMain8001 {
    public static void main(String[] args) {
        SpringApplication.run(PaymentMain8001.class, args);
    }
}

　　2、編輯Controller，啟用服務發現之后，它會自動向容器注入DiscoveryClient（服務發現客戶端）

　　　　通過調用DiscoveryClient的getServices方法，從注冊中心獲取服務列表

　　　　通過調用DiscoveryClient的getInstances方法，從注冊中心獲取服務實例集

public class PaymentController {

    @Autowired
    private DiscoveryClient discoveryClient;

    @GetMapping(value = "/payment/discovery")
    public Object discovery(){
        // 獲取服務列表
        List<String> services = discoveryClient.getServices();
        for (String element : services) {
            log.info("=====element:" + element);
        }
        
        // 獲取服務實例集
        List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");
        for (ServiceInstance instance : instances) {
            log.info("服務發現" + "\n"
                    + "getServiceId === " + instance.getServiceId() + "\n"
                    + "getHost === " + instance.getHost() + "\n"
                    + "getPort === " + instance.getPort() + "\n"
                    + "getUri === " + instance.getUri() );
        }

        return  this.discoveryClient;
    }

} 

 　　3、啟用服務，使用地址：http://localhost:8001/payment/discovery，進行訪問

　　　　頁面結果：

　　　　

　　　　后台日志：

　　　　

　　　　由上可知，通過DiscoveryClient能獲取到注冊進eureka里面的微服務信息。