springcloud gateway动态路由实现，mysql存储配置

标签：point   context   repo   cto   put   spring   重要   页面   als   

1、mysql数据库表结构

2、pom.xml依赖

1.  
   <dependency>
2.  
   <groupId>org.springframework.boot</groupId>
3.  
   <artifactId>spring-boot-starter-actuator</artifactId>
4.  
   </dependency>
5.  
   <!-- springcloud gateway网关依赖 -->
6.  
   <dependency>
7.  
   <groupId>org.springframework.cloud</groupId>
8.  
   <artifactId>spring-cloud-starter-gateway</artifactId>
9.  
   </dependency>
10.  
    <dependency>
11.  
    <groupId>org.springframework.cloud</groupId>
12.  
    <artifactId>spring-cloud-gateway-webflux</artifactId>
13.  
    </dependency>
14.  
     
15.  
    <!-- 集成redis -->
16.  
    <dependency>
17.  
    <groupId>org.springframework.boot</groupId>
18.  
    <artifactId>spring-boot-starter-data-redis</artifactId>
19.  
    </dependency>

3、application.yml添加

1.  
   #开启端点
2.  
   management:
3.  
   endpoints:
4.  
   web:
5.  
   exposure:
6.  
   include: ‘*‘
7.  
   security:
8.  
   enabled: false

4、核心配置类，加载路由配置到redis，官网核心包从redis获取路由配置，提高效率

1.  
   import com.alibaba.fastjson.JSON;
2.  
   import org.springframework.beans.factory.annotation.Autowired;
3.  
   import org.springframework.cloud.gateway.route.RouteDefinition;
4.  
   import org.springframework.cloud.gateway.route.RouteDefinitionRepository;
5.  
   import org.springframework.cloud.gateway.support.NotFoundException;
6.  
   import org.springframework.data.redis.core.RedisTemplate;
7.  
   import org.springframework.stereotype.Component;
8.  
   import reactor.core.publisher.Flux;
9.  
   import reactor.core.publisher.Mono;
10.  
     
11.  
    import java.util.ArrayList;
12.  
    import java.util.List;
13.  
     
14.  
    /**
15.  
    *将定义好的路由表信息通过此类读写到redis中
16.  
    */
17.  
    @Component
18.  
    public class RedisRouteDefinitionRepository implements RouteDefinitionRepository {
19.  
     
20.  
    public static final String GATEWAY_ROUTES = "gateway:routes";
21.  
    @Autowired
22.  
    private RedisTemplate<String,Object> redisTemplate;
23.  
     
24.  
    //请注意，此方法很重要，从redis取路由信息的方法，官方核心包要用，核心路由功能都是从redis取的
25.  
    @Override
26.  
    public Flux<RouteDefinition> getRouteDefinitions() {
27.  
    List<RouteDefinition> routeDefinitions = new ArrayList<>();
28.  
    redisTemplate.opsForHash().values(GATEWAY_ROUTES).stream().forEach(routeDefinition -> {
29.  
    routeDefinitions.add(JSON.parseObject(routeDefinition.toString(), RouteDefinition.class));
30.  
    });
31.  
    return Flux.fromIterable(routeDefinitions);
32.  
    }
33.  
     
34.  
    @Override
35.  
    public Mono<Void> save(Mono<RouteDefinition> route) {
36.  
    return route
37.  
    .flatMap(routeDefinition -> {
38.  
    redisTemplate.opsForHash().put(GATEWAY_ROUTES, routeDefinition.getId(),
39.  
    JSON.toJSONString(routeDefinition));
40.  
    return Mono.empty();
41.  
    });
42.  
    }
43.  
     
44.  
    @Override
45.  
    public Mono<Void> delete(Mono<String> routeId) {
46.  
    return routeId.flatMap(id -> {
47.  
    if (redisTemplate.opsForHash().hasKey(GATEWAY_ROUTES, id)) {
48.  
    redisTemplate.opsForHash().delete(GATEWAY_ROUTES, id);
49.  
    return Mono.empty();
50.  
    }
51.  
    return Mono.defer(() -> Mono.error(new NotFoundException("路由文件没有找到: " + routeId)));
52.  
    });
53.  
    }
54.  
     
55.  
    }

5、核心配置类，项目初始化加载数据库的路由配置到redis

1.  
   import java.net.URI;
2.  
   import java.util.Arrays;
3.  
   import java.util.HashMap;
4.  
   import java.util.List;
5.  
   import java.util.Map;
6.  
    
7.  
   import org.springframework.beans.factory.annotation.Autowired;
8.  
   import org.springframework.boot.CommandLineRunner;
9.  
   import org.springframework.cloud.gateway.event.RefreshRoutesEvent;
10.  
    import org.springframework.cloud.gateway.filter.FilterDefinition;
11.  
    import org.springframework.cloud.gateway.handler.predicate.PredicateDefinition;
12.  
    import org.springframework.cloud.gateway.route.RouteDefinition;
13.  
    import org.springframework.context.ApplicationEventPublisher;
14.  
    import org.springframework.context.ApplicationEventPublisherAware;
15.  
    import org.springframework.stereotype.Service;
16.  
    import org.springframework.web.util.UriComponentsBuilder;
17.  
     
18.  
    import com.alibaba.fastjson.JSON;
19.  
    import com.smc.gateway.dao.GatewayRouteMapper;
20.  
    import com.smc.gateway.entity.GatewayRoute;
21.  
    import com.smc.gateway.repository.RedisRouteDefinitionRepository;
22.  
     
23.  
    import lombok.extern.slf4j.Slf4j;
24.  
    import reactor.core.publisher.Mono;
25.  
     
26.  
    @Slf4j
27.  
    @Service
28.  
    public class GatewayServiceHandler implements ApplicationEventPublisherAware, CommandLineRunner {
29.  
    @Autowired
30.  
    private RedisRouteDefinitionRepository routeDefinitionWriter;
31.  
    private ApplicationEventPublisher publisher;
32.  
     
33.  
    @Override
34.  
    public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
35.  
    this.publisher = applicationEventPublisher;
36.  
    }
37.  
     
38.  
    //自己的获取数据dao
39.  
    @Autowired
40.  
    private GatewayRouteMapper gatewayRouteMapper;
41.  
     
42.  
    @Override
43.  
    public void run(String... args){
44.  
    this.loadRouteConfig();
45.  
    }
46.  
     
47.  
    public String loadRouteConfig() {
48.  
    log.info("====开始加载=====网关配置信息=========");
49.  
    //删除redis里面的路由配置信息
50.  
    redisTemplate.delete(RedisRouteDefinitionRepository.GATEWAY_ROUTES);
51.  
     
52.  
    //从数据库拿到基本路由配置
53.  
    List<GatewayRoute> gatewayRouteList = gatewayRouteMapper.queryAllRoutes();
54.  
    gatewayRouteList.forEach(gatewayRoute -> {
55.  
    RouteDefinition definition=handleData(gatewayRoute);
56.  
    routeDefinitionWriter.save(Mono.just(definition)).subscribe();
57.  
    });
58.  
     
59.  
    this.publisher.publishEvent(new RefreshRoutesEvent(this));
60.  
     
61.  
    log.info("=======网关配置信息===加载完成======");
62.  
    return "success";
63.  
    }
64.  
     
65.  
    public void saveRoute(GatewayRoute gatewayRoute){
66.  
    RouteDefinition definition=handleData(gatewayRoute);
67.  
    routeDefinitionWriter.save(Mono.just(definition)).subscribe();
68.  
    this.publisher.publishEvent(new RefreshRoutesEvent(this));
69.  
    }
70.  
     
71.  
    public void update(GatewayRoute gatewayRoute) {
72.  
    RouteDefinition definition=handleData(gatewayRoute);
73.  
    try {
74.  
    this.routeDefinitionWriter.delete(Mono.just(definition.getId()));
75.  
    routeDefinitionWriter.save(Mono.just(definition)).subscribe();
76.  
    this.publisher.publishEvent(new RefreshRoutesEvent(this));
77.  
    } catch (Exception e) {
78.  
    e.printStackTrace();
79.  
    }
80.  
    }
81.  
     
82.  
     
83.  
    public void deleteRoute(String routeId){
84.  
    routeDefinitionWriter.delete(Mono.just(routeId)).subscribe();
85.  
    this.publisher.publishEvent(new RefreshRoutesEvent(this));
86.  
    }
87.  
     
88.  
    /**
89.  
    * 路由数据转换公共方法
90.  
    * @param gatewayRoute
91.  
    * @return
92.  
    */
93.  
    private RouteDefinition handleData(GatewayRoute gatewayRoute){
94.  
    RouteDefinition definition = new RouteDefinition();
95.  
    Map<String, String> predicateParams = new HashMap<>(8);
96.  
    PredicateDefinition predicate = new PredicateDefinition();
97.  
    FilterDefinition filterDefinition = new FilterDefinition();
98.  
    Map<String, String> filterParams = new HashMap<>(8);
99.  
     
100.  
     URI uri = null;
101.  
     if(gatewayRoute.getUri().startsWith("http")){
102.  
     //http地址
103.  
     uri = UriComponentsBuilder.fromHttpUrl(gatewayRoute.getUri()).build().toUri();
104.  
     }else{
105.  
     //注册中心
106.  
     uri = UriComponentsBuilder.fromUriString("lb://"+gatewayRoute.getUri()).build().toUri();
107.  
     }
108.  
      
109.  
     definition.setId(gatewayRoute.getServiceId());
110.  
     // 名称是固定的，spring gateway会根据名称找对应的PredicateFactory
111.  
     predicate.setName("Path");
112.  
     predicateParams.put("pattern",gatewayRoute.getPredicates());
113.  
     predicate.setArgs(predicateParams);
114.  
      
115.  
     // 名称是固定的, 路径去前缀
116.  
     filterDefinition.setName("StripPrefix");
117.  
     filterParams.put("_genkey_0", gatewayRoute.getFilters().toString());
118.  
     filterDefinition.setArgs(filterParams);
119.  
      
120.  
     definition.setPredicates(Arrays.asList(predicate));
121.  
     definition.setFilters(Arrays.asList(filterDefinition));
122.  
     definition.setUri(uri);
123.  
     definition.setOrder(Integer.parseInt(gatewayRoute.getGOrder()));
124.  
      
125.  
     return definition;
126.  
     }
127.  
     }

6、自定义controller层；

     直接在数据库添加路由配置信息；

     前端页面增、删、改路由配置信息，并刷新redis使配置信息立即生效；

1.  
   import org.springframework.beans.factory.annotation.Autowired;
2.  
   import org.springframework.web.bind.annotation.GetMapping;
3.  
   import org.springframework.web.bind.annotation.PathVariable;
4.  
   import org.springframework.web.bind.annotation.PostMapping;
5.  
   import org.springframework.web.bind.annotation.RequestBody;
6.  
   import org.springframework.web.bind.annotation.RequestMapping;
7.  
   import org.springframework.web.bind.annotation.RestController;
8.  
   import org.springframework.beans.BeanUtils;
9.  
    
10.  
    import com.smc.gateway.dto.GatewayRouteDto;
11.  
    import com.smc.gateway.route.GatewayRouteService;
12.  
    import com.smc.gateway.route.GatewayServiceHandler;
13.  
     
14.  
    @RestController
15.  
    @RequestMapping("/route")
16.  
    public class RouteController {
17.  
     
18.  
    @Autowired
19.  
    private GatewayServiceHandler gatewayServiceHandler;
20.  
     
21.  
    @Autowired
22.  
    private GatewayRouteService gatewayRouteService;
23.  
     
24.  
    /**
25.  
    * 刷新路由配置
26.  
    *
27.  
    * @param gwdefinition
28.  
    * @return
29.  
    */
30.  
    @GetMapping("/refresh")
31.  
    public String refresh() throws Exception {
32.  
    return this.gatewayServiceHandler.loadRouteConfig();
33.  
    }
34.  
     
35.  
    /**
36.  
    * 增加路由记录
37.  
    *
38.  
    * @param gwdefinition
39.  
    * @return
40.  
    */
41.  
    @PostMapping("/add")
42.  
    public String add(@RequestBody GatewayRouteDto gatewayRouteDto) throws Exception {
43.  
    gatewayRouteService.add(gatewayRouteDto);
44.  
    GatewayRoute gatewayRoute=new GatewayRoute();
45.  
    BeanUtils.copyProperties(gatewayRouteDto, gatewayRoute);
46.  
    gatewayServiceHandler.saveRoute(gatewayRoute);
47.  
    return "success";
48.  
    }
49.  
     
50.  
    @PostMapping("/update")
51.  
    public String update(@RequestBody GatewayRouteDto gatewayRouteDto) throws Exception {
52.  
    gatewayRouteService.update(gatewayRouteDto);
53.  
    GatewayRoute gatewayRoute=new GatewayRoute();
54.  
    BeanUtils.copyProperties(gatewayRouteDto, gatewayRoute);
55.  
    gatewayServiceHandler.update(gatewayRoute);
56.  
    return "success";
57.  
    }
58.  
     
59.  
    @GetMapping("/delete")
60.  
    public String delete(@PathVariable String id) throws Exception {
61.  
    gatewayRouteService.delete(id);
62.  
    gatewayServiceHandler.deleteRoute(id);
63.  
    return "success";
64.  
    }
65.  
     
66.  
    }

7、自定义service层，增、删、改、查数据库路由配置信息

1.  
   import java.util.Date;
2.  
    
3.  
   import org.springframework.beans.BeanUtils;
4.  
   import org.springframework.beans.factory.annotation.Autowired;
5.  
   import org.springframework.stereotype.Service;
6.  
    
7.  
   import com.smc.gateway.dao.GatewayRouteMapper;
8.  
   import com.smc.gateway.dto.GatewayRouteDto;
9.  
   import com.smc.gateway.entity.GatewayRoute;
10.  
     
11.  
    @Service
12.  
    public class GatewayRouteService {
13.  
     
14.  
    @Autowired
15.  
    private GatewayRouteMapper gatewayRouteMapper;
16.  
     
17.  
    public Integer add(GatewayRouteDto gatewayRouteDto) {
18.  
    GatewayRoute gatewayRoute = new GatewayRoute();
19.  
    BeanUtils.copyProperties(gatewayRouteDto, gatewayRoute);
20.  
    gatewayRoute.setCreateDate(new Date());
21.  
    gatewayRoute.setCreatorId("");
22.  
    return gatewayRouteMapper.insertSelective(gatewayRoute);
23.  
    }
24.  
     
25.  
    public Integer update(GatewayRouteDto gatewayRouteDto) {
26.  
    GatewayRoute gatewayRoute = new GatewayRoute();
27.  
    BeanUtils.copyProperties(gatewayRouteDto, gatewayRoute);
28.  
    gatewayRoute.setUpdateDate(new Date());
29.  
    gatewayRoute.setUpdateId("");
30.  
    return gatewayRouteMapper.updateByPrimaryKeySelective(gatewayRoute);
31.  
    }
32.  
     
33.  
    public Integer delete(String id) {
34.  
    return gatewayRouteMapper.deleteByPrimaryKey(Long.parseLong(id));
35.  
    }
36.  
     
37.  
    }

8、前端参数dto

1.  
   import lombok.AllArgsConstructor;
2.  
   import lombok.Builder;
3.  
   import lombok.Data;
4.  
   import lombok.NoArgsConstructor;
5.  
    
6.  
   @Data
7.  
   @Builder
8.  
   @NoArgsConstructor
9.  
   @AllArgsConstructor
10.  
    public class GatewayRouteDto {
11.  
    private Long id;
12.  
     
13.  
    private String serviceId;
14.  
     
15.  
    private String uri;
16.  
     
17.  
    private String predicates;
18.  
     
19.  
    private String filters;
20.  
     
21.  
    private String order;
22.  
     
23.  
    private String remarks;
24.  
    }

9、数据库实体

1.  
   import java.util.Date;
2.  
   import lombok.AllArgsConstructor;
3.  
   import lombok.Builder;
4.  
   import lombok.Data;
5.  
   import lombok.NoArgsConstructor;
6.  
    
7.  
   /**
8.  
   * Created by Mybatis Generator on 2019/06/17
9.  
   */
10.  
    @Data
11.  
    @Builder
12.  
    @NoArgsConstructor
13.  
    @AllArgsConstructor
14.  
    public class GatewayRoute {
15.  
    private Long id;
16.  
     
17.  
    private String serviceId;
18.  
     
19.  
    private String uri;
20.  
     
21.  
    private String predicates;
22.  
     
23.  
    private String filters;
24.  
     
25.  
    private String order;
26.  
     
27.  
    private String creatorId;
28.  
     
29.  
    private Date createDate;
30.  
     
31.  
    private String updateId;
32.  
     
33.  
    private Date updateDate;
34.  
     
35.  
    private String remarks;
36.  
     
37.  
    private String delFlag;
38.  
    }

10、访问地址

查看路由配置信息  http://localhost:18080/actuator/gateway/routes

手动刷新路由配置信息  http://localhost:18080/route/refresh

1、mysql数据库表结构

2、pom.xml依赖

1.  
   <dependency>
2.  
   <groupId>org.springframework.boot</groupId>
3.  
   <artifactId>spring-boot-starter-actuator</artifactId>
4.  
   </dependency>
5.  
   <!-- springcloud gateway网关依赖 -->
6.  
   <dependency>
7.  
   <groupId>org.springframework.cloud</groupId>
8.  
   <artifactId>spring-cloud-starter-gateway</artifactId>
9.  
   </dependency>
10.  
    <dependency>
11.  
    <groupId>org.springframework.cloud</groupId>
12.  
    <artifactId>spring-cloud-gateway-webflux</artifactId>
13.  
    </dependency>
14.  
     
15.  
    <!-- 集成redis -->
16.  
    <dependency>
17.  
    <groupId>org.springframework.boot</groupId>
18.  
    <artifactId>spring-boot-starter-data-redis</artifactId>
19.  
    </dependency>

3、application.yml添加

1.  
   #开启端点
2.  
   management:
3.  
   endpoints:
4.  
   web:
5.  
   exposure:
6.  
   include: ‘*‘
7.  
   security:
8.  
   enabled: false

4、核心配置类，加载路由配置到redis，官网核心包从redis获取路由配置，提高效率

1.  
   import com.alibaba.fastjson.JSON;
2.  
   import org.springframework.beans.factory.annotation.Autowired;
3.  
   import org.springframework.cloud.gateway.route.RouteDefinition;
4.  
   import org.springframework.cloud.gateway.route.RouteDefinitionRepository;
5.  
   import org.springframework.cloud.gateway.support.NotFoundException;
6.  
   import org.springframework.data.redis.core.RedisTemplate;
7.  
   import org.springframework.stereotype.Component;
8.  
   import reactor.core.publisher.Flux;
9.  
   import reactor.core.publisher.Mono;
10.  
     
11.  
    import java.util.ArrayList;
12.  
    import java.util.List;
13.  
     
14.  
    /**
15.  
    *将定义好的路由表信息通过此类读写到redis中
16.  
    */
17.  
    @Component
18.  
    public class RedisRouteDefinitionRepository implements RouteDefinitionRepository {
19.  
     
20.  
    public static final String GATEWAY_ROUTES = "gateway:routes";
21.  
    @Autowired
22.  
    private RedisTemplate<String,Object> redisTemplate;
23.  
     
24.  
    //请注意，此方法很重要，从redis取路由信息的方法，官方核心包要用，核心路由功能都是从redis取的
25.  
    @Override
26.  
    public Flux<RouteDefinition> getRouteDefinitions() {
27.  
    List<RouteDefinition> routeDefinitions = new ArrayList<>();
28.  
    redisTemplate.opsForHash().values(GATEWAY_ROUTES).stream().forEach(routeDefinition -> {
29.  
    routeDefinitions.add(JSON.parseObject(routeDefinition.toString(), RouteDefinition.class));
30.  
    });
31.  
    return Flux.fromIterable(routeDefinitions);
32.  
    }
33.  
     
34.  
    @Override
35.  
    public Mono<Void> save(Mono<RouteDefinition> route) {
36.  
    return route
37.  
    .flatMap(routeDefinition -> {
38.  
    redisTemplate.opsForHash().put(GATEWAY_ROUTES, routeDefinition.getId(),
39.  
    JSON.toJSONString(routeDefinition));
40.  
    return Mono.empty();
41.  
    });
42.  
    }
43.  
     
44.  
    @Override
45.  
    public Mono<Void> delete(Mono<String> routeId) {
46.  
    return routeId.flatMap(id -> {
47.  
    if (redisTemplate.opsForHash().hasKey(GATEWAY_ROUTES, id)) {
48.  
    redisTemplate.opsForHash().delete(GATEWAY_ROUTES, id);
49.  
    return Mono.empty();
50.  
    }
51.  
    return Mono.defer(() -> Mono.error(new NotFoundException("路由文件没有找到: " + routeId)));
52.  
    });
53.  
    }
54.  
     
55.  
    }

5、核心配置类，项目初始化加载数据库的路由配置到redis

1.  
   import java.net.URI;
2.  
   import java.util.Arrays;
3.  
   import java.util.HashMap;
4.  
   import java.util.List;
5.  
   import java.util.Map;
6.  
    
7.  
   import org.springframework.beans.factory.annotation.Autowired;
8.  
   import org.springframework.boot.CommandLineRunner;
9.  
   import org.springframework.cloud.gateway.event.RefreshRoutesEvent;
10.  
    import org.springframework.cloud.gateway.filter.FilterDefinition;
11.  
    import org.springframework.cloud.gateway.handler.predicate.PredicateDefinition;
12.  
    import org.springframework.cloud.gateway.route.RouteDefinition;
13.  
    import org.springframework.context.ApplicationEventPublisher;
14.  
    import org.springframework.context.ApplicationEventPublisherAware;
15.  
    import org.springframework.stereotype.Service;
16.  
    import org.springframework.web.util.UriComponentsBuilder;
17.  
     
18.  
    import com.alibaba.fastjson.JSON;
19.  
    import com.smc.gateway.dao.GatewayRouteMapper;
20.  
    import com.smc.gateway.entity.GatewayRoute;
21.  
    import com.smc.gateway.repository.RedisRouteDefinitionRepository;
22.  
     
23.  
    import lombok.extern.slf4j.Slf4j;
24.  
    import reactor.core.publisher.Mono;
25.  
     
26.  
    @Slf4j
27.  
    @Service
28.  
    public class GatewayServiceHandler implements ApplicationEventPublisherAware, CommandLineRunner {
29.  
    @Autowired
30.  
    private RedisRouteDefinitionRepository routeDefinitionWriter;
31.  
    private ApplicationEventPublisher publisher;
32.  
     
33.  
    @Override
34.  
    public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
35.  
    this.publisher = applicationEventPublisher;
36.  
    }
37.  
     
38.  
    //自己的获取数据dao
39.  
    @Autowired
40.  
    private GatewayRouteMapper gatewayRouteMapper;
41.  
     
42.  
    @Override
43.  
    public void run(String... args){
44.  
    this.loadRouteConfig();
45.  
    }
46.  
     
47.  
    public String loadRouteConfig() {
48.  
    log.info("====开始加载=====网关配置信息=========");
49.  
    //删除redis里面的路由配置信息
50.  
    redisTemplate.delete(RedisRouteDefinitionRepository.GATEWAY_ROUTES);
51.  
     
52.  
    //从数据库拿到基本路由配置
53.  
    List<GatewayRoute> gatewayRouteList = gatewayRouteMapper.queryAllRoutes();
54.  
    gatewayRouteList.forEach(gatewayRoute -> {
55.  
    RouteDefinition definition=handleData(gatewayRoute);
56.  
    routeDefinitionWriter.save(Mono.just(definition)).subscribe();
57.  
    });
58.  
     
59.  
    this.publisher.publishEvent(new RefreshRoutesEvent(this));
60.  
     
61.  
    log.info("=======网关配置信息===加载完成======");
62.  
    return "success";
63.  
    }
64.  
     
65.  
    public void saveRoute(GatewayRoute gatewayRoute){
66.  
    RouteDefinition definition=handleData(gatewayRoute);
67.  
    routeDefinitionWriter.save(Mono.just(definition)).subscribe();
68.  
    this.publisher.publishEvent(new RefreshRoutesEvent(this));
69.  
    }
70.  
     
71.  
    public void update(GatewayRoute gatewayRoute) {
72.  
    RouteDefinition definition=handleData(gatewayRoute);
73.  
    try {
74.  
    this.routeDefinitionWriter.delete(Mono.just(definition.getId()));
75.  
    routeDefinitionWriter.save(Mono.just(definition)).subscribe();
76.  
    this.publisher.publishEvent(new RefreshRoutesEvent(this));
77.  
    } catch (Exception e) {
78.  
    e.printStackTrace();
79.  
    }
80.  
    }
81.  
     
82.  
     
83.  
    public void deleteRoute(String routeId){
84.  
    routeDefinitionWriter.delete(Mono.just(routeId)).subscribe();
85.  
    this.publisher.publishEvent(new RefreshRoutesEvent(this));
86.  
    }
87.  
     
88.  
    /**
89.  
    * 路由数据转换公共方法
90.  
    * @param gatewayRoute
91.  
    * @return
92.  
    */
93.  
    private RouteDefinition handleData(GatewayRoute gatewayRoute){
94.  
    RouteDefinition definition = new RouteDefinition();
95.  
    Map<String, String> predicateParams = new HashMap<>(8);
96.  
    PredicateDefinition predicate = new PredicateDefinition();
97.  
    FilterDefinition filterDefinition = new FilterDefinition();
98.  
    Map<String, String> filterParams = new HashMap<>(8);
99.  
     
100.  
     URI uri = null;
101.  
     if(gatewayRoute.getUri().startsWith("http")){
102.  
     //http地址
103.  
     uri = UriComponentsBuilder.fromHttpUrl(gatewayRoute.getUri()).build().toUri();
104.  
     }else{
105.  
     //注册中心
106.  
     uri = UriComponentsBuilder.fromUriString("lb://"+gatewayRoute.getUri()).build().toUri();
107.  
     }
108.  
      
109.  
     definition.setId(gatewayRoute.getServiceId());
110.  
     // 名称是固定的，spring gateway会根据名称找对应的PredicateFactory
111.  
     predicate.setName("Path");
112.  
     predicateParams.put("pattern",gatewayRoute.getPredicates());
113.  
     predicate.setArgs(predicateParams);
114.  
      
115.  
     // 名称是固定的, 路径去前缀
116.  
     filterDefinition.setName("StripPrefix");
117.  
     filterParams.put("_genkey_0", gatewayRoute.getFilters().toString());
118.  
     filterDefinition.setArgs(filterParams);
119.  
      
120.  
     definition.setPredicates(Arrays.asList(predicate));
121.  
     definition.setFilters(Arrays.asList(filterDefinition));
122.  
     definition.setUri(uri);
123.  
     definition.setOrder(Integer.parseInt(gatewayRoute.getGOrder()));
124.  
      
125.  
     return definition;
126.  
     }
127.  
     }

6、自定义controller层；

     直接在数据库添加路由配置信息；

     前端页面增、删、改路由配置信息，并刷新redis使配置信息立即生效；

1.  
   import org.springframework.beans.factory.annotation.Autowired;
2.  
   import org.springframework.web.bind.annotation.GetMapping;
3.  
   import org.springframework.web.bind.annotation.PathVariable;
4.  
   import org.springframework.web.bind.annotation.PostMapping;
5.  
   import org.springframework.web.bind.annotation.RequestBody;
6.  
   import org.springframework.web.bind.annotation.RequestMapping;
7.  
   import org.springframework.web.bind.annotation.RestController;
8.  
   import org.springframework.beans.BeanUtils;
9.  
    
10.  
    import com.smc.gateway.dto.GatewayRouteDto;
11.  
    import com.smc.gateway.route.GatewayRouteService;
12.  
    import com.smc.gateway.route.GatewayServiceHandler;
13.  
     
14.  
    @RestController
15.  
    @RequestMapping("/route")
16.  
    public class RouteController {
17.  
     
18.  
    @Autowired
19.  
    private GatewayServiceHandler gatewayServiceHandler;
20.  
     
21.  
    @Autowired
22.  
    private GatewayRouteService gatewayRouteService;
23.  
     
24.  
    /**
25.  
    * 刷新路由配置
26.  
    *
27.  
    * @param gwdefinition
28.  
    * @return
29.  
    */
30.  
    @GetMapping("/refresh")
31.  
    public String refresh() throws Exception {
32.  
    return this.gatewayServiceHandler.loadRouteConfig();
33.  
    }
34.  
     
35.  
    /**
36.  
    * 增加路由记录
37.  
    *
38.  
    * @param gwdefinition
39.  
    * @return
40.  
    */
41.  
    @PostMapping("/add")
42.  
    public String add(@RequestBody GatewayRouteDto gatewayRouteDto) throws Exception {
43.  
    gatewayRouteService.add(gatewayRouteDto);
44.  
    GatewayRoute gatewayRoute=new GatewayRoute();
45.  
    BeanUtils.copyProperties(gatewayRouteDto, gatewayRoute);
46.  
    gatewayServiceHandler.saveRoute(gatewayRoute);
47.  
    return "success";
48.  
    }
49.  
     
50.  
    @PostMapping("/update")
51.  
    public String update(@RequestBody GatewayRouteDto gatewayRouteDto) throws Exception {
52.  
    gatewayRouteService.update(gatewayRouteDto);
53.  
    GatewayRoute gatewayRoute=new GatewayRoute();
54.  
    BeanUtils.copyProperties(gatewayRouteDto, gatewayRoute);
55.  
    gatewayServiceHandler.update(gatewayRoute);
56.  
    return "success";
57.  
    }
58.  
     
59.  
    @GetMapping("/delete")
60.  
    public String delete(@PathVariable String id) throws Exception {
61.  
    gatewayRouteService.delete(id);
62.  
    gatewayServiceHandler.deleteRoute(id);
63.  
    return "success";
64.  
    }
65.  
     
66.  
    }

7、自定义service层，增、删、改、查数据库路由配置信息

1.  
   import java.util.Date;
2.  
    
3.  
   import org.springframework.beans.BeanUtils;
4.  
   import org.springframework.beans.factory.annotation.Autowired;
5.  
   import org.springframework.stereotype.Service;
6.  
    
7.  
   import com.smc.gateway.dao.GatewayRouteMapper;
8.  
   import com.smc.gateway.dto.GatewayRouteDto;
9.  
   import com.smc.gateway.entity.GatewayRoute;
10.  
     
11.  
    @Service
12.  
    public class GatewayRouteService {
13.  
     
14.  
    @Autowired
15.  
    private GatewayRouteMapper gatewayRouteMapper;
16.  
     
17.  
    public Integer add(GatewayRouteDto gatewayRouteDto) {
18.  
    GatewayRoute gatewayRoute = new GatewayRoute();
19.  
    BeanUtils.copyProperties(gatewayRouteDto, gatewayRoute);
20.  
    gatewayRoute.setCreateDate(new Date());
21.  
    gatewayRoute.setCreatorId("");
22.  
    return gatewayRouteMapper.insertSelective(gatewayRoute);
23.  
    }
24.  
     
25.  
    public Integer update(GatewayRouteDto gatewayRouteDto) {
26.  
    GatewayRoute gatewayRoute = new GatewayRoute();
27.  
    BeanUtils.copyProperties(gatewayRouteDto, gatewayRoute);
28.  
    gatewayRoute.setUpdateDate(new Date());
29.  
    gatewayRoute.setUpdateId("");
30.  
    return gatewayRouteMapper.updateByPrimaryKeySelective(gatewayRoute);
31.  
    }
32.  
     
33.  
    public Integer delete(String id) {
34.  
    return gatewayRouteMapper.deleteByPrimaryKey(Long.parseLong(id));
35.  
    }
36.  
     
37.  
    }

8、前端参数dto

1.  
   import lombok.AllArgsConstructor;
2.  
   import lombok.Builder;
3.  
   import lombok.Data;
4.  
   import lombok.NoArgsConstructor;
5.  
    
6.  
   @Data
7.  
   @Builder
8.  
   @NoArgsConstructor
9.  
   @AllArgsConstructor
10.  
    public class GatewayRouteDto {
11.  
    private Long id;
12.  
     
13.  
    private String serviceId;
14.  
     
15.  
    private String uri;
16.  
     
17.  
    private String predicates;
18.  
     
19.  
    private String filters;
20.  
     
21.  
    private String order;
22.  
     
23.  
    private String remarks;
24.  
    }

9、数据库实体

1.  
   import java.util.Date;
2.  
   import lombok.AllArgsConstructor;
3.  
   import lombok.Builder;
4.  
   import lombok.Data;
5.  
   import lombok.NoArgsConstructor;
6.  
    
7.  
   /**
8.  
   * Created by Mybatis Generator on 2019/06/17
9.  
   */
10.  
    @Data
11.  
    @Builder
12.  
    @NoArgsConstructor
13.  
    @AllArgsConstructor
14.  
    public class GatewayRoute {
15.  
    private Long id;
16.  
     
17.  
    private String serviceId;
18.  
     
19.  
    private String uri;
20.  
     
21.  
    private String predicates;
22.  
     
23.  
    private String filters;
24.  
     
25.  
    private String order;
26.  
     
27.  
    private String creatorId;
28.  
     
29.  
    private Date createDate;
30.  
     
31.  
    private String updateId;
32.  
     
33.  
    private Date updateDate;
34.  
     
35.  
    private String remarks;
36.  
     
37.  
    private String delFlag;
38.  
    }

10、访问地址

查看路由配置信息  http://localhost:18080/actuator/gateway/routes

手动刷新路由配置信息  http://localhost:18080/route/refresh

 转自：https://blog.csdn.net/qq_42714869/article/details/92794911

springcloud gateway动态路由实现，mysql存储配置

标签：point   context   repo   cto   put   spring   重要   页面   als   

原文地址：https://www.cnblogs.com/javalinux/p/14377494.html