devbox
从前慢现在也慢
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

springcloud（1）—— eureka本地集群搭建以及实现微服务的负载均衡调用_本地eureka

作者：从前慢现在也慢 | 2024-07-17 08:42:37

赞

踩

本地eureka

什么是服务治理?
Spring Cloud 封装了 Netflix 公司开发的 Eureka 模块来实现服务治理
在传统的rpc远程调用框架中，管理每个服务与服务之间依赖关系比较复杂，所以需要使用服务治理，管理服务与服务之间依赖关系，可以实现服务调用、负载均衡、容错等，实现服务发现与注册！

什么是服务注册与发现
Eureka采用了CS的设计架构，Eureka Server 作为服务注册功能的服务器，它是服务注册中心。而系统中的其他微服务，使用 Eureka的客户端连接到 Eureka Server并维持心
跳连接。这样系统的维护人员就可以通过 Eureka Server 来监控系统中各个服务是否正常运行。
在服务注册与发现中，有一个注册中心，当服务器启动的时候，会把当前自己服务器的信息比如服务地址、通讯地址等以别名方式注册到注册中心上。另一方 (消费者|服务提供
者) ，以该别名的方式去注册中心上获取到实际的服务通讯地址，然后再实现本地RPC调用。RPC远程调用框架核心设计思想: 在于注册中心，因为使用注册中心管理每个服务与
服务之间的一个依赖关系(服务治理概念)。在任何rpc远程框架中，都会有一个注册中心(存放服务地址相关信息(接口地址)) 

在这里插入图片描述

Eureka包含两个组件: Eureka Server和Eureka Client
Eureka Server提供服务注册服务：
各个微服务节点通过配置启动后，会在EurekaServer中进行注册，这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观看到。


EurekaClient通过注册中心进行访问：
是一个Java客户端，用于简化Eureka Server的交互，客户端同时也具备一个内置的、使用轮询(round-robinm)负载算法的负载均衡器。在应用启动后，将会向Eureka Server发送心跳默认周期为30秒。如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳，EurekaServer将会从服务注册表中把这个服务节点移除 (默认90秒)。

我们直接利用eureka搭建一个服务注册与发现的集群，实现一个微服务调用的的功能

1、新建一个maven父工程（springcloud）

  1. <!--统一管理jar包版本-->
  2.   <properties>
  3.     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  4.     <maven.compiler.source>1.8</maven.compiler.source>
  5.     <maven.compiler.target>1.8</maven.compiler.target>
  6.     <junit.version>4.12</junit.version>
  7.     <lombok.version>1.18.10</lombok.version>
  8.     <log4j.version>1.2.12</log4j.version>
  9.     <mysql.version>8.0.18</mysql.version>
  10.     <druid.version>1.1.10</druid.version>
  11.     <mybatis.spring.boot.version>1.3.2</mybatis.spring.boot.version>
  12.   </properties>
  13.  
  14.   <!--子模块继承之后，提供作用：锁定版本+子module不用写groupId和version-->
  15.   <dependencyManagement>
  16.     <dependencies>
  17.       <!--spring boot 2.2.2-->
  18.       <dependency>
  19.         <groupId>org.springframework.boot</groupId>
  20.         <artifactId>spring-boot-dependencies</artifactId>
  21.         <version>2.2.2.RELEASE</version>
  22.         <type>pom</type>
  23.         <scope>import</scope>
  24.       </dependency>
  25.       <!--spring cloud Hoxton.SR1-->
  26.       <dependency>
  27.         <groupId>org.springframework.cloud</groupId>
  28.         <artifactId>spring-cloud-dependencies</artifactId>
  29.         <version>Hoxton.SR1</version>
  30.         <type>pom</type>
  31.         <scope>import</scope>
  32.       </dependency>
  33.       <!--spring cloud alibaba-->
  34.       <dependency>
  35.         <groupId>com.alibaba.cloud</groupId>
  36.         <artifactId>spring-cloud-alibaba-dependencies</artifactId>
  37.         <version>2.1.0.RELEASE</version>
  38.         <type>pom</type>
  39.         <scope>import</scope>
  40.       </dependency>
  41.       <!--mysql-->
  42.       <dependency>
  43.         <groupId>mysql</groupId>
  44.         <artifactId>mysql-connector-java</artifactId>
  45.         <version>${mysql.version}</version>
  46.         <scope>runtime</scope>
  47.       </dependency>
  48.       <!-- druid-->
  49.       <dependency>
  50.         <groupId>com.alibaba</groupId>
  51.         <artifactId>druid-spring-boot-starter</artifactId>
  52.         <version>${druid.version}</version>
  53.       </dependency>
  54.  
  55.       <!--mybatis-->
  56.       <dependency>
  57.         <groupId>org.mybatis.spring.boot</groupId>
  58.         <artifactId>mybatis-spring-boot-starter</artifactId>
  59.         <version>${mybatis.spring.boot.version}</version>
  60.       </dependency>
  61.       <!--junit-->
  62.       <dependency>
  63.         <groupId>junit</groupId>
  64.         <artifactId>junit</artifactId>
  65.         <version>${junit.version}</version>
  66.       </dependency>
  67.       <!--log4j-->
  68.       <dependency>
  69.         <groupId>log4j</groupId>
  70.         <artifactId>log4j</artifactId>
  71.         <version>${log4j.version}</version>
  72.       </dependency>
  73.     </dependencies>
  74.  
  75.   </dependencyManagement>

2、创建3个eureka服务

（cloud-eureka-server7001、cloud-eureka-server7002、cloud-eureka-server7003）

主启动类：其他两个就不贴了

  1. @EnableEurekaServer //表示此项目是eureka的服务注册中心
  2. @SpringBootApplication
  3. public class EurekaMain7001 {
  4.     public static void main(String[] args) {
  5.         SpringApplication.run(EurekaMain7001.class, args);
  6.     }
  7. }

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.         <dependency>
  8.             <groupId>org.springframework.boot</groupId>
  9.             <artifactId>spring-boot-starter-web</artifactId>
  10.         </dependency>
  11.         <!--监控-->
  12.         <dependency>
  13.             <groupId>org.springframework.boot</groupId>
  14.             <artifactId>spring-boot-starter-actuator</artifactId>
  15.         </dependency>
  16.         <!-- 一般通用配置 -->
  17.         <dependency>
  18.             <groupId>org.springframework.boot</groupId>
  19.             <artifactId>spring-boot-devtools</artifactId>
  20.             <scope>runtime</scope>
  21.             <optional>true</optional>
  22.         </dependency>
  23.         <dependency>
  24.             <groupId>org.projectlombok</groupId>
  25.             <artifactId>lombok</artifactId>
  26.             <optional>true</optional>
  27.         </dependency>
  28.         <dependency>
  29.             <groupId>org.springframework.boot</groupId>
  30.             <artifactId>spring-boot-starter-test</artifactId>
  31.             <scope>test</scope>
  32.         </dependency>
  33.     </dependencies>

application.yml 另外两个就不贴了，改下port和defaultZone

  1. server:
  2.   port: 7001
  3.  
  4. eureka:
  5.   instance:
  6.     hostname: eureka7001.com  #eureka服务端的实例名称
  7.   client:
  8.     #false表示不向注册中心注册自己（想注册也可以，不过没必要）
  9.     register-with-eureka: false
  10.     #false表示自己端就是注册中心，职责就是维护服务实例，并不需要去检索服务
  11.     fetch-reapplication.ymlgistry: false
  12.     service-url:
  13.       #设置与eurekaServer交互的地址查询服务和注册服务都需要依赖这个地址  单机
  14.       #defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
  15.       #集群版  相互注册，相互守望
  16.       defaultZone: http://eureka7002.com:7002/eureka/, http://eureka7003.com:7003/eureka/
  17.  
  18.       #    defaultZone是固定写法，如果想自定义，需要按以下写法才行：
  19.       #    region: eureka-server
  20.       #    availability-zones:
  21.       #      eureka-server: server1,server2
  22.       #    service-url:
  23.       #      server1: http://eureka7002.com:7002/eureka/
  24.       #      server2: http://eureka7003.com:7003/eureka/
  25.  
  26.   server:
  27.     #关闭自我保护，默认为true
  28.     enable-self-preservation: false
  29.     #心跳的间隔时间，单位毫秒
  30.     eviction-interval-timer-in-ms: 2000

 修改下hosts文件：

 3、搭建消费者和服务者

3.1、创建实体中间件工程

cloud-api-commons

包路径为：

com.cjian.springcloud.bean
  1. public class CommonResult<T> {
  2.  
  3.     private Integer code;
  4.     private String message;
  5.     private T data;
  6.  
  7.     public CommonResult(Integer code, String message, T data) {
  8.         this.code = code;
  9.         this.message = message;
  10.         this.data = data;
  11.     }
  12.  
  13.     public CommonResult(Integer code, String message){
  14.         this(code, message, null);
  15.     }
  16.  
  17.     public CommonResult() {
  18.     }
  19.  
  20.     public Integer getCode() {
  21.         return code;
  22.     }
  23.  
  24.     public void setCode(Integer code) {
  25.         this.code = code;
  26.     }
  27.  
  28.     public String getMessage() {
  29.         return message;
  30.     }
  31.  
  32.     public void setMessage(String message) {
  33.         this.message = message;
  34.     }
  35.  
  36.     public T getData() {
  37.         return data;
  38.     }
  39.  
  40.     public void setData(T data) {
  41.         this.data = data;
  42.     }
  43. }
  1. public class Payment implements Serializable {
  2.  
  3.     private Long id;
  4.     private String serial;
  5.  
  6.  
  7.     public Long getId() {
  8.         return id;
  9.     }
  10.  
  11.     public void setId(Long id) {
  12.         this.id = id;
  13.     }
  14.  
  15.     public String getSerial() {
  16.         return serial;
  17.     }
  18.  
  19.     public void setSerial(String serial) {
  20.         this.serial = serial;
  21.     }
  22. }

3.2、搭建两个服务提供者 

cloud-provider-payment8001、cloud-provider-payment8002
  1. <dependencies>
  2.         <dependency>
  3.             <groupId>org.springframework.cloud</groupId>
  4.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  5.         </dependency>
  6.         <dependency>
  7.             <groupId>com.cjian.springloud</groupId>
  8.             <artifactId>cloud-api-commons</artifactId>
  9.             <version>${project.version}</version>
  10.         </dependency>
  11.         <dependency>
  12.             <groupId>org.springframework.boot</groupId>
  13.             <artifactId>spring-boot-starter-web</artifactId>
  14.         </dependency>
  15.         <dependency>
  16.             <groupId>org.springframework.boot</groupId>
  17.             <artifactId>spring-boot-starter-actuator</artifactId>
  18.         </dependency>
  19.  
  20.         <dependency>
  21.             <groupId>org.mybatis.spring.boot</groupId>
  22.             <artifactId>mybatis-spring-boot-starter</artifactId>
  23.             <version>1.3.2</version>
  24.         </dependency>
  25.  
  26.         <!-- alibaba的druid数据库连接池 -->
  27.         <dependency>
  28.             <groupId>com.alibaba</groupId>
  29.             <artifactId>druid-spring-boot-starter</artifactId>
  30.             <version>1.1.10</version>
  31.         </dependency>
  32.         <!--mysql-connector-java-->
  33.         <dependency>
  34.             <groupId>mysql</groupId>
  35.             <artifactId>mysql-connector-java</artifactId>
  36.             <version>8.0.18</version>
  37.         </dependency>
  38.         <!--jdbc-->
  39.         <dependency>
  40.             <groupId>org.springframework.boot</groupId>
  41.             <artifactId>spring-boot-starter-jdbc</artifactId>
  42.         </dependency>
  43.         <dependency>
  44.             <groupId>org.springframework.boot</groupId>
  45.             <artifactId>spring-boot-devtools</artifactId>
  46.             <scope>runtime</scope>
  47.             <optional>true</optional>
  48.         </dependency>
  49.         <dependency>
  50.             <groupId>org.projectlombok</groupId>
  51.             <artifactId>lombok</artifactId>
  52.             <optional>true</optional>
  53.         </dependency>
  54.         <dependency>
  55.             <groupId>org.springframework.boot</groupId>
  56.             <artifactId>spring-boot-starter-test</artifactId>
  57.             <scope>test</scope>
  58.         </dependency>
  59.     </dependencies>

application.yml

  1. server:
  2.   port: 8001
  3.  
  4. spring:
  5.   application:
  6.     name: cloud-payment-service
  7.   datasource:
  8.     type: com.alibaba.druid.pool.DruidDataSource      # 当前数据源操作类型
  9.     driver-class-name: com.mysql.cj.jdbc.Driver       # mysql驱动包
  10.     url: jdbc:mysql://127.0.0.1:3306/mysql?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC
  11.     username: root
  12.     password: 123456
  13.  
  14. mybatis:
  15.   mapperLocations: classpath:mapper/*.xml
  16.   type-aliases-package: com.cjian.springcloud.bean    # 所有Entity别名类所在包
  17.  
  18.  
  19. eureka:
  20.   client:
  21.     register-with-eureka: true
  22.     fetch-registry: true
  23.     service-url:
  24.       #defaultZone: http://localhost:7001/eureka
  25.       defaultZone: http://eureka7001.com:7001/eureka,http://eureka7001.com:7002/eureka,http://eureka7001.com:7003/eureka
  26.  
  27.   instance:
  28.     instance-id: payment8001
  29.     prefer-ip-address: true   #访问路径可以显示ip地址
  30.  
  31.   #Eureka客户端向服务端发送心跳的时间间隔，单位秒（默认30秒）
  32.   lease-renewal-interval-in-seconds: 1
  33.   #Eureka服务端在收到最后一次心跳后等待的时间上限，单位秒（默认90秒），超时剔除服务
  34.   lease-expiration-duration-in-seconds: 2

包路径：com.cjian.springcloud

  1. @Mapper
  2. public interface PaymentDao {
  3.  
  4.     public int create(Payment payment);
  5.  
  6.     public Payment getPaymentById(@Param("id") Long id);
  7. }
  1. public interface  PaymentService {
  2.     public int create(Payment payment);
  3.  
  4.     public Payment getPaymentById(@Param("id") Long id);
  5. }
  1. @Service
  2. public class PaymentServiceImpl implements PaymentService {
  3.     @Resource
  4.     private PaymentDao paymentDao;
  5.  
  6.     public int create(Payment payment)
  7.     {
  8.         return paymentDao.create(payment);
  9.     }
  10.  
  11.     public Payment getPaymentById(Long id)
  12.     {
  13.         return paymentDao.getPaymentById(id);
  14.     }
  15. }
  1. @RestController
  2. public class PaymentController {
  3.     @Resource
  4.     private PaymentService paymentService;
  5.  
  6.     @Value("${server.port}")
  7.     private String serverPort;
  8.  
  9.     @PostMapping(value = "/payment/create")
  10.     public CommonResult create(@RequestBody Payment payment)
  11.     {
  12.         int result = paymentService.create(payment);
  13.         System.out.println(("*****插入结果：" + result));
  14.  
  15.         if(result > 0)
  16.         {
  17.             return new CommonResult(200,"插入数据库成功,serverPort: "+serverPort,result);
  18.         }else{
  19.             return new CommonResult(444,"插入数据库失败",null);
  20.         }
  21.     }
  22.  
  23.     @GetMapping(value = "/payment/get/{id}")
  24.     public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id)
  25.     {
  26.         Payment payment = paymentService.getPaymentById(id);
  27.  
  28.         if(payment != null)
  29.         {
  30.             return new CommonResult(200,"查询成功,serverPort:  "+serverPort,payment);
  31.         }else{
  32.             return new CommonResult(444,"没有对应记录,查询ID: "+id,null);
  33.         }
  34.     }
  35. }
  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
  3.  
  4. <mapper namespace="com.cjian.springcloud.dao.PaymentDao">
  5.  
  6.     <resultMap id="BaseResultMap" type="com.cjian.springcloud.bean.Payment">
  7.         <id column="id" property="id" jdbcType="BIGINT"/>
  8.         <id column="serial" property="serial" jdbcType="VARCHAR"/>
  9.     </resultMap>
  10.  
  11.     <insert id="create" parameterType="com.cjian.springcloud.bean.Payment" useGeneratedKeys="true" keyProperty="id">
  12.         insert into payment(serial)  values(#{serial});
  13.     </insert>
  14.     <select id="getPaymentById" parameterType="Long" resultMap="BaseResultMap">
  15.         select * from payment where id=#{id};
  16.     </select>
  17.  
  18. </mapper>

主启动类：

这里

  1. @SpringBootApplication
  2. //@EnableEurekaClient  不加该注解也是可以的，下面分析eureka原理的时候再说
  3. public class PaymentMain001 {
  4.     public static void main(String[] args) {
  5.         SpringApplication.run(PaymentMain001.class, args);
  6.     }
  7. }

建表sql：

  1. CREATE TABLE `payment`(
  2. 	`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'ID',
  3.    `serial` varchar(200) DEFAULT '',
  4. 	PRIMARY KEY (id)
  5. )ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4

另一个服务提供者不做赘述~

3.3、搭建一个消费者 

cloud-consumer-order80 

  1.  <dependencies>
  2.         <!-- eureka-client -->
  3.         <dependency>
  4.             <groupId>org.springframework.cloud</groupId>
  5.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  6.         </dependency>
  7.         <dependency>
  8.             <groupId>com.cjian.springloud</groupId>
  9.             <artifactId>cloud-api-commons</artifactId>
  10.             <version>1.0-SNAPSHOT</version>
  11.         </dependency>
  12.         <dependency>
  13.             <groupId>org.springframework.boot</groupId>
  14.             <artifactId>spring-boot-starter-web</artifactId>
  15.         </dependency>
  16.         <dependency>
  17.             <groupId>org.springframework.boot</groupId>
  18.             <artifactId>spring-boot-starter-actuator</artifactId>
  19.         </dependency>
  20.         <!--热部署-->
  21.         <dependency>
  22.             <groupId>org.springframework.boot</groupId>
  23.             <artifactId>spring-boot-devtools</artifactId>
  24.             <scope>runtime</scope>
  25.             <optional>true</optional>
  26.         </dependency>
  27.         <dependency>
  28.             <groupId>org.projectlombok</groupId>
  29.             <artifactId>lombok</artifactId>
  30.             <optional>true</optional>
  31.         </dependency>
  32.         <dependency>
  33.             <groupId>org.springframework.boot</groupId>
  34.             <artifactId>spring-boot-starter-test</artifactId>
  35.             <scope>test</scope>
  36.         </dependency>
  37.     </dependencies>

  1. @Configuration
  2. public class ApplicationContextConfig {
  3.     //往容器中添加一个RestTemplate
  4.     //RestTemplate提供了多种便捷访问远程http访问的方法
  5.     @Bean
  6.     @LoadBalanced//开启负载均衡功能
  7.     public RestTemplate restTemplate(){
  8.         return new RestTemplate();
  9.     }
  10. }
  1. @RestController
  2. public class OrderController {
  3.  
  4.     // public static final String PAYMENT_URL = "http://localhost:8001";
  5.      public static final String PAYMENT_URL = "http://CLOUD-PAYMENT-SERVICE";
  6.  
  7.     @Resource
  8.     private RestTemplate restTemplate;
  9.  
  10.     //因为浏览器只支持get请求，为了方便这里就用get
  11.     @GetMapping("/consumer/payment/create")
  12.     public CommonResult<Payment> create(Payment payment){
  13.         System.out.println("********插入的数据：" + payment);
  14.         //postForObject分别有三个参数：请求地址，请求参数，返回的对象类型
  15.         return restTemplate.postForObject(PAYMENT_URL + "/payment/create", payment, CommonResult.class);
  16.     }
  17.  
  18.     @GetMapping("/consumer/payment/get/{id}")
  19.     public CommonResult<Payment> getPayment(@PathVariable("id") Long id){
  20.         System.out.println("********查询的id：" + id);
  21.         //getForObject两个参数：请求地址，返回的对象类型
  22.         return restTemplate.getForObject(PAYMENT_URL + "/payment/get/" + id, CommonResult.class);
  23.     }
  24.  
  25. }

 application.yml

  1. #访问一个网站时，默认是80端口，给用户80端口，用户就可以不用加端口直接访问页面
  2. server:
  3.   port: 81
  4.  
  5. spring:
  6.   application:
  7.     name: cloud-order-service
  8.  
  9. eureka:
  10.   client:
  11.     register-with-eureka: true
  12.     etch-registry: true
  13.     service-url:
  14.       #defaultZone: http://localhost:7001/eureka
  15.       defaultZone: http://eureka7001.com:7001/eureka,http://eureka7001.com:7002/eureka,http://eureka7001.com:7003/eureka
  16.  
  17.   instance:
  18.     instance-id: consumer81
  19.     prefer-ip-address: true   #访问路径可以显示ip地址
  20.  
  21.   #Eureka客户端向服务端发送心跳的时间间隔，单位秒（默认30秒）
  22.   lease-renewal-interval-in-seconds: 1
  23.   #Eureka服务端在收到最后一次心跳后等待的时间上限，单位秒（默认90秒），超时剔除服务
  24.   lease-expiration-duration-in-seconds: 2

主启动类：

  1. @SpringBootApplication
  2. //@EnableDiscoveryClient
  3. public class OrderMain80 {
  4.     public static void main(String[] args) {
  5.         SpringApplication.run(OrderMain80.class, args);
  6.     }
  7. }

4、测试功能

依次启动3个注册中心、消费者和2个服务提供者，访问 localhost:7001

访问  http://localhost:81/consumer/payment/get/3

再次访问：

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/从前慢现在也慢/article/detail/839062
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号