Eureka集群构建步骤

本是古典 何须时尚 2023-10-11 20:31 116阅读 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

  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.atguigu.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路径下的hosts文件

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

badbb7c6e4dd421698251ee66bd8a23c.png

（四）写YML

7001

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

7002

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

（五）主启动

  1. @SpringBootApplication
  2. @EnableEurekaServer
  3. public class EurekaMain7002
  4. {
  5.     public static void main(String[] args)
  6.     {
  7.         SpringApplication.run(EurekaMain7002.class,args);
  8.     }
  9. }

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

修改YML配置文件

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

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

  1. server:
  2.   port: 80
  4. spring:
  5.     application:
  6.         name: cloud-order-service
  8. eureka:
  9.   client:
  10.     #表示是否将自己注册进EurekaServer默认为true。
  11.     register-with-eureka: true
  12.     #是否从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
  13.     fetchRegistry: true
  14.     service-url:
  15.       #defaultZone: http://localhost:7001/eureka
  16.       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

a09836d9293443ac95ea231596569cf9.png

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

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

2、修改8001/8002的Controller

8001

  1. @RestController
  2. @Slf4j
  3. public class PaymentController
  4. {
  5.     @Value("${server.port}")
  6.     private String serverPort;
  8.     @Resource
  9.     private PaymentService paymentService;
  11.     @PostMapping(value = "/payment/create")
  12.     public CommonResult create(@RequestBody Payment payment)
  13.     {
  14.         int result = paymentService.create(payment);
  15.         log.info("*****插入操作返回结果:" + result);
  17.         if(result > 0)
  18.         {
  19.             return new CommonResult(200,"插入成功,返回结果"+result+"\t 服务端口："+serverPort,payment);
  20.         }else{
  21.             return new CommonResult(444,"插入失败",null);
  22.         }
  23.     }
  25.     @GetMapping(value = "/payment/get/{id}")
  26.     public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id)
  27.     {
  28.         Payment payment = paymentService.getPaymentById(id);
  29.         log.info("*****查询结果:{}",payment);
  30.         if (payment != null) {
  31.             return new CommonResult(200,"查询成功"+"\t 服务端口："+serverPort,payment);
  32.         }else{
  33.             return new CommonResult(444,"没有对应记录,查询ID: "+id,null);
  34.         }
  35.     }
  36. }

8002

  1. @RestController
  2. @Slf4j
  3. public class PaymentController
  4. {
  5.     @Value("${server.port}")
  6.     private String serverPort;
  8.     @Resource
  9.     private PaymentService paymentService;
  11.     @PostMapping(value = "/payment/create")
  12.     public CommonResult create(@RequestBody Payment payment)
  13.     {
  14.         int result = paymentService.create(payment);
  15.         log.info("*****插入操作返回结果:" + result);
  17.         if(result > 0)
  18.         {
  19.             return new CommonResult(200,"插入成功,返回结果"+result+"\t 服务端口："+serverPort,payment);
  20.         }else{
  21.             return new CommonResult(444,"插入失败",null);
  22.         }
  23.     }
  25.     @GetMapping(value = "/payment/get/{id}")
  26.     public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id)
  27.     {
  28.         Payment payment = paymentService.getPaymentById(id);
  29.         log.info("*****查询结果:{}",payment);
  30.         if (payment != null) {
  31.             return new CommonResult(200,"查询成功"+"\t 服务端口："+serverPort,payment);
  32.         }else{
  33.             return new CommonResult(444,"没有对应记录,查询ID: "+id,null);
  34.         }
  35.     }
  36. }

七、负载均衡

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

  1. //public static final String PAYMENT_SRV = "http://localhost:8001";
  3. // 通过在eureka上注册过的微服务名称调用
  4. 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

d0f89afbbfa540a99a8e3be50fb21d15.png

6cf1e0dc9a294de986d3bed944a51eda.png

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

发表评论

表情：
评论列表 （有 0 条评论，116人围观）

还没有评论，来说两句吧...

相关阅读

    相关 Eureka集群配置

    如果注册中心是单点的话，遇到故障就是毁灭性的。在一个分布式系统中，服务注册中心是最重要的基础部分，理应随时处于可以提供服务的状态。为了维持其可用性，使用集群是很好的解决方案。E

    た 入场券た 入场券/ 0 赞/ 90 阅读