Nginx gateway叢集和動態閘道器的實現思路

@Service
public class GatewayService implements ApplicationEventPublisherAware {
    private ApplicationEventPublisher publisher;
    @Autowired
    private RouteDefinitionWriter routeDefinitionWriter;
 
    @Override
    public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
        this.publisher = applicationEventPublisher;
    }
 
    public void initAllRoute() {
        // 從資料庫查詢設定的閘道器設定
        List<GatewayRouteEntity> gateWayEntities = gatewayRouteMapper.gateWayAll();
        for (GatewayRouteEntity gw :
                gateWayEntities) {
            loadRoute(gw);
        }
 
    }
 
    public String loadRoute1() {
        RouteDefinition definition = new RouteDefinition();
        Map<String, String> predicateParams = new HashMap<>(8);
        PredicateDefinition predicate = new PredicateDefinition();
        FilterDefinition filterDefinition = new FilterDefinition();
        Map<String, String> filterParams = new HashMap<>(8);
        // 如果設定路由type為0的話 則從註冊中心獲取服務
        URI uri = UriComponentsBuilder.fromUriString("lb://kaico-member/").build().toUri();
        // 定義的路由唯一的id
        definition.setId("member");
        predicate.setName("Path");
        //路由轉發地址
        predicateParams.put("pattern", "/member/**");
        predicate.setArgs(predicateParams);
 
        // 名稱是固定的, 路徑去字首
        filterDefinition.setName("StripPrefix");
        filterParams.put("_genkey_0", "1");
        filterDefinition.setArgs(filterParams);
        definition.setPredicates(Arrays.asList(predicate));
        definition.setFilters(Arrays.asList(filterDefinition));
        definition.setUri(uri);
        routeDefinitionWriter.save(Mono.just(definition)).subscribe();
        this.publisher.publishEvent(new RefreshRoutesEvent(this));
        return "success";
    }
 
}