Nginx gateway集群和动态网关的实现思路_Nginx

Nginx gateway集群和动态网关的实现思路

2023-05-17 11:55张志翔 ̮ Nginx

这篇文章主要介绍了Nginx gateway集群和动态网关,动态网关即任何配置都实现不用重启网关服务器都可以及时刷新，对Nginx gateway集群相关知识感兴趣的朋友一起看看吧

网关是系统的唯一对外的入口，介于客户端和服务器端之间的中间层，处理非业务功能，提供路由请求、鉴权、监控、缓存、限流等功能。无论你查看任何一个微服务项目架构，你都会发现在客户端和服务器端之间有一个网关，移动端的任何请求都必须经过网关才能到达服务端。

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

基于nginx部署gateway集群

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

Nginx gateway集群和动态网关的实现思路

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

动态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";

									    }

									}