springcloud

转载于狂神老师 ，本文仅作为笔记使用

回顾之前的知识~●JavaSE ●数据库●前端●Servlet ●Http ●Mybatis ●Spring ●SpringMVC ●SpringBoot ●Dubbo. Zookeeper. 分布式基础●Maven. Git ●Ajax. json ●…

这个阶段该如何学~三层架构+ MVC

框架:

spring IOC AOP

SprintBoot,新一代的JavaEE开发标准， 自动装配

模块化~all in one

模块化的开发===all in one, 代码没变化~

微服务架构4个核心问题?1.服务很多，客户端该怎么访问?2.这么多服务? 服务之间如何通信?3.这么多服务? 如何治理?4.服务挂了怎么办?

解决方案:Spring Cloud 生态! SpringBoot

。。。。

新概念:服务网格~ Server Mesh

istio

万变不离其宗1.API———->路由问题

2.HTTP ,RPC———-》通信问题

3.注册和发现———-》高可用问题

4.熔断机制————》服务降级问题，防止服务雪崩

1、导入依赖2、编写配置文件3、开启这个功能@Enab1eXXXXX 4、配置类

网络不可靠!

1、常见面试题

2、微服务概述

什么是微服务?

微服务(Microservice Architecture)是近几年流行的一种架构思想，关于它的概念很难一言以蔽之。

究竟什么是微服务呢?

我们在此引用ThoughtWorks公司的首席科学家Martin Fowler于2014年提出的一段话:

• 就目前而言,对于微服务，业界并没有一个统一的，标准的定义
• 但通常而言，微服务架构是- 种架构模式，或者说是一 种架构风格， 它提倡将单一的应用程序划分成一组小的服务,每个服务运行在其独立的自己的进程内，服务之间互相协调，互相配置，为用户提供最终价值。服务之间采用轻量级的通信机制互相沟通,每个服务都围绕着具体的业务进行构建，并且能够被独立的部署到生产环境中，另外,应尽量避免统一的, 集中式的服务管理机制，对具体的一个服务而言，应根据业务上下文,选择合适的语言，工具对其进行构建，可以有一个非常轻量级的集中式管理来协调这些服务,可以使用不同的语言来编写服务，也可以使用不同的数据存储;

可能有的人觉得官方的话太过生涩，我们从技术维度来理解下:

• 微服务化的核心就是将传统的一站式应用，根据业务拆分成一个一个的服务,彻底地去耦合，每一个微服务提供单个业务功能的服务，一个服务做一件事情， 从技术角度看就是一种小而独立的处理过程，类似进程的概念,能够自行单独启动或销毁，拥有自己独立的数据库。

微服务

强调的是服务的大小，他关注的是某一个点， 是具体解决某一个问题/提供落地对应服务的一 个服务应用，狭义的看，可以看做是IDEA中的一个个微服务工程,或者Moudel

微服务架构

一种新的架构形式， Martin Fowler, 2014提出微服务架构是一种架构模式，它提倡将单- -应用程序划分成一组小的服务，服务之间互相协调，互相配合，为用户提供最终价值。每个服务运行在其独立的进程中，服务于服务间采用轻量级的通信机制互相协作，每个服务都围绕着具体的业务进行构建，并且能够被独立的部署到生产环境中,另外，应尽量避免统一的, 集中式的服务管理机制，对具体的一个服务而言,应根据业务上下文,选择合适的语言,工具对其进行构建。

• 每个服务足够内聚,足够小，代码容易理解,这样能聚焦一个指定的业务功能或业务需求;
• 开发简单,开发效率提高，-个服务可能就是专- -的只干一 -件事;
• 微服务能够被小团队单独开发,这个小团队是2~5人的开发人员组成;
• 微服务是松耦合的，是有功能意义的服务，无论是在开发阶段或部署阶段都是独立的。
• 微服务能使用不同的语言开发。
• 易于和第三方集成，微服务允许容易且灵活的方式集成自动部署,通过持续集成工具,如 jenkins, Hudson,bamboo
• 微服务易于被一个开发人员理解，修改和维护，这样小团队能够更关注自己的工作成果。无需通过合作才能体现价值。
• 微服务允许你利用融合最新技术。
• 微服务只是业务逻辑的代码，不会和HTML，CSS 或其他界面混合
• 每个微服务都有自己的存储能力，可以有自己的数据库,也可以有统- -数据库

缺点:

• 开发人员要处理分布式系统的复杂性
• 多服务运维难度，随着服务的增加，运维的压力也在增大
• 系统部署依赖
• 服务间通信成本
• 数据一致性
• 系统集成测试
• 性能监控…

1、选型依据

• 整体解决方案和框架成熟度
• 社区热度
• 可维护性
• 学习曲线

2、当前各大IT公司用的微服务架构有哪些?

• 阿里: dubbo+HFS
• 京东: JSF
• 新浪: Motan
• 当当网DubboX

3、各微服务框架对比

3、SpringCloud入门概述

SpringCloud,基于SpringBoot提供了一套微服务解决方案，包括服务注册与发现，配置中心，全链路监控,服务网关,负载均衡，熔断器等组件,除了基于NetFlix的开源组件做高度抽象封装之外,还有一些选型中立的开源组件。

SpringCloud利用SpringBoot的开发便利性,巧妙地简化了分布式系统基础设施的开发, SpringCloud为开发人员提供了快速构建分布式系统的一些工具， 包括配置管理，服务发现，断路器，路由,微代理，事件总线，全局锁， 决策竞选，分布式会话等等，他们都可以用SpringBoot的开发风格做到一键启动和部署。

SpringBoot并没有重复造轮子，它只是将目前各家公司开发的比较成熟，经得起实际考研的服务框架组合起来,通过SpringBoot风格进行再封装，屏蔽掉了复杂的配置和实现原理， 最终给开发者留出了一套简单易懂,易部署 和易维护的分布式系统开发工具包

SpringCloud是分布式微服务架构下的一站式解决方案:是各个微服务架构落地技术的集合体,俗称微服务全家桶。

• SpringBoot专注于快速方便的开发单个个体微服务。- Jar
• SpringCloud是关注全局的微服务协调整理治理框架，它将SpringBoot开发的一 个个单体微服务整合并管理起来,为各个微服务之间提供:配置管理，服务发现，断路器，路由，微代理，事件总线，全局锁,决策竞选,分布式会话等等集成服务。
• SpringBoot可以离开SpringClooud独立使用，开发项目,但是SpringCloud离不开SpringBoot, 属于依赖关系
• *SpringBoot专注于快速、 方便的开发单个个体微服务, SpringCloud关注全局的服务治理框架

1、分布式+服务治理Dubbo

目前成熟的互联网架构:应用服务化拆分+消息中间件

一个完善的项目

2、Dubbo 和SpringCloud对比

结果:

最大区别: SpringCloud抛弃 了Dubbo的RPC通信,采用的是基于HTTP的REST方式。

严格来说，这两种方式各有优劣。虽然从一定程度 上来说，后者牺牲了服务调用的性能，但也避免了上面提到的原生RPC带来的问题。而且REST相比RPC更为灵活,服务提供方和调用方的依赖只依靠一纸契约， 不存在代码级别的强依赖，这在强调快速演化的微服务环境下，显得更加合适。

品牌机与组装机的区别很明显，Spring Cloud的功能比DUBBO更加强大,涵盖面更广，而且作为Spring的拳头项目，它也能够与Spring Framework. Spring Boot. Spring Data. Spring Batch等其他Spring项目完美融合,这些对于微服务而言是至关重要的。使用Dubbo构建的微服务架构就像组装电脑，各环节我们的选择自由度很高，但是最终结果很有可能因为一条内存质量不行就点不亮了，总是让人不怎么放心，但是如果你是一名高手, 那这些都不是问题;而Spring Cloud就像品牌机，在Spring Source的整合下，做了大量的兼容性测试，保证了机器拥有更高的稳定性，但是如果要在使用非原装组件外的东西，就需要对其基础有足够的了解。

社区支持与更新力度最为重要的是，DUBBO停止了5年左右的更新，虽然2017.7重启了。 对于技术发展的新需求，需要由开发者自行拓展升级(比如当当网弄出了DubboX),这对于很多想要采用微服务架构的中小软件组织， 显然是不太合适的,中小公司没有这么强大的技术能力去修改Dubbo源码+周边的一整套解决方案，并不是每-个公司都有阿里的大牛+真实的线上生产环境测试过。

设计模式+微服务拆分思想:不-定善于表达,软实力，活跃度

总结:曾风靡国内的开源RPC服务框架Dubbo在重启维护后，令许多用户为之雀跃，但同时，也迎来了一些质疑的声音。互联网技术发展迅速，Dubbo 是否还能跟上时代? Dubbo 与Spring Cloud相比又有何优势和差异?是否会有相关举措保证Dubbo的后续更新频率?

人物: Dubbo重启维护开发的刘军，主要负责人之一刘军，阿里巴巴中间件高级研发工程师，主导了Dubbo重启维护以后的几个发版计划，专注于高性能RPC框架和微服务相关领域。曾负责网易考拉RPC框架的研发及指导在内部使用，参与了服务治理平台、分布式跟踪系统、分布式-致性框架等从无到有的设计与开发过程。

解决的问题域不一样: Dubbo的定位是-款RPC框架， Spring Cloud的目标是微服务架构下的一站式解决方案

• Distributed/vjersioned configuration (分布式/版本控制配置)
• Service registration and discovery (服务注册与发现)
• Routing (路由)
• Service-to-service calls (服务到服务的调用)
• Load balancing (负载均衡配置)
• Circuit Breakers (断路器)
• Distributed messaging (分布式消息管理)

Spring cloud是一 一个由众多独立子项目组成的大型综合项目，每个子项目有不同的发行节奏，都维护着自己的发布版本号。Spring cloud通过一个资源清单BOM (Bi11 of Materials)来管理每个版本的子项目清单。为避免与子项目的发布号混淆，所以没有采用版本号的方式，而是通过命名的方式。这些版本名称的命名方式采用了伦敦地铁站的名称，同时根据字母表的顺序来对应版本时间顺序，比如:最早的Release版本: Angel, 第二个Release版本: Brixton, 然后是Camden、Dalston、 Edgware, 目前最新的是Finchley版本。

4、Rest学习环境搭建

• 我们会使用- -个Dept部门模块做-个微服务通 用案例Consumer消费者(Client) 通过REST调用Provider提供者(Server)提供的服务。

• 回忆Spring, SpringMVC, MyBatis等以往学习的知识。。.

• Maven的分包分模块架构复习

一个简单的Maven模块结构是这样的:-- app-parent: - - 个父项目(app-parent) 聚合很多子项目(app-util, app-dao, app-web...)|-- pom. xml|-- app-core| l----pom. xml| -- app -web| |----pom. xml

一个父工程带着多个子Module子模块MicroServiceCloud父工程(Project) 下初次带着3个子模块(Module)

• microservicecloud-api [封装的整体entity/接口/公共配置等]|
• microservicecloud-provider-dept-8001 [服务提供者]
• microservicecloud-consumer-dept-80 [服务消费者]
• 动手开干!

各大版本说明

实际开发版本关系

使用最后的这两个

●新建父工程项目microservicecloud, 切记Packageing是pom模式●主要是定义POM文件，将后续各个子模块公用的jar包等统- 提取出来,类似-个抽象父类

父pom.xml

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">    4.0.0    com.kuang    springcloud    1.0-SNAPSHOT            springcloud-api        springcloud-priovider-dept-8001            pom            UTF-8                1.8        1.8        4.12        1.16.10        1.2.7                                                                    org.springframework.cloud                spring-cloud-dependencies                Greenwich.SR1                pom                import                                        org.springframework.boot                spring-boot-dependencies                2.1.4.RELEASE                pom                import                                                    mysql                mysql-connector-java                5.1.47                                                    com.alibaba                druid                1.1.10                                                    org.mybatis.spring.boot                mybatis-spring-boot-starter                1.3.2                                                    junit                junit                ${junit.version}                                                                ch.qos.logback                logback-core                1.2.3                                                    org.projectlombok                lombok                ${lombok.version}                                                    log4j                log4j                ${log4j.version}

1、pom.xml

org.projectlombok            lombok

2、创建数据库，表

3、实体类

package com.kuang.pojo;import lombok.experimental.Accessors;import java.io.Serializable;@Accessors(chain = true)//链式写法public class Dept implements Serializable {//Dept 实体类 orm 类表关系映射    private Long deptno;//主键    private String dname;    //这个数据数存在哪个数据库的字段~微服务，一个服务对应一个数据库，同一个信息可能存在不同的数据库    private String db_source;    public Dept(String dname) {        this.dname = dname;    }    /*    链式写法    Dept dept = new Dept();    dept. setDeptNo(11). setDname(' 'SSSS ') . setDb_ source( '001' ) ;     */    public Dept() {    }    public Long getDeptno() {        return deptno;    }    public void setDeptno(Long deptno) {        this.deptno = deptno;    }    public String getDname() {        return dname;    }    public void setDname(String dname) {        this.dname = dname;    }    public String getDb_source() {        return db_source;    }    public void setDb_source(String db_source) {        this.db_source = db_source;    }    @Override    public String toString() {        return "Dept{" +                "deptno=" + deptno +                ", dname='" + dname + '\'' +                ", db_source='" + db_source + '\'' +                '}';    }}

1、pom.xml

com.kuang            springcloud-api            1.0-SNAPSHOT                                    junit            junit                            mysql            mysql-connector-java                            com.alibaba            druid                            ch.qos.logback            logback-core                            org.mybatis.spring.boot            mybatis-spring-boot-starter                                    org.springframework.boot            spring-boot-test                            org.springframework.boot            spring-boot-starter-web                                    org.springframework.boot            spring-boot-starter-jetty                                    org.springframework.boot            spring-boot-devtools

热部署工具:代码修改后，无需重启服务器，刷新一下即可

2、application.yml

server: port: 8001#mybatis配置mybatis: type-aliases-package: com.kuang.pojo config-location: classpath:mybatis/mybatis-config.xml mapper-locations: classpath:mybatis/mapper/*.xml#spring的配置&autoReconnect=truespring: application:  name: springcloud-provider-dept datasource:  type: com.alibaba.druid.pool.DruidDataSource  driver-class-name: org.gjt.mm.mysql.Driver  url: jdbc:mysql://localhost:3306/db01?useUnicode=true&characterEncoding=utf-8  username: root  password: 981204

3、mybatis-config.xml

PUBLIC "-//mybatis.org//DTD Config 3.0//EN"        "http://mybatis.org/dtd/mybatis-3-config.dtd">

4、DeptDao

@Mapper@Repositorypublic interface DeptDao {    boolean addDept(Dept dept);    Dept queryById(Long id);    List queryAll();}

5、DeptDao.xml

PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">            insert into dept (dname, db_source)        values (#{dname}, DATABASE())                select * from dept where deptno = #{deptno};                select * from dept;

6、DeptService

public interface DeptService {    boolean addDept(Dept dept);    Dept queryById(Long id);    List queryAll();}

7、DeptServiceImpl

@Servicepublic class DeptServiceImpl implements DeptService {    @Autowired    private DeptDao deptDao;    @Override    public boolean addDept(Dept dept) {        return deptDao.addDept(dept);    }    @Override    public Dept queryById(Long id) {        return deptDao.queryById(id);    }    @Override    public List queryAll() {        return deptDao.queryAll();    }}

8、DeptController

//提供Restfui服务@RestControllerpublic class DeptController {    @Autowired    private DeptService deptService;    @PostMapping("/dept/add")    public boolean addDept(Dept dept) {        return deptService.addDept(dept);    }    @GetMapping("/dept/get/{id}")    public Dept get(@PathVariable("id") Long id) {        return deptService.queryById(id);    }    @GetMapping("/dept/list")    public List queryAll() {        return deptService.queryAll();    }}

9、启动类：DeptPriovider_8001

@SpringBootApplicationpublic class DeptPriovider_8001 {    public static void main(String[] args) {        SpringApplication.run(DeptPriovider_8001.class, args);    }}

10、启动测试

项目结构

pom.xml

com.kuang            springcloud-api            1.0-SNAPSHOT                            org.springframework.boot            spring-boot-starter-web                            org.springframework.boot            spring-boot-devtools

2、application.yml

server: port: 80

3、配置ConfigBean

@Configurationpublic class ConfigBean {    @Bean    public RestTemplate getRestTemplate() {//@Configuration-- 以前在spring applicationContext.xml中配置        return new RestTemplate();    }}

4、DeptConsumerController

@RestControllerpublic class DeptConsumerController {    // 理解: 消费者，不应该有service层    // RestTemplate .... 供我们直接调用就可以了!注册到spring中    // (url,实体: Map , Class responseType)|    @Autowired    private RestTemplate restTemplate; // 提供多种便捷访问远http服务的方法，简单的Restful服务模板~    private static final String REST_URL_PREFIX = "http://localhost:8001";    @RequestMapping("/consumer/dept/add")    public boolean add(Dept dept) {        return restTemplate.postForObject(REST_URL_PREFIX + "/dept/add", dept, Boolean.class);    }    @RequestMapping("/consumer/dept/get/{id}")    public Dept get(@PathVariable("id") Long id) {        return restTemplate.getForObject(REST_URL_PREFIX + "/dept/get/" + id, Dept.class);    }    @RequestMapping("/consumer/dept/list")    public List list() {        return restTemplate.getForObject(REST_URL_PREFIX + "/dept/list", List.class);    }}

5、启动类

@SpringBootApplicationpublic class DeptConsumer_80 {    public static void main(String[] args) {        SpringApplication.run(DeptConsumer_80.class, args);    }}

6、测试，先启动提供者，再启动消费者

注：80为可以省略的默认端口

项目结构：

5、Eureka服务注册与发现

• Eureka: 怎么读? .
• Netflix 在设计Eureka时，遵循的就是AP原则

• Eureka是Netflix的一 个子模块，也是核心模块之一 。Eureka是一 个基于REST的服务，用于定位服务,以实现云端中间层服务发现和故障转移，服务注册与发现对于微服务来说是非常重要的，有了服务发现与注册，只需要使用服务的标识符，就可以访问到服务,而不需要修改服务调用的配置文件了，功能类似于Dubbo的注册中心，比如Zookeeper;

• Eureka的基本架构

• SpringCloud封装了NetFlix公司开发的Eureka模块来实现服务注册和发现(对比Zookeeper)
• Eureka采用 了C-S的架构设计，EurekaServer 作为服务注册功能的服务器，他是服务注册中心
• 而系统中的其他微服务。使用Eureka的客户端连接到EurekaServer并维持心跳连接。这样系统的维护人员就可以通过EurekaServer来监控系统中各个微服务是否正常运行，SpringCloud的一 些其他模块(比如Zuul)就可以通过EurekaServer来发现系统中的其他微服务,并执行相关的逻辑;
• 和Dubbo架构对比
• Eureka 包含两个组件: Eureka Server和Eureka Client。
• Eureka Server提供服务注册服务，各个节点启动后，会在EurekaServer中进行注册，这样Eureka Server 中的服务注册表中将会村粗所有可用服务节点的信息，服务节点的信息可以在界面中直观的看到。
• Eureka Client是一 个Java客户端，用于简化EurekaServer的交互，客户端同时也具备一 个内置的，使用轮询负载算法的负载均衡器。在应用启动后,将会向EurekaServer发送心跳(默认周期为30秒)。如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳，EurekaServer将会从服务注册表中把这个服务节点移除掉(默认周期为90秒)
• 三大角色
• Eureka Server: 提供服务的注册于发现。
• Service Provider:将自身服务注册到Eureka中,从而使消费方能够找到。
• Service Consumer:服务消费方从Eureka中获取注册服务列表,从而找到消费服务。
• 盘点目前工程状况

1、pom.xml

org.springframework.cloud            spring-cloud-starter-eureka-server            1.4.6.RELEASE                            org.springframework.boot            spring-boot-devtools

2、application.yml

server:  port: 7001#Eureka配置eureka:  instance:    hostname: localhost #Eureka 服务端的实例名称  client:    register-with-eureka: false #表示是否向eureka注册中心注册自己    fetch-registry: false #fetch-registry如果为false,则表示自己为注册中心    service-url: # 监控页面~      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

3、启动类EurekaServer_7001

//启动之后，访问http://Localhost: 7001/@SpringBootApplication@EnableEurekaServer //EnableEurekaServer服务端的启动类，可以接受别人注册进*public class EurekaServer_7001 {    public static void main(String[] args) {        SpringApplication.run(EurekaServer_7001.class, args);    }}

4、访问测试，先启动7001，再启动8001

将8001的服务入驻到7001的eureka中!

1、pom.xml 修改8001服务的pom文件,增加eureka的支持!

org.springframework.cloud            spring-cloud-starter-eureka            1.4.6.RELEASE

2、application.yml 增加配置

#Eureka的配置，服务注册到哪里eureka: client:  service-url:   defaultZone: http://localhost:7001/eureka/ instance:  instance-id: springcloud-provider-dept8001 #修改eureka 上的默认描述信息!

3、8001的主启动类注解支持

启动类中添加注解

@EnableEurekaClient //在服务启动后自动注册到eureka中

4、测试

现在服务端也有了，客户端也有了启动7001，再启动8001,测试访问

1、pom.xml

org.springframework.boot            spring-boot-starter-actuator

2、application.yml 增加配置

#info配置info: app.name: kuangshen-springcloud company.name: blog.kuangstudy.com

3、重启测试

可观察到

我们修改一个服务名,故意制造错误!

自我保护机制:好死不如赖活着

一句话总结:某时刻某一个微服务不可以用了，eureka不会立刻清理，依旧会对该微服务的信息进行保存!

• 默认情况下，如果EurekaServer在一 定时间内没有接收到某个微服务实例的心跳，EurekaServer将会注销该实例(默认90秒)。但是当网络分区故障发生时，微服务与Eureka之间无法正常通行，以上行为可能变得非常危险了–因为微服务本身其实是健康的， 此时本不应该注销这个服务。Eureka通过 自我保护机制来解决这个问题–当EurekaServer节点在短时间内丢失过多客户端时(可能发生了网络分区故障)，那么这个节点就会进入自我保护模式。- -旦进入该模式，EurekaServer就会保护服务注册表中的信息, 不再删除服务注册表中的数据(也就是不会注销任何微服务)。当网络故障恢复后，该EurekaServer节点会自动退出自我保护模式。
• 在自我保护模式中，EurekaServer会保护服务注册表中的信息，不再注销任何服务实例。当它收到的心跳数重新恢复到阈值以上时，该EurekaServer节 点就会自动退出自我保护模式。它的设计哲学就是宁可保留错误的服务注册信息，也不盲目注销任何可能健康的服务实例。-句话:好死不如赖活着
• 综上，自我保护模式是一种应对网络异常的安全保护措施。它的架构哲学是宁可同时保留所有微服务(健康的微服务和不健康的微服务都会保留)，也不盲目注销任何健康的微服务。使用自我保护模式，可以让Eureka 集群更加的健壮和稳定

• 在SpringCloud中，可以使用eureka. server . enable-self-preservation = false 禁用自我保护模式[不推荐关闭自我保护机制]

• 对于注册进eureka里面的微服务,可以通过服务发现来获得该服务的信息。[对外暴露服务 ]

• 修改microservicecloud-provider-dept-8001I程中的DeptController

可以了解多应的服务信息，实现一些消息转换、服务发现

1、Controller中

//获取一些配置的信息，得到具体的微服务!    @Autowired    private DiscoveryClient client;//注册进来的微服务~，获取-些消息~    @GetMapping("/dept/discovery")    public Object discovery() {        //获取微服务列表的清业        List services = client.getServices();        System.out.println("discovery=>services:" + services);        //得到一- 个具体的微服务信息通过具体的微服务id, appl icaioinName;        List instances = client.getInstances("SPRINGCLOUD-PROVIDER-DEPT");        for (ServiceInstance instance : instances) {            System.out.println(                    instance.getHost() + "\t" +                            instance.getPort() + "\t" +                            instance.getUri() + "\t" +                            instance.getServiceId()            );        }        return this.client;    }

2、启动类开启注解支持

@EnableDiscoveryClient//服务发现

@SpringBootApplication@EnableEurekaClient //在服务启动后自动注册到eureka中@EnableDiscoveryClient//服务发现public class DeptPriovider_8001 {    public static void main(String[] args) {        SpringApplication.run(DeptPriovider_8001.class, args);    }}

3、访问测试

控制器输出

每台远程服务均可以互相访问

这么多服务? 如何治理?

1.创建三个项目，改上面的就行

springcloud-eureka-7001

springcloud-eureka-7002

springcloud-eureka-7003

2、添加域名

集群配置分析

3、该yml配置

三个eureka

server:  port: 7001#Eureka配置eureka:  instance:    hostname: eureka7001.com #Eureka 服务端的实例名称  client:    register-with-eureka: false #表示是否向eureka注册中心注册自己    fetch-registry: false #fetch-registry如果为false,则表示自己为注册中心    service-url: # 监控页面~      #单机 http://${eureka.instance.hostname}:${server.port}/eureka/      #(集群)关联 http://eureka7002.com:7002,http://eureka7003.com:7003      defaultZone: http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/server:  port: 7002#Eureka配置eureka:  instance:    hostname: eureka7002.com #Eureka 服务端的实例名称  client:    register-with-eureka: false #表示是否向eureka注册中心注册自己    fetch-registry: false #fetch-registry如果为false,则表示自己为注册中心    service-url: # 监控页面~      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7003.com:7003/eureka/server:  port: 7003#Eureka配置eureka:  instance:    hostname: eureka7003.com #Eureka 服务端的实例名称  client:    register-with-eureka: false #表示是否向eureka注册中心注册自己    fetch-registry: false #fetch-registry如果为false,则表示自己为注册中心    service-url: # 监控页面~      defaultZone: http://eureka7002.com:7002/eureka/,http://eureka7001.com:7001/eureka/

提供者中

defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/

测试，先启动7001/7002/7003/8001三个地址可以相互访问

三个地址服务均注册进去

消费者只需在配置中改链接即可

回顾CAP原则

RDBMS (Mysql. Oracle、 sqIServer) ===>ACID

NoSQL (redis. mongdb) ===> CAP

ACID是什么?

• A (Atomicity) 原子性
• C (Consistency) 一致性
• I (Isolation) 隔离性
• D (Durability) 持久性

CAP是什么?

• C (Consistency)强一致性
• A (Availability) 可用性
• P (Partition tolerance) 分区容错性

CAP的三进二: CA、AP. CP .

CAP理论的核心

• 一个分布式系统不可能同时很好的满足-致性，可用性和分区容错性这三个需求
• 根据CAP原理，将NoSQL数据库分成了满足CA原则，满足CP原则和满足AP原则三大类:
• CA:单点集群，满足一致性，可用性的系统，通常可扩展性较差
• CP:满足-致性,分区容错性的系统，通常性能不是特别高
• AP:满足可用性,分区容错性的系统，通常可能对一致性要求低- -些

著名的CAP理论指出，一个分布式系统不可能同时满足C (一致性)、A (可用性)、P (容错性)。由于分区容错性P在分布式系统中是必须要保证的，因此我们只能在A和C之间进行权衡。

• Zookeeper保证的是CP;
• Eureka保证的是AP:

Zookeeper保证的是CP

当向注册中心查询服务列表时，我们可以容忍注册中心返回的是几分钟以前的注册信息，但不能接受服务直接down掉不可用。也就是说，服务注册功能对可用性的要求要高于-致性。 但是zk会出现这样一种情况， 当master 节点因为网络故障与其他节点失去联系时，剩余节点会重新进行leader选举。问题在于,选举leader的时间太长,30~120s，且选举期间整个zk集群都是不可用的，这就导致在选举期间注册服务瘫痪。在云部署的环境下，因为网络问题使得zk集群失去master节点是较大概率会发生的事件,虽然服务最终能够恢复，但是漫长的选举时间导致的注册长期不可用是不能容忍的。

Eureka保证的是AP

Eureka看明白了这一点，因此在设计时就优先保证可用性。Eureka各个节 点都是平等的，几个节点挂掉不会影响正常节点的工作,剩余的节点依然可以提供注册和查询服务。而Eureka的客户端在向某个Eureka注册时，如果发现连接失败，则会自动切换至其他节点，只要有一台Eureka还在, 就能保住注册服务的可用性，只不过查到的信息可能不是最新的，除此之外，Eureka还有一 种自我保护机制，如果在15分钟内超过85%的节点都没有正常的心跳，那么Eureka就认为客户端与注册中心出现了网络故障,此时会出现以下几种情况:

因此，Eureka可以很好的应对因网络故障导致部分节点失去联系的情况，而不会像zookeeper那样使整 个注册服务瘫痪

6、Ribbon负载均衡

例如一万个人发送请求，负载均衡把请求平摊给五台服务器

ribbon怎么读?ribbon是什么?●Spring Cloud Ribbon是基于Netflix Ribbon实现的一 套 客户端负载均衡的工具。●简单的说，Ribbon是Netflix发布的开源项目, 主要功能是提供客户端的软件负载均衡算法，将NetFlix的中间层服务连接在一起。 Ribbon的客户端组件提供-系列完整的配置项如:连接超时、重试等等。简单的说，就是在配置文件中列出LoadBalancer (简称LB:负载均衡)后面所有的机器，Ribbon会 自动的帮助你基于某种规则(如简单轮询，随机连接等等)去连接这些机器。我们也很容易使用Ribbon实现自定义的负载均衡算法! ribbon能干嘛?●LB,即负载均衡(Load Balance) ，在微服务或分布式集群中经常用的一种应用。● 负载均衡简单的说就是将用户的请求平摊的分配到多个服务上,从而达到系统的HA (高可用)。●常见的负载均衡软件有Nginx, Lvs等等●dubbo. SpringCloud中均给我们提供了 负载均衡， SpringCloud的负载均衡算法可以自定义●负载均衡简单分类:。集中式LB ■即在服务的消费方和提供方之间使用独立的LB设施，如Nginx, 由该设施负责把访问请求通过某种策略转发至服务的提供方!。进程式LB ■将LB逻辑集成到消费方，消费方从服务注册中心获知有哪些地址可用，然后自己再从这些地址中选出一个合适的服务器。■Ribbon就属于进程内LB，它只是一个类库,集成于消费方进程，消费方通过它来获取到服务提供方的地址

springcloud-cosumer-dept-80中

1、添加依赖pom.xml

org.springframework.cloud            spring-cloud-starter-ribbon            1.4.6.RELEASE                                            org.springframework.cloud            spring-cloud-starter-eureka            1.4.6.RELEASE

2、添加yml

#Eureka配置eureka: client:  register-with-eureka: false #不向Eureka注册自己  service-url:   defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/

3、配置类中添加注解 @LoadBalanced //Ribbon

@Configurationpublic class ConfigBean {    //配置负载均衡实现Rest Template    @Bean    @LoadBalanced //Ribbon    public RestTemplate getRestTemplate() {//@Configuration-- 以前在spring applicationContext.xml中配置        return new RestTemplate();    }}

4、修改DeptConsumerController

//Ribbon. 我们这里的地址，应该是一个变量。通过服务名来访问//private static final String REST_URL_PREFIX = "http://localhost:8001";private static final String REST_URL_PREFIX = "http://SPRINGCLOUD-PROVIDER-DEPT";

5、启动类中添加@EnableEurekaClient

//Ribbon和Eureka整合以后，客户端可以直接调用。相关心IP地址和端口号@SpringBootApplication@EnableEurekaClientpublic class DeptConsumer_80 {    public static void main(String[] args) {        SpringApplication.run(DeptConsumer_80.class, args);    }}

6、启动7001/7002/8001/80测试

1、创建三个提供者

springcloud-priovider-dept-8001

springcloud-priovider-dept-8002

springcloud-priovider-dept-8003

2、复制springcloud-priovider-dept-8001，更改里面的配置yml

server: port: 8002#mybatis配置mybatis: type-aliases-package: com.kuang.pojo config-location: classpath:mybatis/mybatis-config.xml mapper-locations: classpath:mybatis/mapper/*.xml#spring的配置&autoReconnect=truespring: application:  name: springcloud-provider-dept #三个服务名称一致 datasource:  type: com.alibaba.druid.pool.DruidDataSource  driver-class-name: org.gjt.mm.mysql.Driver  url: jdbc:mysql://localhost:3306/db02?useUnicode=true&characterEncoding=utf-8  username: root  password: 981204#Eureka的配置，服务注册到哪里eureka: client:  service-url:   #http://localhost:7001/eureka/,http://localhost:7002/eureka/,http://localhost:7003/eureka/   #http://eureka7001.com:7001,http://eureka7002.com:7002,http://eureka7003.com:7003   defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/ instance:  instance-id: springcloud-provider-dept8002 #修改eureka 上的默认描述信息!#info配置info: app.name: kuangshen-springcloud company.name: blog.kuangstudy.com

2、更改主启动类

package com.kuang;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;@SpringBootApplication@EnableEurekaClient //在服务启动后自动注册到eureka中@EnableDiscoveryClient//服务发现public class DeptPriovider_8002{    public static void main(String[] args) {        SpringApplication.run(DeptPriovider_8002.class, args);    }}

3、启动测试

启动7001，发现有两个提供者注册进去

再启动8001/8002/8003/80，结果是 轮询，判断自己是要连哪个

1、使用随机算法代替默认的轮询算法

// IRule// RoundRobinRule轮询// RandomRule随机// AvailabilityFilteringRule :会先过滤掉， 跳闸，访问故障的服务~，对利下的进行轮海~// RetryRule :会先按照轮 询获取服务~，如果服务获取失败，则会在指定的时间内进行，重试@Configurationpublic class KuangRule {    @Bean    public IRule myRu1e() {        return new RandomRule();    }}

1、复制RandomRule，自己更改将 原来的默认轮询访问改为 每个服务访问5次,再换下一个服务(3个)

package com.kuang.myrule;

import com.netflix.client.config.IClientConfig;
import com.netflix.loadbalancer.AbstractLoadBalancerRule;
import com.netflix.loadbalancer.ILoadBalancer;
import com.netflix.loadbalancer.Server;

import java.util.List;
import java.util.concurrent.ThreadLocalRandom;

public class KuangRandomRule extends AbstractLoadBalancerRule {
    //每个服务，访问次,换下一个服务(3个)
    // total=0, 默认=0，如果=5，我们指向下一个服务节点
    // index=0. 默认=0，如果total=5, index+1.
    private int total = 0; //被调用的次数
    private int currentIndex = 0; //当前是谁在提供服务d


    //@SuppressWarnings({"RCN_REDUNDANT_NULLCHECK_OF_NULL_VALUE"})
    public Server choose(ILoadBalancer lb, Object key) {
        if (lb == null) {
            return null;
        } else {
            Server server = null;

            while (server == null) {
                if (Thread.interrupted()) {
                    return null;
                }

                List upList = lb.getReachableServers();//获得活着的服务
                List allList = lb.getAllServers();//获得全部服务
                int serverCount = allList.size();
                if (serverCount == 0) {
                    return null;
                }


                // int index = this.chooseRandomInt(serverCount);//生成区间随机数
                //server = (Server) upList.get(index);//从活着的服务中，随机获取一个

                //===============================================
                if (total < 5) {
                    server = upList.get(currentIndex);
                    total++;
                } else {
                    total = 0;
                    currentIndex++;
                    if (currentIndex > upList.size()) {
                        currentIndex = 0;
                    }
                    server = upList.get(currentIndex); //从活着的服务中，获取指定的服务来进行操作
                }
                //=================================================


                if (server == null) {
                    Thread.yield();
                } else {
                    if (server.isAlive()) {
                        return server;
                    }

                    server = null;
                    Thread.yield();
                }
            }

            return server;
        }
    }

    protected int chooseRandomInt(int serverCount) {
        return ThreadLocalRandom.current().nextInt(serverCount);
    }

    public Server choose(Object key) {
        return this.choose(this.getLoadBalancer(), key);
    }

    public void initWithNiwsConfig(IClientConfig clientConfig) {
    }
}

2、配置中调用该自定义负载均衡算法

@Configurationpublic class KuangRule {    @Bean    public IRule myRu1e() {        return new KuangRandomRule();    }}

3、启动7001/8001/8002/8003/80访问测试

发现 每个服务访问5次,再换下一个服务(3个)

7、Feign负载均衡

feign是声明式的web service客户端，它让微服务之间的调用变得更简单了，类似controller调用service。 Spring Cloud集成了Ribbon和Eureka,可在使用Feign时提供负载均衡的http客户端。

只需要创建一个接口，然后添加注解即可!

feign,主要是社区,大家都习惯面向接口编程。这个是很多开发人员的规范。调用微服务访问两种方法

Feign能干什么?

• Feign旨在使编写Java Http客户端变得更容易
• 前面在使用Ribbon + RestTemplate时, 利用RestTemplate对Http请求的封装处理， 形成了一 套模板化的调用方法。但是在实际开发中，由于对服务依赖的调用可能不止一-处, 往往-个接口会被多处调用，所以通常都会针对每个微服务自行封装-一些客户端类来包装这些依赖服务的调用。 所以，Feign在此基础 上做了进一步封装,由他来帮助我们定义和实现依赖服务接口的定义，在Feign的实现下，我们只需要创建一个接口并使用 注解的方式来配置它(类似于以前Dao接口上标注Mapper注解，现在是一个微服务接口上面标注一个Feign注解即可。) 即可完成对服务提供方的接口绑定,简化了使用Spring Cloud Ribbon时,自动封装服务调用客户端的开发量。

Feign集成了Ribbon

• 利用Ribbon维护了MicroServiceCloud-Dept的服务列表信息,并且通过轮询实现了客户端的负载均衡，而与Ribbon不同的是，通过Feign只需要定义服务绑定接口且以声明式的方法，优雅而且简单的实现了服务调用。

1.创建springcloud-cosumer-dept-feign导入springcloud-cosumer-dept-80的那些配置

2.在模块springcloud-api和springcloud-cosumer-dept-feign中添加依赖

org.springframework.cloud            spring-cloud-starter-feign            1.4.6.RELEASE

3.在模块springcloud-api中编写DeptClientService

@Component@FeignClient(value = "SPRINGCLOUD-PROVIDER-DEPT")public interface DeptClientService {    @GetMapping("/dept/get/{id}")    public Dept queryById(@PathVariable("id") Long id);    @GetMapping("/dept/list")    public List queryAll();    @PostMapping("/dept/add")    public boolean addDept(Dept dept);}

4.springcloud-cosumer-dept-feign中编写DeptConsumerController

@RestControllerpublic class DeptConsumerController {    //@Autowired(required=true)：当使用@Autowired注解的时候，其实默认就是@Autowired(required=true)，表示注入的时候，该bean必须存在，否则就会注入失败。    @Autowired(required = false)    private DeptClientService service = null;    @RequestMapping("/consumer/dept/add")    public boolean add(Dept dept) {        return this.service.addDept(dept);    }    @RequestMapping("/consumer/dept/get/{id}")    public Dept get(@PathVariable("id") Long id) {        return this.service.queryById(id);    }    @RequestMapping("/consumer/dept/list")    public List list() {        return this.service.queryAll();    }}

5.编写主启动类

//Ribbon和Eureka整合以后，客户端可以直接调用。相关心IP地址和端口号@SpringBootApplication@EnableEurekaClient@EnableFeignClients(basePackages = {"com.kuang"})public class FeignDeptConsumer_80 {    public static void main(String[] args) {        SpringApplication.run(FeignDeptConsumer_80.class, args);    }}

6.启动7001/8001/8002、fegin80测试访问，发现也是默认轮询

8、Hystrix服务熔断

分布式系统面临的问题

复杂分布式体系结构中的应用程序有数十个依赖关系，每个依赖关系在某些时候将不可避免的失败!

服务雪崩

多个微服务之间调用的时候，假设微服务A调用微服务B和微服务C,微服务B和微服务(C又调用其他的微服务,这就是所谓的”扇出”、如果扇出的链路上某个微服务的调用响应时间过长或者不可用，对微服务A的调用就会占用越来越多的系统资源，进而引起系统崩溃，所谓的”雪崩效应”。​ 对于高流量的应用来说，单- -的后端依赖可能会导致所有服务器上的所有资源都在几秒中内饱和。比失败更糟糕的是，这些应用程序还可能导致服务之间的延迟增加，备份队列,线程和其他系统资源紧张，导致整个系统发生更多的级联故障，这些都表示需要对故障和延迟进行隔离和管理，以便单个依赖关系的失败,不能取消整个应用程序或系统。​ 我们需要:弃车保帅.

什么是HystrixHystrix是一个用于处理分布式系统的延迟和容错的开源库, 在分布式系统里,许多依赖不可避免的会调用失败，比如超时，异常等, Hystrix能够保证在一个依赖出问题的情况下， 不会导致整体服务失败，避免级联故障,以提高分布式系统的弹性。

“断路器”本身是一种开关装置， 当某个服务单元发生故障之后，通过断路器的故障监控(类似熔断保险丝)， 向 调用方返回- -个服务预期的，可处理的备选响应(FallBack) , 而不是长时间的等待或者抛出调用方法无法处理 的异常，这样就可以保证了服务调用方的线程不会被长时间，不必要的占用，从而避免了故障在分布式系统中的蔓延，乃至雪崩

能干嘛●服务降级.●服务熔断●服务限流●接近实时的监控

是什么熔断机制是对应雪崩效应的一种微服务链路保护机制。

当扇出链路的某个微服务不可用或者响应时间太长时，会进行服务的降级, 进而熔断该节点微服务的调用，快 速返回错误的响应信息。当检测到该节点微服务调用响应正常后恢复调用链路。在SpringCloud框架里熔断机制通过Hystrix实现。Hystrix会监控微服务间调用的状况，当失败的调用到一定阈值，缺省是5秒内20次调用失败就会启动熔断机制。熔断机制的注解是@HystrixCommand.

1.创建一个项目springcloud-priovider-dept-hystrix-8001复制springcloud-priovider-dept-8001的配置

2.添加pom依赖

org.springframework.cloud            spring-cloud-starter-hystrix            1.4.6.RELEASE

3.DeptController

//提供Restfui服务@RestControllerpublic class DeptController {    @Autowired    private DeptService deptService;    @GetMapping("/dept/get/{id}")    @HystrixCommand(fallbackMethod = "hystrixGet")    public Dept get(@PathVariable("id") Long id) {        Dept dept = deptService.queryById(id);        if (dept == null) {            throw new RuntimeException("id=>" + id + ".不存在该用户。或者信息无法找到~");        }        return dept;    }    //备选方法    public Dept hystrixGet(@PathVariable("id") Long id) {        Dept dept = new Dept();        dept.setDeptno(id);        dept.setDname("id=>" + id + "没有对应的信息。null--@Hystrix");        dept.setDb_source("no this database in MySQL");        return dept;    }}

4.添加@EnableCircuitBreaker//添加对熔断的支持

@SpringBootApplication@EnableEurekaClient //在服务启动后自动注册到eureka中@EnableDiscoveryClient//服务发现@EnableCircuitBreaker//添加对熔断的支持public class DeptPrioviderHystrix_8001 {    public static void main(String[] args) {        SpringApplication.run(DeptPrioviderHystrix_8001.class, args);    }}

5.启动7001/7002、hystrix8001/80测试访问：

彩蛋：显示ip地址

prefer-ip-address: true #true 可以显示服务的ip地址

配置前

配置后

服务器访问量大时关闭部分其它服务器

1.springcloud-api中编写DeptClientServiceFallbackFacktory

//降级@Componentpublic class DeptClientServiceFallbackFacktory implements FallbackFactory {    @Override    public DeptClientService create(Throwable throwable) {        return new DeptClientService() {            @Override            public Dept queryById(Long id) {                Dept dept = new Dept();                dept.setDeptno(id);                dept.setDname("id=>" + id + "没有对应的信息。客户端提供了降级的信息。这个服务现在已经被关闭");                dept.setDb_source("没有数据~");                return dept;            }            @Override            public List queryAll() {                return null;            }            @Override            public boolean addDept(Dept dept) {                return false;            }        };    }}

2.DeptClientService

@FeignClient(value = "SPRINGCLOUD-PROVIDER-DEPT", fallbackFactory = DeptClientServiceFallbackFacktory.class)

3.springcloud-cosumer-dept-feign中添加配置

#开启降级feign. hystrixfeign: hystrix:  enabled: true

4.启动7001/8001、feign80测试

5.关闭8001

查询结果

服务熔断:服务券菜 个服务超时或者异常，引起熔断，保险丝~服务降级:客户端从整体网站请求负载考虑。当菜个服务熔断或者关闭之后。服务将不再被调用此时在客户端，我们可以准备一- 个FallbackFactory. 返回- – 个默认的值(缺省值)，整体的服务水中下降不但是，好歹能用比直按挂掉强

写监控页面

1.创建springcloud-cosumer-hystrix-dashboard

2.添加依赖

org.springframework.cloud            spring-cloud-starter-hystrix            1.4.6.RELEASE                            org.springframework.cloud            spring-cloud-starter-hystrix-dashboard            1.4.6.RELEASE

3.设置端口号

server: port: 9001

4.编写启动类启动

@SpringBootApplication@EnableHystrixDashboard //开启public class DeptConsumerDashboard_9001 {    public static void main(String[] args) {        SpringApplication.run(DeptConsumerDashboard_9001.class,args);    }}

5、访问测试

开始监控了

项目springcloud-priovider-dept-8001中

1.主启动类中

@SpringBootApplication@EnableEurekaClient //在服务启动后自动注册到eureka中@EnableDiscoveryClient//服务发现public class DeptPriovider_8001 {    public static void main(String[] args) {        SpringApplication.run(DeptPriovider_8001.class, args);    }    //增加一个Servlet    @Bean    public ServletRegistrationBean hystrixMetricsStreamServlet() {        ServletRegistrationBean registrationBean = new ServletRegistrationBean(new HystrixMetricsStreamServlet());        registrationBean.addUrlMappings("/actuator/hystrix.stream");        return registrationBean;    }}

2.启动7001/9001/8001测试

每次发送请求观察监控变化

**关于监控

。如何看■7色

■一圈实心圆:公有两种含义,他通过颜色的变化代表了实例的健康程度它的健康程度从绿色

■一线曲线:用来记录2分钟内流量的相对变化，可以通过它来观察到流量的上升和下降趋势!

■整图说明

。搞懂一个才能看懂复杂的

9、Zuul路由网关

什么是Zuul?

Zuul包含了对请求的路由和过滤两个最主要的功能:其中路由功能负责将外部请求转发到具体的微服务实例上，实现外部访问统-入口的基础， 而过滤器功能则负责对请求的处理过程进行干预，是实现请求校验，服务聚合等功能的基础。Zuul和Eureka进行整合,将Zuul自身注册为Eureka服务治理下的应用，同时从Eureka中获得其他微服务的消息，也即以后的访问微服务都是通过Zuul跳转后获得。

注意: Zuul服务最终还是会注册进Eureka 提供:代理+路由+过滤三大功能!

本地更改

1.创建springcloud-zuul-9527

2.导入依赖

org.springframework.cloud            spring-cloud-starter-zuul            1.4.6.RELEASE                            org.springframework.cloud            spring-cloud-starter-hystrix            1.4.6.RELEASE                            org.springframework.cloud            spring-cloud-starter-hystrix-dashboard            1.4.6.RELEASE                                            org.springframework.cloud            spring-cloud-starter-ribbon            1.4.6.RELEASE                                            org.springframework.cloud            spring-cloud-starter-eureka            1.4.6.RELEASE                                    com.kuang            springcloud-api            1.0-SNAPSHOT                            org.springframework.boot            spring-boot-starter-web                            org.springframework.boot            spring-boot-devtools

3.添加配置

server:  port: 9527spring:  application:    name: springcloud-zuuleureka:  client:    service-url:      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/  instance:    instance-id: zuul9527.com    prefer-ip-address: trueinfo:  app.name: kuang-springcloud  company.name: blog.kuangstudy.com

4.启动类

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

5.启动7001/8001/9527测试访问

使用路由网关保证了本地域名不被泄漏

添加yml配置

zuul:  routes:    mydept.serviceId: springcloud-provider-dept    mydept.path: /mydept/**  ignored-services: "*" #不能再使用这个路径访间了ignored :忽略。隐藏全部的~  prefix: /kuang #设置公共的前缀

启动7001/8001/9527访问测试

10、config分布式配置

分布式系统面临的-配置文件的问题微服务意味着要将单体应用中的业务拆分成一个个子服务,每个服务的粒度相对较小，因此系统中会出现大量的服务,由于每个服务都需要必要的配置信息才能运行，所以一套集中式的，动态的配置管理设施是必不可少的。SpringCloud提供了ConfigServer来解决这个问题，我们每一个微服务自己带着- -个application.yml, 那上百的的配置文件要修改起来，岂不是要发疯! .

什么是SpringCloud config分布式配置中心

Spring Cloud Config为微服务架构中的微服务提供集中化的外部配置支持,配置服务器为 各个不同微服务应用的所有环节提供了一个 中心化的外部配置。

Spring Cloud Config 分为 服务端和 客户端两部分;服务端也称为分布式配置中心，它是一 个独立的微服务应用，用来连接配置服务器并为客户端提供获取配置信息，加密，解密信息等访问接口。客户端则是通过指定的配置中心来管理应用资源，以及与业务相关的配置内容,并在启动的时候从配置中心获取和加载配置信息。配置服务器默认采用gjt来存储配置信息,这样就有助于对环境配置进行版本管理。并且可以通过git客户端工具来方便的管理和访问配置内容。

SpringCloud config分布式配置中心能干嘛●集中管理配置文件●不同环境，不同配置，动态化的配置更新，分环境部署，比如/dev /test/ /prod /beta /release-●运行期间动态调整配置，不再需要在每个服务部署的机器上编写配置文件,服务会向配置中心统一拉取配置自己的信息。●当配置发生变动时，服务不需要重启，即可感知到配置的变化,并应用新的配置●将配置信息以REST接口的形式暴露SpringCloud config分布式配置中心与github整合由于Spring Cloud Config默认使用Git来存储配置文件(也有其他方式， 比如支持SVN和本地文件)，但是最推荐的还是Git，而且使用的是http 1 https访问的形式;

仓库下载到本地

3、点击克隆下载，选中SSH，复制

4、创建文件夹GIT，右击打开Git Bash Here

git clone git@gitee.com:zhuanqianyangxibei/springcloud-config.git

yes

解决办法

1、打开码云，点击设置点击SSH公钥,生成一个公钥

ssh-keygen -t rsa -C "2458736697@qq.com"

2、可以在这个位置找到生成的公钥

3、添加公钥到码云

4、输入克隆命令

5、成功克隆到本地

1.在springcloud-config目录下创建application.yml

2.输入命令

切换当前目录下

cd springcloud-config/

git add .

获得状态

git status

提交以及设置提交名字

git commit -m "first commit"

远程提交到码云

git push origin master

3、刷新码云发现远程提交成功

1.导入依赖

org.springframework.cloud        spring-cloud-config-server        2.1.1.RELEASE                        org.springframework.boot        spring-boot-starter-actuator                org.springframework.boot        spring-boot-starter-web

2.编写配置文件

server:  port: 3344spring:  application:    name: springcloud-config-server    #连接远程仓库  cloud:    config:      server:        git:          uri: https://gitee.com/zhuanqianyangxibei/springcloud-config.git # https ,不是SSH#通过config-server可以连接到git， 访问其中的资源以及配置~

3、启动类及开启服务

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

4、启动测试

实现了远程访问

D:\Project\IdeaProject\GIT\springcloud-config中创建一个config-client.yml

四步远程提交到码云

1.导入依赖

org.springframework.cloud        spring-cloud-starter-config        2.1.1.RELEASE                org.springframework.boot        spring-boot-starter-actuator                org.springframework.boot        spring-boot-starter-web

2.编写配置文件

bootstrap.yml

#系统级别的配置spring:  cloud:    config:      name: config-client #需要从git上读取的资源名称，不要后缀      profile: dev      label: master      uri: http://localhost:3344

application.yml

#用户级别的配置spring:  application:    name: springcloud-config-client-3355

3、编写ConfigClientController

@RestControllerpublic class ConfigClientController {    @Value("${spring.application.name}")    private String applicationName;    @Value("${eureka.client.service-url.defaultZone}")    private String eurekaServer;    @Value("${server.port}")    private String port;    @RequestMapping("/config")    public String getConfig() {        return " applicationName : " + applicationName +                "eurekaServer : " + eurekaServer +                "port:" + port;    }}

4、编写启动类

@SpringBootApplicationpublic class ConfigClient_3355 {    public static void main(String[] args) {        SpringApplication.run(ConfigClient_3355.class, args);    }}

5、启动3344/3355测试访问

以eureka为例创建配置

spring:  profiles:    active: dev  ---  server:  port: 7001  #spring配置spring:  profiles: dev  application:    name: springcloud-config-eureka  #Eureka配置eureka:  instance:    hostname: eureka7001.com   client:    register-with-eureka: false    fetch-registry: false     service-url: # 监控页面~      #单机 http://${eureka.instance.hostname}:${server.port}/eureka/      #(集群)关联 http://eureka7002.com:7002,http://eureka7003.com:7003      defaultZone: http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/      ---  server:  port: 7001  #spring配置spring:  profiles: test  application:    name: springcloud-config-eureka  #Eureka配置eureka:  instance:    hostname: eureka7001.com   client:    register-with-eureka: false    fetch-registry: false     service-url: # 监控页面~      #单机 http://${eureka.instance.hostname}:${server.port}/eureka/      #(集群)关联 http://eureka7002.com:7002,http://eureka7003.com:7003      defaultZone: http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/

编写项目springcloud-config-eureka-7001

1、导入pom

org.springframework.cloud            spring-cloud-starter-config            2.1.1.RELEASE                                    org.springframework.cloud            spring-cloud-starter-eureka-server            1.4.6.RELEASE                            org.springframework.boot            spring-boot-devtools

2、编写配置文件

bootstrap.yml（ 连接远程）

#系统级别的配置spring:  cloud:    config:      name: config-eureka #需要从git上读取的资源名称，不要后缀      profile: dev      label: master      uri: http://localhost:3344

application.yml

#用户级别的配置spring:  application:    name: springcloud-config-eureka-7001

3、启动类

@SpringBootApplication@EnableEurekaServer //EnableEurekaServer服务端的启动类，可以接受别人注册进*public class EurekaServer_7001 {    public static void main(String[] args) {        SpringApplication.run(EurekaServer_7001.class, args);    }}

4、先启动3344

再启动7001

远程配置成功

Original: https://www.cnblogs.com/Argilgamesh/p/16339171.html
Author: ArGilgamesh
Title: springcloud