SpringCloudAlibaba

简介

Spring Cloud Alibaba 致力于提供微服务开发的一站式解决方案。此项目包含开发分布式应用微服务的必需组件，方便开发者通过 Spring Cloud 编程模型轻松使用这些组件来开发分布式应用服务。

依托 Spring Cloud Alibaba，您只需要添加一些注解和少量配置，就可以将 Spring Cloud 应用接入阿里微服务解决方案，通过阿里中间件来迅速搭建分布式应用系统。

主要功能描述

[图片上传失败...(image-f2053d-1641891798976)][图片上传失败...(image-ffcaa7-1641891798976)]

毕业版本和组件版本依赖关系[图片上传失败...(image-2f955c-1641891798976)][图片上传失败...(image-1786d1-1641891798976)]

组件

Sentinel：把流量作为切入点，从流量控制、熔断降级、系统负载保护等多个维度保护服务的稳定性。

Nacos：一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。

RocketMQ：一款开源的分布式消息系统，基于高可用分布式集群技术，提供低延时的、高可靠的消息发布与订阅服务。

Dubbo：Apache Dubbo™ 是一款高性能 Java RPC 框架。

Seata：阿里巴巴开源产品，一个易于使用的高性能微服务分布式事务解决方案。

Alibaba Cloud OSS: 阿里云对象存储服务（Object Storage Service，简称 OSS），是阿里云提供的海量、安全、低成本、高可靠的云存储服务。您可以在任何应用、任何时间、任何地点存储和访问任意类型的数据。

Alibaba Cloud SchedulerX: 阿里中间件团队开发的一款分布式任务调度产品，提供秒级、精准、高可靠、高可用的定时（基于 Cron 表达式）任务调度服务。

Alibaba Cloud SMS: 覆盖全球的短信服务，友好、高效、智能的互联化通讯能力，帮助企业迅速搭建客户触达通道。

微服务注册中心Nacos搭建

[图片上传失败...(image-69fcf8-1641891798976)]

服务的提供者 & 服务的消费者是相对的概念。

比如用户服务是订单服务的消费者，订单服务是用户服务的提供者。

但是对于 订单服务---->库存服务，那么订单服务就成为服务消费者。

[图片上传失败...(image-482120-1641891798976)]

Feign

Feign是Netflix公司开源的轻量级rest客户端，使用Feign可以非常方便的实现Http 客户端。Spring Cloud引入Feign并且集成了Ribbon实现客户端负载均衡调用。

生产者

主程序

@EnableDiscoveryClient//自动注册服务中心
@SpringBootApplication//springboot自动装配
@EnableFeignClients//feign启动
public class FirstApplication {
    public static void main(String[] args) {
        SpringApplication.run(FirstApplication.class, args);
        System.out.println("=FirstApplication启动成功=");

    }
}

controller 一个普通的接口

@RestController
@RequestMapping("/first")
@RefreshScope//nacos配置改变，启动刷新
public class testController {

    @Value("${app.url}")
    private String url;

    @GetMapping("/test")
    public String testFirst() {
        return "fisrt_test";
    }


    @GetMapping("/test2")
    public String testFirst2() {
        return "fisrt_test2" + url;
    }


}

消费者

主程序

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

        System.out.println("=SecondApplication启动成功=");
    }
}

feign接口

//消费者 通过feign调用 fisrt提供者服务端
@Component
@FeignClient(name = "cloud-base-first")//定义一个restHttp风格客户端
public interface IFirstTest {

    @GetMapping("/fisrt/test")
    String testFirst();

}

controller 消费者 调用 生产者的接口

@RestController
@RequestMapping("/second")
public class secondController {

    @Autowired
    private IFirstTest firstTest;


    @GetMapping("/test")
    public String testSecond() {

        String s = firstTest.testFirst();

        return "second服务调用first服务接口：" + s;
    }

    @GetMapping("/test2")
    public String test2() {
        return "second2";
    }


}

启动 生产者和消费者，调用消费者seond/test

测试，消费者报错

[图片上传失败...(image-cfe67f-1641891798976)]

大致意思：定义的接口，我这里就是IFirstTest接口需要有一个controller，与URL映射。 大家都知道，springmvc可以根据URL可以找到对应的controller。

改动的

消费者 feign接口

//消费者 通过feign调用 fisrt提供者服务端
@FeignClient(name = "cloud-base-first")//定义一个restHttp风格客户端
@RequestMapping("/first")
public interface IFirstTest {

    @RequestMapping( value = "/test", method = RequestMethod.GET)
    String testFirst();

}

调用成功 http://localhost:9001/second/test

[图片上传失败...(image-98a04a-1641891798976)]

注意：@FeignClient(name = "cloud-base-first") 深入了解

name：指定FeignClient的名称，如果项目使用了Ribbon，name属性会作为微服务的名称，用于服务发现
url: url一般用于调试，可以手动指定@FeignClient调用的地址
decode404:当发生http 404错误时，如果该字段位true，会调用decoder进行解码，否则抛出FeignException
configuration: Feign配置类，可以自定义Feign的Encoder、Decoder、LogLevel、Contract
fallback: 定义容错的处理类，当调用远程接口失败或超时时，会调用对应接口的容错逻辑，fallback指定的类必须实现@FeignClient标记的接口
fallbackFactory: 工厂类，用于生成fallback类示例，通过这个属性我们可以实现每个接口通用的容错逻辑，减少重复的代码
path: 定义当前FeignClient的统一前缀，当我们项目中配置了server.context-path,server.servlet-path时使用

fallback 可以定义一个熔断类，处理服务调异常的回调service

消费者feign,fallback = Hysitx.class

//消费者 通过feign调用 fisrt提供者服务端
@FeignClient(name = "cloud-base-first", fallback = Hysitx.class)//定义一个restHttp风格客户端
@RequestMapping("/first")
public interface IFirstTest {

    @RequestMapping( value = "/test2", method = RequestMethod.GET)
    String testFirst();

}

熔断类

/**
 * @description:熔断类 处理调用错误失败回调函数
 */
public class Hysitx implements IFirstTest  {
    @Override
    public String testFirst() {
        System.out.println("消费者调用生产服务失败");
        return null;
    }
}

网关GateWay(鉴权请求)

相关术语：

Route（路由）：网关的基本构建块。由一个 ID，一个目标 URI，一组断言和一组过滤器定义。如果断言为真，则路由匹配。

Predicate（断言）：这是一个 Java 8 的 Predicate。输入类型是一个 ServerWebExchange。我们可以使用它来匹配来自 HTTP 请求的任何内容，例如 headers 或参数。

Filter（过滤器）：这是org.springframework.cloud.gateway.filter.GatewayFilter的实例，我们可以使用它修改请求和响应。

API 网关出现的原因是微服务架构的出现，不同的微服务一般会有不同的网络地址，而外部客户端可能需要调用多个服务的接口才能完成一个业务需求，如果让客户端直接与各个微服务通信，会有以下的问题：

（1）客户端会多次请求不同的微服务，增加了客户端的复杂性。

（2）存在跨域请求，在一定场景下处理相对复杂。

（3）认证复杂，每个服务都需要独立认证。

（4）难以重构，随着项目的迭代，可能需要重新划分微服务。例如，可能将多个服务合并成一个或者将一个服务拆分成多个。如果客户端直接与微服务通信，那么重构将会很难实施。

以上这些问题可以借助 API 网关解决。API 网关是介于客户端和服务器端之间的中间层，所有的外部请求都会先经过 API 网关这一层。也就是说，API 的实现方面更多的考虑业务逻辑，而安全、性能、监控可以交由 API 网关来做，这样既提高业务灵活性又不缺安全性

优点：

• 性能强劲：是第一代网关Zuul的1.6倍
• 功能强大：内置了很多实用的功能，例如转发、监控、限流等
• 设计优雅，容易扩展

缺点：

• 其实现依赖Netty与WebFlux，不是传统的Servlet编程模型，学习成本高
• 不能将其部署在Tomcat、Jetty等Servlet容器里，只能打成jar包执行
• 需要Spring Boot 2.0及以上的版本，才支持

基本使用

pom

        </dependency>
<!--        网关-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-gateway</artifactId>
        </dependency>

启动类

@SpringBootApplication
@EnableDiscoveryClient
public class GatewayApplication {
    public static void main(String[] args) {
        SpringApplication.run(GatewayApplication.class, args);
        System.out.println("=GatewayApplication启动成功=");
    }
}

启动bug

</parent>
<modelVersion>4.0.0</modelVersion>

<artifactId>cloud_base_third</artifactId>

<properties>
    <spring.cloud.alibaba.version>2.2.5.RELEASE</spring.cloud.alibaba.version>
    <spring.cloud.version>Hoxton.SR3</spring.cloud.version>
    <java.version>1.8</java.version>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <log4j.version>2.15.0</log4j.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>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-alibaba-dependencies</artifactId>
            <version>${spring.cloud.alibaba.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

<dependencies>

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter</artifactId>
    </dependency>
    <!--nacos配置中心-->
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
    </dependency>
    <!--nacos注册中心-->
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>

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

    <dependency>
        <groupId>log4j</groupId>
        <artifactId>log4j</artifactId>
        <version>1.2.16</version>
    </dependency>
</dependencies>

</project>

**配置**

```yaml
server:
  port: 8081


spring:
  application:
    name: cloud-base-gateway
  cloud:
    nacos:
#      config:
#        server-addr: 127.0.0.1:8848
#        file-extension: yaml
#        refresh: true
#        group: gzsz
#        namespace: 51c02bce-53a2-4a03-8a62-e378becc4638
      discovery:
        server-addr: 127.0.0.1:8848
        group: gzsz
        namespace: 51c02bce-53a2-4a03-8a62-e378becc4638
    gateway:
      routes:
        - id: cloud-base-first # 路由的id,没有规定规则但要求唯一,建议配合服务名
          uri: lb://cloud-base-first  #匹配后提供服务的路由地址
          predicates:
            - Path=/** # 断言，路径相匹配的进行路由


ribbon:
  ReadTimeout: 60000
  ConnectTimeout: 60000

app:
  url: "Fsdf"

启动成功

[图片上传失败...(image-922166-1641891798976)]

测试

直接访问消费者

[图片上传失败...(image-fa94f8-1641891798976)]

通过网关访问

[图片上传失败...(image-69aa06-1641891798976)]

网关进阶使用-网关鉴权

路由配置

gateway:
      routes:
        - id: cloud-base-first # 路由的id,没有规定规则但要求唯一,建议配合服务名
          uri: lb://cloud-base-first  #匹配后提供服务的路由地址
          predicates:
            - Path=/first/** # 断言，路径相匹配的进行路由

        - id: cloud-base-second # 路由的id,没有规定规则但要求唯一,建议配合服务名
          uri: lb://cloud-base-second  #匹配后提供服务的路由地址
          predicates:
            - Path=/second/** # 断言，路径相匹配的进行路由

问题

当我们在未登录状态下点击“购买课程”按钮时，会显示“未知错误”，查看trade微服务控制台，发现控制台中报错，提示JWT为空，无法鉴权。

解决方案

微服务网关中添加自定义全局过滤器，统一处理需要鉴权的服务

鉴权逻辑描述

1. 当客户端第一次请求服务时，服务端对用户进行信息认证（登录）
2. 认证通过，将用户信息进行加密形成token，返回给客户端
3. 作为登录凭证以后每次请求，客户端都携带认证的token
4. 服务端对token进行解密，判断是否有效

1. [图片上传失败...(image-ddc56c-1641891798976)]

对于验证用户是否已经登录鉴权的过程可以在网关统一检验。检验的标准就是请求中是否携带token凭证以及token的正确性。

下面的我们自定义一个GlobalFilter，去校验所有的请求参数中是否包含“token”，如何不包含请求

参数“token”则不转发路由，否则执行正常的逻辑。