1.简单情况

1554196218744.png

2.为了达到Eureka的高可用,可以多个Eureka互相注册。

1554198693041.png

3.我们需要修改两处:

  • Eureka Client
  • Eureka Server

3.1 Eureka Client

在Client的配置文件中,分别配置所有的Eureka Server地址

eureka:
  client:
    service-url:
      defaultZone: http://192.168.93.1:8761/eureka/,http://192.168.93.1:8762/eureka/,http://192.168.93.1:8763/eureka/

3.2 Eureka Server

例如我们需要3个Eureka Server

在每个Server的配置文件中,修改其注册地址,使其两两注册。

如上图:

  • Eureka1 注册 http://localhost:8762/ 和 http://localhost:8763/

    eureka:
      client:
        service-url:
          defaultZone: http://192.168.93.1:8762/eureka/,http://192.168.93.1:8763/eureka/
  • Eureka2 注册 http://localhost:8761/ 和 http://localhost:8763/

    eureka:
      client:
        service-url:
          defaultZone: http://192.168.93.1:8761/eureka/,http://192.168.93.1:8763/eureka/
  • Eureka3 注册 http://localhost:8761/ 和 http://localhost:8762/

    eureka:
      client:
        service-url:
          defaultZone: http://192.168.93.1:8761/eureka/,http://192.168.93.1:8762/eureka/

Eureka是Netflix开发的服务发现框架,本身是一个基于REST的服务,主要用于定位运行在AWS域中的中间层服务,以达到负载均衡和中间层服务故障转移的目的。SpringCloud将它集成在其子项目spring-cloud-netflix中,以实现SpringCloud的服务发现功能。

Eureka包含两个组件:Eureka Server和Eureka Client。

Eureka Server提供服务注册服务,各个节点启动后,会在Eureka Server中进行注册,这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息,服务节点的信息可以在界面中直观的看到。

Eureka Client是一个java客户端,用于简化与Eureka Server的交互,客户端同时也就是一个内置的、使用轮询(round-robin)负载算法的负载均衡器。

在应用启动后,将会向Eureka Server发送心跳,默认周期为30秒,如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳,Eureka Server将会从服务注册表中把这个服务节点移除(默认90秒)。

Eureka Server之间通过复制的方式完成数据的同步,Eureka还提供了客户端缓存机制,即使所有的Eureka Server都挂掉,客户端依然可以利用缓存中的信息消费其他服务的API。综上,Eureka通过心跳检查、客户端缓存等机制,确保了系统的高可用性、灵活性和可伸缩性。

[scode type="yellow"] 版本: SpringBoot 2.0.0.M3 SpringCloud Finchley.M2 JDK 8 [/scode]

SpringCloud Eureka

  • 基于Netflix Eureka 做了二次开发
  • 两个组件

    • Eureka Server 注册中心
    • Eureka Client 服务注册

Eureka Server 注册中心创建

1.新建一个Spring项目

1554192241739.png

1554192295308.png

2.修改pom文件

因为我使用的是里程碑版本,所以要增加一个

完整的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>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.0.M3</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.imooc</groupId>
    <artifactId>eureka</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>eureka</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Finchley.M2</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>
    </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>
    <repositories>
        <repository>
            <id>spring-snapshots</id>
            <name>Spring Snapshots</name>
            <url>https://repo.spring.io/snapshot</url>
            <snapshots>
                <enabled>true</enabled>
            </snapshots>
        </repository>
        <repository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/milestone</url>
            <snapshots>
                <enabled>false</enabled>
            </snapshots>
        </repository>
    </repositories>

    <pluginRepositories>
        <pluginRepository>
            <id>spring-snapshots</id>
            <name>Spring Snapshots</name>
            <url>https://repo.spring.io/snapshot</url>
            <snapshots>
                <enabled>true</enabled>
            </snapshots>
        </pluginRepository>
        <pluginRepository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/milestone</url>
            <snapshots>
                <enabled>false</enabled>
            </snapshots>
        </pluginRepository>
    </pluginRepositories>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

3.修改启动类

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

@EnableEurekaServer : 表示这个项目有注册中心这个功能

4.运行项目

发现有报错,先不用管:
1554192790935.png

浏览器输入:http://localhost:8080

1554192832233.png

这就是一个注册中心。

报错的问题:

这是由于这个应用虽然是一个Server端,但是同时也是一个Client端,它也需要找一个注册中心把自己注册上去。

点进去@EnableEurekaServer发现 @EnableDiscoveryClient ,它包含了Client:

@EnableDiscoveryClient
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Import(EurekaServerMarkerConfiguration.class)
public @interface EnableEurekaServer {
}

解决报错:

修改配置文件,我使用yml格式的——application.yml

eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/

再次启动,发现启动是的时候还会报错,是因为它自己既是客户端又是服务端,服务端还没启动好,客户端就启动,就会报错。 它采用的是一种心跳的方式,隔一段时间就OK了

登陆 http://localhost:8080

1554193493997.png

此时Application 显示出一条信息,名字为:UNKNOWN

这个应用本来就是注册中心,所以不需要在上面显示,而且为了区分显示出端口号,我们需要修改端口号。以及修改Application 的名字:

eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/
    register-with-eureka: false
spring:
  application:
    name: eureka
server:
  port: 8761

Eureka Client 注册

1.新建项目

1554194992683.png

2.修改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>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.0.M3</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.imooc</groupId>
    <artifactId>client</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>client</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Finchley.M2</spring-cloud.version>
    </properties>

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

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </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>

    <repositories>
        <repository>
            <id>spring-snapshots</id>
            <name>Spring Snapshots</name>
            <url>https://repo.spring.io/snapshot</url>
            <snapshots>
                <enabled>true</enabled>
            </snapshots>
        </repository>
        <repository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/milestone</url>
            <snapshots>
                <enabled>false</enabled>
            </snapshots>
        </repository>
    </repositories>

    <pluginRepositories>
        <pluginRepository>
            <id>spring-snapshots</id>
            <name>Spring Snapshots</name>
            <url>https://repo.spring.io/snapshot</url>
            <snapshots>
                <enabled>true</enabled>
            </snapshots>
        </pluginRepository>
        <pluginRepository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/milestone</url>
            <snapshots>
                <enabled>false</enabled>
            </snapshots>
        </pluginRepository>
    </pluginRepositories>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

3.修改启动类增加注解@EnableDiscoveryClient

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

4.修改配置文件

eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/
  #自定义连接
#  instance:
#    hostname: clientname

# 修改应用名称
spring:
  application:
    name: client

微服务的设计原则:

一、AKF拆分原则

业界对于可扩展的系统架构设计有一个朴素的理念:通过加机器就可以解决容量和可用性问题(如果一台不行就两台)。

微信图片_20190404180413.png

Y轴(功能)——关注应用中功能划分,基于不同的业务拆分
X轴(水平扩展)——关注水平扩展,也就是“加机器解决问题”
Z轴(数据区分)——关注服务和数据的优先级划分,如按地域划分

1.Y轴(功能)

Y轴扩展会将庞大的整体应用拆分为多个服务。每个服务实现一组相关的功能,如订单管理、客户管理等。在工程上常见的方案是服务化架构(SOA)。
比如对于一个电子商务平台,我们可以拆分成不同的服务,组成下面这样的架构:

1552883227580.png

但通过观察上图容易发现,当服务数量增多时,服务调用关系变得复杂。
为系统添加一个新功能,要调用的服务数也变得不可控,由此引发了服务管理上的混乱。
所以,一般情况下,需要采用服务注册的机制形成服务网关来进行服务治理。
系统的架构将变成下图所示:

1552883363705.png

2.X轴(水平扩展)

x轴扩展与我们前面朴素理念是一致的,通过绝对平等地复制服务与数据,以解决容量和可用性的问题。
其实就是将微服务运行多个实例,做集群加负载均衡的模式。为了提升单个服务的可用性和容量,对每一个服务进行 轴扩展划分。

1552883518499.png

3.Z轴(数据分区)

Z轴扩展通常是指基于请求者或用户独特的需求,进行系统划分,并使得划分出来的子系统是相互隔离但又是完整的。
以生产汽车的工厂来举例:福特公司为了发展在中国的业务,或者利用中国的廉价劳动力,在中国建立一个完整的子工厂,与美国工厂一样,负责完整的汽车生产。这就是一种Z轴扩展。

工程领域常见的Z轴扩展有以下两种方案:
  1. 单元化架构
    在分布式服务设计领域,一个单元(Cell)就是满足某个分区所有业务操作的自包含闭环。
    如上面我们说到的轴扩展的SOA架构,客户端对服务端节点的选择一般是随机的,但是,如果在此加上Z轴扩展,那服务节点的选择将不再是随机的了,而是每个单元自成一体。如下图:

1552883953611.png

  1. 数据分区
    为了性能数据安全上的考虑,我们将一个完整的数据集按一定的维度划分出不同的子集。一个分区(Shard) ,就是整体数据集的一个子集。比如用尾号来划分用户,那同样尾号的那部分用户就可以认为是一个分区。教据分区为一般包括以下几种数据划分的方式:

    数据类型(如:业务类型)
    数据范围(如:时间段,用户ID)
    数据热度(如:用户活跃度,商品热度)
    按读写分(如:商品描述,商品库存)

二、前后端分离原则

1552884347803.png

何为前后端分离?前后端本来不就分离么?这要从尴尬的jsp讲起。分工精细化从来都是蛋糕做大的原则,多个领域工程师最好在不需要接触其他领域知识的情况下合作,才可能使效率越来越高,维护也会变得简单。jsp的模板技术融合了html和java代码,使得传统MVC开发中的前后端在这里如胶似漆,前端做好页面,后端转成模板,发现问题再找前端,前端又看不懂java代码......前后端分离的目的就是将这尴尬局面打破。

前后端分离原则,简单来讲就是前端和后端的代码分离,我们推荐的模式是最好采用物理分离的方式部署,进一步促使更彻底的分离。如果继续直接使用服务端模板技术,如: jsp,把java、js、html、css都堆到一个页面里,稍微复杂一点的页面就无法维护了。

1552884698368.png

这种分离方式有几个好处:

  1. 前后端技术分离,可以由各自的专家来对各自的领域进行优化,这样前段的用户体 验优化效果更好。
  2. 分离模式下,前后端交互界面更清晰,就剩下了接口模型,后端的接口简洁明了,更容易维护。
  3. 前端多渠道集成场景更容易实现,后端服务无需变更,采用统一的数据和模型,可以支持多个前端:例如:微信 h5 前端、PC 前端、安卓前端、IOS 前端。

三、无状态服务

1552884877669.png

对于无状态服务,首先说一下什么是状态:
如果一个数据需要被多个服务共享,才能完成一笔交易,那么这个数据被称为状态。进而依赖这个“状态”数据的 服务被称为有状态服务,反之称为无状态服务。

那么这个无状态服务原则并不是说在微服务架构里就不允许存在状态,表达的真实意思是要把有状态的业务服务改变为无状态的计算类服务,那么状态数据 也就相应的迁移到对应的“有状态数据服务”中。

场景说明:例如我们以前在本地内存中建立的数据缓存、Session 缓存,到现在的微服务架构中就应该把这些数据迁移到分布式缓存中存储,让业务服务变成一个无状态的计算节点。迁移后,就可以做到按需动态伸缩,微服务应用在运行时动态增删节点,就不再需要考虑缓存数据如何同步的问题。

四、RestFul的通讯风格

1552885273357.png

作为一个原则来讲本来应该是个“无状态通信原则”,在这里我们直接推荐一个实践优选的 Restful 通信风格 ,因为他有很多好处:

  1. 无状态协议 HTTP,具备先天优势,扩展能力很强。例如需要安全加密,有现成的成熟方案 HTTPS即可。
  2. JSON 报文序列化,轻量简单,人与机器均可读,学习成本低,搜索引擎友好。
  3. 语言无关,各大热门语言都提供成熟的 RestfulAPI 框架,相对其他的一些 RPC 框架生态更完善。

MVC、RPC、SOA、微服务架构的区别:

一、MVC架构

MVC架构就是一种单体架构。
代表技术:Struts2、SpringMVC、Spring、Mybatis等等。

二、RPC架构

RPC(Remote Procedure Call):远程过程调用。它是一种通过网络从远程计算机程序上请求服务,而不需要了解底层网络技术的协议。
代表技术:Thrift、Hessian

三、SOA架构

SOA(Service Oriented Architecture):面向服务架构

ESB (Enterparise Service Bus):企业服务总线,服务中介。主要提供了服务与服务之间的交互。
ESB包含的功能:负载均衡、流量控制、加密处理、服务的监控、异常处理、监控告急等等。

代表技术:Mule(不开源)、WSO2(开源)

四、微服务架构

微服务就是一个轻量级的服务治理方案。注册中心是企业服务总线的轻量级的替代。
代表技术:SpringCloud、Dubbo等等
1552882593824.png

微服务的特点

  1. 一系列微小的服务共同组成
  2. 跑在自己的进程里
  3. 每个服务为独立的业务开发
  4. 独立部署
  5. 分布式管理
  6. 异构——不同的语言、不同类型的数据库

微服务架构的基础框架/组件

  • 服务注册发现
  • 服务网关(Service Gateway)
  • 后端通用服务(中间层服务)Middle Tier Service
  • 前端服务(边缘服务)Edge Service

SpringCloud是什么?

是一个开发工具集,内含了多个子项目

  • 利用springboot的开发便利
  • 主要是基于对NetFlix开源组件的进一步封装

Springcloud简化了分布式开发

1554191362006.png

SpringCloud的服务调用方式:

REST