SpringCloud整合Eureka

怼烎@ 2023-10-15 12:23 10阅读 0赞

**目录**

说明

什么是Eureka注册与发现(认真读)

什么是服务治理

Eureka两大组件

Eureka的快速入门

架构

mycloud父类

pom

Commons公共模块

pom

代码

编辑

Eureka7001

pom

application.yml

代码

provider8001

pom

application.yml

controller

consumer80 消费者

pom

application.yml

远程调用的配置

controller

结语

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

## 说明 ##

Eureka框架在2X版本社区已经不更新了，所以在现在的市场上使用Eureka的注册与发现很少，但是要我们要了解，我会通过一个快速入门，让你了解一下什么是Eureka。

## **什么是Eureka注册与发现(认真读)** ##

Eureka采用了CS的设计架构，Eureka Server 作为服务注册功能的服务器，它是服务注册中心。而系统中的其他微服务，使用 Eureka的客户端连接到 Eureka Server并维持心跳连接。这样系统的维护人员就可以通过 Eureka Server 来监控系统中各个微服务是否正常运行。

在服务注册与发现中，有一个注册中心。当服务器启动的时候，会把当前自己服务器的信息 比如 服务地址通讯地址等以别名方式注册到注册中心上。另一方（消费者|服务提供者），以该别名的方式去注册中心上获取到实际的服务通讯地址，然后再实现本地RPC调用RPC远程调用框架核心设计思想：在于注册中心，因为使用注册中心管理每个服务与服务之间的一个依赖关系(服务治理概念)。在任何rpc远程框架中，都会有一个注册中心(存放服务地址相关信息(接口地址))

![36474422692a48159fbdc4b9f7df0785.png][]

## 什么是服务治理 ##

Spring Cloud 封装了 Netflix 公司开发的 Eureka 模块来实现服务治理

在传统的rpc远程调用框架中，管理每个服务与服务之间依赖关系比较复杂，管理比较复杂，所以需要使用服务治理，管理服务于服务之间依赖关系，可以实现服务调用、负载均衡、容错等，实现服务发现与注册。

## Eureka两大组件 ##

Eureka包含两个组件：**Eureka Server**和**Eureka Client**

Eureka Server提供服务注册服务

各个微服务节点通过配置启动后，会在EurekaServer中进行注册，这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观看到。

EurekaClient通过注册中心进行访问

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

## Eureka的快速入门 ##

熟记：

**依赖  >  配置 > 代码**

因为Eureka采用了是CS架构，所以，我们使用的是：**实现本地RPC调用RPC远程调用框架核心设计思想**

### 架构 ###

![e4c75ad90e044a65943554c36ce3f26a.png][]

父类

commons 为公用的工具类等

7001为Eureka注册中心

8001为服务端

80为消费端

### mycloud父类 ###

#### pom ####

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>com.atdession</groupId>
        <artifactId>mycloud</artifactId>
        <version>1.0-SNAPSHOT</version>
      
        <packaging>pom</packaging>
    
    
    
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <maven.compiler.source>1.8</maven.compiler.source>
            <maven.compiler.target>1.8</maven.compiler.target>
            <junit.version>4.12</junit.version>
            <log4j.version>1.2.17</log4j.version>
            <lombok.version>1.16.18</lombok.version>
            <mysql.version>8.0.21</mysql.version>
            <druid.version>1.1.16</druid.version>
            <mybatis.spring.boot.version>1.3.0</mybatis.spring.boot.version>
            <mybatisplus.spring.boot.version>3.5.1</mybatisplus.spring.boot.version>
        </properties>
    
    
        <dependencyManagement>
            <dependencies>
    
                <dependency>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-dependencies</artifactId>
                    <version>2.2.2.RELEASE</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
    
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>Hoxton.SR1</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
    
    
                <dependency>
                    <groupId>com.alibaba.cloud</groupId>
                    <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                    <version>2.1.0.RELEASE</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
    
    
                <dependency>
                    <groupId>mysql</groupId>
                    <artifactId>mysql-connector-java</artifactId>
                    <version>${mysql.version}</version>
                </dependency>
    
                <dependency>
                    <groupId>com.alibaba</groupId>
                    <artifactId>druid</artifactId>
                    <version>${druid.version}</version>
                </dependency>
    
                <dependency>
                    <groupId>org.mybatis.spring.boot</groupId>
                    <artifactId>mybatis-spring-boot-starter</artifactId>
                    <version>${mybatis.spring.boot.version}</version>
                </dependency>
    
    
                <dependency>
                    <groupId>com.baomidou</groupId>
                    <artifactId>mybatis-plus-boot-starter</artifactId>
                    <version>${mybatisplus.spring.boot.version}</version>
                </dependency>
    
                <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>${junit.version}</version>
                </dependency>
    
                <dependency>
                <groupId>log4j</groupId>
                <artifactId>log4j</artifactId>
                <version>${log4j.version}</version>
                </dependency>
    
                <dependency>
                    <groupId>org.projectlombok</groupId>
                    <artifactId>lombok</artifactId>
                    <version>${lombok.version}</version>
                    <optional>true</optional>
                </dependency>
    
            </dependencies>
        </dependencyManagement>
    
    
    
       <build>
        <plugins>
         <plugin>
         <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
            <configuration>
    
                     <addResources>true</addResources>
         </configuration>
        </plugin>
        </plugins>
        </build>
    
    </project>

### Commons公共模块 ###

#### pom ####

#### 代码 ####

![55fae505a5c340ab9e3a88b1ac8dcaab.png][]

Payment类

import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    import lombok.ToString;
    
    @Data
    @AllArgsConstructor
    @NoArgsConstructor
    @ToString
    public class Payment {
        private Long id;
        private String serial;
    
    
    }

CommonResult类

import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    
    @Data
    @AllArgsConstructor
    @NoArgsConstructor
    public class CommonResult<T> {
    private Integer code;
    private String message;
    private T data;
    
        public CommonResult(Integer code, String message) {
            this(code,message,null);
        }
    }

#### ![81afd7b1ca0846d7b6671a9c999cdbde.png][] ####

### Eureka7001 ###

#### pom ####

#### application.yml ####

server:
      port: 7001
    
    eureka:
      instance:
        hostname: localhost #eureka服务端的实例名称
      client:
        #表示不向注册中心注册自己
        register-with-eureka: false
    
        #表示自己就是注册中心，职责就是维护服务实例
        fetch-registry: false
    
        service-url:
          #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址。
         
          #单机模式：指向自己
            defaultZone: http://localhost:7001/eureka/

#### 代码 ####

@SpringBootApplication
    //开启Eureka的Server服务器
    @EnableEurekaServer
    public class EurekaMain7001 {
    
        public static void main(String[] args) {
            SpringApplication.run(EurekaMain7001.class,args);
        }
    }

### provider8001 ###

**生产者**:

当你启动好7001 和8001的时候，浏览器搜索 你自己的服务注册网站 localhost:7001

![2094530b0bff4decb7fa81ee915a256d.png][]

#### pom ####

#### application.yml ####

server:
      port: 8001
    spring:
      application:
        name: cloud-payment-service
      datasource:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: 自己的数据库路径
        username: 自己的账号
        password: 自己的密码
    mybatis:
      mapper-locations: classpath:mapper/*.xml
      type-aliases-package: com.atdession.springcloud.entity
    
    eureka:
      client:
        #注册进去
        register-with-eureka: true
        #是否从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
        fetch-registry: true
    
        service-url:
          #单机版
          defaultZone: http://localhost:7001/eureka

代码

写一个对数据库的查询 :这几个步骤我就不写了，自己写一下

![cd9ec1af622d42f08d5ea05af1ec23f4.png][]

主启动类

@SpringBootApplication
    // 开启eureka的客户端
    @EnableEurekaClient
    public class PaymentMain8001 {
        public static void main(String[] args) {
            SpringApplication.run(PaymentMain8001.class,args);
    
        }
    }

#### controller ####

@RestController
    @Slf4j
    public class PaymentController {
        @Autowired
        PaymentService paymentService;
    
    
        @Value("${server.port}")
        private String serverPort;
    
    
        @GetMapping("/get/{id}")
        public CommonResult getPaymentById(@PathVariable("id")Long id){
            Payment payment = paymentService.getPayment(id);
            log.info("查询结果为{}",payment);
            return new CommonResult(200,"查询陈工"+serverPort,payment);
        }
    }

### consumer80 消费者 ###

#### pom ####

#### application.yml ####

server:
      port: 80
    
    spring:
      application:
        name: cloud-consumer-order80
    
    eureka:
      client:
        register-with-eureka: true
        fetch-registry: true
        service-url:
    
          defaultZone: http://eureka7001.com:7001/eureka

启动类

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

#### 远程调用的配置 ####

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

#### controller ####

@RestController
    @Slf4j
    @RequestMapping("/consumer")
    public class OrderController {
        
    //对应你注册到Eureka中的名称大写,就是provider8001中的那个截图
        public static final String PAYMENT_URL="http://CLOUD-PAYMENT-SERVICE";
    
        @Autowired
        RestTemplate restTemplate;
    
    
        @GetMapping("/payment/get/{id}")
        public CommonResult<Payment> getPayment(@PathVariable("id")Long id){
                          //远程调用生产者中的controller
            return restTemplate.getForObject(PAYMENT_URL+"/get/"+id,CommonResult.class);
        }
    
    }

### 结语 ###

好了，以上就是Eureka的快速配置与实现，虽然现在这个eureka已经停更了，但是逻辑思维我们还是要了解的，在使用Zookeeper 、Consul、Nacos，这些服务注册的时候，我们也会快速上手，因为这些注册中心全都是大差不差的！！

[36474422692a48159fbdc4b9f7df0785.png]: https://img-blog.csdnimg.cn/36474422692a48159fbdc4b9f7df0785.png
[e4c75ad90e044a65943554c36ce3f26a.png]: https://img-blog.csdnimg.cn/e4c75ad90e044a65943554c36ce3f26a.png
[55fae505a5c340ab9e3a88b1ac8dcaab.png]: https://img-blog.csdnimg.cn/55fae505a5c340ab9e3a88b1ac8dcaab.png
[81afd7b1ca0846d7b6671a9c999cdbde.png]: https://img-blog.csdnimg.cn/81afd7b1ca0846d7b6671a9c999cdbde.png
[2094530b0bff4decb7fa81ee915a256d.png]: https://img-blog.csdnimg.cn/2094530b0bff4decb7fa81ee915a256d.png
[cd9ec1af622d42f08d5ea05af1ec23f4.png]: https://img-blog.csdnimg.cn/cd9ec1af622d42f08d5ea05af1ec23f4.png