SpringCloud------Eureka集群版整合生产(集群)以及消费（五）

青旅半醒 2024-03-22 12:04 29阅读 0赞

## SpringCloud------Eureka集群版整合生产以及消费（五） ##

集群避免单点故障的发生。  
服务注册：  
将服务信息注册进服务中心  
服务发现：  
从注册中心上获取服务信息  
实质：存key服务名，取value调用地址

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

### 集群的原理： ###

互相注册，相互守望，对外暴露为一个整体

### EurekaServer集群环境构建步骤 ###

> 1.参考cloud-erueka-server7001，新建cloud-erueka-server7002  
> 2.改pom  
> 3.修改映射配置  
> 4.写YML（以前单机）  
> 5.主启动

第一二步与7001一致。  
3.修改映射配置  
找到hosts文件

> C:\\Windows\\System32\\drivers\\etc

修改映射配置，添加进hosts文件  
模拟不同的eureka机器，实际映射的都是同一台机器

127.0.0.1	eureka7001.com
    127.0.0.1	eureka7001.com

7002 ynl文件修改：

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

7001 yml文件修改：

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

重启两服务，运行结果如图所示  
7001指向7002，7002指向7001，相互注册  
![在这里插入图片描述][c024c62c099f4bcf9c430582455b388f.png]  
![在这里插入图片描述][60e888900200477a828227a67756467b.png]  
此时完成eureka集群配置。

### 此时需要将生产者、消费者都发布在两台eureka集群配置中。 ###

重点在修改yml文件。  
将配置文件中，原本只向一个服务注册中心注册的配置，改为向两个服务中心注册即可。

service-url:
          #defaultZone: http://localhost:7001/eureka
          defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka

#### 此时eureka是已经是集群配置，需要再将服务提供者进行集群配置。 ####

> 1.参考8001新建8002  
> 2.该pom  
> 3.写YML  
> 4.主启动  
> 5.业务类  
> 6.修改8001/8002的controller

1、2、3、4、5复制8001到8002即可，注意修改端口、以及启动类即可  
6.修改controller

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

8001和8002都新增server.port  
获取配置文件中的端口号，加到日志输出中，便于观察消费者调用生产者的哪一个。  
启动8002后，可以看到有两个生产者。  
**此时对外暴漏的不再是地址和端口，而是微服务名称**  
![在这里插入图片描述][f86c5e7ec3ef4465a3cfe9a96c3ae008.png]  
**同样在消费者处也需要修改**  
原本是将URL写死IP+端口号，之后要改成**服务名**

//    public static final String URL = "http://localhost:8001";
        public static final String URL = "http://CLOUD-PAYMENT-SERVICE";

**直接这样调用也会报错。因为没有开启负载均衡配置**  
使用@LoadBalanced注解赋予RestTemplate负载均衡的能力

/**
     * RestTemplate 配置类类
     */
    @Configuration
    public class ApplicationContextConfig {
        
    
        @Bean
        @LoadBalanced
        public RestTemplate getRestTemplate(){
        
            return new RestTemplate();
        }
    }

此时通过测试调用生产者，能够看到日志打印的端口号，8001一次8002一次，采用轮询的机制，各调用一次。  
【Ribbon的负载均衡功能，默认的就是轮询】

#### Ribbon和Eureka整合后Consumer可以直接调用服务而不用再关心地址和端口号，并且该服务还具有负载均衡功能 ####

消费者只关注微服务的名称。

[c024c62c099f4bcf9c430582455b388f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/95a71ff0818d49d9919f4d3c14c18028.png
[60e888900200477a828227a67756467b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/eae89199f21d4ed3871e3e04f0ed7a9d.png
[f86c5e7ec3ef4465a3cfe9a96c3ae008.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/b4a476cfcc1747b28f04c4c9d770659c.png