線上項目發(fā)布一般有以下幾種方案:

停機發(fā)布 這種發(fā)布一般在夜里或者進行大版本升級的時候發(fā)布，因為需要停機，所以現(xiàn)在大家都在研究 Devops 方案。

藍綠部署 需要準備兩個相同的環(huán)境。一個環(huán)境新版本，一個環(huán)境舊版本，通過負載均衡進行切換與回滾，目的是為了減少服務(wù)停止時間。

滾動部署 就是在升級過程中，并不一下子啟動所有新版本，是先啟動一臺新版本，再停止一臺老版本，然后再啟動一臺新版本，再停止一臺老版本，直到升級完成。基于 k8s 的升級方案默認就是滾動部署。

灰度發(fā)布 也叫金絲雀發(fā)布，灰度發(fā)布中，常常按照用戶設(shè)置路由權(quán)重，例如 90%的用戶維持使用老版本，10%的用戶嘗鮮新版本。不同版本應(yīng)用共存，經(jīng)常與 A/B 測試一起使用，用于測試選擇多種方案。

上邊介紹的幾種發(fā)布方案，主要是引出我們接下來介紹的 spring-cloud-gateway 動態(tài)路由，我們可以基于動態(tài)路由、負載均衡和策略加載去實現(xiàn) 灰度發(fā)布。當然現(xiàn)在有很多開源的框架可以實現(xiàn) 灰度發(fā)布，這里只是研究學(xué)習(xí)。

spring-cloud-gateway 默認將路由加載在內(nèi)存中。具體可以參見 InMemoryRouteDefinitionRepository 類的實現(xiàn)。

這里我們基于 Redis 實現(xiàn)動態(tài)路由。基礎(chǔ)項目見 spring-cloud-gateway 簡介

1. 將 actuator 的端點暴露出來。

management: endpoints: web: exposure: include: '*'

2. redis 配置

@Configurationpublic class RedisConfig { @Bean(name = {'redisTemplate', 'stringRedisTemplate'}) public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory factory) { StringRedisTemplate redisTemplate = new StringRedisTemplate(); redisTemplate.setConnectionFactory(factory); return redisTemplate; }}

3. 將原內(nèi)存路由持久化到 redis

@Componentpublic class RedisRouteDefinitionRepository implements RouteDefinitionRepository { /** * hash存儲的key */ public static final String GATEWAY_ROUTES = 'gateway_dynamic_route'; @Resource private StringRedisTemplate redisTemplate; /** * 獲取路由信息 * @return */ @Override public Flux<RouteDefinition> getRouteDefinitions() { List<RouteDefinition> routeDefinitions = new ArrayList<>(); redisTemplate.opsForHash().values(GATEWAY_ROUTES).stream().forEach(routeDefinition -> routeDefinitions.add(JSON.parseObject(routeDefinition.toString(), RouteDefinition.class))); return Flux.fromIterable(routeDefinitions); } @Override public Mono<Void> save(Mono<RouteDefinition> route) { return route.flatMap(routeDefinition -> { redisTemplate.opsForHash().put(GATEWAY_ROUTES, routeDefinition.getId(), JSONObject.toJSONString(routeDefinition)); return Mono.empty(); }); } @Override public Mono<Void> delete(Mono<String> routeId) { return routeId.flatMap(id -> { if (redisTemplate.opsForHash().hasKey(GATEWAY_ROUTES, id)) {redisTemplate.opsForHash().delete(GATEWAY_ROUTES, id);return Mono.empty(); } return Mono.defer(() -> Mono.error(new NotFoundException('route definition is not found, routeId:' + routeId))); }); }}

4. 重寫動態(tài)路由服務(wù)

@Servicepublic class GatewayDynamicRouteService implements ApplicationEventPublisherAware { @Resource private RedisRouteDefinitionRepository redisRouteDefinitionRepository; private ApplicationEventPublisher applicationEventPublisher; /** * 增加路由 * @param routeDefinition * @return */ public int add(RouteDefinition routeDefinition) { redisRouteDefinitionRepository.save(Mono.just(routeDefinition)).subscribe(); applicationEventPublisher.publishEvent(new RefreshRoutesEvent(this)); return 1; } /** * 更新 * @param routeDefinition * @return */ public int update(RouteDefinition routeDefinition) { redisRouteDefinitionRepository.delete(Mono.just(routeDefinition.getId())); redisRouteDefinitionRepository.save(Mono.just(routeDefinition)).subscribe(); applicationEventPublisher.publishEvent(new RefreshRoutesEvent(this)); return 1; } /** * 刪除 * @param id * @return */ public Mono<ResponseEntity<Object>> delete(String id) { return redisRouteDefinitionRepository.delete(Mono.just(id)).then(Mono.defer(() -> Mono.just(ResponseEntity.ok().build()))).onErrorResume(t -> t instanceof NotFoundException, t -> Mono.just(ResponseEntity.notFound().build())); } @Override public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) { this.applicationEventPublisher = applicationEventPublisher; }}

5. 對外暴露接口

@RestController@RequestMapping('/gateway')public class GatewayDynamicRouteController { @Resource private GatewayDynamicRouteService gatewayDynamicRouteService; @PostMapping('/add') public String create(@RequestBody RouteDefinition entity) { int result = gatewayDynamicRouteService.add(entity); return String.valueOf(result); } @PostMapping('/update') public String update(@RequestBody RouteDefinition entity) { int result = gatewayDynamicRouteService.update(entity); return String.valueOf(result); } @DeleteMapping('/delete/{id}') public Mono<ResponseEntity<Object>> delete(@PathVariable String id) { return gatewayDynamicRouteService.delete(id); }}

測試

測試前刪除我們配置的靜態(tài)路由，因為靜態(tài)路由和 redis 動態(tài)路由同時存在時取并集。

訪問 http://localhost:2000/actuator/gateway/routes , 可以看到只有默認路由。

[ { 'route_id': 'CompositeDiscoveryClient_consul', 'route_definition': { 'id': 'CompositeDiscoveryClient_consul', 'predicates': [{ 'name': 'Path', 'args': { 'pattern': '/consul/**' }} ], 'filters': [{ 'name': 'RewritePath', 'args': { 'regexp': '/consul/(?<remaining>.*)', 'replacement': '/${remaining}' }} ], 'uri': 'lb://consul', 'order': 0 }, 'order': 0 }, { 'route_id': 'CompositeDiscoveryClient_idc-gateway', 'route_definition': { 'id': 'CompositeDiscoveryClient_idc-gateway', 'predicates': [{ 'name': 'Path', 'args': { 'pattern': '/idc-gateway/**' }} ], 'filters': [{ 'name': 'RewritePath', 'args': { 'regexp': '/idc-gateway/(?<remaining>.*)', 'replacement': '/${remaining}' }} ], 'uri': 'lb://idc-gateway', 'order': 0 }, 'order': 0 }, { 'route_id': 'CompositeDiscoveryClient_idc-provider1', 'route_definition': { 'id': 'CompositeDiscoveryClient_idc-provider1', 'predicates': [{ 'name': 'Path', 'args': { 'pattern': '/idc-provider1/**' }} ], 'filters': [{ 'name': 'RewritePath', 'args': { 'regexp': '/idc-provider1/(?<remaining>.*)', 'replacement': '/${remaining}' }} ], 'uri': 'lb://idc-provider1', 'order': 0 }, 'order': 0 }, { 'route_id': 'CompositeDiscoveryClient_idc-provider2', 'route_definition': { 'id': 'CompositeDiscoveryClient_idc-provider2', 'predicates': [{ 'name': 'Path', 'args': { 'pattern': '/idc-provider2/**' }} ], 'filters': [{ 'name': 'RewritePath', 'args': { 'regexp': '/idc-provider2/(?<remaining>.*)', 'replacement': '/${remaining}' }} ], 'uri': 'lb://idc-provider2', 'order': 0 }, 'order': 0 }]

這個時候訪問 http://192.168.124.5:2000/idc-provider1/provider1/1 根據(jù)結(jié)果可以推測能正確路由到 provider1， 測試結(jié)果一致。

創(chuàng)建 provider1 路由，將路徑設(shè)置為 /p1/**，測試是否生效。

POST 請求 http://localhost:2000/gateway/add

{ 'id':'provider1', 'predicates':[ { 'name':'Path', 'args':{ '_genkey_0':'/p1/**' } }, { 'name':'RemoteAddr', 'args':{ '_genkey_0':'192.168.124.5/16' } } ], 'filters':[ { 'name':'StripPrefix', 'args':{ '_genkey_0':'1' } } ], 'uri':'lb://idc-provider1', 'order':0}

查看 redis 存儲，或者請求 http://localhost:2000/actuator/gateway/routes , 都可以看到配置成功。

訪問

curl http://localhost:2000/p1/provider1/1

結(jié)果輸出 2001，與期望一致。

由此可見動態(tài)路由已經(jīng)生效。

到此這篇關(guān)于spring-cloud-gateway動態(tài)路由的實現(xiàn)方法的文章就介紹到這了,更多相關(guān)spring-cloud-gateway動態(tài)路由內(nèi)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！