2021年4月12日星期一

SpringCloud学习笔记

本文主要介绍 SpringCloud 的入门

一、SpringCloud 的五大组件

（需要牢牢记住他们，现在混个眼熟，下面会详细介绍。）

image

自学参考文档：

  • SpringCloud 官方文档（汉化版）：https://springcloud.cc/spring-cloud-dalston.html
  • SpringCloud中国社区 id="二、什么是微服务">二、什么是微服务

    Spring官网：https://spring.io/
    image

    微服务(Microservice Architecture) 是近几年流行的一种架构思想，关于它的概念很难一言以蔽之。究竟什么是微服务呢？我们在此引用ThoughtWorks 公司的首席科学家 Martin Fowler 于2014年提出的一段话：

    原文：https://martinfowler.com/articles/microservices.html

    中文：https://www.cnblogs.com/liuning8023/p/4493156.html

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

    三、传统开发模式 VS 微服务

    • 传统的web开发方式

    一般被称为Monolithic（单体式开发）。所有的功能打包在一个 WAR包里，基本没有外部依赖（除了容器），部署在一个JEE容器（Tomcat，JBoss，WebLogic）里，包含了 DO/DAO，Service，UI等所有逻辑。

    image

    优点：
    集中式管理，开发简单，功能都在本地，没有分布式的管理和调用。

    缺点：
    1.效率低，开发都在同一个项目改代码，互相等待，冲突不断；
    2.稳定性差，一个微小的问题，可能导致整个程序挂掉；
    3.维护性难，代码高耦合，内部关系难以摸清楚；
    4.扩展性差，无法满足高并发下的业务需求；

    • 随着业务的发展，移动端兴起

    image

    这一阶段，架构设计存在着很多不合理的地方：
    1.网站和移动端存在着很多相同业务逻辑的重复代码；
    2.数据库被多个应用依赖，无法重构和优化；
    3.数据有时候通过数据库共享，有时候通过接口调用传输，接口调用关系杂乱；
    4.单个应用为了给其他应用提供接口，设计得越来越复杂，包含本不属于它得逻辑；
    5.应用之间界限模糊，功能归属混乱，出现问题后各部门职责很难划分，出现分歧或争端；
    6.所有的应用都在一个数据库上操作，数据库出现性能瓶颈；
    7.管理后台保障级别比较低，添加新的功能可能影响到其他应用；
    8.开发、部署、维护、升级愈发困难；

    • 下一阶段，除去大量的冗余代码

    image

    在这一阶段，服务已经被拆分开了，但是数据库依然是共用的。会出现一些问题：
    1.数据库性能瓶颈，而且存在一定的风险；
    2.数据库表结构可能被多个服务依赖，维护困难；

    • 提高系统的实时性，再次升级架构（微服务）

    image

    此时，拆分后的各个服务可以采用异构的技术。比如，数据分析服务可以使用数据仓库作为持久化层，以便于高效地做一些统计计算；促销服务访问比较频繁，因此可以加入缓存机制。

    微服务，它是具体解决某一个问题/提供落地对应服务的一个服务应用，狭义的看，可以看作是IDEA中的一个个微服务工程，或者Moudel。IDEA 工具里面使用Maven开发的一个个独立的小Moudel，它具体是使用SpringBoot开发的一个小模块，专业的事情交给专业的模块来做，一个模块就做着一件事情。强调的是一个个的个体，每个个体完成一个具体的任务或者功能。

    微服务的优点：
    1.单一职责原则；
    2.每个服务足够内聚，足够小，代码容易理解；
    3.开发效率高，一个服务可能就是专一的只干一件事；
    4.微服务能够被小团队单独开发，这个团队只需2-5个开发人员组成；
    5.松耦合，无论是在开发阶段或部署阶段都是独立的；
    6.可以使用不同的语言开发；
    7.易于和第三方集成，微服务允许容易且灵活的方式集成自动部署，通过持续集成工具，如jenkins，Hudson，bamboo；
    8.每个微服务都有自己的存储能力，可以有自己的数据库，也可以有统一的数据库；

    微服务的缺点:
    1.开发人员要处理分布式系统的复杂性；
    2.多服务运维难度，随着服务的增加，运维的压力也在增大；
    3.各个服务间的通信成本问题；
    4.整个应用分散成多个服务，定位故障相对困难；
    5.一个服务故障可能产生雪崩效用，导致整个系统故障；

    整体解决思路如下：
    image

    四、SpringCloud入门

    官网 src="https://img2020.cnblogs.com/blog/1155461/202104/1155461-20210406172021936-154690837.png" alt="image" loading="lazy">

    SpringCloud没有采用数字编号的方式命名版本号，而是采用了伦敦地铁站的名称，同时根据字母表的顺序来对应版本时间顺序，比如最早的Realse版本：Angel，第二个Realse版本：Brixton，然后是Camden、Dalston、Edgware，目前最新的是Hoxton SR4 CURRENT GA通用稳定版。

    • 微服务技术栈有那些？
    微服务技术条目落地技术
    服务开发SpringBoot、Spring、SpringMVC等
    服务配置和管理Netfix公司的Archaius、阿里的Diamond等
    服务注册与发现Eureka、Consul、Zookeeper等
    服务调用Rest、PRC、gRPC
    服务熔断器Hystrix、Envoy等
    负载均衡Ribbon、Nginx等
    服务接口调用（客户端调用服务的简化工具Fegin等
    消息队列Kafka、RabbitMQ、ActiveMQ等
    服务配置中心管理SpringCloudConfig、Chef等
    服务路由（API网关）Zuul等
    服务监控Zabbix、Nagios、Metrics、Specatator等
    全链路追踪Zipkin、Brave、Dapper等
    数据流操作开发包SpringCloud Stream(封装与Redis，Rabbit，Kafka等发送接收消息)
    时间消息总站SpringCloud Bus
    服务部署Docker、OpenStack、Kubernetes等
    • 各微服务框架对比
    功能点/服务框架Netflix/SpringCloudMotangRPCThritDubbo/DubboX
    功能定位完整的微服务框架RPC框架，但整合了ZK或Consul，实现集群环境的基本服务注册发现RPC框架RPC框架服务框架
    支持Rest是，Ribbon支持多种可拔插的序列号选择否否否否
    支持RPC否是(Hession2)是是是
    支持多语言是(Rest形式)否是是否
    负载均衡是(服务端zuul+客户端Ribbon)，zuul-服务，动态路由，云端负载均衡Eureka（针对中间层服务器）是(客户端)否否是(客户端)
    配置服务Netfix Archaius，Spring Cloud Config Server 集中配置是(Zookeeper提供)否否否
    服务调用链监控是(zuul)，zuul提供边缘服务，API网关否否否否
    高可用/容错是(服务端Hystrix+客户端Ribbon)是(客户端)否否是(客户端)
    典型应用案例NetflixSinaGoogleFacebook
    社区活跃程度高一般高一般2017年后重新开始维护，之前中断了5年
    学习难度中等低高高低
    文档丰富程度高一般一般一般高
    其他Spring Cloud Bus为我们的应用程序带来了更多管理端点支持降级Netflix内部在开发集成gRPCIDL定义实践的公司比较多
    • Rest 搭建学习环境

    1.创建父工程 springcloud （使用 pom 打包方式）

    <?

    注意：父工程为 springcloud，其下有多个子 module

    2.创建子模块 springcloud-api，它只负责接管 pojo

    pom 依赖

    <?

    3.在SQLyog中创建数据库 db01

    image

    idea连接此数据库并创建一些字段和数据

    image

    insert into dept (dname, db_source) VALUES ('开发部',DATABASE());insert into dept (dname, db_source) VALUES ('设计部',DATABASE());insert into dept (dname, db_source) VALUES ('人事部',DATABASE());insert into dept (dname, db_source) VALUES ('运营部',DATABASE());insert into dept (dname, db_source) VALUES ('企划部',DATABASE());insert into dept (dname, db_source) VALUES ('编辑部',DATABASE());

    4.创建实体类

    package com.zhou.springcloud.pojo;import lombok.Data;import lombok.NoArgsConstructor;import lombok.experimental.Accessors;import java.io.Serializable;@Data@NoArgsConstructor@Accessors(chain = true) //链式编程，默认 boolean chain() default false;public class Dept implements Serializable { //Dept 实体类 private Long deptno;//主键 private String dname; //这个数据存在那个数据库的字段，微服务，一个服务对应一个数据库，同一个信息可能存在不同的数据库 private String db_source; public Dept(String dname) {  this.dname = dname; }}

    5.创建子模块 springcloud-provider-dept-8001 (服务的提供者)

    子模块 springcloud-provider-dept-8001 的整体项目结构如下：

    image

    pom 依赖

    <?

    application.yaml

    server: port: 8001#mybatis 配置mybatis: type-aliases-package: com.zhou.springcloud.pojo config-location: classpath:mybatis/mybatis-config.

    mybatis-config.

    <?

    DeptMapper 接口

    package com.zhou.springcloud.mapper;import com.zhou.springcloud.pojo.Dept;import org.apache.ibatis.annotations.Mapper;import org.apache.ibatis.annotations.Param;import org.springframework.stereotype.Repository;import java.util.List;@Mapper@Repositorypublic interface DeptMapper { boolean addDept(Dept dept); Dept queryById(@Param("id") Long id); List<Dept> queryAll();}

    DeptMapper.

    <?

    DeptService 接口

    package com.zhou.springcloud.service;import com.zhou.springcloud.pojo.Dept;import java.util.List;public interface DeptService { boolean addDept(Dept dept); Dept queryById(Long id); List<Dept> queryAll();}

    DeptServiceImpl.java

    package com.zhou.springcloud.service;import com.zhou.springcloud.mapper.DeptMapper;import com.zhou.springcloud.pojo.Dept;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Service;import java.util.List;@Servicepublic class DeptServiceImpl implements DeptService{ @Autowired private DeptMapper deptMapper; @Override public boolean addDept(Dept dept) {  return deptMapper.addDept(dept); } @Override public Dept queryById(Long id) {  return deptMapper.queryById(id); } @Override public List<Dept> queryAll() {  return deptMapper.queryAll(); }}

    DeptController.java

    package com.zhou.springcloud.controller;import com.zhou.springcloud.pojo.Dept;import com.zhou.springcloud.service.DeptService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.PostMapping;import org.springframework.web.bind.annotation.RestController;import java.util.List;//提供Restful服务@RestControllerpublic class DeptController { @Autowired private DeptService deptService; @GetMapping("/dept/add")//方便此时的测试，这里用了Get，没有用Post public boolean addDept(Dept dept) {  return deptService.addDept(dept); } @GetMapping("/dept/get/{id}") public Dept getDept(@PathVariable("id") Long id){  return deptService.queryById(id); } @GetMapping("/dept/list") public List<Dept> queryAll(){  return deptService.queryAll(); }}

    6.启动类

    package com.zhou.springcloud;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;//启动类@SpringBootApplicationpublic class DeptProvider_8001 { public static void main(String[] args) {  SpringApplication.run(DeptProvider_8001.class,args); }}

    7.Run 测试

    访问 （测试成功！）

    访问 （测试成功！）

    访问 （测试成功！）

    查询数据库
    image

    1.创建子模块 springcloud-consumer-dept-80 (服务的消费者)

    pom 依赖

    <?

    application.yml

    server: port: 80

    ConfigBean.java

    package com.zhou.springcloud.config;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.web.client.RestTemplate;@Configuration //@Configuration 相当于 spring中 applicationContext.

    RestTemplate 部分源码：
    image

    DeptConsumerController.java

    package com.zhou.springcloud.controller;import com.zhou.springcloud.pojo.Dept;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Controller;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.ResponseBody;import org.springframework.web.client.RestTemplate;import java.util.List;@Controllerpublic class DeptConsumerController { //理解：消费者，不应该有 service 层 //RestTemplate.... 供我们直接调用就可以了，注册到Spring中 @Autowired private RestTemplate restTemplate; / private static final String REST_URL_PREFIX="http://localhost:8081"; @RequestMapping("/consumer/dept/add") @ResponseBody public boolean add(Dept dept){  return restTemplate.postForObject(REST_URL_PREFIX + "/dept/add", dept,Boolean.class); } @RequestMapping("/consumer/dept/get/{id}") @ResponseBody public Dept get(@PathVariable("id") Long id){  return restTemplate.getForObject(REST_URL_PREFIX + "/dept/get/" + id, Dept.class); } @RequestMapping("/consumer/dept/list") @ResponseBody public List<Dept> list(){  return restTemplate.getForObject(REST_URL_PREFIX + "/dept/list", List.class); }}

    DeptConsumer_80.java 启动类

    package com.zhou.springcloud;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplicationpublic class DeptConsumer_80 { public static void main(String[] args) {  SpringApplication.run(DeptConsumer_80.class,args); }}

    2.修改：springcloud-provider-dept-8001 它的 DeptController.java类的addDept()方法

    （否则，在下面测试中，使用浏览器url传参的方式来插入数据时，数据库中显示dname的值为null）
    image

     @PostMapping("dept/add") public boolean addDept(@RequestBody Dept dept){  return deptService.addDept(dept); }

    3.启动

    首先，启动服务的提供者 springcloud-provider-dept-8001 的启动类 DeptProvider_8001
    其次，启动服务的消费者 springcloud-consumer-dept-80 的启动类 DeptConsumer_80

    image

    4.Run 测试

    访问 src="https://img2020.cnblogs.com/blog/1155461/202104/1155461-20210409210746964-1397907664.png" alt="image" loading="lazy">

    访问 src="https://img2020.cnblogs.com/blog/1155461/202104/1155461-20210409210902626-1593780321.png" alt="image" loading="lazy">

    访问 src="https://img2020.cnblogs.com/blog/1155461/202104/1155461-20210409221602995-99550987.png" alt="image" loading="lazy">

    查看数据库

    image

    五、Eureka服务注册中心

    • Eureka 定义

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

    image

    在云中，应用程序不能总是知道其他服务的确切位置。一个服务注册中心，比如Netflix Eureka，或者一个sidecar解决方案，比如HashiCorp Consul，都会有所帮助。springcloud为流行的注册中心提供DiscoveryClient实现，比如Eureka、Consul、Zookeeper，甚至Kubernetes的内置系统。还有一个springcloud负载均衡器可以帮助您在服务实例之间小心地分配负载。

    官方介绍：https://spring.io/projects/spring-cloud-netflix
    image

    springcloudnetflix通过自动配置并绑定到Spring环境和其他Spring编程模型习惯用法，为Spring启动应用程序提供Netflix操作系统集成。通过一些简单的注释，您可以快速启用和配置应用程序中的常见模式，并使用经过测试的Netflix组件构建大型分布式系统。提供的模式包括服务发现（Eureka）、断路器（Hystrix）、智能路由（Zuul）和客户端负载平衡（Ribbon）

    • Dubbo 和 SpringCloud对比

    最大区别：Spring Cloud 抛弃了Dubbo的RPC通信，采用的是基于HTTP的REST方式。
    二者解决的问题域不一样：Dubbo的定位是一款RPC框架，而SpringCloud的目标是微服务架构下的一站式解决方案。

    DubboSpringCloud
    服务注册中心ZookeeperSpring Cloud Netfilx Eureka
    服务调用方式RPCREST API
    服务监控Dubbo-monitorSpring Boot Admin
    断路器不完善Spring Cloud Netfilx Hystrix
    服务网关无Spring Cloud Netfilx Zuul
    分布式配置无Spring Cloud Config
    服务跟踪无Spring Cloud Sleuth
    消息总栈无Spring Cloud Bus
    数据流无Spring Cloud Stream
    批量任务无Spring Cloud Task

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

    • Eureka基本的架构

    1.Springcloud 封装了Netflix公司开发的Eureka模块来实现服务注册与发现 (对比Zookeeper).
    2.Eureka采用了C-S的架构设计，EurekaServer作为服务注册功能的服务器，他是服务注册中心.
    3.系统中的其他微服务，使用Eureka的客户端连接到EurekaServer并维持心跳连接。（方便监控系统中各个微服务是否正常运行）

    image

    • 与Dubbo架构对比

    image

    • 构建 Eureka 代码示例

    1.创建子模块 springcloud-eureka-7001

    pom 依赖

    <artifactId>springcloud-eureka-7001</artifactId>	<!--导入依赖--><dependencies>	<!--spring-cloud-starter-netflix-eureka-server 依赖-->	<!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-netflix-eureka-server -->	<dependency>		<groupId>org.springframework.cloud</groupId>		<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>		<version>2.2.7.RELEASE</version>	</dependency>	<!--热部署-->	<dependency>		<groupId>org.springframework.boot</groupId>		<artifactId>spring-boot-devtools</artifactId>	</dependency></dependencies>

    application.yaml

    server: port: 7001# Eureka 部署eureka: instance: # Eureka服务端的实例名字 hostname: localhost client: # 表示是否向 Eureka 注册中心注册自己（这个模块本事是服务器，所以不需要） register-with-eureka: false # fetch-registry 如果为 false，则表示自己为注册中心，客户端的为 true fetch-registry: false # Eureka 监控页面 service-url:  #public static final String DEFAULT_URL = "http://localhost:8761/eureka/";  defaultZone: EurekaServer_7001.java
    package com.zhou.springcloud;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;/** * @Auther: zhouzhou * @Description: 启动之后，访问 */@SpringBootApplication@EnableEurekaServer //服务端的启动类，可以接受别人注册进来public class EurekaServer_7001 { public static void main(String[] args) {  SpringApplication.run(EurekaServer_7001.class,args); }}
    Run 测试
    报错信息：Caused by: java.lang.ClassNotFoundException: org.springframework.boot.context.properties.ConfigurationPropertiesBean
    image
    观察报错信息，得出有可能是版本冲突问题，解决办法是将 spring-cloud-starter-netflix-eureka-server 依赖的版本降为2.1.4.RELEASE
    【注意】：报错原因是版本问题，可以选择到官网查看版本是否一致，比如 SPRINGCLOUD的版本，我的父依赖用的是GREENWICH.SR1
    你如果用了HOXTON.SR10 甚至更新的，请自行查找对应的版本依赖。
    继续测试，Run 成功！
    image
    访问 src="https://img2020.cnblogs.com/blog/1155461/202104/1155461-20210410194335441-889072430.png" alt="image" loading="lazy">
    • Eureka 服务注册 信息配置以及自我保护机制
    配置 Eureka-client
    1.在上面创建的子模块 springlouc-provider-dept-8001 的 pom 中添加依赖
    <!--Eureka:spring-cloud-starter-netflix-eureka-client 依赖--><!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-netflix-eureka-client --><dependency>	<groupId>org.springframework.cloud</groupId>	<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>	<version>2.1.4.RELEASE</version></dependency>
    2.application.yaml 中添加设置
    # Eureka配置：配置注册中心地址eureka: client: service-url:  defaultZone: @EnableEurekaClient注解
    package com.zhou.springcloud;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.netflix.eureka.EnableEurekaClient;//启动类@SpringBootApplication@EnableEurekaClientpublic class DeptProvider_8001 { public static void main(String[] args) {  SpringApplication.run(DeptProvider_8001.class,args); }}
    4.先启动7001服务端，再启动8001客户端进行测试，访问监控页 产看结果如图，成功
    image
    5.修改 Eureka 上的默认描述信息
    # Eureka配置：配置注册中心地址eureka: client: service-url:  defaultZone: instance: instance-id: springcloud-provider-dept8001 # 修改eureka上的默认描述信息 prefer-ip-address: true
    查看：
    image
    6.配置关于服务加载的监控信息(springcloud-provider-dept-8001)
    没配置之前，访问：springcloud-provider-dept8001
    image
    跳出的页面如下：
    image
    配置服务加载的监控信息步骤如下：
    pom.
    <!--actuator完善监控信息--><dependency>	<groupId>org.springframework.boot</groupId>	<artifactId>spring-boot-starter-actuator</artifactId></dependency>
    application.yaml 中添加配置
    # info配置info: # 项目名称 app.name: zhouzhou-springcloud # 公司名称 company.name: blog.zhouzhou.com
    7.Run 再刷新页面，继续访问：springcloud-provider-dept8001，跳出页面如下
    image
    • EureKa自我保护机制
    默认情况下，如果Eureka Server在90秒内没有接收到某个微服务实例的心跳，会注销该实例。但是在微服务架构下服务之间通常都是跨进程调用，网络通信往往面临很多问题，比如微服务状态正常，网络分区故障，导致此实例被注销。
    固定时间内大量实例被注销，可能会严重威胁某个微服务架构的可用性，为了解决这个问题，Eureka开发了自我保护机制。
    Eureka Server在运行期间会去统计心跳失败比例在15分钟之内是否低于85%，如果低于85%，Eureka Server即进入自我保护机制。
    Eureka Server触发自我保护机制后，页面会出现提示：
    image
    Eureka Server进入自我保护机制，会出现以下几种情况：
    （1）Eureka不再从注册列表中移除因为长时间没收到心跳而应该过期的服务；
    （2）Eureka仍然能够接受新服务的注册和查询，但是不会被同步到其它节点上（即保证当前节点依然可用）；
    （3）当网络稳定后，当前实例新的注册信息会被同步到其它节点上；
    Eureka自我保护机制是为了防止误杀服务而提供的一种机制。当个别客户端出现心跳失联时，则认为是客户端的问题，剔除客户端；当Eureka 捕获到大量的心跳失败时，则认为可能是网络问题，进入自我保护机制；当客户端心跳恢复时，Eureka会自动退出自我保护机制。
    如果在保护期内刚好这个服务提供者非正常下线了，此时服务消费者就会拿到一无效的服务实例，则会调用失败。对于这个问题需要服务消费者要有一些容错机制，比如重试，断路器等。
    • 注册进来的微服务，获取其中的一些信息（团队开发）
    1.查看 EurekaDiscoveryClient 源码：
    image
    2.观察 DiscoveryClient 源码：
    image
    3.在 springcloud-provider-dept-8001 的 DeptController.java中添加 discovery() 方法
    //DiscoveryClient 可以用来获取一些配置的信息，得到具体的微服务 @Autowired private DiscoveryClient discoveryClient; /**  * 获取一些注册进来的微服务的信息  * @return  */ @GetMapping("dept/discovery") public Object discovery(){  //获取微服务列表清单  System.out.println("getServices()=>"+discoveryClient.getServices());  System.out.println("description()=>"+discoveryClient.description());  List<ServiceInstance> instances = discoveryClient.getInstances("SPRINGCLOUD-PROVIDER-DEPT");  for (ServiceInstance instance : instances) {   System.out.println(     instance.getHost()+"\t"+ //主机名称     instance.getPort()+"\t"+ //端口号     instance.getUri()+"\t"+ //uri     instance.getInstanceId() //服务id   );  }  return this.discoveryClient; }
    4.上面 discoveryClient.getInstances()的参数 ---> SPRINGCLOUD-PROVIDER-DEPT
    image
    5.主启动类中加入 @EnableDiscoveryClient 注解
    package com.zhou.springcloud;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客户端注解，在服务启动后自动向注册中心注册服务@EnableEurekaClient//@EnableDiscoveryClient 开启服务发现客户端的注解，可以用来获取一些配置的信息，得到具体的微服务@EnableDiscoveryClientpublic class DeptProvider_8001 { public static void main(String[] args) {  SpringApplication.run(DeptProvider_8001.class,args); }}
    6.Run 测试
    先启动 springcloud-eureka-7001 中的住启动类 EurekaServer_7001，
    再启动 springcloud-provider-dept-8001 中的主启动类 DeptProvider_8001，
    访问 一切正常
    image
    继续访问 src="https://img2020.cnblogs.com/blog/1155461/202104/1155461-20210412201952772-405214740.png" alt="image" loading="lazy">
    springcloud-provider-dept-8001 控制台输出：
    image
    • Eureka：集群环境配置
    整体结构如下：
    image
    1.新建 子模块springcloud-eureka-7002 和 springcloud-eureka-7003
    2.添加 pom 依赖 (与springcloud-eureka-7001相同)
    3.application.yml配置 (与springcloud-eureka-7001相同)
    (端口号用各自的 7001、7002和7003)
    4.主启动类 (与springcloud-eureka-7001相同)
    5.集群成员相互关联
    配置一些自定义本机名字，在C:\Windows\System32\drivers\etc找到本机hosts文件，在hosts文件最后加上，要访问的本机名称（默认是localhost）
    image
    127.0.0.1  eureka7001.com127.0.0.1  eureka7002.com127.0.0.1  eureka7003.com
    【注意】：修改hosts文件后一定要保存，如果遇到 修改hosts文件无权限的问题，参考下图配置：
    image
    6.修改 各自的 application.yml 的配置
    （1）设置各自的 服务端的实例名字（hostname）
    （2）设置各自的 集群（关联）
    springcloud-eureka-7001 的 application.yaml
    server: port: 7001# Eureka 部署eureka: instance: # Eureka服务端的实例名字 hostname: eureka7001.com client: # 表示是否向 Eureka 注册中心注册自己（这个模块本事是服务器，所以不需要） register-with-eureka: false # fetch-registry 如果为 false，则表示自己为注册中心，客户端的为 true fetch-registry: false # Eureka 监控页面 service-url:  # public static final String DEFAULT_URL = "http://localhost:8761/eureka/";  # 单机：defaultZone:  # 集群（关联）：7001关联 7002、7003  defaultZone: 的 application.yaml
    server: port: 7002eureka: instance: # Eureka服务端的实例名字 hostname: eureka7002.com client: register-with-eureka: false fetch-registry: false service-url:  # 集群（关联）：7002关联 7001、7003  defaultZone: 的 application.yaml
    server: port: 7003eureka: instance: # Eureka服务端的实例名字 hostname: eureka7003.com client: register-with-eureka: false fetch-registry: false service-url:  # 集群（关联）：7003关联 7001、7002  defaultZone: springcloud-provider-dept-8001 的yaml配置文件，修改 Eureka 的配置：配置服务注册中心地址
    image
    # Eureka配置：配置注册中心地址eureka: client: service-url:  defaultZone: instance: instance-id: springcloud-provider-dept8001 # 修改eureka上的默认描述信息 prefer-ip-address: true
    8.模拟集群搭建完毕。（可以把一个项目挂载到三个服务器上了）
    测试，访问 src="https://img2020.cnblogs.com/blog/1155461/202104/1155461-20210412220752693-844823281.png" alt="image" loading="lazy">
    测试，访问 src="https://img2020.cnblogs.com/blog/1155461/202104/1155461-20210412221355001-1976826388.png" alt="image" loading="lazy">
    测试，访问 src="https://img2020.cnblogs.com/blog/1155461/202104/1155461-20210412221410892-1748018904.png" alt="image" loading="lazy">



     
     
     

       
    原文转载：http://www.shaoqun.com/a/680735.html
    跨境电商：https://www.ikjzd.com/
    心怡科技：https://www.ikjzd.com/w/1327
     
    promotion：https://www.ikjzd.com/w/127
     
    本文主要介绍SpringCloud的入门一、SpringCloud的五大组件（需要牢牢记住他们，现在混个眼熟，下面会详细介绍。）自学参考文档：SpringCloud官方文档（汉化版）：https://springcloud.cc/spring-cloud-dalston.htmlSpringCloud中国社区id="二、什么是微服务">二、什么是微服务Spring官网：h
    勤商网：https://www.ikjzd.com/w/2219
    环球华网：https://www.ikjzd.com/w/1063
    阿里巴巴 批发：https://www.ikjzd.com/w/1084
    亚马逊加入CBP，入境美国的包裹将严审？：https://www.ikjzd.com/home/114573
    口述爱爱好爽细节过程 把腿抬高我要添你下面：http://lady.shaoqun.com/a/248104.html
    男友和我姐一见钟情后不能自控：http://lady.shaoqun.com/a/270867.html
发帖者 时间：

没有评论:

发表评论

订阅： 博文评论 (Atom)