从零开始搭建公司SpringCloud架构技术栈(史上最细),这套架构绝...

程序员闪充宝

共 11867字,需浏览 24分钟

 ·

2022-01-06 10:14

efb5ba7c4b897a9e10d53d3fb3913e84.webp

来自:CSDN,作者:Anakki

链接:https://blog.csdn.net/qq_29519041/article/details/85238270

一、微服务基础

1.什么是SpringCloud?

SpringCloud官网:https://spring.io/projects/spring-cloud(个人建议是用谷歌浏览器访问官网打开中文翻译粗略把官网读一遍)

个人理解:

以前的服务器就好像,一个会语数外全能的老师,为学生提供服务,这个老师生病了,那全校停课。现在微服务流行后,学校有了数学教研组,语文教研组,外语教研组,每个教研组有一群老师具体负责某科的教学,缺了谁,学校都照样运转。

而这个变化中,那些改变历史的程序员就是把一个服务器中的众多服务,或好几台服务器中的众多服务,分类出来,解耦合出来,把他们类似的功能交给同一个集群来做,把互相耦合在一起的功能剥离出来,按业务,按功能来把他们作为一个个微服务放在服务器上,而这个服务器就只提供一个服务,或较少的服务。让一个超大的服务逻辑,解耦合为一个个小服务,均匀的分布在各自的服务器中。微服务就微在这。

每个教研组就是一个微服务集群。他们提供同样的服务,而注册中心Eureka就是这个存放这个教研组老师名单的地方,学生们想先访问这个注册中心获取教师名单,然后根据相应的负载方法去访问各自老师。不至于让集群中某一老师累死也不至于让某一老师闲死。

而Zuul网关呢,就是学校的门卫,某些学生来学校找谁,它负责指引(路由),并且通过一些非常简单的配置,达到阻拦一些人进入(身份验证),或者控制想学数学的人只能去数学教研组,不能去核能教研组学怎么造原子弹(权限验证)。

那Hystrix熔断器呢,可以把它当成学校的志愿者,当一个教研组集体罢课后,学生找不到老师了,这些志愿者及时的告诉来访问的学生,相应的结果,异常信息等,免得大量的学生在学校等待,这些志愿者赶快把这些等待的学生梳理出去,学生一直在学校等待,那其他需要学生的学校,也会等待学生,最后造成大面积的学校瘫痪。这里学生我们看成一个个请求。熔断器就是把某事故的蔓延即使熔断了。

当然这些组件也是微服务需要注册到Eureka注册中心

那SpringCloud就可以看成是这个学校了。众多上面提到的组件相当于都是这个学校的各职能部门。

二、微服务的搭建

ps:  博主基于Maven+idea搭建。

另外SpringCloud需要基于springboot搭建。

引入Spring Boot相关依赖:这里的springboot用的是1.5.7版本;引入Spring Cloud相关依赖:这里为 Edgware.SR5

2.1 工程初始化配置

在Idea中创建工程:File -> New ->Project

198663dd889fae33b0021ceee279b917.webp

点击   Empty Project -> Next

ecf73b913bbf5af59a7f964e5010c38c.webp

项目命名 -> 项目位置

3273bdb31d02f10706ae3ef1cd71b19c.webp

选择模组 modules ->next

60f817bb2e76ff036f73320eaddcc651.webp

进入新的窗口后,开始配置Maven,打开设置 setting

280a68128bac5fbce9b65c12d4b7899f.webp

116f699aa8d5a6d8a46e037dd30c923a.webp

因为我之前做过配置,因此只需要改变框1的路径,如第一次配置需要自己找到你maven放置的位置,以及settings.xml,repository的位置,实在不会的百度  maven集成idea

295c675148468735cb2994cbd969c88c.webp

3个框选择完毕后点击 ok

接下来新建module

abc6080ef60f0910a2362e5a4239a093.webp

这里可能会出现加载不出archetype list的问题

e69c78f1bc9f57bc3b9c204537a62be6.webp

用了网上的所有解决办法花了3个小时解决都没用,重启之后竟然可以了····你敢信?????小时候网吧网管的至理名言都忘了!!重启一下嘛!!

出来之后 选择quickstart ->下一步

674da8be483c225330ac87888b294e5f.webp

名字自己想 想好后,复制一下你想好的  ArtifactId点击Next,groupId为组织名 也是自己想一个,一般为公司网址反写。

bed7f5db047e3910123f92dd9be8f174.webp

粘贴后下一步

63360f4d29f7bd0bbd4334f1f5d440b9.webp
7d61b7093067184de00c7f8a7a818be7.webp

提供注册服务的服务器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.yun</groupId>
  <artifactId>springcloud-eureka-server</artifactId>
  <version>1.0-SNAPSHOT</version>
 
  <name>springcloud-eureka-server</name>
  <!-- FIXME change it to the project's website -->
  <url>http://www.example.com</url>
 
  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <maven.compiler.source>1.7</maven.compiler.source>
    <maven.compiler.target>1.7</maven.compiler.target>
  </properties>
 
  <!--引入springboot-parent父项目-->
  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.7.RELEASE</version>
  </parent>
 
  <dependencies>
    <!--引入springcloud的euekea server依赖-->
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    </dependency>
 
  </dependencies>
 
 
  <!--指定下载源和使用springcloud的版本-->
  <dependencyManagement>
    <dependencies>
      <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-dependencies</artifactId>
        <version>Edgware.SR5</version>
        <type>pom</type>
        <scope>import</scope>
      </dependency>
    </dependencies>
  </dependencyManagement>
</project>

点击Import Changes

ee0c36413bb8ae5d9fa49ab46e1a71e5.webp

等待右下角加载springcloud的依赖

028ae06abd82ab467346471b41af92be.webp

2.2 Springboot的搭建 以及提供注册服务 的 服务配置

创建resources文件夹

a15dd55ddfa68999ea9655e2ae775a8c.webp

并设置作为资源根目录,之后文件变成这样874524a4c3094da7f81a57563fc39820.webp之后文件夹变成有黄色的横杠

cc8ce662f094b3d2cfc664016f3dc2ad.webp

在resources下新建文件,文件名为application.yml    (对是yml  不是xml ,博主第一次学习时,还以为是其他博主打错了,踩了一个小坑)

eb5135a457cbb987589634759cd83fa5.webp

配置yml,注意:如果只配置前两行端口号信息会报错

4b2026ecc5d9e44bfb0f336c9f0d2b6e.webp
server:
  port: 8700 # 端口自己决定
  
# 指定当前eureka客户端的注册地址,也就是eureka服务的提供方,当前配置的服务的注册服务方
eureka:
  client:
    service-url:
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka
    register-with-eureka: false #自身 不在向eureka注册
    fetch-registry: false  #启动时禁用client的注册
  instance:
    hostname: localhost
 
#指定应用名称
spring:
  application:
    name: eureka-server

知识补充:

c75b3001cb8efc0c0254d43ae9ba2e07.webp

开发springboot的入口类 EurekaServerApplication.java

0c67a1d8c106b71bf3626372d2b4f004.webp

EurekaServerApplication.java

package com.yun;
 
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
 
@SpringBootApplication
@EnableEurekaServer //当前使用eureka的server
public class EurekaServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaServerApplication.class,args);
    }
}

右键运行当前类:

8b43958ea9056e4ef7f6b37056c4495d.webp

运行成功console画面

594d7d5bb367cffbdc8df20a98c7aa67.webp

尝试进入eureka管理界面 端口号为 yml里配置的(端口号自己设置 需要大于公用和保留的端口号)1024~65535

一般我喜欢设置为 8700到8800之间

如下  管理界面已经可以登录了。

f809ee18d3f6a82bfcc07444beae04a1.webp

2.3 客户端client  提供真正服务的角色的配置, 它提供服务 在 服务注册方server (注册中心)进行注册

同样新建module,选择quickstart点击下一步

7d83ccff4c6da0fe1b2a0046239f7428.webp

两个位置 置空

4088ad6511559b1673109c158038c08b.webp

取名 下一步

6254a85c67063c489bdf81e54bd816b5.webp

注意这里要在根目录springcloud 下创建模组,content root 会默认在之前的模组之下创建模组 这样创建模组会出现问题并报错

263a1ffb6e61bb40bf15e154d4560125.webp

推荐这种配置方法  在content root下springcloud后改名字   如下图配置点下一步,红框处一般默认为上一个模组的文件目录名,需要改为你的模组名

7737ab40ec954ffbf462c17a44e89e9f.webp

成功后为并列状态,如不为并列或报错请重新配置

5308b2f0a54fd59e8dcc6acb35d5b9fa.webp

配置servicesupport的pom,与server的pom配置相同,只需要把第一个pom的1的方框处server改为client

和第一个微服务同理 我们需要配置入口类 pom.xml  application.yml,因为是服务提供者,这里还需编写服务类controller

application.yml

server:
  port: 8701 # 服务提供方
 
# 指定当前eureka客户端的注册地址,
eureka:
  client:
    service-url:
      defaultZone: http://${eureka.instance.hostname}:8700/eureka
  instance:
    hostname: localhost
 
#当前服务名称
spring:
  application:
    name: eureka-service

pom.xml:

3e5e9bb36b5c8f5fe4f875a6aaca9aa3.webp

编写所提供的 服务controller:

package com.yun;
 
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
 
@RestController
@RequestMapping("/Hello")
public class Controller {
    @RequestMapping("/World")
    public String helloWorld(String s){
        System.out.println("传入的值为:"+s);
        return "传入的值为:"+s;
    }
}

入口类 并运行此微服务:

package com.yun;
 
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
 
@SpringBootApplication
@EnableDiscoveryClient//代表自己是一个服务提供方
public class EurekaServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaServiceApplication.class,args);
    }
}

右键入口类名点击 run(当然开启此服务时需要先开启server服务 就是我们第一个编写的微服务)

e84711b98a6e8f5f0c3133411fbd321f.webp

此时再进入服务注册的页面 http://localhost:8700/

可以看见服务提供者已被注册进 服务注册者

2148425b4136ce3dc0abe039982b894a.webp

在直接访问一下服务提供者的 网络位置http://localhost:8701/Hello/World?s=小沛

我们已经看见 可以访问了,证明此微服务可用。

12cafd8e73659d28e6d751dcf3ef5e40.webp

但是我们一般不直接调用所需的微服务,而是经过提供注册服务的服务器server,获取所需的服务提供者列表(为一个列表,此列表包含了能提供相应服务的服务器),他们也许是个集群,因此server会返回一个 ip+端口号的表,服务消费者通过相应算法访问这表上的不同服务器,这些服务器提供的是相同的服务,这种在服务消费者一方挑选服务器为自己服务的方式是一种客户端的负载均衡。

目前博主所知的有 轮询和随机两种方式 访问这些服务器,轮询就是循环的意思,假如有3台服务器,访问方式就是1,2,3,1,2,3,1,2,3····,随机就是随机,回想一下random方法,一种无规律的方式。这两种方式都是为了,访问每个服务器的可能性尽量的相同。还有权重负载这种算法,意思就是 根据服务器负载能力的分配相应的服务。能力大的干得多。能力小的干得少。

2.4 服务的调用方式

第一种调用方式:restTemplate+ribbon

c085b68db40c9893516a4c5969b0dc6a.webp5367395f6d3aabf86ad510f64ac91a09.webp

第二种调用方式:feign

3217ef2d2d2bceb5e694221996b1de2f.webp

2.4.1 restTemplate+ribbon

ribbon是一种负载均衡的客户端,它是什么呢?请详读https://www.jianshu.com/p/1bd66db5dc46

可以看见其中的一段如下:

而客户端负载均衡和服务端负载均衡最大的不同点在于上面所提到服务清单所存储的位置。在客户端负载均衡中,所有客户端节点都维护着自己要访问的服务端清单,而这些服务端端清单来自于服务注册中心,比如上一章我们介绍的Eureka服务端。同服务端负载均衡的架构类似,在客户端负载均衡中也需要心跳去维护服务端清单的健康性,默认会创建针对各个服务治理框架的Ribbon自动化整合配置,比如Eureka中的org.springframework.cloud.netflix.ribbon.eureka.RibbonEurekaAutoConfiguration,Consul中的org.springframework.cloud.consul.discovery.RibbonConsulAutoConfiguration。在实际使用的时候,我们可以通过查看这两个类的实现,以找到它们的配置详情来帮助我们更好地使用它。

接下来我们来搭建基于ribbon的客户端,他用于消费服务。

同理先搭建springboot的环境

与之前搭建servicesupport不同的是:

第一步:现在pom中需要在dependencies中添加ribbon依赖

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-ribbon</artifactId>
        </dependency>

第二步:yml如下配置:

server:
  port: 8702 # 服务消费方
 
# 指定当前eureka客户端的注册地址,
eureka:
  client:
    service-url:
      defaultZone: http://${eureka.instance.hostname}:8700/eureka
  instance:
    hostname: localhost
 
#当前服务名称
spring:
  application:
    name: eureka-consumer

服务的消费方依旧需要在注册方8700端口去注册。配置当前服务消费方的端口8072,名字为eureka-consumer

第三步:依旧需要启动类,因为它是一个springboot的架构:

package com.yun;
 
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
 
 
@SpringBootApplication
@EnableDiscoveryClient //当前使用eureka的server
public class EurekaConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaConsumerApplication.class,args);
    }
}
2a988df6da450d6f4c8860e0d8207f57.webp

如上图:

我们需要一个controller类来编写ribbon的代码。

package com.yun.controller;
 
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
 
@RestController
@RequestMapping("/Hello")
class ConsumerController {
    @Autowired
    private LoadBalancerClient loadBalancerClient;
    @Autowired
    private RestTemplate restTemplate;
    @RequestMapping("/Consumer")
    public String helloWorld(String s){
        System.out.println("传入的值为:"+s);
        //第一种调用方式
        //String forObject = new RestTemplate().getForObject("http://localhost:8071/Hello/World?s=" + s, String.class);
 
        //第二种调用方式
        //根据服务名 获取服务列表 根据算法选取某个服务 并访问某个服务的网络位置。
        //ServiceInstance serviceInstance = loadBalancerClient.choose("EUREKA-SERVICE");
        //String forObject = new RestTemplate().getForObject("http://"+serviceInstance.getHost()+":"+serviceInstance.getPort()+"/Hello/World?s="+s,String.class);
 
        //第三种调用方式 需要restTemplate注入的方式
        String forObject = restTemplate.getForObject("http://EUREKA-SERVICE/Hello/World?s=" + s, String.class);
        return forObject;
    }
}

我们常用第三种调用方式。

第一种是直接调用:不经过注册中心那服务列表,直接访问的servicesupport

第二种:是根据服务名选择调用,如上图需要做如下注入

@Autowired
    private LoadBalancerClient loadBalancerClient;

如上图代码中第二种调用方法的代码所示。

用服务名去注册中心获取服务列表,当前客户端底层会做随机算法的选取获得服务并访问。

第三种需要一个@Bean的注解自动注入并直接调用restTemplate对象调用服务。底层调用模式与第二种调用方式一样。如下:

package com.yun.beans;
 
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;
 
@Configuration
public class Beans {
    //管理简单对象
    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
    }
}

@Bean注解告诉工厂,这个方法需要自动注入。

@LoadBalanced,表示需要做负载匀衡。

然后如controller中一样注入一下restTemplate,并且使用他,区别是可以直接使用服务名访问了

String forObject = restTemplate.getForObject("http://EUREKA-SERVICE/Hello/World?s=" + s, String.class);

开始测试:

1.运行server的启动类:d45bd6558b61f22ae936b54f82ebe755.webp

2.运行servicesupport的启动类:94893af9b3011648fb41a30a3941627f.webp

3.运行serviceconsume的启动类:0cea5e195b527e0f08cbc29a4fcbe37c.webp

浏览器访问:2f66db8d107d6507e787fe9d750cd4f2.webp

8072为服务消费方的端口

访问方法解析:

  • 访问服务消费方@RequestMapping指定的路径及消费方的端口来访问消费方的controller

  • controller根据服务名去server方获取获取服务列表,获取服务列表后根据随机的模式负载匀衡后去选择服务地址去访问servicesupport:如下图

80a8aa5aae8decb7c9a59b231b7a290b.webp

----------    更新于星期日2018年12月30日 20:02    待续....---------

待续...

2.5   Eureka server的高可用配置

点击下图配置

0eea2b7651d398eff3004e902144c30d.webp

74f6c2843d0ed1b6e2624fb4705d8e55.webp

接下来配置三台01,02,03的虚拟机参数

01:8699

6aed7c4f411705a2b0ec41480b69df70.webp

02:8698

77f600264351e5eef92a5e3664ca65f4.webp

03:8697

f37e113716bc81068433e0bbff01e829.webp

之后点ok保存,可看见多出三个启动项

597911e954f329ddc687af6da9300637.webp

接下来分别改注册端口号,defaultZone分别启动三个启动项

打开server的yml配置,删掉前两行端口号配置(图中有错,请把instance 和hostname那两行删掉)

cf8456764f901fa34fdf7dc297dbe64f.webp

配置好yml后点击启动

56fe5947bf6cd56355f7d2c2a7e068c0.webp

同理,我们再次改动端口号为8699和8697后,把启动项改为02,之后启动(图中有错,请把instance 和hostname那两行删掉)

a0064b65c64360416f82208b5f5603c5.webp

同理把yml端口改为8699 和 8698后,把启动项改为03,之后启动(图中有错,请把instance 和hostname那两行删掉)

f15cc55d1c130320a3c9352b9cf8c17b.webp

启动后分别访问三个01,02,03端口,已经可以看见可以访问了。

9d9df4bcd0cd8e73971f063fe8f5d9ae.webpc571d73fcdc54ac622d282f447b5331b.webp1df1bc3901d84b1143b5d0ed06fb0aa3.webp

打开服务提供方的yml配置如下,把端口号改为三个中其中的一个。

0a0380d65ac02d4d0c39737f3a9efc64.webp

启动服务提供方之后,再次访问三个01,02,03我们会发现

重点:即使服务提供方只注册了一个端口号8699,但是另外两个端口号,也能感知到服务提供方8701的存在了。如下图:

c743a84a4150d68cccc39fb52091e180.webp

cdee5f20269c6d72ed35c1f14707d887.webp

88be0eda54009c06cfdd59c4e00ad770.webp

接下来像服务消费方中添加服务注册者的端口号,这样在server挂掉任何一个的时候,都能有其他的server也能获取服务列表

802059317967fbd8b86cd5389b89d3bd.webp

访问以下服务消费方,发现可以通过消费方调用server服务列表并且访问service了

22fc7f1589b5fb2a71fdeebd0f170706.webp

我么随便关闭其中两个server的副本,重启serviceconsume,再进行访问。必须重启serviceconsume才能清空缓存,清掉consume里面有的服务列表。

f926a44a6d012f844254d637a4f94de8.webp

上图发现即使关闭两台server后依旧可以访问,如下图,依旧从server中获取了服务列表,从中也能看见之后不用再获取服务列表了。

f926a44a6d012f844254d637a4f94de8.webp

但是当我们关掉所有server后。访问还是没问题,因为缓存了服务列表。9b6bc4cace5d71191d6f726899fe99d7.webp

但是让我们来重启一下serviceconsume,再访问就不行了。

15194b6bd59314b67250f009dcb1624e.webp

综上我们就完成了springcloud中server的高可用配置

搭好了别忘点赞呀~

往期推荐

SpringBoot+ Dubbo + Mybatis + Nacos +Seata整合来实现Dubbo分布式事务,绝了!

最详细的 Intellij IDEA 中使用 Debug 教程

SpringBoot 定时任务动态管理通用解决方案

Spring Cloud与Dubbo优缺点详解

12 个适合做外包项目的开源后台管理系统

整理了35个快速开发平台,前后端都有 ,接私活拿来即用,非常方便!

浏览 44
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报
评论
图片
表情
推荐
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报