SpringCloud Eureka 服务注册与发现-下

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

为什么需要集群Eureka Server

示意图

说明

1. 微服务RPC 远程服务调用最核心的是实现高可用

2. 如果注册中心只有1 个，它出故障，会导致整个服务环境不可用

3. 解决办法∶搭建Eureka 注册中心集群，实现负载均衡+故障容错

示意图

搭建Eureka Server 集群

创建e-commerce-eureka-server-9002 微服务模块[作为注册中心]

创建步骤参考e-commerce-eureka-server-9001

修改pom.xml , 加入依赖

    <!--引入相关的依赖: 如果有需要，可以调整-->
    <dependencies>
        <!--引入eureka-server 场景启动器starter: 使用版本仲裁-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
        <!--引入web-starter 说明我们使用版本仲裁(从父项目继承了版本)
        -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!--说明:starter-actuator 是springboot程序的监控系统, 可以实现系统的健康检测
        可以通过http://localhost:9002/actuator 看到相关的连接,和信息
        -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>


        <!--lombok-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>

        <!--引入test-starter-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
        <!--引入e_commerce_center-common-api-->
        <dependency>
            <groupId>com.hspedu.springcloud</groupId>
            <artifactId>e_commerce_center-common-api</artifactId>
            <version>${project.version}</version>
        </dependency>
    </dependencies>

创建resources/application.yml

server:
  port: 9002

#配置eureka-server
eureka:
  instance:
    hostname: eureka9002.com #服务实例名
  client:
    #配置不向注册中心注册自己
    register-with-eureka: false
    #表示自己就是注册中心,作用就是维护注册服务实例, 不需要去检索服务
    fetch-registry: false
    service-url:
      #这里注册到eureka9001 server
      defaultZone: http://eureka9001.com:9001/eureka/

创建主启动类EurekaApplication9002.java

@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication9002 {
    public static void main(String[] args) {
        SpringApplication.run(EurekaApplication9002.class, args);
    }
}

修改e-commerce-eureka-server-9001 微服务模块

server:
  port: 9001

#配置eureka-server
eureka:
  instance:
    hostname: eureka9001.com #服务实例名
  client:
    #配置不向注册中心注册自己
    register-with-eureka: false
    #表示自己就是注册中心,作用就是维护注册服务实例, 不需要去检索服务
    fetch-registry: false
    service-url:
      #设置与eureka server 交互模块, 查询服务和注册服务都需要依赖这个地址
      #defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
      #相互注册，这里应该注册到eureka server9002
      defaultZone: http://eureka9002.com:9002/eureka/

修改hosts 文件

1. 文件: C:\Windows\System32\drivers\etc\host
2. 文件可以先拷贝到桌面，修改后，再拷贝会去
3. 加入内容

#eureka 主机名和ip 映射
127.0.0.1 eureka9001.com
127.0.0.1 eureka9002.com

完成测试

1 启动e-commerce-eureka-server-9001

2 启动e-commerce-eureka-server-9002

3 浏览器: http://eureka9001.com:9001 浏览器: http://eureka9002.com:9002

将member-service-provider-10000 注册到EurekaServer 集群(目前2 台)

修改resources/application.yml

service-url:
# defaultZone: http://localhost:9001/eureka #表示将自己注册到哪个eurekaServer
# 将本微服务注册到多个eurekaServer, 使用逗号隔开
defaultZone: http://eureka9001.com:9001/eureka,http://eureka9002.com:9002/eureka

完成测试

1. 启动e-commerce-eureka-server-9001 和e-commerce-eureka-server-9002
2. 启动member-service-provider-10000
3. 观察member-service-provider-10000 是否注册到Eureka 集群(目前2 台)

浏览器输入: http://eureka9001.com:9001/

浏览器输入: http://eureka9002.com:9002/

将member-service-consumer-80 注册到EurekaServer 集群(目前2 台)

修改resources/application.yml

service-url:
# defaultZone: http://localhost:9001/eureka #表示将自己注册到哪个eurekaServer
# 将本微服务注册到多个eurekaServer, 使用逗号隔开
defaultZone: http://eureka9001.com:9001/eureka,http://eureka9002.com:9002/eureka

完成测试

1. 启动e-commerce-eureka-server-9001 和e-commerce-eureka-server-9002
2. 启动member-service-provider-10000
3. 观察member-service-provider-10000 是否注册到Eureka 集群(目前2 台)

浏览器输入: http://eureka9001.com:9001/

浏览器输入: http://eureka9002.com:9002/

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

– 示意图

创建member-service-provider-10002

1. 参考member-service-provider-10000 来创建member-service-provider-10002 即可

2. 创建好后，使用member-service-provider-10000 的源码和配置替换member-service-provider-10002 生成的代码(不要到磁盘整体拷贝，会出现关联到member-service-provider-10000 的问题，很麻烦,可以创建好新项目的包，然后再拷贝对应包下的文件，就不会出问题)

3. 提醒，拷贝时不要忘记拷贝resources/mapper/MemberMapper.xml 这些xxx.xml 文件

创建resources/application.yml

1. 创建好application.yml
2. 从member-service-provider-10000 拷贝application.yml 的内容
3. 修改端口号即可

server:
port: 10002

创建启动类MemberApplication10002

//@EnableEurekaClient: 将该程序标识为eureka-client
@EnableEurekaClient
@SpringBootApplication
public class MemberApplication10002 {
    public static void main(String[] args) {
        SpringApplication.run(MemberApplication10002.class, args);
    }
}

完成测试

1 启动eureka server 集群(目前2 台)

2 启动member-service-provider-10000

3 启动member-service-provider-10002

完成测试

浏览器输入: http://eureka9001.com:9001/

浏览器输入: http://eureka9002.com:9002/

注意事项和细节

1. 因为member-service-provider-10000 和member-service-provider-10002 作为一个集群提供服务, 因此需要将spring.application.name 进行统一

2. 这样消费方通过统一的别名进行负载均衡调用

将member-service-provider-10000 和member-service-provider-10002的名字统一成member-service-provider进行负载均衡调用

spring:
  application:
    name: member-service-provider #配置应用的名称

配置服务消费端member-service-consumer-80 使用会员中心服务集群

示意图

修改MemberConsumerController.java

// 文件位置: member-service-consumer-80 模块
com/springcloud/controller/MemberConsumerController.java

@RestController
@Slf4j
public class MemberConsumerController {

    //定义member_service_provider_url 这是一个基础url地址
    //使用shift+ctrl+u 进行字母大小写的切换
    /**
     * 说明:
     * 1. MEMBER-SERVICE-PROVIDER 就是服务提供方[集群], 注册到Eureka Server 的名称
     * 2. 也就是服务提供方[集群]对外暴露的名称为 MEMBER-SERVICE-PROVIDER
     * 3. MEMBER-SERVICE-PROVIDER 目前有 两个 Availability Zones member-service-provider:10000
     *    还有一个 member-service-provider:10002
     *    需要增加一个注解@LoadBalanced 赋予 RestTemplate 负载均衡的能力,也就是会根据你的负载均衡算法
     *    来选择某个服务去访问, 默认是轮询算法, 当然我们也可以自己配置负载均衡算法
     */
    public static final String MEMBER_SERVICE_PROVIDER_URL =
            "http://MEMBER-SERVICE-PROVIDER"; //后面这里地方会修改成提供服务模块的注册别名
    //装配RestTemplate bean/对象
    @Resource
    private RestTemplate restTemplate;

    //装配DiscoveryClient
    @Resource
    private DiscoveryClient discoveryClient;

修改CustomizationBean.java

//文件位置：member-service-consumer-80 模块

@Configuration
public class CustomizationBean {

    //说明: 配置注入RestTemplate bean/对象
    //这里的@LoadBalanced 就是赋予 RestTemplate 负载均衡的能力
    //默认是使用轮询算法来访问远程调用接口/地址
    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }
}

为了看到测试效果，修改服务提供方

如 member-service-provider-10000

1. 在两个服务提供方的查询和添加返回结果处增加自己服务名称信息，其它位置可参考加入

    @GetMapping(value = "/member/get/{id}")
    public Result getMemberById(@PathVariable("id") Long id) {
        Member member = memberService.queryMemberById(id);
        log.info("查询结果= " + member);
        if (member != null) {
            return Result.success("查询成功member-service-provider-10000", member);
        } else {
            return Result.error("402", "ID= " + id + " 不存在");
        }
    }

完成测试

1 启动eureka server 集群(目前2 台)

2 启动member-service-provider-10000

3 启动member-service-provider-10002

http://localhost:10000/member/get/1

http://localhost:10002/member/get/1

启动member-service-consumer-80

浏览器访问: http://localhost/member/consumer/get/1

再次访问，会看到访问到不同的服务.

交替访问member 服务说明:

1. 注解@LoadBalanced 底层是Ribbon 支持算法

2.Ribbon 和Eureka整合后consumer 直接调用服务而不用再关心地址和端口号，且该服务还有负载功能

包依赖配置图

1.spring-cloud-starter-netflix-eureka-client 自带
spring-cloud-starter-netflix-ribbon(如图)

获取Eureka Server 服务注册信息-DiscoveryClient

先看需求分析示意图

这里我们以服务消费方, 去获取Eureka Server 的服务注册信息为例讲解

当然也可以在服务提供方获取Eureka Server 的服务注册信息

代码实现

1. 所在模块member-service-consumer-80
2. 修改controller/MemberConsumerController.java

    //装配DiscoveryClient
    @Resource
    private DiscoveryClient discoveryClient;


    @GetMapping("/member/consumer/discovery")
    public Object discovery() {

        List<String> services = discoveryClient.getServices();
        //遍历services
        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;
    }

这样配置之后还要在主启动类开启

//@EnableEurekaClient 将程序标识为eureka client
@EnableEurekaClient
@SpringBootApplication
@EnableDiscoveryClient //启用服务发现
public class MemberConsumerApplication {
    public static void main(String[] args) {

        SpringApplication.run(MemberConsumerApplication.class,args);
    }
}