Eureka集群原理说明

image.png
服务注册：将服务信息注册进注册中心
服务发现：从注册中心上获取服务信息
实质：存key服务命 取value调用地址

  1. 先启动eureka注主册中心
  2. 启动服务提供者payment支付服务
  3. 支付服务启动后会把自身信息（比如服务地址以别名方式注朋进eureka）
  4. 消费者order服务在需要调用接口时，使用服务别名去注册中心获取实际的RPC远程调用地址
  5. 消去者获得调用地址后，底层实际是利用HttpClient技术实现远程调用
  6. 消费者获得服务地址后会缓存在本地jvm内存中，默认每间隔30秒更新—次服务调用地址

问题:微服务RPC远程服务调用最核心的是什么
高可用，试想你的注册中心只有一个only one，出故障就GG了，会导致整个为服务环境不可用。

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

EurekaServer集群环境构建步骤

参考cloud-eureka-server7001
新建moudle cloud-eureka-server7002
pom.xml

  1.  <dependencies>
  2.         <!--eureka-server-->
  3.         <dependency>
  4.             <groupId>org.springframework.cloud</groupId>
  5.             <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  6.         </dependency>
  7.         <!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  8.         <dependency>
  9.             <groupId>com.holden.springcloud</groupId>
  10.             <artifactId>cloud-api-commons</artifactId>
  11.             <version>${project.version}</version>
  12.         </dependency>
  13.         <!--boot web actuator-->
  14.         <dependency>
  15.             <groupId>org.springframework.boot</groupId>
  16.             <artifactId>spring-boot-starter-web</artifactId>
  17.         </dependency>
  18.         <dependency>
  19.             <groupId>org.springframework.boot</groupId>
  20.             <artifactId>spring-boot-starter-actuator</artifactId>
  21.         </dependency>
  22.         <!--一般通用配置-->
  23.         <dependency>
  24.             <groupId>org.springframework.boot</groupId>
  25.             <artifactId>spring-boot-devtools</artifactId>
  26.             <scope>runtime</scope>
  27.             <optional>true</optional>
  28.         </dependency>
  29.         <dependency>
  30.             <groupId>org.projectlombok</groupId>
  31.             <artifactId>lombok</artifactId>
  32.         </dependency>
  33.         <dependency>
  34.             <groupId>org.springframework.boot</groupId>
  35.             <artifactId>spring-boot-starter-test</artifactId>
  36.             <scope>test</scope>
  37.         </dependency>
  38.         <dependency>
  39.             <groupId>junit</groupId>
  40.             <artifactId>junit</artifactId>
  41.         </dependency>
  42.     </dependencies>

修改映射配置
打开C:\Windows\System32\drivers\etc下的host文件，添加
127.0.0.1 eureka7001.com
127.0.0.1 eureka7002.com

修改7001下的yml文件

  1. server:
  2.   port: 7001
  4. eureka:
  5.   instance:
  6.     hostname: eureka7001.com #eureka服务端的实例名称
  7.   client:
  8.     register-with-eureka: false     #false表示不向注册中心注册自己。
  9.     fetch-registry: false     #false表示自己端就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
  10.     service-url:
  11.       #集群指向其它eureka
  12.       defaultZone: http://eureka7002.com:7002/eureka/
  13.       #单机就是7001自己
  14.       #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址
  15.       #defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

修改7002下的yml文件

server:
  port: 7002


eureka:
  instance:
    hostname: eureka7002.com #eureka服务端的实例名称
  client:
    register-with-eureka: false     #false表示不向注册中心注册自己。
    fetch-registry: false     #false表示自己端就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
    service-url:
      #集群指向其它eureka
      defaultZone: http://eureka7001.com:7001/eureka/

7002主启动类

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

image.pngimage.png
将支付服务8001微服务发布到上面2台Eureka集群配置中
**defaultZone**``:http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka
将订单服务80微服务发布到上面2台Eureka集群配置中
**defaultZone**``:http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka

测试：
按序启动7001、7002、8001、80
image.png

支付服务提供者集群环境构建

互相注册，相互守望.png
参考8001，
新建moudle cloud-provider-payment8002
修改8001、8002中PaymentController——添加serverport

@RestController
@Slf4j
public class PaymentController {
    @Resource
    private PaymentService paymentService;

    @Value("${server.port}")
    private String serverPort;

    @PostMapping(value = "/payment/create")
    public CommonResult create(@RequestBody Payment payment) {
        int result = paymentService.create(payment);
        log.info("*****插入结果：" + result);

        if (result > 0) {
            return new CommonResult(200, "插入数据库成功,serverPort:"+serverPort, result);
        } else {
            return new CommonResult(404, "插入数据库失败,serverPort:"+serverPort, null);
        }
    }

    @GetMapping(value = "/payment/get/{id}")
    public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id) {

        Payment payment = paymentService.getPaymentById(id);
        log.info("*****查询结果：" + payment);

        if (payment != null) {
            return new CommonResult(200, "查询成功,serverPort:"+serverPort, payment);
        } else {
            return new CommonResult(404, "没有对应记录，查询ID"+id, null);
        }
    }
}

多次测试，均为8001——bug，原因80中地址写死了
image.png
OrderController.java，修改PAYMENT_URL属性

public class OrderController {
        public static final String PAYMENT_URL = "http://CLOUD-PAYMENT-SERVICE";
。。。。。。
}

继续测试，报错；
识别不了，此时还不能负载均衡
image.png
解决：使用@LoadBalanced注解赋予RestTemplate负载均衡的能力
80中ApplicationContextConfig类

@Configuration
public class ApplicationContextConfig {
    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
    }
}

测试，运行成功，8001、8002交替出现，默认使用轮询方式
image.png
Ribbon和Eureka整合后Consumer可以直接调用服务而不用再关心地址和端口号，且该服务还有负载功能了