SpringCloud gateway如何實(shí)現(xiàn)動(dòng)態(tài)路由

1 通知SpringBoot配置文件有變化
ApplicationContext..publishEvent(new EnvironmentChangeEvent(changedKeys));
2 通知gateway刷新路由
ApplicationEventPublisher.publishEvent(new RefreshRoutesEvent(this));

以apollo配置中心為例,SpringCloud gateway實(shí)現(xiàn)動(dòng)態(tài)路由代碼如下:

package com.sa.config;

import com.ctrip.framework.apollo.model.ConfigChangeEvent;
import com.ctrip.framework.apollo.spring.annotation.ApolloConfigChangeListener;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeansException;
import org.springframework.cloud.context.environment.EnvironmentChangeEvent;
import org.springframework.cloud.gateway.event.RefreshRoutesEvent;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
import org.springframework.stereotype.Component;

/**
 * apollo動(dòng)態(tài)路由
 *
 * @author gongmin
 * @date 2024/1/23 15:06
 */
@Component
@Slf4j
public class GatewayPropertiesRefresher implements ApplicationContextAware, ApplicationEventPublisherAware {
    private ApplicationContext applicationContext;
    private ApplicationEventPublisher publisher;

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        this.applicationContext = applicationContext;
    }

    @Override
    public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
        this.publisher = applicationEventPublisher;
    }

    /**
     * 監(jiān)聽apollo配置,實(shí)現(xiàn)網(wǎng)關(guān)路由動(dòng)態(tài)更新
     *
     * @param changeEvent 更新事件
     */
    @ApolloConfigChangeListener(value = "application.yml", interestedKeyPrefixes = "spring.cloud.gateway.")
    public void onChange(ConfigChangeEvent changeEvent) {
        refreshGatewayProperties(changeEvent);
    }

    /**
     * 刷新路由
     *
     * @param changeEvent 更新事件
     */
    private void refreshGatewayProperties(ConfigChangeEvent changeEvent) {
        log.debug("<refreshGatewayProperties> start");
        this.applicationContext.publishEvent(new EnvironmentChangeEvent(changeEvent.changedKeys()));
        refreshGatewayRouteDefinition();
        log.debug("<refreshGatewayProperties> end");
    }

    /**
     * 刷新路由
     */
    private void refreshGatewayRouteDefinition() {
        log.debug("<refreshGatewayRouteDefinition> start");
        this.publisher.publishEvent(new RefreshRoutesEvent(this));
    }
}
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡書系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容