重新定义cloud 第2章 spring Cloud Eureka上篇

以你之姓@ 2023-02-25 03:43 16阅读 0赞

# 服务发现概述 #

## Eureka ##

*  Eureka是 Netflix开源的一款基于 REST的服务发现组件，包括eureka server 和 eureka client
 *  Spring Cloud Netflix Eureka 是 Pivotal公司将 网飞的eureka整合于 Spring Cloud生态系统提供的版本
 *  Finchley 对应 eureka的 1.9.2 版本
 *  2020 07 09 cloud 2.3.1.RELEASE，Hoxton.SR6，eureka server为：2.2.3.RELEASE 版本
 *  最初为 netflix 针对 aws 不提供 中间服务层 的负载均衡 的限制 而设计开发的
 *

## CAP选择一致性 选择可用性 节点失去联系 ##

*  明显的区别可能就是Zookeeper为CP设计,而**Eureka为AP设计**
 *  consul 也是 cp
 *  CAP理论提出就是针对分布式数据库环境的，所以P这个属性是必须具备的。
 *  因为P是必须的，那么我们需要选择的就是A和C。

大家知道，在分布式环境下，为了保证系统可用性，通常都采取了复制的方式，避免一个节点损坏，导致系统不可用。那么就出现了每个节点上的数据出现了很多个副本的情况，而数据从一个节点复制到另外的节点时需要时间和要求网络畅通的，所以，**当P发生时，也就是无法向某个节点复制数据时**，

最常见的例子是读写分离，某个节点负责写入数据，然后将数据同步到其它节点，其它节点提供读取的服务，当两个节点出现通信问题时，你就面临着选择

*  **A（继续提供服务，但是数据不保证准确）**，
 *  **C（用户处于等待状态，一直等到数据同步完成）**。
 *  p
    
    P就是在分布式环境中，由于网络的问题可能导致某个节点和其它节点失去联系，这时候就形成了P(partition)，
    
    也就是由于网络问题，将系统的成员隔离成了2个区域，互相无法知道对方的状态，这在分布式环境下是非常常见的。
 *  a
    
    选择可用性 A(Availability)，此时，那个失去联系的节点依然可以向系统提供服务，不过它的数据就不能保证是同步的了（失去了C属性）。
 *  c
    
    选择一致性C(Consistency)，为了保证数据库的一致性，我们必须等待失去联系的节点恢复过来，在这个过程中，那个节点是不允许对外提供服务的，这时候系统处于不可用状态(失去了A属性)。

# cloud Eureka 入门案例 #

## 1. 创建父类项目 和子项目 ##

<?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>cn.springcloud.book</groupId>
        <artifactId>ch2-1</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <packaging>pom</packaging>
    
        <name>ch2-1</name>
        <description>ch2-1</description>
    
        <modules> //指定子类
            <module>ch2-1-eureka-server</module>
            <module>ch2-1-eureka-client</module>
        </modules>
    
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.0.3.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.RELEASE</spring-cloud.version>
        </properties>
    
        <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>
    
        <dependencies> //注意啦，web项目在clinet端必须引用，要不无法启动
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

<parent>
    		<groupId>cn.springcloud.book</groupId>
    		<artifactId>ch2-1</artifactId>
    		<version>0.0.1-SNAPSHOT</version>
    		<relativePath>../pom.xml</relativePath>
    	</parent>

## 2. 创建 eureka server ##

<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    		</dependency>

>     @EnableEurekaServer

server:
      port: 8761
    
    eureka:
      instance:
        hostname: localhost
      client:
        registerWithEureka: false ##注册到eureka关闭
        fetchRegistry: false ##抓取其他eureka的实例注册信息
        serviceUrl:    ## 访问eureka 界面的url
          defaultZone: http://${ eureka.instance.hostname}:${ server.port}/eureka/
      server:
          waitTimeInMsWhenSyncEmpty: 0 ##asyn是异步，sync是同步，等待时间秒数 当 同步 为空时 为0
          enableSelfPreservation: false ## 打开自保留 为false

preservable 
    英 [prɪ'zɜːvəbl]  美 [prɪ'zɝvəbəl]
    adj. 可保存的；可保管的；能储藏的
    
    preservation 
    英 [prezə'veɪʃ(ə)n]  美 [,prɛzɚ'veʃən]
    n. 保存，保留

*  server的application.yml 设置

spring:
      profiles:
        active: standalone

*  所以会启动 application-standalone.yml

## 3. 创建eureka client ##

<dependencies>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    		</dependency>
    	</dependencies>

>     @EnableDiscoveryClient

spring:
      profiles:
        active: demo
    
    #demo配置文件如下:
    
    server:
      port: 8081
    
    spring:
      application:
        name: demo-client1
    
    eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:8761/eureka/

## 4. 测试 ##

*  http://localhost:8761/eureka/apps
 *  http://localhost:8761/eureka/apps/demo-client1
 *  http://localhost:8761/eureka/instances/LAPTOP-GDF1FAHL:demo-client1:8081
 *  注销应用实例：后面跟的是 instanceId  
    curl -i -X DELETE http://localhost:8761/eureka/apps/demo-client1/zhangsan:demo-client1:8081
 *  恢复应用实例：
    
    curl -i -X DELETE http://localhost:8761/eureka/apps/demo-client1/zhangsan:demo-client1:8081/status
 *  测试心跳：  
    curl -i -X PUT http://localhost:8761/eureka/apps/demo-client1/zhangsan:demo-client1:8081