SpringCloud Gateway動態(tài)路由配置詳解

更新時間：2023年03月17日 16:09:54 作者：苦瓜不苦077

這篇文章主要為大家介紹了SpringCloud Gateway動態(tài)路由配置詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

路由

gateway最主要的作用是，提供統(tǒng)一的入口，路由，鑒權(quán)，限流，熔斷；這里的路由就是請求的轉(zhuǎn)發(fā)，根據(jù)設(shè)定好的某些條件，比如斷言，進(jìn)行轉(zhuǎn)發(fā)。

動態(tài)

動態(tài)的目的是讓程序更加可以在運(yùn)行的過程中兼容更多的業(yè)務(wù)場景。

涉及到兩個服務(wù)，一個是門戶服務(wù)（作用是提供給運(yùn)營人員管理入口--包括：管理路由、綁定路由），一個是網(wǎng)關(guān)服務(wù)（gateway組件，為門戶服務(wù)提供：查詢路由信息、添加路由、刪除路由、編輯路由接口）。

路由模型實(shí)體類

/**
 * 路由模型
 *
 * @author 苦瓜不苦
 * @date 2022/11/13 23:23
 **/
@Data
public class RouteDefinitionObject {
    /**
     * 路由的Id
     */
    private String id;
    /**
     * 路由斷言集合配置
     */
    private List&lt;PredicateDefinition&gt; predicates;
    /**
     * 路由過濾器集合配置
     */
    private List&lt;FilterDefinition&gt; filters;
    /**
     * 路由規(guī)則轉(zhuǎn)發(fā)的目標(biāo)uri
     */
    private String uri;
    /**
     * 路由執(zhí)行的順序
     */
    private Integer order = 0;
    @Data
    public static class PredicateDefinition {
        /**
         * 斷言對應(yīng)的Name
         */
        private String name;
        /**
         * 配置的斷言規(guī)則
         */
        private Map&lt;String, String&gt; args;
    }
    @Data
    public static class FilterDefinition {
        /**
         * 斷言對應(yīng)的Name
         */
        private String name;
        /**
         * 配置的斷言規(guī)則
         */
        private Map&lt;String, String&gt; args;
    }
}

動態(tài)路徑配置

/**
 * 動態(tài)路由配置
 *
 * @author 苦瓜不苦
 * @date 2022/11/13 23:26
 **/
@Slf4j
@RestController
@RequestMapping("/route")
public class GatewayRouteConfig implements ApplicationEventPublisherAware {
    public final Map&lt;String, RouteDefinitionObject&gt; MAP = new ConcurrentHashMap&lt;&gt;();
    private final RouteDefinitionWriter routeDefinitionWriter;
    private ApplicationEventPublisher applicationEventPublisher;
    public GatewayRouteConfig(RouteDefinitionWriter routeDefinitionWriter) {
        this.routeDefinitionWriter = routeDefinitionWriter;
    }
    @Override
    public void setApplicationEventPublisher(@NonNull ApplicationEventPublisher applicationEventPublisher) {
        this.applicationEventPublisher = applicationEventPublisher;
    }
    /**
     * 新增路由
     * {"filters":[{"name":"StripPrefix","args":{"_genkey_0":"2"}}],"id":"item-system","uri":"lb://item-system","order":0,"predicates":[{"name":"Path","args":{"_genkey_0":"/api/system/**"}}]}
     */
    @PostMapping("/save")
    public R&lt;String&gt; save(@RequestBody RouteDefinitionObject routeDefinitionObject) {
        try {
            // 路由模型轉(zhuǎn)換成路由對象
            RouteDefinition definition = BeanUtil.toBean(routeDefinitionObject, RouteDefinition.class);
            URI uri = routeDefinitionObject.getUri().startsWith("http") ? UriComponentsBuilder.fromHttpUrl(routeDefinitionObject.getUri()).build().toUri() : URI.create(routeDefinitionObject.getUri());
            definition.setUri(uri);
            // 新增
            routeDefinitionWriter.save(Mono.just(definition)).subscribe();
            applicationEventPublisher.publishEvent(new RefreshRoutesEvent(this));
            MAP.put(routeDefinitionObject.getId(), routeDefinitionObject);
            return R.success();
        } catch (Exception e) {
            log.error("\n", e);
        }
        return R.failed();
    }
    /**
     * 刪除路由
     */
    @GetMapping("/delete")
    public R&lt;Mono&lt;ResponseEntity&lt;Object&gt;&gt;&gt; delete(@RequestParam("id") String id) {
        try {
            Mono&lt;ResponseEntity&lt;Object&gt;&gt; responseEntityMono = routeDefinitionWriter.delete(Mono.just(id))
                    .then(Mono.defer(() -&gt;
                            Mono.just(ResponseEntity.ok().build())
                    )).onErrorResume((t) -&gt;
                                    t instanceof NotFoundException
                            , (t) -&gt;
                                    Mono.just(ResponseEntity.notFound().build())
                    );
            MAP.remove(id);
            return R.success(responseEntityMono);
        } catch (Exception e) {
            log.error("\n", e);
        }
        return R.failed();
    }
    /**
     * 更新路由
     * {"filters":[{"name":"StripPrefix","args":{"_genkey_0":"2"}}],"id":"item-system","uri":"lb://item-system","order":0,"predicates":[{"name":"Path","args":{"_genkey_0":"/api/system/**"}}]}
     */
    @PostMapping("/update")
    public R&lt;String&gt; update(@RequestBody RouteDefinitionObject routeDefinitionObject) {
        try {
            // 刪除
            delete(routeDefinitionObject.getId());
            // 新增
            save(routeDefinitionObject);
            return R.success();
        } catch (Exception e) {
            log.error("\n", e);
        }
        return R.failed();
    }
    /**
     * 查詢路由
     */
    @GetMapping("/list")
    public R&lt;Collection&lt;RouteDefinitionObject&gt;&gt; list() {
        return R.success(MAP.values());
    }
}

路由模型JSON數(shù)據(jù)

{
    "filters":[
        {
            "name":"StripPrefix",
            "args":{
                "_genkey_0":"2"
            }
        }
    ],
    "id":"item-system",
    "uri":"lb://item-system",
    "order":0,
    "predicates":[
        {
            "name":"Path",
            "args":{
                "_genkey_0":"/api/system/**"
            }
        }
    ]
}

以上就是SpringCloud Gateway動態(tài)路由配置詳解的詳細(xì)內(nèi)容，更多關(guān)于SpringCloud Gateway動態(tài)路由的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: