SpringCloudGateway网关动态路由

　　背景
　　现在很多服务都要求不下线发布，这就要求我们在开发微服务的时候，新增一个接口或者服务中心，必须做到线上发布。新增中心
　　新增一个服务中心，gateway有几种方法，最常见的就是在配置文件里面新增routes路由。现在我们把这个配置文件改成读取redis。先上redis数据结构。
　　所有中心
　　用户中心redis路由结构
　　用的map结构存储，这里面有几个重要参数，filters：在路由前面加上/api，id:名称，predicates:匹配/user/**的路径，uri:发送的服务（appetite-user对应用户中心），当然我们还可以自定义一些其他的，自己探索吧。有了这些后，我们就能访问到对应的服务，比如我前端访问/user/a/b，到了网关就会将这个路径转化成/api/user/a/b，去访问用户中心对应的服务。代码import com.alibaba.fastjson2.JSON; import java.util.ArrayList; import java.util.List; import javax.annotation.Resource; import lombok.extern.slf4j.Slf4j; import org.springframework.cloud.gateway.route.RouteDefinition; import org.springframework.cloud.gateway.route.RouteDefinitionRepository; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Component; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono;  /**  * @program: appetite-work  * @description: redis作为网关路由存储  * @author: pl  * @create: 2022-08-08 15:35  **/ @Slf4j @Component public class RedisRouteDefinitionRepository implements RouteDefinitionRepository {    /**    * hash存储的key    */   public static final String GATEWAY_ROUTES = ＂appetite_gateway_dynamic_route＂;    @Resource   private RedisTemplate redisTemplate;    /**    * 获取路由信息    *    * @return    */   @Override   public Flux getRouteDefinitions() {      List routeDefinitions = new ArrayList<>();     redisTemplate.opsForHash().values(GATEWAY_ROUTES).stream()         .forEach(routeDefinition -> routeDefinitions             .add(JSON.parseObject(routeDefinition.toString(), RouteDefinition.class)));     return Flux.fromIterable(routeDefinitions);    }    public List getRoutes() {     List routeDefinitions = new ArrayList<>();     redisTemplate.opsForHash().values(GATEWAY_ROUTES).stream()         .forEach(routeDefinition -> routeDefinitions             .add(JSON.parseObject(routeDefinition.toString(), RouteDefinition.class)));     return routeDefinitions;    }    @Override   public Mono save(Mono route) {     return route.flatMap(routeDefinition -> {       redisTemplate.opsForHash()           .put(GATEWAY_ROUTES, routeDefinition.getId(), JSON.toJSONString(routeDefinition));       return Mono.empty();     });   }    @Override   public Mono delete(Mono routeId) {     return routeId.flatMap(id -> {       redisTemplate.opsForHash().delete(GATEWAY_ROUTES, id);       return Mono.empty();     });   } }
　　这个是在springCloudGateway的代码，既然只要redis有这些数据，那么我就能在其他中心对redis进行操作，从而达到动态加载，我放在了认证中心，如下：import com.alibaba.fastjson2.JSON; import com.pl.appetite.constants.CakeConstants; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service;  import java.util.*;  /**  * @program: appetite20221020  * @description: 网关新增中心到redis  * @author: pl  * @create: 2022-11-19 20:01  **/ @Service public class GatewayRedisService {      public RedisTemplate redisTemplate;      public GatewayRedisService(RedisTemplate redisTemplate) {         this.redisTemplate = redisTemplate;     }      /**      * 新增网关中心路由      * @param centerCode  appetite-user      */     public void addCenter(String centerCode){         String[] code = centerCode.split(＂-＂);          Map filMap = new LinkedHashMap();          List