Eureka源码分析【一】之Client和Server环境搭建

朴灿烈づ我的快乐病毒、 2022-12-24 09:59 100阅读 0赞

# 一、背景 #

在之前对`Spring Cloud`微服务系列组件进行了一个系统的学习，并且在前面的一些微服务组件学习过程中，总结了一些学习心得以及对于在学习这些微服务组件后的一些个人理解；恰好最近公司有个规模较大的项目，需要考虑到上微服务架构，所以我就主动申请了挑战一下这个新技术。

# 二、面对技术选型的挑战 #

大家都知道，在`Spring Cloud`经历过几个大版本的发布后，变得愈来愈成熟，而其中的大部分组件是由国外著名的`Netflix`的流媒体播放公司开源贡献的，在后续的更新中，`Netflix`公司提出了一些组件相继停更。然后就出现了新的一代微服务`Spring Cloud Alibaba`，既然国内开源了新的一代微服务`Spring Cloud Alibaba`相关组件，所以我在`Spring Cloud`和`Spring Cloud Alibaba`之间做技术选型，最后如下：

*  服务注册与发现： Spring Cloud Alibaba Nacos
 *  分布式配置中心： Spring Cloud Alibaba Nacos
 *  分布式事务处理： Spring Cloud Alibaba Seata
 *  服务保护断路器： Spring Cloud Hystrix
 *  服务调用与通讯： Spring Cloud Feign
 *  服务负载均衡器： Spring Cloud Ribbon
 *  微服务API网关： Spring Cloud Gateway
 *  微服务链路追踪： Spring Cloud Seluth+ZipKin

# 三、目的 #

在经理过几个微服务项目实战后，想要更深入的了解这些微服务组件的底层实现原理，只要懂得了其中一个组件的设计思想和实现原理，运用举一反三的原理，那么其他框架原理基本类似，在做程序员这个行业，在学习框架的这些过程中，我们需要明白： **学框架学的是思想，思想理解了，代码只是一个实现方式而已。** 所以从本篇开始深入研究`Eureka`源码分析，对`Eureka`源码做一个初步的解读。

> **在写【Eureka源码分析】专栏之前，以这篇文章为开端，搭建一下客户端和Eureka 服务端环境，作为后面阅读调试源码的例子，在后面的文章中不再重复搭建，毕竟是个很简单的东西。**

# 四、搭建Eureka Server端 #

`IDEA`工具中新建一个基本的`Maven`项目，这里方便理解名字就叫`eureka-server`。

*  **pom.xml**

<?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.thinkingcao.eureka.server</groupId>
        <artifactId>eureka-server</artifactId>
        <version>1.0-SNAPSHOT</version>
    
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.0.2.RELEASE</version>
            <relativePath/> 
        </parent>
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
            <java.version>1.8</java.version>
            <spring-cloud.version>Finchley.RC2</spring-cloud.version>
        </properties>
        <dependencies>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-autoconfigure</artifactId>
            </dependency>
        </dependencies>
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>${spring-cloud.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
        <repositories>
            <repository>
                <id>spring-milestones</id>
                <name>Spring Milestones</name>
                <url>https://repo.spring.io/milestone</url>
                <snapshots>
                    <enabled>false</enabled>
                </snapshots>
            </repository>
        </repositories>
    </project>

*  **application.yml**

server:
       port: 8081 #服务注册中心端口号
    eureka:
       instance:
          hostname: 127.0.0.1 #服务注册中心IP地址
       client:
          registerWithEureka: false #是否向服务注册中心注册自己
          fetchRegistry: false #是否检索服务
          serviceUrl: #服务注册中心的配置内容，指定服务注册中心的位置
             defaultZone: http://${ eureka.instance.hostname}:${ server.port}/eureka/
       server:
          # 关闭自我保护机制，保证不可用的服务被及时剔除 true为开启 false为关闭
          enable-self-preservation: true
          # 如果2秒内没有收到某个微服务的心跳，那就剔除该微服务，单位为毫秒
          eviction-interval-timer-in-ms: 2000

*  **EurekaApplication启动类**

package com.thinkingcao.eureka.server;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    
    /** * @desc: Eureka服务端 * @author: cao_wencao * @date: 2020-11-27 16:50 */
    @SpringBootApplication
    @EnableEurekaServer
    public class EurekaApplication { 
        public static void main(String[] args) { 
            SpringApplication.run(EurekaApplication.class);
        }
    }

# 五、搭建Eureka Client客户端 #

在微服务中，所有的微服务实例都是以客户端的角色将当前的服务实例信息注册到`Eureka Server`上的，这里拿经常提到的商品服务作为一个客户端例子，创建`product-client`项目，同样是`maven`的。

*  **pom.xml**

<?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.thinkingcao.client.product</groupId>
        <artifactId>product-client</artifactId>
        <version>1.0-SNAPSHOT</version>
    
    
        <description>Demo project for Spring Boot</description>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.0.2.RELEASE</version>
            <relativePath/> 
        </parent>
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
            <java.version>1.8</java.version>
            <spring-cloud.version>Finchley.RC2</spring-cloud.version>
        </properties>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>fastjson</artifactId>
                <version>1.2.62</version>
            </dependency>
        </dependencies>
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>${spring-cloud.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
        <repositories>
            <repository>
                <id>spring-milestones</id>
                <name>Spring Milestones</name>
                <url>https://repo.spring.io/milestone</url>
                <snapshots>
                    <enabled>false</enabled>
                </snapshots>
            </repository>
        </repositories>
    
    </project>

*  **application.yml**

eureka:
      client:
        serviceUrl: #注册中心的注册地址
          defaultZone: http://127.0.0.1:8081/eureka/
      instance:
        #心跳检测与续约时间（开发环境可以将值设小一点，保证服务关闭后注册中心能及时剔除）
        lease-expiration-duration-in-seconds: 15
        #Eureka客户端向服务端发送心跳的时间间隔，单位为秒（客户端告诉服务端自己会遵循该规则）
        lease-renewal-interval-in-seconds: 5
    server:
      port: 8093 #服务端口号
    spring:
      application:
        name: product-client #服务名称--调用的时候根据名称来调用该服务的方法

*  **ProductApplication启动类**

package com.thinkingcao.client.product;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
    /** * @desc: Product客户端 * @author: cao_wencao * @date: 2020-11-27 16:57 */
    @SpringBootApplication
    @EnableEurekaClient  //@EnableDiscoveryClient
    public class ProductApplication { 
        public static void main(String[] args) { 
            SpringApplication.run(ProductApplication.class,args);
        }
    }

# 六、源码 #

[https://github.com/Thinkingcao/SpringCloudLearning/eureka-opensource-example][https_github.com_Thinkingcao_SpringCloudLearning_eureka-opensource-example]

# 七、加群 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1RoaW5raW5nY2Fv_size_16_color_FFFFFF_t_70]

[https_github.com_Thinkingcao_SpringCloudLearning_eureka-opensource-example]: https://github.com/Thinkingcao/SpringCloudLearning/eureka-opensource-example
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1RoaW5raW5nY2Fv_size_16_color_FFFFFF_t_70]: /images/20221120/8a4ccf8c9b9846b086e7b8bbd72ac51a.png