目錄
- 基于nginx部署gateway集群
- 動態(tài)Gateway
- 使用數(shù)據(jù)庫實現(xiàn)動態(tài)路由
網(wǎng)關(guān)是系統(tǒng)的唯一對外的入口，介于客戶端和服務(wù)器端之間的中間層，處理非業(yè)務(wù)功能，提供路由請求、鑒權(quán)、監(jiān)控、緩存、限流等功能。無論你查看任何一個微服務(wù)項目架構(gòu)，你都會發(fā)現(xiàn)在客戶端和服務(wù)器端之間有一個網(wǎng)關(guān)，移動端的任何請求都必須經(jīng)過網(wǎng)關(guān)才能到達(dá)服務(wù)端。
網(wǎng)關(guān)怎么實現(xiàn)集群：使用nginx實現(xiàn)。
基于nginx部署gateway集群
1、將網(wǎng)關(guān)項目多個部署啟動
例如：
網(wǎng)關(guān)1 127.0.0.1:81
網(wǎng)關(guān)1 127.0.0.1:82
2、各個微服務(wù)如何知道是哪個網(wǎng)關(guān)請求的
在網(wǎng)關(guān)的過濾器中給請求頭添加可以區(qū)別網(wǎng)關(guān)的信息。
動態(tài)Gateway
動態(tài)網(wǎng)關(guān)：任何配置都實現(xiàn)不用重啟網(wǎng)關(guān)服務(wù)器都可以及時刷新。
實現(xiàn)思路：
1、分布式配置中心，閱讀性差。
2、基于數(shù)據(jù)庫表結(jié)構(gòu)設(shè)計。
gateway提供對應(yīng)的接口：1、直接新增路由；2、直接修改路由
使用api添加gateway 路由，直接注入該bean 調(diào)用 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() {
// 從數(shù)據(jù)庫查詢配置的網(wǎng)關(guān)配置
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的話 則從注冊中心獲取服務(wù)
URI uri = UriComponentsBuilder.fromUriString("lb://kaico-member/").build().toUri();
// 定義的路由唯一的id
definition.setId("member");
predicate.setName("Path");
//路由轉(zhuǎn)發(fā)地址
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";
}
}
使用數(shù)據(jù)庫實現(xiàn)動態(tài)路由
根據(jù)上面的案例，將配置信息添加到數(shù)據(jù)庫中（數(shù)據(jù)庫表的設(shè)計只要符合只用場景就可以了，沒有什么特別要求），在調(diào)用相關(guān)的api添加到gateway中即可。
參考學(xué)習(xí)文檔：https://www.cnblogs.com/crazymakercircle/p/11704077.html
官放文檔：https://docs.spring.io/spring-cloud-gateway/docs/3.0.5-SNAPSHOT/reference/html/#gateway-starter
