SpringCloud Eureka-服务注册与发现02

3.搭建EurekaServer集群-实现负载均衡&故障容错

3.1为什么需要集群EurekaServer？

1. 微服务RPC远程服务调用最核心的是高可用
2. 如果注册中心只有1个，如果出现故障，会导致整个服务环境不可用
3. 解决办法就是搭建Eureka注册中心集群，实现负载均衡和故障容错（构成集群的几个主机之间的提供的服务是相同的）

3.2搭建EurekaServer集群

3.2.1搭建第二个注册中心

搭建 e-commerce-eureka-server-9002 微服务模块，作为第二个 EurekaServer -注册中心。

搭建的具体步骤和 e-commerce-eureka-server-9001 一样，见上篇2.2

（1）创建Module，在pom.xml加入相关依赖（略）

（2）创建配置文件application.yml

server:
  port: 9002

#配置Eureka-server
eureka:
  instance:
    hostname: eureka9002.com #服务实例名
  client: #如果Eureka是一个集群，那么相互两个EurekaServer之间也可以当做对方为客户端
    #配置是否向注册中心注册自己
    register-with-eureka: false
    #表示自己就是注册中心，作用是维护注册的服务实例，不需要去检索服务
    fetch-registry: false
    service-url:
      #当前的注册中心 需要注册到 Eureka9001 注册中心
      defaultZone: http://eureka9001.com:9001/eureka/

（3）创建主启动类

package com.li.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

/**
 * @author 李
 * @version 1.0
 */
@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication9002 {
    public static void main(String[] args) {
        SpringApplication.run(EurekaApplication9002.class,args);
    }
}

3.2.2修改第一个注册中心

（1）修改 e-commerce-eureka-server-9001 的 application.yml 文件

server:
  port: 9001

#配置Eureka-server
eureka:
  instance:
    hostname: eureka9001.com #服务实例名
  client: #如果Eureka是一个集群，那么相互两个EurekaServer之间也可以当做对方为客户端
    #配置是否向注册中心注册自己
    register-with-eureka: false
    #表示自己就是注册中心，作用是维护注册的服务实例，不需要去检索服务
    fetch-registry: false
    service-url: #设置于 Eureka server 的交互模块，查询服务和注册服务都需要依赖这个地址
      #EurekaServer之间相互注册
      defaultZone: http://eureka9002.com:9002/eureka/

（2）将e-commerce-eureka-server-9001的主启动类的名称修改为 EurekaApplication9001

3.2.3修改host文件

因为是在一台电脑上模拟的集群，为了浏览器输入类似eureka9002.com:9002/eureka/的地址，可以直接访问到，这里修改host文件，对上述指定域名进行本机的ip映射。

文件位置：C:\Windows\System32\drivers\etc\hosts

3.2.4完成测试

分别启动两个注册中心，在浏览器中访问上图配置的地址：

3.3.5将其他微服务注册到EurekaServer集群

（1）将member-service-provider-10000注册到 EurekaServer 集群

部分配置：

eureka:
    service-url:
      #将本微服务注册到多个EurekaServer，使用逗号间隔
      defaultZone: http://eureka9001.com:9001/eureka,http://eureka9002.com:9002/eureka

（2）将member-service-consumer-80注册到 EurekaServer 集群：同上，修改位置相同（略）。

（3）启动这些微服务，可以看到在所有EurekaServer的监控页面中都注册了上述微服务：

3.3搭建会员中心服务提供方集群

同样的，为了高可用性，我们不仅在EurekaServer中要使用集群，在服务提供方也要使用集群（构成集群的几个主机之间的提供的服务是相同的）。

3.3.1搭建第二个服务提供方

所以参考 member-service-provider-10000 的代码来创建 member-service-provider-10002 ，以下简称为10000 和 10002

（1）创建Module-member-service-provider-10002

（2）可以将磁盘下10000子模块的main目录复制替换10002的main目录

（3）然后在10002的pom.xml中导入和10000的pom.xml相同的依赖

（4）最后修改10002的端口和当前应用的名称，并修改10002的主程序名称。

（5）测试

3.3.2注意事项和细节

因为member-service-provider-10000和member-service-provider-10002是作为一个集群对外提供服务的，因为我们需要将两个微服务的spring.application.name进行统一，这样消费方可以通过统一的别名进行负载均衡调用。

spring:
  application:
    name: member-service-provider #同一将服务提供方的应用名设置为member-service-provider

设置后，重新启动服务启动方，在EurekaServer中可以看到注册列表中只有一个服务提供名，但是它包含了两个远程调用的接口：

3.4配置服务消费端使用会员中心服务集群

配置服务消费端 member-service-consumer-80，让它可以使用会员中心服务集群。

（1）修改MemberConsumerController.java

package com.li.springcloud.controller;

import ...

/**
 * @author 李
 * @version 1.0
 */
@RestController
@Slf4j
public class MemberConsumerController {
    @Resource
    private RestTemplate restTemplate;

    /**
     * 1.MEMBER-SERVICE-PROVIDER 是服务提供方[集群]注册到EurekaServer的别名
     * 2.也是服务提供方[集群]对方暴露的名称
     * 3.这里MEMBER-SERVICE-PROVIDER 目前有两个可以获取的区域：
     *   member-service-provider-10000、member-service-provider-10002
     */
    public static final String MEMBER_SERVICE_PROVIDER_URL =
            "http://MEMBER-SERVICE-PROVIDER";//改为提供服务模块的别名

    //添加对象到数据库表中
    @PostMapping("/member/consumer/save")
    public Result<Member> save(Member member) {
        return restTemplate.postForObject
                (MEMBER_SERVICE_PROVIDER_URL + "/member/save",
                        member,
                        Result.class);
    }
    
    //根据id调用服务接口，返回member对象信息
    @GetMapping("/member/consumer/get/{id}")
    public Result<Member> getMemberById(@PathVariable("id") Integer id) {
        return restTemplate.getForObject
                (MEMBER_SERVICE_PROVIDER_URL + "/member/get/" + id,
                        Result.class);
    } 
}

（2）修改 CustomInitBean.java

需要增加注解 @LoadBalanced，赋予 RestTemplate负载均衡能力，即选择 MEMBER-SERVICE-PROVIDER 某一个服务访问，默认是轮询算法

package com.li.springcloud.config;

import ...

/**
 * @author 李
 * @version 1.0
 * 注入RestTemplate Bean
 */
@Configuration
public class CustomInitBean {
    @Bean
    @LoadBalanced //赋予RestTemplate负载均衡的能力，默认是使用轮询算法来访问远程调用接口
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }
}

（3）依次启动EurekaServer集群、服务提供方集群、服务消费方

为了区分，可以在服务提供方的Controller中打印当前的服务提供方的名称

• 先用浏览器直接访问服务提供方集群的接口，目的是测试服务提供方是否正常工作：

  注意这里访问的分别是不同的服务提供方的接口

• 在用浏览器访问服务消费方的接口，测试服务消费方是否正常工作：

  可以看到浏览器访问同一个地址（即只有一个服务消费方模块），但是底层调用的服务提供方是不一样的（轮询访问）

  第一次访问：

  

第二次访问：

交替访问member服务说明：

1. 注解 @LoadBalanced底层是Ribbon支持算法
2. Ribbon和Eureka整合后，服务消费方可以直接调用服务，而不用再关心服务提供方的地址和端口号
3. 该服务还有负载功能

3.5通过DiscoveryClient获取EurekaServer服务注册信息

无论是服务消费方还是服务提供方，它们都是EurekaClient。如果希望获取到EurekaServer的服务注册信息，可以使用DiscoveryClient。

这里以服务消费方为例，获取EurekaServer的服务注册信息：

（1）修改 MemberConsumerController.java

package com.li.springcloud.controller;

import ...

/**
 * @author 李
 * @version 1.0
 */
@RestController
@Slf4j
public class MemberConsumerController {
    @Resource
    private RestTemplate restTemplate;

    //装配一个DiscoveryClient，
    //注意用的包是 import org.springframework.cloud.client.discovery.DiscoveryClient;
    @Resource
    private DiscoveryClient discoveryClient;

    @GetMapping("/member/consumer/discovery")
    public Object discovery() {
        List<String> services = discoveryClient.getServices();
        for (String service : services) {
            log.info("服务名={}", service);
            //通过服务名来获取服务名对应的实例
            List<ServiceInstance> instances = discoveryClient.getInstances(service);
            for (ServiceInstance instance : instances) {
                log.info("id={},host={},port={},uri={}",
                        instance.getServiceId(), instance.getHost(), 
                         instance.getPort(), instance.getUri());
            }
        }
        return discoveryClient;
    }
    
    //其他方法略..
}

（2）修改启动类，添加注解启用服务发现

（3）重启服务消费模块，浏览器访问 http://localhost/member/consumer/discovery，后台输出如下：