|
|
@ -1,21 +1,21 @@ |
|
|
|
package com.gitee.sop.gateway.manager; |
|
|
|
package com.gitee.sop.gateway.manager; |
|
|
|
|
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSON; |
|
|
|
import com.alibaba.fastjson.JSON; |
|
|
|
|
|
|
|
import com.alibaba.nacos.api.annotation.NacosInjected; |
|
|
|
import com.alibaba.nacos.api.config.ConfigService; |
|
|
|
import com.alibaba.nacos.api.config.ConfigService; |
|
|
|
import com.alibaba.nacos.api.config.listener.AbstractListener; |
|
|
|
import com.alibaba.nacos.api.config.listener.AbstractListener; |
|
|
|
import com.gitee.fastmybatis.core.query.Query; |
|
|
|
import com.gitee.fastmybatis.core.query.Query; |
|
|
|
import com.gitee.sop.gateway.mapper.ConfigRouteBaseMapper; |
|
|
|
import com.gitee.sop.gateway.mapper.ConfigRouteBaseMapper; |
|
|
|
import com.gitee.sop.gateway.mapper.ConfigRouteLimitMapper; |
|
|
|
import com.gitee.sop.gateway.mapper.ConfigRouteLimitMapper; |
|
|
|
import com.gitee.sop.gatewaycommon.bean.ChannelMsg; |
|
|
|
import com.gitee.sop.gatewaycommon.bean.ChannelMsg; |
|
|
|
import com.gitee.sop.gatewaycommon.bean.RouteDefinition; |
|
|
|
|
|
|
|
import com.gitee.sop.gatewaycommon.bean.NacosConfigs; |
|
|
|
import com.gitee.sop.gatewaycommon.bean.NacosConfigs; |
|
|
|
import com.gitee.sop.gatewaycommon.bean.RouteConfig; |
|
|
|
import com.gitee.sop.gatewaycommon.bean.RouteConfig; |
|
|
|
|
|
|
|
import com.gitee.sop.gatewaycommon.bean.RouteDefinition; |
|
|
|
import com.gitee.sop.gatewaycommon.bean.TargetRoute; |
|
|
|
import com.gitee.sop.gatewaycommon.bean.TargetRoute; |
|
|
|
import com.gitee.sop.gatewaycommon.manager.DefaultRouteConfigManager; |
|
|
|
import com.gitee.sop.gatewaycommon.manager.DefaultRouteConfigManager; |
|
|
|
import com.gitee.sop.gatewaycommon.manager.RouteRepositoryContext; |
|
|
|
import com.gitee.sop.gatewaycommon.manager.RouteRepositoryContext; |
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.cloud.alibaba.nacos.NacosConfigProperties; |
|
|
|
|
|
|
|
import org.springframework.core.env.Environment; |
|
|
|
import org.springframework.core.env.Environment; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
|
|
|
|
|
|
|
@ -38,8 +38,8 @@ public class DbRouteConfigManager extends DefaultRouteConfigManager { |
|
|
|
@Autowired |
|
|
|
@Autowired |
|
|
|
Environment environment; |
|
|
|
Environment environment; |
|
|
|
|
|
|
|
|
|
|
|
@Autowired |
|
|
|
@NacosInjected |
|
|
|
private NacosConfigProperties nacosConfigProperties; |
|
|
|
private ConfigService configService; |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void load() { |
|
|
|
public void load() { |
|
|
@ -75,7 +75,6 @@ public class DbRouteConfigManager extends DefaultRouteConfigManager { |
|
|
|
|
|
|
|
|
|
|
|
@PostConstruct |
|
|
|
@PostConstruct |
|
|
|
protected void after() throws Exception { |
|
|
|
protected void after() throws Exception { |
|
|
|
ConfigService configService = nacosConfigProperties.configServiceInstance(); |
|
|
|
|
|
|
|
configService.addListener(NacosConfigs.DATA_ID_ROUTE_CONFIG, NacosConfigs.GROUP_CHANNEL, new AbstractListener() { |
|
|
|
configService.addListener(NacosConfigs.DATA_ID_ROUTE_CONFIG, NacosConfigs.GROUP_CHANNEL, new AbstractListener() { |
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void receiveConfigInfo(String configInfo) { |
|
|
|
public void receiveConfigInfo(String configInfo) { |
|
|
|