Nginx gateway集群和动态网关

Posted 2022-11-10 张志翔 ̮

网关怎么实现集群：使用nginx实现。

基于nginx部署gateway集群

1、将网关项目多个部署启动
例如：
网关1 127.0.0.1:81
网关1 127.0.0.1:82

3、各个微服务如何知道是哪个网关请求的
在网关的过滤器中给请求头添加可以区别网关的信息。

动态Gateway

动态网关：任何配置都实现不用重启网关服务器都可以及时刷新。
实现思路：
1、分布式配置中心，阅读性差。
2、基于数据库表结构设计。

gateway提供对应的接口：1、直接新增路由；2、直接修改路由

使用api添加gateway 路由，直接注入该bean 调用 loadRoute1方法就可以添加路由策略了。

@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";
    

使用数据库实现动态路由

根据上面的案例，将配置信息添加到数据库中（数据库表的设计只要符合只用场景就可以了，没有什么特别要求），在调用相关的api添加到gateway中即可。

参考学习文档：https://www.cnblogs.com/crazymakercircle/p/11704077.html

官放文档：https://docs.spring.io/spring-cloud-gateway/docs/3.0.5-SNAPSHOT/reference/html/#gateway-starter