spring cloud gateway 如何工作

2021-02-04 19:16

阅读：362

标签：discover obj discovery slist toc bin ring stream order

spring cloud gateway的包结构(在Idea 2019.3中展示)
技术图片

这个包是spring-cloud-gateway-core.这里是真正的spring-gateway的实现的地方.
为了证明,我们打开spring-cloud-starter-gateway的pom文件

    org.springframework.cloud
            spring-cloud-starter
        org.springframework.cloud
            spring-cloud-gateway-core
        org.springframework.boot
            spring-boot-starter-webflux

除了cloud-start,starter-webflux就是cloud-gateway-core.所以后面我们就分析
cloud-gateway-core这个jar包.

技术图片

其中actuate中定义了GatewayControllerEndpoint,它提供了对外访问的接口.

    // TODO: Flush out routes without a definition
    @GetMapping("/routes")
    public Flux> routes() {
        return this.routeLocator.getRoutes().map(this::serialize);
    }

    @GetMapping("/routes/{id}")
    public Mono>> route(@PathVariable String id) {
        //......
    }
//以下方法是继承于父类,抽象类AbstractGatewayControllerEndpoint
    @PostMapping("/refresh")
    public Mono refresh() {
        this.publisher.publishEvent(new RefreshRoutesEvent(this));
        return Mono.empty();
    }

    @GetMapping("/globalfilters")
    public Mono> globalfilters() {
        return getNamesToOrders(this.globalFilters);
    }

    @GetMapping("/routefilters")
    public Mono> routefilers() {
        return getNamesToOrders(this.GatewayFilters);
    }

    @GetMapping("/routepredicates")
    public Mono> routepredicates() {
        return getNamesToOrders(this.routePredicates);
    }
    @PostMapping("/routes/{id}")
    @SuppressWarnings("unchecked")
    public Mono> save(@PathVariable String id,
            @RequestBody RouteDefinition route) {}
    @DeleteMapping("/routes/{id}")
    public Mono> delete(@PathVariable String id) {
        return this.routeDefinitionWriter.delete(Mono.just(id))
                .then(Mono.defer(() -> Mono.just(ResponseEntity.ok().build())))
                .onErrorResume(t -> t instanceof NotFoundException,
                        t -> Mono.just(ResponseEntity.notFound().build()));
    }

    @GetMapping("/routes/{id}/combinedfilters")
    public Mono> combinedfilters(@PathVariable String id) {
        // TODO: missing global filters
    }

config包里定义了一些Autoconfiguration和一些properties.读取配置文件就在这里完成.
技术图片

我们这里看一下GatewayProperties.java

@ConfigurationProperties("spring.cloud.gateway")
@Validated
public class GatewayProperties {

    /**
     * List of Routes.
     */
    @NotNull
    @Valid
    private List routes = new ArrayList();

    /**
     * List of filter definitions that are applied to every route.
     */
    private List defaultFilters = new ArrayList();

    private List streamingMediaTypes = Arrays
            .asList(MediaType.TEXT_EVENT_STREAM, MediaType.APPLICATION_STREAM_JSON);
    #该类包括三个属性,路由列表,默认过滤器列表和MediaType列表.路由列表中的路由定义RouteDefinition.
        过滤器中定义的FilterDefinition.

discovery定义了注册中心的一些操作.
event定义了一系列事件,都继承自ApplicationEvent.
filter定义了spring gateway实现的一些过滤器,包括gatewayfilter,globalfilter.

spring cloud gateway 如何工作

标签：discover obj discovery slist toc bin ring stream order

原文地址：https://blog.51cto.com/8745668/2491105

上一篇：09-python--file

下一篇：07-python--list

文章来自：搜素材网的编程语言模块，转载请注明文章出处。
文章标题：spring cloud gateway 如何工作
文章链接：http://soscw.com/index.php/essay/51028.html

亲，登录后才可以留言！

spring cloud gateway 如何工作

评论

热门文章

推荐文章

最新文章

置顶文章