You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by ra...@apache.org on 2021/03/24 03:28:50 UTC
[dubbo-admin] branch develop updated: Fix route rule some problem
(#712)
This is an automated email from the ASF dual-hosted git repository.
ranke pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/dubbo-admin.git
The following commit(s) were added to refs/heads/develop by this push:
new e049435 Fix route rule some problem (#712)
e049435 is described below
commit e049435181bdf40a4b251eb492200d76178673a4
Author: haoyann <10...@qq.com>
AuthorDate: Wed Mar 24 11:27:37 2021 +0800
Fix route rule some problem (#712)
* `BaseDTO` remove service
fix condition query problem
* remove condition service group
fix serviceGroup and serviceVersion null string
* fix test
* fix condition application query
* fix ci
---
.../dubbo/admin/common/util/ConvertUtil.java | 26 ++--
.../controller/ConditionRoutesController.java | 76 ++++++-----
.../org/apache/dubbo/admin/model/dto/BaseDTO.java | 18 ---
.../{BaseDTO.java => ConditionRouteResultDTO.java} | 36 ++----
.../apache/dubbo/admin/service/RouteService.java | 9 +-
.../dubbo/admin/service/impl/RouteServiceImpl.java | 25 ++--
.../admin/controller/AccessesControllerTest.java | 3 +-
.../controller/ConditionRoutesControllerTest.java | 141 +++++++++++++++++++--
.../src/components/governance/RoutingRule.vue | 43 ++++---
9 files changed, 253 insertions(+), 124 deletions(-)
diff --git a/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/common/util/ConvertUtil.java b/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/common/util/ConvertUtil.java
index cc7a2b8..7179601 100644
--- a/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/common/util/ConvertUtil.java
+++ b/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/common/util/ConvertUtil.java
@@ -54,13 +54,20 @@ public class ConvertUtil {
if (StringUtils.isNotEmpty(baseDTO.getApplication())) {
id = baseDTO.getApplication();
} else {
- // id format: "${class}:${version}:${group}"
- id = new StringBuilder(baseDTO.getService()).append(COLON).append(null2EmptyString(baseDTO.getServiceVersion()))
- .append(COLON).append(null2EmptyString(baseDTO.getServiceGroup())).toString();
+ id = baseDTO.getService();
}
return id;
}
+ public static String getIdFromDTO(BaseDTO baseDTO, String serviceVersion, String serviceGroup) {
+ if (StringUtils.isNotEmpty(baseDTO.getApplication())) {
+ return baseDTO.getApplication();
+ }
+ // id format: "${class}:${version}:${group}"
+ return new StringBuilder(baseDTO.getService()).append(COLON).append(null2EmptyString(serviceVersion))
+ .append(COLON).append(null2EmptyString(serviceGroup)).toString();
+ }
+
/**
* Detach interface class, version and group from id.
* @param id
@@ -74,17 +81,18 @@ public class ConvertUtil {
}
}
- public static String getServiceIdFromDTO(BaseDTO baseDTO, boolean groupAsFolder) {
+ public static String getServiceIdFromDTO(BaseDTO baseDTO, String serviceVersion, String serviceGroup,
+ boolean groupAsFolder) {
StringBuilder buf = new StringBuilder();
buf.append(baseDTO.getService());
- if (StringUtils.isNotEmpty(baseDTO.getServiceVersion())) {
- buf.append(COLON).append(baseDTO.getServiceVersion());
+ if (StringUtils.isNotEmpty(serviceVersion)) {
+ buf.append(COLON).append(serviceVersion);
}
- if (StringUtils.isNotEmpty(baseDTO.getServiceGroup())) {
+ if (StringUtils.isNotEmpty(serviceGroup)) {
if (groupAsFolder) {
- buf.insert(0, baseDTO.getServiceGroup() + "/");
+ buf.insert(0, serviceGroup + "/");
} else {
- buf.append(COLON).append(baseDTO.getServiceGroup());
+ buf.append(COLON).append(serviceGroup);
}
}
return buf.toString();
diff --git a/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/controller/ConditionRoutesController.java b/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/controller/ConditionRoutesController.java
index 6cbebe7..6a7a63b 100644
--- a/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/controller/ConditionRoutesController.java
+++ b/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/controller/ConditionRoutesController.java
@@ -24,7 +24,9 @@ import org.apache.dubbo.admin.common.exception.ParamValidationException;
import org.apache.dubbo.admin.common.exception.ResourceNotFoundException;
import org.apache.dubbo.admin.common.exception.VersionValidationException;
import org.apache.dubbo.admin.common.util.Constants;
+import org.apache.dubbo.admin.common.util.ConvertUtil;
import org.apache.dubbo.admin.model.dto.ConditionRouteDTO;
+import org.apache.dubbo.admin.model.dto.ConditionRouteResultDTO;
import org.apache.dubbo.admin.service.ProviderService;
import org.apache.dubbo.admin.service.RouteService;
import org.springframework.beans.factory.annotation.Autowired;
@@ -55,7 +57,9 @@ public class ConditionRoutesController {
@RequestMapping(method = RequestMethod.POST)
@ResponseStatus(HttpStatus.CREATED)
- public boolean createRule(@RequestBody ConditionRouteDTO routeDTO, @PathVariable String env) {
+ public boolean createRule(@RequestBody ConditionRouteDTO routeDTO, @PathVariable String env,
+ @RequestParam(required = false) String serviceVersion,
+ @RequestParam(required = false) String serviceGroup) {
String serviceName = routeDTO.getService();
String app = routeDTO.getApplication();
if (StringUtils.isEmpty(serviceName) && StringUtils.isEmpty(app)) {
@@ -64,8 +68,7 @@ public class ConditionRoutesController {
if (StringUtils.isNotEmpty(app) && providerService.findVersionInApplication(app).equals("2.6")) {
throw new VersionValidationException("dubbo 2.6 does not support application scope routing rule");
}
-
- routeService.createConditionRoute(routeDTO);
+ routeService.createConditionRoute(routeDTO, serviceVersion, serviceGroup);
return true;
}
@@ -75,33 +78,34 @@ public class ConditionRoutesController {
@RequestParam(required = false) String serviceGroup) {
id = id.replace(Constants.ANY_VALUE, Constants.PATH_SEPARATOR);
ConditionRouteDTO crDTO = new ConditionRouteDTO();
+ String serviceName = newConditionRoute.getService();
+ if (StringUtils.isNotEmpty(serviceName)) {
+ id = ConvertUtil.getIdFromDTO(newConditionRoute, serviceVersion, serviceGroup);
+ }
crDTO.setService(id);
- crDTO.setServiceVersion(serviceVersion);
- crDTO.setServiceGroup(serviceGroup);
ConditionRouteDTO oldConditionRoute = routeService.findConditionRoute(crDTO);
if (oldConditionRoute == null) {
throw new ResourceNotFoundException("can not find route rule for: " + id);
}
- routeService.updateConditionRoute(newConditionRoute);
+ routeService.updateConditionRoute(newConditionRoute, serviceVersion, serviceGroup);
return true;
}
@RequestMapping(method = RequestMethod.GET)
- public List<ConditionRouteDTO> searchRoutes(@RequestParam(required = false) String application,
- @RequestParam(required = false) String service, @PathVariable String env,
- @RequestParam(required = false) String serviceVersion,
- @RequestParam(required = false) String serviceGroup) {
- ConditionRouteDTO conditionRoute;
- List<ConditionRouteDTO> result = new ArrayList<>();
+ public List<ConditionRouteResultDTO> searchRoutes(@RequestParam(required = false) String application,
+ @RequestParam(required = false) String service, @PathVariable String env,
+ @RequestParam(required = false) String serviceVersion,
+ @RequestParam(required = false) String serviceGroup) {
+ ConditionRouteResultDTO conditionRoute;
+ List<ConditionRouteResultDTO> result = new ArrayList<>();
ConditionRouteDTO crDTO = new ConditionRouteDTO();
if (StringUtils.isNotBlank(application)) {
crDTO.setService(application);
conditionRoute = routeService.findConditionRoute(crDTO);
} else if (StringUtils.isNotBlank(service)) {
crDTO.setService(service);
- crDTO.setServiceVersion(serviceVersion);
- crDTO.setServiceGroup(serviceGroup);
- conditionRoute = routeService.findConditionRoute(crDTO);
+ String id = ConvertUtil.getIdFromDTO(crDTO, serviceVersion, serviceGroup);
+ conditionRoute = routeService.findConditionRoute(id);
} else {
throw new ParamValidationException("Either Service or application is required.");
}
@@ -112,15 +116,18 @@ public class ConditionRoutesController {
}
@RequestMapping(value = "/{id}", method = RequestMethod.GET)
- public ConditionRouteDTO detailRoute(@PathVariable String id, @PathVariable String env,
- @RequestParam(required = false) String serviceVersion,
- @RequestParam(required = false) String serviceGroup) {
+ public ConditionRouteResultDTO detailRoute(@PathVariable String id, @PathVariable String env,
+ @RequestParam(required = false) String serviceVersion,
+ @RequestParam(required = false) String serviceGroup,
+ @RequestParam String scope) {
id = id.replace(Constants.ANY_VALUE, Constants.PATH_SEPARATOR);
ConditionRouteDTO crDTO = new ConditionRouteDTO();
crDTO.setService(id);
- crDTO.setServiceVersion(serviceVersion);
- crDTO.setServiceGroup(serviceGroup);
- ConditionRouteDTO conditionRoute = routeService.findConditionRoute(crDTO);
+ if (Constants.SERVICE.equals(scope)) {
+ id = ConvertUtil.getIdFromDTO(crDTO, serviceVersion, serviceGroup);
+ crDTO.setService(id);
+ }
+ ConditionRouteResultDTO conditionRoute = routeService.findConditionRoute(crDTO);
if (conditionRoute == null || conditionRoute.getConditions() == null) {
throw new ResourceNotFoundException("Unknown ID!");
}
@@ -130,12 +137,15 @@ public class ConditionRoutesController {
@RequestMapping(value = "/{id}", method = RequestMethod.DELETE)
public boolean deleteRoute(@PathVariable String id, @PathVariable String env,
@RequestParam(required = false) String serviceVersion,
- @RequestParam(required = false) String serviceGroup) {
+ @RequestParam(required = false) String serviceGroup,
+ @RequestParam String scope) {
id = id.replace(Constants.ANY_VALUE, Constants.PATH_SEPARATOR);
ConditionRouteDTO crDTO = new ConditionRouteDTO();
crDTO.setService(id);
- crDTO.setServiceVersion(serviceVersion);
- crDTO.setServiceGroup(serviceGroup);
+ if (Constants.SERVICE.equals(scope)) {
+ id = ConvertUtil.getIdFromDTO(crDTO, serviceVersion, serviceGroup);
+ crDTO.setService(id);
+ }
routeService.deleteConditionRoute(crDTO);
return true;
}
@@ -143,12 +153,15 @@ public class ConditionRoutesController {
@RequestMapping(value = "/enable/{id}", method = RequestMethod.PUT)
public boolean enableRoute(@PathVariable String id, @PathVariable String env,
@RequestParam(required = false) String serviceVersion,
- @RequestParam(required = false) String serviceGroup) {
+ @RequestParam(required = false) String serviceGroup,
+ @RequestParam String scope) {
id = id.replace(Constants.ANY_VALUE, Constants.PATH_SEPARATOR);
ConditionRouteDTO crDTO = new ConditionRouteDTO();
crDTO.setService(id);
- crDTO.setServiceVersion(serviceVersion);
- crDTO.setServiceGroup(serviceGroup);
+ if (Constants.SERVICE.equals(scope)) {
+ id = ConvertUtil.getIdFromDTO(crDTO, serviceVersion, serviceGroup);
+ crDTO.setService(id);
+ }
routeService.enableConditionRoute(crDTO);
return true;
}
@@ -156,12 +169,15 @@ public class ConditionRoutesController {
@RequestMapping(value = "/disable/{id}", method = RequestMethod.PUT)
public boolean disableRoute(@PathVariable String id, @PathVariable String env,
@RequestParam(required = false) String serviceVersion,
- @RequestParam(required = false) String serviceGroup) {
+ @RequestParam(required = false) String serviceGroup,
+ @RequestParam String scope) {
id = id.replace(Constants.ANY_VALUE, Constants.PATH_SEPARATOR);
ConditionRouteDTO crDTO = new ConditionRouteDTO();
crDTO.setService(id);
- crDTO.setServiceVersion(serviceVersion);
- crDTO.setServiceGroup(serviceGroup);
+ if (Constants.SERVICE.equals(scope)) {
+ id = ConvertUtil.getIdFromDTO(crDTO, serviceVersion, serviceGroup);
+ crDTO.setService(id);
+ }
routeService.disableConditionRoute(crDTO);
return true;
}
diff --git a/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/model/dto/BaseDTO.java b/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/model/dto/BaseDTO.java
index 203bf72..223b25f 100644
--- a/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/model/dto/BaseDTO.java
+++ b/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/model/dto/BaseDTO.java
@@ -24,8 +24,6 @@ package org.apache.dubbo.admin.model.dto;
public abstract class BaseDTO {
private String application;
private String service;
- private String serviceVersion;
- private String serviceGroup;
public String getApplication() {
return application;
@@ -42,20 +40,4 @@ public abstract class BaseDTO {
public void setService(String service) {
this.service = service;
}
-
- public String getServiceVersion() {
- return serviceVersion;
- }
-
- public void setServiceVersion(String serviceVersion) {
- this.serviceVersion = serviceVersion;
- }
-
- public String getServiceGroup() {
- return serviceGroup;
- }
-
- public void setServiceGroup(String serviceGroup) {
- this.serviceGroup = serviceGroup;
- }
}
diff --git a/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/model/dto/BaseDTO.java b/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/model/dto/ConditionRouteResultDTO.java
similarity index 73%
copy from dubbo-admin-server/src/main/java/org/apache/dubbo/admin/model/dto/BaseDTO.java
copy to dubbo-admin-server/src/main/java/org/apache/dubbo/admin/model/dto/ConditionRouteResultDTO.java
index 203bf72..2f9d247 100644
--- a/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/model/dto/BaseDTO.java
+++ b/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/model/dto/ConditionRouteResultDTO.java
@@ -14,34 +14,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
+
package org.apache.dubbo.admin.model.dto;
-/**
- * BaseDTO
- *
- * For receive ID parameter with @RequestBody
- */
-public abstract class BaseDTO {
- private String application;
- private String service;
+
+public class ConditionRouteResultDTO extends ConditionRouteDTO {
private String serviceVersion;
private String serviceGroup;
-
- public String getApplication() {
- return application;
- }
-
- public void setApplication(String application) {
- this.application = application;
- }
-
- public String getService() {
- return service;
- }
-
- public void setService(String service) {
- this.service = service;
- }
+ private String scope;
public String getServiceVersion() {
return serviceVersion;
@@ -58,4 +38,12 @@ public abstract class BaseDTO {
public void setServiceGroup(String serviceGroup) {
this.serviceGroup = serviceGroup;
}
+
+ public String getScope() {
+ return scope;
+ }
+
+ public void setScope(String scope) {
+ this.scope = scope;
+ }
}
diff --git a/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/service/RouteService.java b/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/service/RouteService.java
index b63c175..ef42f25 100644
--- a/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/service/RouteService.java
+++ b/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/service/RouteService.java
@@ -18,6 +18,7 @@ package org.apache.dubbo.admin.service;
import org.apache.dubbo.admin.model.dto.AccessDTO;
import org.apache.dubbo.admin.model.dto.ConditionRouteDTO;
+import org.apache.dubbo.admin.model.dto.ConditionRouteResultDTO;
import org.apache.dubbo.admin.model.dto.TagRouteDTO;
/**
@@ -26,9 +27,9 @@ import org.apache.dubbo.admin.model.dto.TagRouteDTO;
*/
public interface RouteService {
- void createConditionRoute(ConditionRouteDTO conditionRoute);
+ void createConditionRoute(ConditionRouteDTO conditionRoute, String serviceVersion, String serviceGroup);
- void updateConditionRoute(ConditionRouteDTO newConditionRoute);
+ void updateConditionRoute(ConditionRouteDTO newConditionRoute, String serviceVersion, String serviceGroup);
void deleteConditionRoute(ConditionRouteDTO conditionRoute);
@@ -46,9 +47,9 @@ public interface RouteService {
void disableConditionRoute(ConditionRouteDTO conditionRoute);
- ConditionRouteDTO findConditionRoute(ConditionRouteDTO crDTO);
+ ConditionRouteResultDTO findConditionRoute(ConditionRouteDTO crDTO);
- ConditionRouteDTO findConditionRoute(String id);
+ ConditionRouteResultDTO findConditionRoute(String id);
void createTagRoute(TagRouteDTO tagRoute);
diff --git a/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/service/impl/RouteServiceImpl.java b/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/service/impl/RouteServiceImpl.java
index fe0f085..a365eef 100644
--- a/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/service/impl/RouteServiceImpl.java
+++ b/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/service/impl/RouteServiceImpl.java
@@ -24,12 +24,14 @@ import org.apache.dubbo.admin.common.util.YamlParser;
import org.apache.dubbo.admin.model.domain.Route;
import org.apache.dubbo.admin.model.dto.AccessDTO;
import org.apache.dubbo.admin.model.dto.ConditionRouteDTO;
+import org.apache.dubbo.admin.model.dto.ConditionRouteResultDTO;
import org.apache.dubbo.admin.model.dto.TagRouteDTO;
import org.apache.dubbo.admin.model.store.RoutingRule;
import org.apache.dubbo.admin.model.store.TagRoute;
import org.apache.dubbo.admin.service.RouteService;
import org.apache.dubbo.common.URL;
import org.apache.dubbo.common.utils.StringUtils;
+import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Component;
import java.util.LinkedList;
@@ -41,8 +43,8 @@ public class RouteServiceImpl extends AbstractService implements RouteService {
private String prefix = Constants.CONFIG_KEY;
@Override
- public void createConditionRoute(ConditionRouteDTO conditionRoute) {
- String id = ConvertUtil.getIdFromDTO(conditionRoute);
+ public void createConditionRoute(ConditionRouteDTO conditionRoute, String serviceVersion, String serviceGroup) {
+ String id = ConvertUtil.getIdFromDTO(conditionRoute, serviceVersion, serviceGroup);
String path = getPath(id, Constants.CONDITION_ROUTE);
String existConfig = dynamicConfiguration.getConfig(path);
RoutingRule existRule = null;
@@ -63,8 +65,8 @@ public class RouteServiceImpl extends AbstractService implements RouteService {
}
@Override
- public void updateConditionRoute(ConditionRouteDTO newConditionRoute) {
- String id = ConvertUtil.getIdFromDTO(newConditionRoute);
+ public void updateConditionRoute(ConditionRouteDTO newConditionRoute, String serviceVersion, String serviceGroup) {
+ String id = ConvertUtil.getIdFromDTO(newConditionRoute, serviceVersion, serviceGroup);
String path = getPath(id, Constants.CONDITION_ROUTE);
String existConfig = dynamicConfiguration.getConfig(path);
if (existConfig == null) {
@@ -261,12 +263,12 @@ public class RouteServiceImpl extends AbstractService implements RouteService {
}
@Override
- public ConditionRouteDTO findConditionRoute(ConditionRouteDTO crDTO) {
+ public ConditionRouteResultDTO findConditionRoute(ConditionRouteDTO crDTO) {
return findConditionRoute(ConvertUtil.getIdFromDTO(crDTO));
}
@Override
- public ConditionRouteDTO findConditionRoute(String id) {
+ public ConditionRouteResultDTO findConditionRoute(String id) {
String path = getPath(id, Constants.CONDITION_ROUTE);
String config = dynamicConfiguration.getConfig(path);
if (config != null) {
@@ -276,12 +278,17 @@ public class RouteServiceImpl extends AbstractService implements RouteService {
if (org.apache.commons.lang3.StringUtils.isNotBlank(service)) {
conditionRouteDTO.setService(service.replace("*", "/"));
}
+ ConditionRouteResultDTO result = new ConditionRouteResultDTO();
+ BeanUtils.copyProperties(conditionRouteDTO, result);
+ result.setScope(routingRule.getScope());
String[] detachResult = ConvertUtil.detachId(id);
if (detachResult.length > 1) {
- conditionRouteDTO.setServiceVersion(detachResult[1]);
- conditionRouteDTO.setServiceGroup(detachResult[2]);
+ result.setServiceVersion(detachResult[1]);
+ }
+ if (detachResult.length > 2) {
+ result.setServiceGroup(detachResult[2]);
}
- return conditionRouteDTO;
+ return result;
}
return null;
}
diff --git a/dubbo-admin-server/src/test/java/org/apache/dubbo/admin/controller/AccessesControllerTest.java b/dubbo-admin-server/src/test/java/org/apache/dubbo/admin/controller/AccessesControllerTest.java
index e087898..aaf6c73 100644
--- a/dubbo-admin-server/src/test/java/org/apache/dubbo/admin/controller/AccessesControllerTest.java
+++ b/dubbo-admin-server/src/test/java/org/apache/dubbo/admin/controller/AccessesControllerTest.java
@@ -22,6 +22,7 @@ import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.dubbo.admin.AbstractSpringIntegrationTest;
import org.apache.dubbo.admin.model.dto.AccessDTO;
import org.apache.dubbo.admin.model.dto.ConditionRouteDTO;
+import org.apache.dubbo.admin.model.dto.ConditionRouteResultDTO;
import org.apache.dubbo.admin.service.ProviderService;
import org.apache.dubbo.admin.service.RouteService;
import org.junit.After;
@@ -130,7 +131,7 @@ public class AccessesControllerTest extends AbstractSpringIntegrationTest {
restTemplate.put(url("/api/{env}/rules/access/{id}"), accessDTO, env, id);
verify(routeService).findConditionRoute(id);
//
- ConditionRouteDTO conditionRouteDTO = mock(ConditionRouteDTO.class);
+ ConditionRouteResultDTO conditionRouteDTO = mock(ConditionRouteResultDTO.class);
when(routeService.findConditionRoute(id)).thenReturn(conditionRouteDTO);
restTemplate.put(url("/api/{env}/rules/access/{id}"), accessDTO, env, id);
verify(routeService).updateAccess(any(AccessDTO.class));
diff --git a/dubbo-admin-server/src/test/java/org/apache/dubbo/admin/controller/ConditionRoutesControllerTest.java b/dubbo-admin-server/src/test/java/org/apache/dubbo/admin/controller/ConditionRoutesControllerTest.java
index 4a879cf..0a7b284 100644
--- a/dubbo-admin-server/src/test/java/org/apache/dubbo/admin/controller/ConditionRoutesControllerTest.java
+++ b/dubbo-admin-server/src/test/java/org/apache/dubbo/admin/controller/ConditionRoutesControllerTest.java
@@ -86,6 +86,8 @@ public class ConditionRoutesControllerTest extends AbstractSpringIntegrationTest
String uuid = UUID.randomUUID().toString();
String application = "application" + uuid;
String service = "service" + uuid;
+ String serviceVersion = "version" + uuid;
+ String serviceGroup = "group" + uuid;
List<String> conditions = Collections.singletonList("=> host != 172.22.3.91");
ConditionRouteDTO dto = new ConditionRouteDTO();
@@ -93,7 +95,7 @@ public class ConditionRoutesControllerTest extends AbstractSpringIntegrationTest
dto.setConditions(conditions);
ResponseEntity<String> responseEntity = restTemplate.postForEntity(
- url("/api/{env}/rules/route/condition"), dto, String.class, env
+ url("/api/{env}/rules/route/condition" + "?serviceVersion=" + serviceVersion + "&serviceGroup=" + serviceGroup), dto, String.class, env
);
assertThat(responseEntity.getStatusCode(), is(HttpStatus.CREATED));
@@ -172,9 +174,9 @@ public class ConditionRoutesControllerTest extends AbstractSpringIntegrationTest
}
@Test
- public void shouldDeleteRule() throws Exception {
+ public void serviceShouldDeleteRule() throws Exception {
String service = "org.apache.dubbo.demo.DemoService";
- String content = "conditions:\n"
+ String serviceContent = "conditions:\n"
+ "- => host != 172.22.3.111\n"
+ "- => host != 172.22.3.112\n"
+ "enabled: true\n"
@@ -185,13 +187,40 @@ public class ConditionRoutesControllerTest extends AbstractSpringIntegrationTest
+ "scope: service";
String path = "/dubbo/config/dubbo/" + service + "::.condition-router";
zkClient.create().creatingParentContainersIfNeeded().forPath(path);
- zkClient.setData().forPath(path, content.getBytes());
+ zkClient.setData().forPath(path, serviceContent.getBytes());
assertNotNull("zk path should not be null before deleting", zkClient.checkExists().forPath(path));
ResponseEntity<String> responseEntity = restTemplate.exchange(
- url("/api/{env}/rules/route/condition/{service}"), HttpMethod.DELETE,
- null, String.class, env, service
+ url("/api/{env}/rules/route/condition/{service}" + "?scope=service"), HttpMethod.DELETE,
+ null, String.class, env, service
+ );
+ assertThat(responseEntity.getStatusCode(), is(HttpStatus.OK));
+
+ assertNull(zkClient.checkExists().forPath(path));
+ }
+
+ @Test
+ public void applicationShouldDeleteRule() throws Exception {
+ String application = "test-application";
+ String serviceContent = "conditions:\n"
+ + "- => host != 172.22.3.111\n"
+ + "- => host != 172.22.3.112\n"
+ + "enabled: true\n"
+ + "force: true\n"
+ + "key: " + application + "\n"
+ + "priority: 0\n"
+ + "runtime: false\n"
+ + "scope: application";
+ String path = "/dubbo/config/dubbo/" + application + ".condition-router";
+ zkClient.create().creatingParentContainersIfNeeded().forPath(path);
+ zkClient.setData().forPath(path, serviceContent.getBytes());
+
+ assertNotNull("zk path should not be null before deleting", zkClient.checkExists().forPath(path));
+
+ ResponseEntity<String> responseEntity = restTemplate.exchange(
+ url("/api/{env}/rules/route/condition/{service}" + "?scope=application"), HttpMethod.DELETE,
+ null, String.class, env, application
);
assertThat(responseEntity.getStatusCode(), is(HttpStatus.OK));
@@ -201,13 +230,13 @@ public class ConditionRoutesControllerTest extends AbstractSpringIntegrationTest
@Test
public void shouldThrowWhenDetailRouteWithUnknownId() {
ResponseEntity<String> responseEntity = restTemplate.getForEntity(
- url("/api/{env}/rules/route/condition/{id}"), String.class, env, "non-existed-service"
+ url("/api/{env}/rules/route/condition/{id}" + "?scope=service"), String.class, env, "non-existed-service"
);
assertThat(responseEntity.getStatusCode(), is(HttpStatus.NOT_FOUND));
}
@Test
- public void shouldGetRouteDetail() throws Exception {
+ public void serviceShouldGetRouteDetail() throws Exception {
String service = "org.apache.dubbo.demo.DemoService";
String content = "conditions:\n"
+ "- => host != 172.22.3.111\n"
@@ -223,7 +252,7 @@ public class ConditionRoutesControllerTest extends AbstractSpringIntegrationTest
zkClient.setData().forPath(path, content.getBytes());
ResponseEntity<ConditionRouteDTO> responseEntity = restTemplate.getForEntity(
- url("/api/{env}/rules/route/condition/{id}"), ConditionRouteDTO.class, env, service
+ url("/api/{env}/rules/route/condition/{id}" + "?scope=service"), ConditionRouteDTO.class, env, service
);
assertThat(responseEntity.getStatusCode(), is(HttpStatus.OK));
@@ -234,7 +263,34 @@ public class ConditionRoutesControllerTest extends AbstractSpringIntegrationTest
}
@Test
- public void shouldEnableRoute() throws Exception {
+ public void applicationShouldGetRouteDetail() throws Exception {
+ String application = "test-application";
+ String content = "conditions:\n"
+ + "- => host != 172.22.3.111\n"
+ + "- => host != 172.22.3.112\n"
+ + "enabled: true\n"
+ + "force: true\n"
+ + "key: " + application + "\n"
+ + "priority: 0\n"
+ + "runtime: false\n"
+ + "scope: application";
+ String path = "/dubbo/config/dubbo/" + application + ".condition-router";
+ zkClient.create().creatingParentContainersIfNeeded().forPath(path);
+ zkClient.setData().forPath(path, content.getBytes());
+
+ ResponseEntity<ConditionRouteDTO> responseEntity = restTemplate.getForEntity(
+ url("/api/{env}/rules/route/condition/{id}" + "?scope=application"), ConditionRouteDTO.class, env, application
+ );
+ assertThat(responseEntity.getStatusCode(), is(HttpStatus.OK));
+
+ ConditionRouteDTO conditionRouteDTO = responseEntity.getBody();
+ assertNotNull(conditionRouteDTO);
+ assertThat(conditionRouteDTO.getConditions(), hasSize(2));
+ assertThat(conditionRouteDTO.getConditions(), containsInAnyOrder("=> host != 172.22.3.111", "=> host != 172.22.3.112"));
+ }
+
+ @Test
+ public void serviceShouldEnableRoute() throws Exception {
String service = "org.apache.dubbo.demo.DemoService";
String content = "conditions:\n"
+ "- => host != 172.22.3.111\n"
@@ -254,7 +310,7 @@ public class ConditionRoutesControllerTest extends AbstractSpringIntegrationTest
RoutingRule rule = YamlParser.loadObject(updatedConfig, RoutingRule.class);
assertFalse(rule.isEnabled());
- restTemplate.put(url("/api/{env}/rules/route/condition/enable/{id}"), null, env, service);
+ restTemplate.put(url("/api/{env}/rules/route/condition/enable/{id}" + "?scope=service"), null, env, service);
bytes = zkClient.getData().forPath(path);
updatedConfig = new String(bytes);
@@ -263,7 +319,36 @@ public class ConditionRoutesControllerTest extends AbstractSpringIntegrationTest
}
@Test
- public void shouldDisableRoute() throws Exception {
+ public void applicationShouldEnableRoute() throws Exception {
+ String application = "test-application";
+ String content = "conditions:\n"
+ + "- => host != 172.22.3.111\n"
+ + "- => host != 172.22.3.112\n"
+ + "enabled: false\n"
+ + "force: true\n"
+ + "key: " + application + "\n"
+ + "priority: 0\n"
+ + "runtime: false\n"
+ + "scope: service";
+ String path = "/dubbo/config/dubbo/" + application + ".condition-router";
+ zkClient.create().creatingParentContainersIfNeeded().forPath(path);
+ zkClient.setData().forPath(path, content.getBytes());
+
+ byte[] bytes = zkClient.getData().forPath(path);
+ String updatedConfig = new String(bytes);
+ RoutingRule rule = YamlParser.loadObject(updatedConfig, RoutingRule.class);
+ assertFalse(rule.isEnabled());
+
+ restTemplate.put(url("/api/{env}/rules/route/condition/enable/{id}" + "?scope=application"), null, env, application);
+
+ bytes = zkClient.getData().forPath(path);
+ updatedConfig = new String(bytes);
+ rule = YamlParser.loadObject(updatedConfig, RoutingRule.class);
+ assertTrue(rule.isEnabled());
+ }
+
+ @Test
+ public void serviceShouldDisableRoute() throws Exception {
String service = "org.apache.dubbo.demo.DemoService";
String content = "conditions:\n"
+ "- => host != 172.22.3.111\n"
@@ -283,11 +368,41 @@ public class ConditionRoutesControllerTest extends AbstractSpringIntegrationTest
RoutingRule rule = YamlParser.loadObject(updatedConfig, RoutingRule.class);
assertTrue(rule.isEnabled());
- restTemplate.put(url("/api/{env}/rules/route/condition/disable/{id}"), null, env, service);
+ restTemplate.put(url("/api/{env}/rules/route/condition/disable/{id}" + "?scope=service"), null, env, service);
+
+ bytes = zkClient.getData().forPath(path);
+ updatedConfig = new String(bytes);
+ rule = YamlParser.loadObject(updatedConfig, RoutingRule.class);
+ assertFalse(rule.isEnabled());
+ }
+
+ @Test
+ public void applicationShouldDisableRoute() throws Exception {
+ String application = "test-application";
+ String content = "conditions:\n"
+ + "- => host != 172.22.3.111\n"
+ + "- => host != 172.22.3.112\n"
+ + "enabled: true\n"
+ + "force: false\n"
+ + "key: " + application + "\n"
+ + "priority: 0\n"
+ + "runtime: false\n"
+ + "scope: application";
+ String path = "/dubbo/config/dubbo/" + application + ".condition-router";
+ zkClient.create().creatingParentContainersIfNeeded().forPath(path);
+ zkClient.setData().forPath(path, content.getBytes());
+
+ byte[] bytes = zkClient.getData().forPath(path);
+ String updatedConfig = new String(bytes);
+ RoutingRule rule = YamlParser.loadObject(updatedConfig, RoutingRule.class);
+ assertTrue(rule.isEnabled());
+
+ restTemplate.put(url("/api/{env}/rules/route/condition/disable/{id}" + "?scope=application"), null, env, application);
bytes = zkClient.getData().forPath(path);
updatedConfig = new String(bytes);
rule = YamlParser.loadObject(updatedConfig, RoutingRule.class);
assertFalse(rule.isEnabled());
}
+
}
diff --git a/dubbo-admin-ui/src/components/governance/RoutingRule.vue b/dubbo-admin-ui/src/components/governance/RoutingRule.vue
index 4316161..b61deb9 100644
--- a/dubbo-admin-ui/src/components/governance/RoutingRule.vue
+++ b/dubbo-admin-ui/src/components/governance/RoutingRule.vue
@@ -90,7 +90,7 @@
>
<template slot="items" slot-scope="props">
<td class="text-xs-left">{{ props.item.service }}</td>
- <td class="text-xs-left">{{ props.item.group }}</td>
+ <td class="text-xs-left">{{ props.item.serviceGroup }}</td>
<td class="text-xs-left">{{ props.item.enabled }}</td>
<td class="text-xs-center px-0">
<v-tooltip bottom v-for="op in operations" :key="op.id">
@@ -381,15 +381,15 @@ export default {
}
const vm = this
rule.service = this.service
- rule.serviceVersion = this.serviceVersion
- rule.serviceGroup = this.serviceGroup
+ const serviceVersion = this.serviceVersion == null ? '' : this.serviceVersion
+ const serviceGroup = this.serviceGroup == null ? '' : this.serviceGroup
rule.application = this.application
if (this.updateId !== '') {
if (this.updateId === 'close') {
this.closeDialog()
} else {
rule.id = this.updateId
- this.$axios.put('/rules/route/condition/' + rule.id, rule)
+ this.$axios.put('/rules/route/condition/' + rule.id + '?serviceVersion=' + serviceVersion + '&serviceGroup=' + serviceGroup, rule)
.then(response => {
if (response.status === 200) {
if (vm.service) {
@@ -407,7 +407,7 @@ export default {
})
}
} else {
- this.$axios.post('/rules/route/condition/', rule)
+ this.$axios.post('/rules/route/condition/' + '?serviceVersion=' + serviceVersion + '&serviceGroup=' + serviceGroup, rule)
.then(response => {
if (response.status === 201) {
if (vm.service) {
@@ -439,27 +439,34 @@ export default {
if (itemId.includes('/')) {
itemId = itemId.replace('/', '*')
}
+ const serviceVersion = item.serviceVersion == null ? '' : item.serviceVersion
+ const serviceGroup = item.serviceGroup == null ? '' : item.serviceGroup
+ const scope = item.scope == null ? '' : item.scope
switch (icon) {
case 'visibility':
- this.$axios.get('/rules/route/condition/' + itemId + '?serviceVersion=' + item.serviceVersion + '&serviceGroup=' + item.serviceGroup)
+ this.$axios.get('/rules/route/condition/' + itemId + '?serviceVersion=' + serviceVersion + '&serviceGroup=' + serviceGroup + '&scope=' + scope)
.then(response => {
const conditionRoute = response.data
this.serviceVersion = conditionRoute.serviceVersion
this.serviceGroup = conditionRoute.serviceGroup
+ this.scope = conditionRoute.scope
delete conditionRoute.serviceVersion
delete conditionRoute.serviceGroup
+ delete conditionRoute.scope
this.handleBalance(conditionRoute, true)
this.updateId = 'close'
})
break
case 'edit':
- this.$axios.get('/rules/route/condition/' + itemId + '?serviceVersion=' + item.serviceVersion + '&serviceGroup=' + item.serviceGroup)
+ this.$axios.get('/rules/route/condition/' + itemId + '?serviceVersion=' + serviceVersion + '&serviceGroup=' + serviceGroup + '&scope=' + scope)
.then(response => {
const conditionRoute = response.data
this.serviceVersion = conditionRoute.serviceVersion
this.serviceGroup = conditionRoute.serviceGroup
+ this.scope = conditionRoute.scope
delete conditionRoute.serviceVersion
delete conditionRoute.serviceGroup
+ delete conditionRoute.scope
this.handleBalance(conditionRoute, false)
this.updateId = itemId
})
@@ -468,22 +475,25 @@ export default {
this.openWarn(' Are you sure to block Routing Rule', 'service: ' + oldItemId)
this.warnStatus.operation = 'disable'
this.warnStatus.id = itemId
- this.warnStatus.serviceVersion = item.serviceVersion
- this.warnStatus.serviceGroup = item.serviceGroup
+ this.warnStatus.serviceVersion = serviceVersion
+ this.warnStatus.serviceGroup = serviceGroup
+ this.warnStatus.scope = scope
break
case 'check_circle_outline':
this.openWarn(' Are you sure to enable Routing Rule', 'service: ' + oldItemId)
this.warnStatus.operation = 'enable'
this.warnStatus.id = itemId
- this.warnStatus.serviceVersion = item.serviceVersion
- this.warnStatus.serviceGroup = item.serviceGroup
+ this.warnStatus.serviceVersion = serviceVersion
+ this.warnStatus.serviceGroup = serviceGroup
+ this.warnStatus.scope = scope
break
case 'delete':
this.openWarn('warnDeleteRouteRule', 'service: ' + oldItemId)
this.warnStatus.operation = 'delete'
this.warnStatus.id = itemId
- this.warnStatus.serviceVersion = item.serviceVersion
- this.warnStatus.serviceGroup = item.serviceGroup
+ this.warnStatus.serviceVersion = serviceVersion
+ this.warnStatus.serviceGroup = serviceGroup
+ this.warnStatus.scope = scope
}
},
handleBalance: function (conditionRoute, readonly) {
@@ -507,8 +517,9 @@ export default {
const operation = warnStatus.operation
const serviceVersion = warnStatus.serviceVersion
const serviceGroup = warnStatus.serviceGroup
+ const scope = warnStatus.scope
if (operation === 'delete') {
- this.$axios.delete('/rules/route/condition/' + id + '?serviceVersion=' + serviceVersion + '&serviceGroup=' + serviceGroup)
+ this.$axios.delete('/rules/route/condition/' + id + '?serviceVersion=' + serviceVersion + '&serviceGroup=' + serviceGroup + '&scope=' + scope)
.then(response => {
if (response.status === 200) {
this.warn = false
@@ -517,7 +528,7 @@ export default {
}
})
} else if (operation === 'disable') {
- this.$axios.put('/rules/route/condition/disable/' + id + '?serviceVersion=' + serviceVersion + '&serviceGroup=' + serviceGroup)
+ this.$axios.put('/rules/route/condition/disable/' + id + '?serviceVersion=' + serviceVersion + '&serviceGroup=' + serviceGroup + '&scope=' + scope)
.then(response => {
if (response.status === 200) {
this.warn = false
@@ -526,7 +537,7 @@ export default {
}
})
} else if (operation === 'enable') {
- this.$axios.put('/rules/route/condition/enable/' + id + '?serviceVersion=' + serviceVersion + '&serviceGroup=' + serviceGroup)
+ this.$axios.put('/rules/route/condition/enable/' + id + '?serviceVersion=' + serviceVersion + '&serviceGroup=' + serviceGroup + '&scope=' + scope)
.then(response => {
if (response.status === 200) {
this.warn = false