Spring Cloud Alibaba 路由网关(Gateway，调用不同的服务配置，网关全局过滤）

超、凢脫俗 2023-02-11 15:25 15阅读 0赞

**\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*服务一nacos-provider\*\*\*\*\*\*\*\*\*\*\*\*\*\*\***[https://github.com/ChenXbFrank/nacos-provider][https_github.com_ChenXbFrank_nacos-provider]

**1.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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.3.0.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>com.cxb</groupId>
        <artifactId>springcloud</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>nacos-provider</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
                <exclusions>
                    <exclusion>
                        <groupId>org.junit.vintage</groupId>
                        <artifactId>junit-vintage-engine</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
                <version>0.9.0.RELEASE</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-alibaba-nacos-config</artifactId>
                <version>0.9.0.RELEASE</version>
            </dependency>
    
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

**2.bootstrap.yml**

spring:
      application:
        name: nacos-provider
      cloud:
        nacos:
          discovery:
            server-addr: 127.0.0.1:8848
          config:
            server-addr: 127.0.0.1:8848
            file-extension: yaml
            prefix: nacos-provider
      profiles:
        active: dev

**3.PayController**

package com.cxb.springcloud.web;
    
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestParam;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    @RequestMapping("/pay")
    public class PayController {
    
        @GetMapping("/balance")
        public String balance(@RequestParam("id")int id){
            return "获取的价格：" + id;
        }
    }

**4.ProviderController**

package com.cxb.springcloud.web;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.cloud.context.config.annotation.RefreshScope;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestParam;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    //实现配置的热加载
    @RefreshScope
    public class ProviderController {
    
        Logger logger = LoggerFactory.getLogger(ProviderController.class);
    
        @Value("${username:frank}")
        private String username;
    
        @Value("${address:china}")
        private String address;
    
        @RequestMapping("/getInfo")
        public String getInfo() {
            return address + ":"+ username;
        }
    
        @GetMapping("/hi")
        public String hi(@RequestParam(value = "name",defaultValue = "frank",required = false)String name){
            logger.info("name:{}", name);
            return "hi "+name;
        }
    }

**5.NacosProviderApplication**

package com.cxb.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    @SpringBootApplication
    @EnableDiscoveryClient
    public class NacosProviderApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(NacosProviderApplication.class, args);
        }
    
    }

最后启动服务一即可，注册中心可以查看服务。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70][]

**\*\*\*\*\*\*\*\*\*\*\*\*实现服务二nacos-server\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\***[https://github.com/ChenXbFrank/nacos-server][https_github.com_ChenXbFrank_nacos-server]

**1.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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            
            <version>2.0.5.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>com.cxb</groupId>
        <artifactId>springcloud</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>nacos-server</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>Finchley.SR1</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
                <dependency>
                    <groupId>com.alibaba.cloud</groupId>
                    <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                    <version>2.0.0.RELEASE</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
                <version>2.0.5.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
    
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

**2.application.properties**

server.port=8070
    spring.application.name=nacos-server
    
    spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848

**3.ServerController**

package com.cxb.springcloud.web;
    
    
    import org.springframework.web.bind.annotation.*;
    
    @RestController
    public class ServerController {
    
        @RequestMapping(value = "/echo/{string}", method = RequestMethod.GET)
        public String echo(@PathVariable String string) {
            return "hello Nacos Discovery " + string;
        }
    
        @RequestMapping(value = "/divide", method = RequestMethod.GET)
        public String divide(@RequestParam Integer a, @RequestParam Integer b) {
            return String.valueOf(a / b);
        }
    }

**4.NacosServerApplication**

package com.cxb.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    @SpringBootApplication
    @EnableDiscoveryClient
    public class NacosServerApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(NacosServerApplication.class, args);
        }
    
    }

最后启动服务二即可，注册中心可以查看服务。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 1][]

**\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*通过nacos-gateway服务配置调用服务一、二\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\***

[https://github.com/ChenXbFrank/nacos-gateway][https_github.com_ChenXbFrank_nacos-gateway]

**1.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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            
            <version>2.0.5.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>com.cxb</groupId>
        <artifactId>springcloud</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>nacos-gateway</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>Finchley.SR1</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
                <dependency>
                    <groupId>com.alibaba.cloud</groupId>
                    <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                    <version>2.0.0.RELEASE</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            <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>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
    
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

**2.application.properties**

server.port=8085
    # 配置 Nacos Server 地址
    spring.application.name=nacos-gateway
    spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848
    management.endpoints.web.exposure.include=*
    
    # 配置文件中配置 Spring Cloud Gateway 路由
    spring.cloud.gateway.routes[0].id=nacos-server-route
    # 格式为：lb://应用注册服务名
    spring.cloud.gateway.routes[0].uri=lb://nacos-server
    spring.cloud.gateway.routes[0].predicates[0].name=Path
    # 当http://localhost:8085/nacos/echo/123 接口以nacos开头时，则会自动调用nacos-server服务的接口
    spring.cloud.gateway.routes[0].predicates[0].args[pattern]=/server/**
    spring.cloud.gateway.routes[0].filters[0]=StripPrefix=1
    
    # 配置路由2
    spring.cloud.gateway.routes[1].id=nacos-provider-route
    # 格式为：lb://应用注册服务名
    spring.cloud.gateway.routes[1].uri=lb://nacos-provider
    spring.cloud.gateway.routes[1].predicates[0].name=Path
    # 当http://localhost:8085/nacos/echo/123 接口以provider开头时，则会自动调用nacos-provider服务的接口
    spring.cloud.gateway.routes[1].predicates[0].args[pattern]=/provider/**
    spring.cloud.gateway.routes[1].filters[0]=StripPrefix=1

**3.NacosGatewayApplication**

package com.cxb.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    @SpringBootApplication
    @EnableDiscoveryClient
    public class NacosGatewayApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(NacosGatewayApplication.class, args);
        }
    
    }

最后启动项目，在服务中心查看。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 2][]

测试服务：

**[http://localhost:8085/server/echo/123][http_localhost_8085_server_echo_123]    调用了服务二的接口**

![20200524093813391.png][]

**[http://localhost:8085/provider/pay/balance?id=100][http_localhost_8085_provider_pay_balance_id_100]   调用了服务一的接口**

![20200524093853290.png][]

**[http://localhost:8085/provider/getInfo][http_localhost_8085_provider_getInfo]  调用了服务一的其他接口**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 3][]

**总结：这里实现途中确实遇到了很多问题，不过大多都是jar依赖等问题，引入maven依赖的时候多注意一下版本。**

**服务一代码：**[https://github.com/ChenXbFrank/nacos-provider][https_github.com_ChenXbFrank_nacos-provider]

**服务二代码：**[https://github.com/ChenXbFrank/nacos-server][https_github.com_ChenXbFrank_nacos-server]

**gateway代码：**[https://github.com/ChenXbFrank/nacos-gateway][https_github.com_ChenXbFrank_nacos-gateway]

# Spring Cloud Alibaba 网关全局过滤 #

**基于上面的代码修改nacos-gateway，新增** AuthFilter即可。

package com.cxb.springcloud.filter;
    
    import com.fasterxml.jackson.core.JsonProcessingException;
    import com.fasterxml.jackson.databind.ObjectMapper;
    import com.google.common.collect.Maps;
    import org.springframework.cloud.gateway.filter.GatewayFilterChain;
    import org.springframework.cloud.gateway.filter.GlobalFilter;
    import org.springframework.core.Ordered;
    import org.springframework.core.io.buffer.DataBuffer;
    import org.springframework.http.HttpStatus;
    import org.springframework.http.server.reactive.ServerHttpResponse;
    import org.springframework.stereotype.Component;
    import org.springframework.web.server.ServerWebExchange;
    import reactor.core.publisher.Mono;
    
    import java.util.Map;
    
    /**
     * 鉴权过滤器
     */
    @Component
    public class AuthFilter implements GlobalFilter, Ordered {
        @Override
        public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
            String token = exchange.getRequest().getQueryParams().getFirst("token");
    
            if (token == null || token.isEmpty()) {
                ServerHttpResponse response = exchange.getResponse();
    
                // 封装错误信息
                Map<String, Object> responseData = Maps.newHashMap();
                responseData.put("code", 401);
                responseData.put("message", "非法请求");
                responseData.put("cause", "Token is empty");
    
                try {
                    // 将信息转换为 JSON
                    ObjectMapper objectMapper = new ObjectMapper();
                    byte[] data = objectMapper.writeValueAsBytes(responseData);
    
                    // 输出错误信息到页面
                    DataBuffer buffer = response.bufferFactory().wrap(data);
                    response.setStatusCode(HttpStatus.UNAUTHORIZED);
                    response.getHeaders().add("Content-Type", "application/json;charset=UTF-8");
                    return response.writeWith(Mono.just(buffer));
                } catch (JsonProcessingException e) {
                    e.printStackTrace();
                }
            }
            return chain.filter(exchange);
        }
    
        /**
         * 设置过滤器的执行顺序
         *
         * @return
         */
        @Override
        public int getOrder() {
            return Ordered.LOWEST_PRECEDENCE;
        }
    }

以上只判断了token是否为空，后续根据自己的业务需求进行相应的修改。

测试：[http://localhost:8085/server/echo/123][http_localhost_8085_server_echo_123] 如果不加入token，则会被拦截。

![20200524095635402.png][]

[http://localhost:8085/server/echo/123?token=123][http_localhost_8085_server_echo_123_token_123]

![20200524095724777.png][]

加入token的访问正常返回结果。

[https_github.com_ChenXbFrank_nacos-provider]: https://github.com/ChenXbFrank/nacos-provider
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200524093218927.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2,size_16,color_FFFFFF,t_70
[https_github.com_ChenXbFrank_nacos-server]: https://github.com/ChenXbFrank/nacos-server
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/2020052409345966.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2,size_16,color_FFFFFF,t_70
[https_github.com_ChenXbFrank_nacos-gateway]: https://github.com/ChenXbFrank/nacos-gateway
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20200524093741685.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2,size_16,color_FFFFFF,t_70
[http_localhost_8085_server_echo_123]: http://localhost:8085/server/echo/123
[20200524093813391.png]: https://img-blog.csdnimg.cn/20200524093813391.png
[http_localhost_8085_provider_pay_balance_id_100]: http://localhost:8085/provider/pay/balance?id=100
[20200524093853290.png]: https://img-blog.csdnimg.cn/20200524093853290.png
[http_localhost_8085_provider_getInfo]: http://localhost:8085/provider/getInfo
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20200524094005991.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2,size_16,color_FFFFFF,t_70
[20200524095635402.png]: https://img-blog.csdnimg.cn/20200524095635402.png
[http_localhost_8085_server_echo_123_token_123]: http://localhost:8085/server/echo/123?token=123
[20200524095724777.png]: https://img-blog.csdnimg.cn/20200524095724777.png