Eureka集群构建步骤

本是古典何须时尚 2023-10-11 20:31 57阅读 0赞

**目录**

一、Eureka集群原理说明

二、EurekaServer集群环境构建步骤

三、将支付服务8001微服务发布到上面2台Eureka集群配置中

四、将订单服务80微服务发布到上面2台Eureka集群配置中

五、测试01

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

七、负载均衡

八、测试02

--------------------

## 一、Eureka集群原理说明 ##

![6f8dbda957254e8d96512a036b24f3d8.png][]  
  
问题：**微服务RPC远程服务调用最核心的是什么**   
高可用，试想你的注册中心只有一个only one， 它出故障了那就呵呵(￣▽￣)"了，会导致整个为服务环境不可用，所以  
　　解决办法：搭建Eureka注册中心集群 ，实现负载均衡+故障容错

**原理**：集群中的每一台Eureka都会相互注册，互相守望

![a85141c99ffa4769a2c5896a5969a405.png][]

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

### （一）新建cloud-eureka-server7002 ###

### （二）改POM ###

<dependencies>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
            </dependency>
            
            <dependency>
                <groupId>com.atguigu.springcloud</groupId>
                <artifactId>cloud-api-commons</artifactId>
                <version>${project.version}</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
            </dependency>
        </dependencies>

### （三）修改映射配置 ###

找到C:\\Windows\\System32\\drivers\\etc路径下的hosts文件

修改映射配置添加进hosts文件

![badbb7c6e4dd421698251ee66bd8a23c.png][]

### （四）写YML ###

7001

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

7002

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

### （五）主启动 ###

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

## 三、将支付服务8001微服务发布到上面2台Eureka集群配置中 ##

修改YML配置文件

server:
      port: 8001
    
    spring:
      application:
        name: cloud-payment-service
      datasource:
        type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
        driver-class-name: org.gjt.mm.mysql.Driver              # mysql驱动包
        url: jdbc:mysql://localhost:3306/db2019?useUnicode=true&characterEncoding=utf-8&useSSL=false
        username: root
        password: 123456
    
    
    eureka:
      client:
        #表示是否将自己注册进EurekaServer默认为true。
        register-with-eureka: true
        #是否从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
        fetchRegistry: true
        service-url:
          #defaultZone: http://localhost:7001/eureka
          defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  # 集群版
    
    mybatis:
      mapperLocations: classpath:mapper/*.xml
      type-aliases-package: com.atguigu.springcloud.entities    # 所有Entity别名类所在包

## 四、将订单服务80微服务发布到上面2台Eureka集群配置中 ##

server:
      port: 80
    
    spring:
        application:
            name: cloud-order-service
    
    eureka:
      client:
        #表示是否将自己注册进EurekaServer默认为true。
        register-with-eureka: true
        #是否从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
        fetchRegistry: true
        service-url:
          #defaultZone: http://localhost:7001/eureka
          defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  # 集群版

## 五、测试01 ##

1、先要启动EurekaServer，7001/7002服务

2、再要启动服务提供者provider，8001

3、再要启动消费者，80

4、[http://localhost/consumer/payment/get/31][http_localhost_consumer_payment_get_31]

![a09836d9293443ac95ea231596569cf9.png][]

## 六、支付服务提供者8001集群环境构建 ##

1、新建cloud-provider-payment8002，与cloud-provider-payment8001一致

2、修改8001/8002的Controller

8001

@RestController
    @Slf4j
    public class PaymentController
    {
        @Value("${server.port}")
        private String serverPort;
    
        @Resource
        private PaymentService paymentService;
    
        @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,"插入成功,返回结果"+result+"\t 服务端口："+serverPort,payment);
            }else{
                return new CommonResult(444,"插入失败",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,"查询成功"+"\t 服务端口："+serverPort,payment);
            }else{
                return new CommonResult(444,"没有对应记录,查询ID: "+id,null);
            }
        }
    }

8002

## 七、负载均衡 ##

1、订单服务访问地址不能写死

//public static final String PAYMENT_SRV = "http://localhost:8001";
     
    // 通过在eureka上注册过的微服务名称调用
    public static final String PAYMENT_SRV = "http://CLOUD-PAYMENT-SERVICE";

2、使用@LoadBalanced注解赋予RestTemplate负载均衡的能力

![db9e0e7b48d0493aab448457e51586a8.png][]

## 八、测试02 ##

先要启动EurekaServer，7001/7002服务

再要启动服务提供者provider，8001/8002服务

[http://localhost/consumer/payment/get/1][http_localhost_consumer_payment_get_31]

![d0f89afbbfa540a99a8e3be50fb21d15.png][]

![6cf1e0dc9a294de986d3bed944a51eda.png][]

Ribbon和Eureka整合后Consumer**可以直接调用服务（服务名称）而不用再关心地址和端口号**，且该服务还有负载功能了。

[6f8dbda957254e8d96512a036b24f3d8.png]: https://img-blog.csdnimg.cn/6f8dbda957254e8d96512a036b24f3d8.png
[a85141c99ffa4769a2c5896a5969a405.png]: https://img-blog.csdnimg.cn/a85141c99ffa4769a2c5896a5969a405.png
[badbb7c6e4dd421698251ee66bd8a23c.png]: https://img-blog.csdnimg.cn/badbb7c6e4dd421698251ee66bd8a23c.png
[http_localhost_consumer_payment_get_31]: http://localhost/consumer/payment/get/31
[a09836d9293443ac95ea231596569cf9.png]: https://img-blog.csdnimg.cn/a09836d9293443ac95ea231596569cf9.png
[db9e0e7b48d0493aab448457e51586a8.png]: https://img-blog.csdnimg.cn/db9e0e7b48d0493aab448457e51586a8.png
[d0f89afbbfa540a99a8e3be50fb21d15.png]: https://img-blog.csdnimg.cn/d0f89afbbfa540a99a8e3be50fb21d15.png
[6cf1e0dc9a294de986d3bed944a51eda.png]: https://img-blog.csdnimg.cn/6cf1e0dc9a294de986d3bed944a51eda.png