课程安排

• 了解神领物流
• 了解物流行业
• 了解项目的技术架构
• 了解项目的业务功能
• 项目功能演示
• 搭建开发环境
• 基于现有代码进行bug修复
• 阅读已有的代码

  1、场景说明

  现在的你，已经学习了目前最主流的系统架构技术《微服务技术栈》，并且呢也拿到了满意的offer，入职了一家物流公司，公司名叫：神领物流公司。

  现在你的心情还是比较复杂的，既开心又担心，开心是这个offer你很满意，担心的是，听朋友说物流行业的项目业务非常复杂，技术涉及的也比较多，而自己从来没有接触过物流项目，就担心自己能不能Hold得住？万一……

  不用过于担心，本套课程就是带着你一点点的了解项目，站到一个新人的角度来看待这个项目，代码从哪里拉取？开发规范是什么？有哪些环境？项目业务是什么样的？ ……

  

  2、神领物流是什么？

  神领物流是一个基于微服务架构体系的**【生产级】**物流项目系统，这可能是目前你能学习到的最接近企业真实场景的项目课程，其业务完整度、真实度、复杂度会让你感到惊讶，在这里你会学习到最核心的物流调度系统，也可以学习到在复杂的微服务架构体系下开发以及相关问题的解决。学完后你的收获会很“哇塞”。

  2.1、公司介绍

  公司从2019年开始业务快速扩张，网点数量从138家扩展至540家，车辆从170台增长到800台。同时，原有的系统非常简单，比如车辆的调度靠人工操作、所有的货物分拣依靠人员，核心订单数据手动录入，人效非常低。

  随着业务不断演进，技术的不断提升，原有运输管理系统已无法满足现有快速扩展下的业务需求，但针对现有系统评估后发现，系统升级成本远高于重新研发。

  因此，公司决定基于现有业务体系进行重新构建，打造一套新的TMS运输系统，直接更替原有系统。业务侧重于展示车辆调研、线路规划等核心业务流程，操作智能化，大幅度提升人效及管控效率。

  2.2、组织架构

  

  Java开发人员所在的一级部门为信息中心，主要负责集团新系统的研发、维护、更新迭代。信息中心下设3个2级部门，产品部、运维部以及开发部门，开发部门总计42人，按照以业务线划分为4个组、TMS项目组之外、WMS项目组、OMS项目、CRM组。

  TMS(Transportation Management System 运输管理系统) 项目组目前共8人，其中前端3人，后端5人。后端人员根据以下功能模块拆分进行任务分配，实际业务中也不可能是一人包打天下，分工合作才是常态化操作。

  2.3、产品说明

  神领物流系统类似顺丰速运，是向C端用户提供快递服务的系统。竞品有：顺丰、中通、圆通、京东快递等。

  项目产品主要有4端产品：

  • 用户端：基于微信小程序开发，外部客户使用，可以寄件、查询物流信息等。
  • 快递员端：基于安卓开发的手机APP，公司内部的快递员使用，可以接收取派件任务等。
  • 司机端：基于安卓开发的手机APP，公司内部的司机使用，可以接收运输任务、上报位置信息等。
  • 后台系统管理：基于vue开发，PC端使用，公司内部管理员用户使用，可以进行基础数据维护、订单管理、运单管理等。

    3、物流行业系统

    从广度上来说，物流系统可以理解为由多个子系统组成，这里我们以一般综合型物流系统举例，在整体框架上可以分为仓储系统WMS、运配系统TMS、单据系统OMS和计费系统BMS。

    这四大系统本质上解决了物流行业的四大核心问题：怎么存放、怎么运送、怎么跟进、怎么结算。

    神领物流系统，是TMS运配系统，本质上解决的是怎样运送的问题。

    本资源分享自 www.cx1314.cn 欢迎访问获取更多资源

    

    4、系统架构和技术架构

    4.1、系统架构

    本资源分享自 www.cx1314.cn 欢迎访问获取更多资源

    

    4.2、技术架构

    下图展现了神领物流项目使用的主要的技术：

    更多最新IT精品 www.cx1314.cn

    

    5、功能演示

    5.1、需求文档

    下面将演示四端的主要功能，更多的功能具体查看各端的需求文档。

    更多最新IT精品 www.cx1314.cn

    用户端	https://share.lanhuapp.com/#/invite?sid=qx01hbI7 密码: UxGE
    快递员端	https://share.lanhuapp.com/#/invite?sid=qxe42Dya 密码: Nomz
    司机端	https://share.lanhuapp.com/#/invite?sid=qX0NEmro 密码: yrzZ
    管理端	https://share.lanhuapp.com/#/invite?sid=qX0axVem 密码: fh3i

    5.2、功能架构

    

    5.3、业务功能流程

    更多最新IT精品 www.cx1314.cn

    

    :::info

    流程说明：

    • 用户在**【用户端】**下单后，生成订单
    • 系统会根据订单生成**【取件任务】，快递员上门取件后成功后生成【运单】**
    • 用户对订单进行支付，会产生**【交易单】**
    • 快件开始运输，会经历起始营业部、分拣中心、转运中心、分拣中心、终点营业部之间的转运运输，在此期间会有多个**【运输任务】**
    • 到达终点网点后，系统会生成**【派件任务】**，快递员进行派件作业
    • 最后，用户将进行签收或拒收操作

      :::

      5.4、用户端

      功能演示操作视频列表：

      下单操作	点击查看
      取消订单	点击查看
      地址簿	点击查看

      

      

      

      5.5、快递员端

      功能演示操作视频列表：

      

      派件操作流程	点击查看
      取件操作流程	点击查看
      全部取派操作流程	点击查看
      搜索操作流程	点击查看
      消息操作流程	点击查看

      

      

      

      

      5.6、司机端

      点击查看演示视频

      

      

      

      

      

      5.7、后台管理系统

      功能演示操作视频列表：

      建立机构	点击查看
      新建员工	点击查看
      绘制作业范围	点击查看
      新建线路	点击查看
      启用车辆	点击查看

      

      

      

      

      

      

      

      

      

      6、开发环境

      6.1、开发模式

      在神领物流开发团队中，采用了分组协作开发的模式，整个开发团队分为5个小组，每个小组4~5人，不同的分组负责不同的微服务。

      开发环境分为本地开发环境、测试环境、生成环境：

      • **本地开发环境：**自己的电脑环境
      • **测试环境：**在内网中搭建的一套大家都可以访问使用的环境
      • **生成环境：**最终给用户使用的环境

        6.2、团队分工

        目前神领物流项目拥有19个微服务，1个网关，1个parent工程，2个公共依赖工程，这些工程由上述的5个小组共同维护开发。

        新入职的你，加入到了开发一组。

        开发组/负责模块	开发一组	开发二组	开发三组	开发四组	开发五组	说明
        sl-express-parent	●					父工程
        sl-express-common	●					通用工程
        sl-express-mq	●					统一消息代码
        sl-express-gateway	●					网关
        sl-express-ms-base	●					基础微服务
        sl-express-ms-carriage		●				运费微服务
        sl-express-ms-courier		●				快递员微服务
        sl-express-ms-dispatch			●			调度微服务
        sl-express-ms-driver				●		司机微服务
        sl-express-ms-oms		●				订单微服务
        sl-express-ms-service-scope				●		服务范围微服务
        sl-express-ms-sms				●		短信微服务
        sl-express-ms-track		●				轨迹微服务
        sl-express-ms-trade			●			支付微服务
        sl-express-ms-transport			●			路线微服务
        sl-express-ms-transport-info			●			物流信息微服务
        sl-express-ms-user					●	用户微服务
        sl-express-ms-web-courier		●				快递员web服务
        sl-express-ms-web-customer					●	用户web服务
        sl-express-ms-web-driver				●		司机web服务
        sl-express-ms-web-manager					●	后台web服务
        sl-express-ms-work			●			运单微服务
        sl-express-ms-search					●	搜索微服务

        :::info

        **思考：**是否需要把所有的工程代码都拉取到本地进行编译运行？

        不需要的。你只需要将自己将要负责的开发任务相关的代码拉取到本地进行开发即可，其他的服务都可以调用测试环境正在运行的服务。

        另外，你有可能是没有权限拉取到其他开发组的代码的。

        :::

        微服务间调用关系如下：

        

        可以看到，四个端的请求都会统一进入网关，再分发到对应的四个web微服务，再由web微服务请求其他微服务完成业务。

        查看微服务间的依赖关系

        6.3、软件环境

        为了模拟企业中的开发环境，所以我们需要通过VMware导入linux虚拟机，该虚拟机中已经安装了课程中所需要的各种环境，包括，git、maven私服、Jenkins、MySQL、RabbitMQ等。

        :::info

        关于JDK版本的说明：神领物流项目使用的JDK版本为11，需要同学们统一下环境，JDK11的安装包在资料中有提供。

        目录：资料\软件包\jdk-11.0.15.1_windows-x64_bin.exe

        :::

        🔔关闭本地开发环境的防火墙（很重要！）

        6.3.1、导入虚拟机

        具体参考文档：虚拟机导入手册

        :::danger

        注意：只要按照文档导入虚拟机即可，其他软件无需自己安装，都已经安装了，并且开机自启。

        :::更多最新IT精品 www.cx1314.cn

        

        :::info

        通过dps命令可以查询上述列表，dps是自定义命令。

        自定义命令方法如下：

        :::

        vim ~/.bashrc
        #增加如下内容
        alias dps='docker ps --format "table{{.ID}}\t{{.Names}}\t{{.Status}}\t{{.Ports}}"'
        #保存退出
        #生效
        source ~/.bashrc
        

        6.3.2、配置本机hosts

        在本机hosts文件中设置如下配置：

        192.168.150.101 git.sl-express.com
        192.168.150.101 maven.sl-express.com
        192.168.150.101 jenkins.sl-express.com
        192.168.150.101 auth.sl-express.com
        192.168.150.101 rabbitmq.sl-express.com
        192.168.150.101 nacos.sl-express.com
        192.168.150.101 neo4j.sl-express.com
        192.168.150.101 xxl-job.sl-express.com
        192.168.150.101 eaglemap.sl-express.com
        192.168.150.101 seata.sl-express.com
        192.168.150.101 skywalking.sl-express.com
        192.168.150.101 api.sl-express.com
        192.168.150.101 admin.sl-express.com
        

        打开浏览器测试：http://git.sl-express.com/

        

        看到这个页面就说明hosts已经生效。（也可以再试试其他的，比如：maven私服、jenkins等）

        6.3.3、服务列表

        :::danger

        说明：如果通过域名访问，无需设置端口。

        :::

        名称	地址	用户名/密码	端口
        git	http://git.sl-express.com/	sl/sl123	10880
        maven	http://maven.sl-express.com/nexus/	admin/admin123	8081
        jenkins	http://jenkins.sl-express.com/	root/123	8090
        权限管家	http://auth.sl-express.com/api/authority/static/index.html	admin/123456	8764
        RabbitMQ	http://rabbitmq.sl-express.com/	sl/sl321	15672
        MySQL	-	root/123	3306
        nacos	http://nacos.sl-express.com/nacos/	nacos/nacos	8848
        neo4j	http://neo4j.sl-express.com/browser/	neo4j/neo4j123	7474
        xxl-job	http://xxl-job.sl-express.com/xxl-job-admin	admin/123456	28080
        EagleMap	http://eaglemap.sl-express.com/	eagle/eagle	8484
        seata	http://seata.sl-express.com/	seata/seata	7091
        Gateway	http://api.sl-express.com/	-	9527
        admin	http://admin.sl-express.com/	-	80
        skywalking	http://skywalking.sl-express.com/	-	48080
        Redis	-	123321	6379
        MongoDB	-	sl/123321	27017

        6.3.4、配置Maven私服

        在本地的maven（建议版本为3.6.x）配置中配置上述的私服，配置文件参考如下：

        settings.xml文件：

        
        
            
            F:\maven\repository
            
            
                
                    sl-releases
                    deployment
                    deployment123
                
                
                    sl-snapshots
                    deployment
                    deployment123
                
            
            
            
                
                    mirror
                    central,jcenter,!sl-releases,!sl-snapshots
                    mirror
                    https://maven.aliyun.com/nexus/content/groups/public
                
            
            
                
                    sl
                    
                    
                        
                            sl-releases::default::http://maven.sl-express.com/nexus/content/repositories/releases/
                        
                        
                            sl-snapshots::default::http://maven.sl-express.com/nexus/content/repositories/snapshots/
                        
                    
                    
                    
                        
                            sl-releases
                            http://maven.sl-express.com/nexus/content/repositories/releases/
                            
                                true
                            
                            
                                false
                            
                        
                        
                            sl-snapshots
                            http://maven.sl-express.com/nexus/content/repositories/snapshots/
                            
                                false
                            
                            
                                true
                            
                        
                    
                
            
            
                 
                sl
            
        
        

        6.3.5、服务版本

        服务名	版本号
        sl-express-parent	1.4
        sl-express-common	1.2-SNAPSHOT
        其他微服务	1.1-SNAPSHOT

        7、开发任务

        7.1、任务描述

        接下来是你加入到开发一组后接到的第一个任务，具体内容是：

        后台管理系统只允许管理员登录，非管理员（司机或快递员）是没有权限登录的，现在的情况是，任何角色的人都能登录到后台管理系统，应该是当非管理员登录时需要提示没有权限。

        这个可以算是一个bug修复的工作。接下来，你需要思考下，该如何解决这个问题。

        解决步骤：

        • 先确定鉴权工作是在哪里完成的

          • 通过前面的系统架构，可以得知是在网关中完成的

          • 拉取到网关的代码

          • 阅读鉴权的业务逻辑

          • 了解权限系统

          • 动手编码解决问题

          • 部署，功能测试

            

            7.1.1、部署后台管理系统

            后台管理系统的部署是使用101机器的Jenkins部署的，具体参考前端部署文档。部署完成后，就可以看到登录页面。

            地址：http://admin.sl-express.com/

            

            可以看到这个页面是可以正常访问，只是没有获取到验证码，是因为验证码的获取是需要后端服务支撑的，目前并没有启动后端服务。

            7.1.2、部署后端服务

            后端服务需要启动如下几个服务：更多最新IT精品 www.cx1314.cn

            

            目前，只启动了itcast-auth-server，其他均未启动：

            

            所以需要在Jenkins中，依次启动这几个服务，类似如下构建（需要找到对应的构建任务进行构建）：

            

            启动完成：

            

            在nacos中已经完成了服务的注册：

            

            7.1.3、测试

            刷新后台管理系统页面，即可成功看到验证码，说明所需要的服务已经启动完成了。

            

            使用默认账号，shenlingadmin/123456 即可完成登录：

            

            使用非管理员账号进行测试，例如：gzsj/123456 （司机账号） 或 hdkdy001/123456 （快递员账号） 进行测试，发现依然是可以登录的。

            

            这样，这个问题就重现了。

            7.2、拉取代码

            拉取代码步骤：

            • 在本地创建 sl-express 文件夹，该目录存放项目课程期间所有的代码
            • 启动idea，打开该目录

              

            • 登录 git 服务，找到 sl-express-gateway 工程，拷贝地址，在idea中拉取代码（注意存储路径）

              

              

            • 拉取到代码后，设置jdk版本为11

              

            • 添加modules，将sl-express-gateway加入进来

              

            • 成功拉取代码

              

            • 说明：该工程会依赖 sl-express-parent，此maven依赖是通过私服拉取到的。

              7.3、权限管家

              在神领物流项目中，快递员、司机、管理人员都是在权限管家中进行管理的，所以他们的登录都是需要对接权限管家完成的。

              具体权限管家的介绍说明参见：权限管家使用说明

              7.4、测试用户登录

              前面已经了解了权限管家，接下来我们将基于权限管家在sl-express-gateway中进行测试用户的登录以及对于token的校验。

              7.4.1、依赖说明

              对接权限管家需要引入依赖：

              
                  com.itheima.em.auth
                  itcast-auth-spring-boot-starter
              
              

              :::info

              该依赖已经导入，并且在parent中指定了版本号。

              该依赖已经上传到maven中央仓库，可以直接下载，地址：https://mvnrepository.com/artifact/com.itheima.em.auth/itcast-auth-spring-boot-starter

              :::

              7.4.2、解读配置

              在bootstrap-local.yml配置文件中配置了nacos配置中心，一些参数存放到了nacos中，这些参数一般都是不同环境不一样配置的。

              sl-express-gateway.properties如下：

              #权限系统的配置
              authority.host = 192.168.150.101
              authority.port = 8764
              authority.timeout = 10000
              #应用id
              authority.applicationId = 981194468570960001
              #角色id
              role.manager = 986227712144197857,989278284569131905,996045142395786081,996045927523359809
              #快递员角色
              role.courier = 989559057641637825
              #司机角色
              role.driver = 989559028277315009
              #RSA公钥
              sl.jwt.public-key = MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQDC6of/EqnM2008gRpFAJJd3iGF5o6P6SuJOcKq4iJQ+62EF4WKGIGQunJjPwVNQFqDuT7ko9bRFZNnMba9A5GrFELtAK7tzO9l19JgFcCBQoU3J6ehPCCunRKz52qJuzS0yiJp0dbB2i6cb7mSCftwZavmcpzhsBaOGQd23AnAmQIDAQAB
              

              其中applicationId、角色id都是需要在权限系统中找到。

              

              角色id需要在数据库表中查询，表为：itcast_auth.itcast_auth_role

              

              7.4.3、测试

              测试用例在AuthTemplateTest中：

                  @Test
                  public void testLogin() {
                      //登录
                      Result result = this.authTemplate.opsForLogin()
                              .token("shenlingadmin", "123456");
                      String token = result.getData().getToken().getToken();
                      System.out.println("token为：" + token);
                      UserDTO user = result.getData().getUser();
                      System.out.println("user信息：" + user);
                      //查询角色
                      Result> resultRole = AuthTemplateFactory.get(token).opsForRole()
                              .findRoleByUserId(user.getId());
                      System.out.println(resultRole);
                  }
              

              token校验测试：

                  @Test
                  public void checkToken() {
                      String token = "xxx.xx.xxx"; //上面方法中生成的token
                      AuthUserInfoDTO authUserInfo = this.tokenCheckService.parserToken(token);
                      System.out.println(authUserInfo);
                      System.out.println(JSONUtil.toJsonStr(authUserInfo));
                  }
              

              :::danger

              **说明：**权限管家生成的token采用的是RSA非对称加密方式，项目中配置的公钥一定要与权限系统中使用的公钥一致，否则会出现无法校验token的情况。

              :::

              

              项目中的公钥文件：

              

              7.5、阅读鉴权代码

              7.5.1、整体流程

              首先需要明确的一点是四个终端都是通过sl-express-gateway进行验证与鉴权的，下面以管理员请求流程为例，其他的流程类似。

              ### 7.5.2、自定义过滤器

              不同终端进入Gateway的请求路径是不一样的，并且不同的终端对于token的校验和鉴权逻辑是不一样的，所以需要在网关中对于各个终端创建不同的过滤器来实现。

              请求路径如下：

              • 快递员端：/courier/**
              • 用户端：/customer/**
              • 司机端：/driver/**
              • 管理端：/manager/**

                具体的配置文件内容如下：

                server:
                  port: 9527
                  tomcat:
                    uri-encoding: UTF-8
                    threads:
                      max: 1000
                      min-spare: 30
                spring:
                  cloud:
                    nacos:
                      username: nacos
                      password: nacos
                      server-addr: 192.168.150.101:8848
                      discovery:
                        namespace: ecae68ba-7b43-4473-a980-4ddeb6157bdc
                        ip: 192.168.150.1
                      config:
                        namespace: ecae68ba-7b43-4473-a980-4ddeb6157bdc
                    gateway:
                      globalcors:
                        cors-configurations:
                          '[/**]':
                            allowed-origin-patterns: "*"
                            allowed-headers: "*"
                            allow-credentials: true
                            allowed-methods:
                              - GET
                              - POST
                              - DELETE
                              - PUT
                              - OPTION
                      discovery:
                        locator:
                          enabled: true #表明gateway开启服务注册和发现的功能，并且spring cloud gateway自动根据服务发现为每一个服务创建了一个router，这个router将以服务名开头的请求路径转发到对应的服务
                      routes:
                        - id: sl-express-ms-web-courier
                          uri: lb://sl-express-ms-web-courier
                          predicates:
                            - Path=/courier/**
                          filters:
                            - StripPrefix=1
                            - CourierToken
                            - AddRequestHeader=X-Request-From, sl-express-gateway
                        - id: sl-express-ms-web-customer
                          uri: lb://sl-express-ms-web-customer
                          predicates:
                            - Path=/customer/**
                          filters:
                            - StripPrefix=1
                            - CustomerToken
                            - AddRequestHeader=X-Request-From, sl-express-gateway
                        - id: sl-express-ms-web-driver
                          uri: lb://sl-express-ms-web-driver
                          predicates:
                            - Path=/driver/**
                          filters:
                            - StripPrefix=1
                            - DriverToken
                            - AddRequestHeader=X-Request-From, sl-express-gateway
                        - id: sl-express-ms-web-manager
                          uri: lb://sl-express-ms-web-manager
                          predicates:
                            - Path=/manager/**
                          filters:
                            - StripPrefix=1
                            - ManagerToken
                            - AddRequestHeader=X-Request-From, sl-express-gateway
                        - id: sl-express-ms-trade
                          uri: lb://sl-express-ms-trade
                          predicates:
                            - Path=/trade/notify/**
                          filters:
                            - StripPrefix=1
                            - AddRequestHeader=X-Request-From, sl-express-gateway
                itcast:
                  authority:
                    host: ${authority.host} #authority服务地址,根据实际情况更改
                    port: ${authority.port} #authority服务端口
                    timeout: ${authority.timeout} #http请求的超时时间
                    public-key-file: auth/pub.key
                    applicationId: ${authority.applicationId}
                #角色id
                role:
                  manager: ${role.manager}
                  courier: ${role.courier}
                  driver: ${role.driver}
                sl:
                  noAuthPaths:
                    - /courier/login/account
                    - /courier/swagger-ui.html
                    - /courier/webjars/
                    - /courier/swagger-resources
                    - /courier/v2/api-docs
                    - /courier/doc.html
                    - /customer/user/login
                    - /customer/user/refresh
                    - /customer/swagger-ui.html
                    - /customer/webjars/
                    - /customer/swagger-resources
                    - /customer/v2/api-docs
                    - /customer/doc.html
                    - /driver/login/account
                    - /driver/swagger-ui.html
                    - /driver/webjars/
                    - /driver/swagger-resources
                    - /driver/v2/api-docs
                    - /driver/doc.html
                    - /manager/login
                    - /manager/webjars/
                    - /manager/swagger-resources
                    - /manager/v2/api-docs
                    - /manager/doc.html
                    - /manager/captcha
                  jwt:
                    public-key: ${sl.jwt.user-secret-key}
                

                可以看到，在配置文件中配置了注册中心、cors跨域、自定义过滤器、自定义配置、白名单路径等信息。

                其中，自定义过滤器配置了4个，与处理类对应关系如下：

                • CourierToken -> com.sl.gateway.filter.CourierTokenGatewayFilterFactory
                • CustomerToken -> com.sl.gateway.filter.CustomerTokenGatewayFilterFactory
                • DriverToken **-> **com.sl.gateway.filter.DriverTokenGatewayFilterFactory
                • ManagerToken **-> **com.sl.gateway.filter.ManagerTokenGatewayFilterFactory

                  在GatewayFilterFactory中，继承AbstractGatewayFilterFactory类，实现GatewayFilterFactory接口中的apply()方法，返回GatewayFilter对象，即可在filter()方法中实现具体的业务逻辑。

                  

                  具体的业务逻辑，在自定义TokenGatewayFilter类中完成。

                  :::info

                  ❓思考：

                  四个终端都共用TokenGatewayFilter类，而各个终端的校验逻辑是不一样的，该怎么做呢？

                  :::

                  7.5.3、TokenGatewayFilter

                  TokenGatewayFilter过滤器是整个项目中的校验/ 鉴权流程的具体实现，由于存在不同的终端，导致具体的校验和鉴权逻辑不一样，所以需要通过自定义接口AuthFilter实现，也就是4个端的TokenGatewayFilterFactory同时也需要实现AuthFilter接口。

                  在向下游服务转发请求时，会携带2个头信息，分别是userInfo和token，也就是会将用户信息和token传递下去。

                  package com.sl.gateway.filter;
                  import cn.hutool.core.util.ObjectUtil;
                  import cn.hutool.core.util.StrUtil;
                  import cn.hutool.json.JSONUtil;
                  import com.itheima.auth.sdk.dto.AuthUserInfoDTO;
                  import com.sl.gateway.config.MyConfig;
                  import com.sl.transport.common.constant.Constants;
                  import lombok.extern.slf4j.Slf4j;
                  import org.springframework.cloud.gateway.filter.GatewayFilter;
                  import org.springframework.cloud.gateway.filter.GatewayFilterChain;
                  import org.springframework.core.Ordered;
                  import org.springframework.http.HttpStatus;
                  import org.springframework.web.server.ServerWebExchange;
                  import reactor.core.publisher.Mono;
                  @Slf4j
                  public class TokenGatewayFilter implements GatewayFilter, Ordered {
                      private MyConfig myConfig;
                      private AuthFilter authFilter;
                      public TokenGatewayFilter(MyConfig myConfig, AuthFilter authFilter) {
                          this.myConfig = myConfig;
                          this.authFilter = authFilter;
                      }
                      @Override
                      public Mono filter(ServerWebExchange exchange, GatewayFilterChain chain) {
                          //获取请求路径
                          String path = exchange.getRequest().getPath().toString();
                          //查看请求路径是否在白名单中
                          if (StrUtil.startWithAny(path, myConfig.getNoAuthPaths())) {
                              //无需校验，直接放行
                              return chain.filter(exchange);
                          }
                          //获取header的参数
                          String token = exchange.getRequest().getHeaders().getFirst(this.authFilter.tokenHeaderName());
                          if (StrUtil.isEmpty(token)) {
                              //没有权限
                              exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
                              return exchange.getResponse().setComplete();
                          }
                          //校验token
                          AuthUserInfoDTO authUserInfoDTO = null;
                          try { //捕获token校验异常
                              authUserInfoDTO = this.authFilter.check(token);
                          } catch (Exception e) {
                              log.error("令牌校验失败，token = {}, path= {}", token, path, e);
                          }
                          if (ObjectUtil.isEmpty(authUserInfoDTO)) {
                              //token失效 或 伪造，响应401
                              exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
                              return exchange.getResponse().setComplete();
                          }
                          //鉴权
                          Boolean result = false;
                          try { //捕获鉴权异常
                              result = this.authFilter.auth(token, authUserInfoDTO, path);
                          } catch (Exception e) {
                              log.error("权限校验失败，token = {}, path= {}", token, path, e);
                          }
                          if (!result) {
                              //没有权限，响应400
                              exchange.getResponse().setStatusCode(HttpStatus.BAD_REQUEST);
                              return exchange.getResponse().setComplete();
                          }
                          //增加参数，向下游微服务传递参数
                          exchange.getRequest().mutate().header(Constants.GATEWAY.USERINFO, JSONUtil.toJsonStr(authUserInfoDTO));
                          exchange.getRequest().mutate().header(Constants.GATEWAY.TOKEN, token);
                          //校验通过放行
                          return chain.filter(exchange);
                      }
                      @Override
                      public int getOrder() {
                          //指定了拦截器的顺序，设置最小值确定第一个被执行
                          return Integer.MIN_VALUE;
                      }
                  }
                  

                  7.5.4、AuthFilter

                  AuthFilter是自定义接口，用于不同客户端（用户端、司机端、快递员端、管理端）校验/鉴权逻辑的实现，该接口定义了3个方法：

                  • check()方法用于校验token
                  • auth()方法用于鉴权
                  • tokenHeaderName()方法是默认实现，默认请求头中token参数的名为：Authorization
                  • 执行流程是先校验token的有效性，再进行鉴权。

                    package com.sl.gateway.filter;
                    import com.itheima.auth.sdk.dto.AuthUserInfoDTO;
                    import com.sl.transport.common.constant.Constants;
                    /**
                     * 鉴权业务的回调，具体逻辑由 GatewayFilterFactory 具体完成
                     */
                    public interface AuthFilter {
                        /**
                         * 校验token
                         *
                         * @param token 请求中的token
                         * @return token中携带的数据
                         */
                        AuthUserInfoDTO check(String token);
                        /**
                         * 鉴权
                         *
                         * @param token        请求中的token
                         * @param authUserInfo token中携带的数据
                         * @param path         当前请求的路径
                         * @return 是否通过
                         */
                        Boolean auth(String token, AuthUserInfoDTO authUserInfo, String path);
                        /**
                         * 请求中携带token的名称
                         *
                         * @return 头名称
                         */
                        default String tokenHeaderName() {
                            return Constants.GATEWAY.AUTHORIZATION;
                        }
                    }
                    

                    7.5.5、管理员校验实现

                    package com.sl.gateway.filter;
                    import com.itheima.auth.sdk.dto.AuthUserInfoDTO;
                    import com.itheima.auth.sdk.service.TokenCheckService;
                    import com.sl.gateway.config.MyConfig;
                    import org.springframework.cloud.gateway.filter.GatewayFilter;
                    import org.springframework.cloud.gateway.filter.factory.AbstractGatewayFilterFactory;
                    import org.springframework.stereotype.Component;
                    import javax.annotation.Resource;
                    /**
                     * 后台管理员token拦截处理
                     */
                    @Component
                    public class ManagerTokenGatewayFilterFactory extends AbstractGatewayFilterFactory