diff --git a/README.md b/README.md index b6c1d32a..012d5562 100644 --- a/README.md +++ b/README.md @@ -127,7 +127,7 @@ System.out.println(responseData); - sop-gateway：网关，统一访问入口，含`Spring Cloud Zuul`和`Spring Cloud Gateway`实现 - sop-example：微服务示例，含springboot,springmvc示例 - sop-website：开放平台对应网站，提供文档API、沙箱测试等内容 -- sop-auth：应用授权服务 +- sop-auth：应用授权服务示例 - sop-admin：后台管理 - sop-sdk：基础sdk，含Java、C#版本 - sop-test：接口调用测试用例 @@ -137,6 +137,7 @@ System.out.println(responseData); - master：发版分支（当前为4.0版本） - develop：日常开发分支 - eureka：使用eureka注册中心 +- pr：接受PR的分支，提交PR请提交到此分支 ## 相关文档 diff --git a/changelog.md b/changelog.md index 264e3c1c..a8111c01 100644 --- a/changelog.md +++ b/changelog.md @@ -1,5 +1,9 @@ # changelog +## 4.2.1 + +- 可指定nacos的group，（`spring.cloud.nacos.discovery.group=xx`） + ## 4.2.0 需要执行`sop-upgrade-4.2.0.sql` diff --git a/doc/docs/_sidebar.md b/doc/docs/_sidebar.md index 88780f43..c3b62b4b 100644 --- a/doc/docs/_sidebar.md +++ b/doc/docs/_sidebar.md @@ -1,34 +1,34 @@ -* [首页](/?t=1595931646391) +* [首页](/?t=1606133657136) * 开发文档 - * [快速体验](files/10010_快速体验.md?t=1595931646394) - * [项目接入到SOP](files/10011_项目接入到SOP.md?t=1595931646412) - * [新增接口](files/10020_新增接口.md?t=1595931646412) - * [开发流程](files/10021_开发流程.md?t=1595931646412) - * [业务参数校验](files/10030_业务参数校验.md?t=1595931646412) - * [错误处理](files/10040_错误处理.md?t=1595931646412) - * [编写文档](files/10041_编写文档.md?t=1595931646412) - * [接口交互详解](files/10050_接口交互详解.md?t=1595931646412) - * [使用签名校验工具](files/10080_使用签名校验工具.md?t=1595931646413) - * [ISV管理](files/10085_ISV管理.md?t=1595931646413) - * [自定义返回结果](files/10087_自定义返回结果.md?t=1595931646413) - * [自定义过滤器](files/10088_自定义过滤器.md?t=1595931646413) - * [自定义校验token](files/10089_自定义校验token.md?t=1595931646413) - * [网关拦截器](files/10090_网关拦截器.md?t=1595931646413) - * [路由授权](files/10090_路由授权.md?t=1595931646413) - * [接口限流](files/10092_接口限流.md?t=1595931646413) - * [路由监控](files/10093_路由监控.md?t=1595931646413) - * [SDK开发](files/10095_SDK开发.md?t=1595931646413) - * [应用授权](files/10097_应用授权.md?t=1595931646414) - * [提供restful接口](files/10100_提供restful接口.md?t=1595931646414) - * [文件上传](files/10104_文件上传.md?t=1595931646414) - * [配置Sleuth链路追踪](files/10109_配置Sleuth链路追踪.md?t=1595931646414) - * [预发布灰度发布](files/10110_预发布灰度发布.md?t=1595931646414) - * [动态修改请求参数](files/10111_动态修改请求参数.md?t=1595931646414) - * [使用eureka](files/10112_使用eureka.md?t=1595931646414) + * [快速体验](files/10010_快速体验.md?t=1606133657138) + * [项目接入到SOP](files/10011_项目接入到SOP.md?t=1606133657161) + * [新增接口](files/10020_新增接口.md?t=1606133657161) + * [开发流程](files/10021_开发流程.md?t=1606133657161) + * [业务参数校验](files/10030_业务参数校验.md?t=1606133657161) + * [错误处理](files/10040_错误处理.md?t=1606133657161) + * [编写文档](files/10041_编写文档.md?t=1606133657162) + * [接口交互详解](files/10050_接口交互详解.md?t=1606133657162) + * [使用签名校验工具](files/10080_使用签名校验工具.md?t=1606133657162) + * [ISV管理](files/10085_ISV管理.md?t=1606133657162) + * [自定义返回结果](files/10087_自定义返回结果.md?t=1606133657162) + * [自定义过滤器](files/10088_自定义过滤器.md?t=1606133657162) + * [自定义校验token](files/10089_自定义校验token.md?t=1606133657162) + * [网关拦截器](files/10090_网关拦截器.md?t=1606133657163) + * [路由授权](files/10091_路由授权.md?t=1606133657163) + * [接口限流](files/10092_接口限流.md?t=1606133657163) + * [路由监控](files/10093_路由监控.md?t=1606133657163) + * [SDK开发](files/10095_SDK开发.md?t=1606133657163) + * [应用授权](files/10097_应用授权.md?t=1606133657163) + * [提供restful接口](files/10100_提供restful接口.md?t=1606133657163) + * [文件上传](files/10104_文件上传.md?t=1606133657163) + * [配置Sleuth链路追踪](files/10109_配置Sleuth链路追踪.md?t=1606133657164) + * [预发布灰度发布](files/10110_预发布灰度发布.md?t=1606133657164) + * [动态修改请求参数](files/10111_动态修改请求参数.md?t=1606133657164) + * [使用eureka](files/10112_使用eureka.md?t=1606133657164) * 原理分析 - * [网关性能测试](files/90001_网关性能测试.md?t=1595931646414) - * [原理分析之如何存储路由](files/90011_原理分析之如何存储路由.md?t=1595931646415) - * [原理分析之如何路由](files/90012_原理分析之如何路由.md?t=1595931646415) - * [原理分析之文档归纳](files/90013_原理分析之文档归纳.md?t=1595931646415) - * [原理分析之预发布灰度发布](files/90014_原理分析之预发布灰度发布.md?t=1595931646415) - * [常见问题](files/90100_常见问题.md?t=1595931646415) + * [网关性能测试](files/90001_网关性能测试.md?t=1606133657164) + * [原理分析之如何存储路由](files/90011_原理分析之如何存储路由.md?t=1606133657164) + * [原理分析之如何路由](files/90012_原理分析之如何路由.md?t=1606133657164) + * [原理分析之文档归纳](files/90013_原理分析之文档归纳.md?t=1606133657164) + * [原理分析之预发布灰度发布](files/90014_原理分析之预发布灰度发布.md?t=1606133657165) + * [常见问题](files/90100_常见问题.md?t=1606133657165) diff --git a/doc/docs/files/10088_自定义过滤器.md b/doc/docs/files/10088_自定义过滤器.md index b95b2d44..853dc57b 100644 --- a/doc/docs/files/10088_自定义过滤器.md +++ b/doc/docs/files/10088_自定义过滤器.md @@ -1,103 +1,39 @@ # 自定义过滤器 -## zuul过滤器 - -zuul过滤器列表如下： - -| 类型 | 顺序 | 过滤器 | 功能 | -| ----- | ---- | ----------------------- | ---------------------------- | -| pre | -1000 | PreValidateFilter (SOP自带) | 校验签名 | -| pre | -998 | PreLimitFilter (SOP自带) | 限流拦截器 | -| pre | -3 | ServletDetectionFilter | 标记处理 Servlet 的类型 | -| pre | -2 | Servlet30WrapperFilter | 包装 HttpServletRequest 请求 | -| pre | -1 | FormBodyWrapperFilter | 包装请求体 Servlet30WrapperFilter | -| pre | 1 | DebugFilter | 标记调试标志 | -| pre | 5 | PreDecorationFilter | 决定路由转发过滤器 | -| route | 10 | RibbonRoutingFilter | serviceId 请求转发 | -| route | 100 | SimpleHostRoutingFilter | url 请求转发 | -| route | 500 | SendForwardFilter | forward 请求转发 | -| post | 0 | SendErrorFilter | 处理有错误的请求响应 | -| post | 1000 | SendResponseFilter | 处理正常的请求响应 | - -顺序值小的优先执行，`-3`之前是sop自带的过滤器，`-3`开始是zuul自带的过滤器。 - -创建自定义过滤器可以从`-500`开始（-1000 ~ -501留给SOP）。下面是一个自定义过虑器的例子： - -```java -public class PreXXXFilter extends BaseZuulFilter { - @Override - protected FilterType getFilterType() { - return FilterType.PRE; - } - - @Override - protected int getFilterOrder() { - return -500; - } - - @Override - protected Object doRun(RequestContext requestContext) throws ZuulException { - HttpServletRequest request = requestContext.getRequest(); - ApiParam apiParam = ZuulContext.getApiParam(); - String appKey = apiParam.fetchAppKey(); - // ...业务处理 - - // 固定返回null - return null; - } -} -``` - -过滤器编写完毕后，在Config中使用： - -```java -@Configuration -public class ZuulConfig extends AlipayZuulConfiguration { - - ... - - @Bean - PreXXXFilter preXXXFilter() { - return new PreXXXFilter(); - } - ... - -} -``` - -## spring cloud gateway - -跟zuul同理 +演示在网关追加一个header ```java -public class XXXFilter implements GlobalFilter, Ordered { +public class CustomFilter implements GlobalFilter, Ordered { @Override public Mono filter(ServerWebExchange exchange, GatewayFilterChain chain) { - ApiParam apiParam = (ApiParam)exchange.getAttribute(SopConstants.CACHE_API_PARAM); - String appKey = apiParam.fetchAppKey(); - // ...业务处理 - ... - return chain.filter(exchange); + // 演示在网关追加header + ApiParam apiParam = ServerWebExchangeUtil.getApiParam(exchange); + String token = apiParam.fetchAccessToken(); + ServerWebExchange serverWebExchange = ServerWebExchangeUtil.addHeaders(exchange, httpHeaders -> { + httpHeaders.add("token", token); + }); + return chain.filter(serverWebExchange); } @Override public int getOrder() { - return -500; + // 自定义过滤器可以从0开始 + return 0; } } ``` -使用过滤器： +使用过滤器，在sop-gateway中找到MyConfig，添加： ```java @Configuration -public class GatewayConfig extends AlipayGatewayConfiguration { +public class MyConfig { ... @Bean - XXXFilter xxxFilter() { - return new XXXFilter(); + CustomFilter customFilter() { + return new CustomFilter(); } ... } diff --git a/doc/docs/files/10090_路由授权.md b/doc/docs/files/10091_路由授权.md similarity index 100% rename from doc/docs/files/10090_路由授权.md rename to doc/docs/files/10091_路由授权.md diff --git a/doc/docs/files/90001_网关性能测试.md b/doc/docs/files/90001_网关性能测试.md index d74fd3fd..d005a802 100644 --- a/doc/docs/files/90001_网关性能测试.md +++ b/doc/docs/files/90001_网关性能测试.md @@ -133,8 +133,8 @@ Transfer/sec: 226.50KB `restart.sh` ```bash -echo "Stopping sop-gateway-4.2.0-SNAPSHOT.jar" -pid=`ps -ef | grep sop-gateway-4.2.0-SNAPSHOT.jar | grep -v grep | awk '{print $2}'` +echo "Stopping sop-gateway-4.2.1-SNAPSHOT.jar" +pid=`ps -ef | grep sop-gateway-4.2.1-SNAPSHOT.jar | grep -v grep | awk '{print $2}'` if [ -n "$pid" ] then echo "kill -9 的id:" $pid @@ -142,7 +142,7 @@ then fi nohup java -jar -verbose:gc -XX:+PrintGCDetails -XX:+PrintHeapAtGC -Xloggc:gc.log \ -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=128m -Xms1024m -Xmx1024m -Xmn256m -Xss256k -XX:SurvivorRatio=8\ - -XX:+UseConcMarkSweepGC sop-gateway-4.2.0-SNAPSHOT.jar\ + -XX:+UseConcMarkSweepGC sop-gateway-4.2.1-SNAPSHOT.jar\ --spring.profiles.active=dev --server.port=8081 & tail -f nohup.out diff --git a/doc/docs/files/90100_常见问题.md b/doc/docs/files/90100_常见问题.md index 0995c8a4..940c85d8 100644 --- a/doc/docs/files/90100_常见问题.md +++ b/doc/docs/files/90100_常见问题.md @@ -1,5 +1,8 @@ # 常见问题 +## Nacos指定group + +可在配置文件中添加：`spring.cloud.nacos.discovery.group=xxx`指定group，不加默认是：DEFAULT_GROUP ## 在SpringCloudGateway中获取请求参数 diff --git a/doc/pom.xml b/doc/pom.xml index 249ed1ba..0e490c84 100644 --- a/doc/pom.xml +++ b/doc/pom.xml @@ -3,7 +3,7 @@ 4.0.0 com.gitee.sop doc - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT diff --git a/pom.xml b/pom.xml index 6b638bea..0ad752ea 100644 --- a/pom.xml +++ b/pom.xml @@ -12,7 +12,7 @@ 4.0.0 com.gitee.sop sop-parent - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT pom 一个开放平台解决方案项目，基于Spring Cloud实现，目标是能够让用户快速得搭建起自己的开放平台 diff --git a/sop-admin/pom.xml b/sop-admin/pom.xml index de967634..caacc7dd 100644 --- a/sop-admin/pom.xml +++ b/sop-admin/pom.xml @@ -6,13 +6,13 @@ com.gitee.sop sop-parent - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT ../pom.xml 4.0.0 sop-admin - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT pom diff --git a/sop-admin/sop-admin-server/pom.xml b/sop-admin/sop-admin-server/pom.xml index ac5f2e55..97f39640 100644 --- a/sop-admin/sop-admin-server/pom.xml +++ b/sop-admin/sop-admin-server/pom.xml @@ -5,13 +5,13 @@ com.gitee.sop sop-parent - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT ../../pom.xml 4.0.0 sop-admin-server - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT jar diff --git a/sop-admin/sop-admin-server/src/main/java/com/gitee/sop/adminserver/service/impl/RegistryServiceNacosImpl.java b/sop-admin/sop-admin-server/src/main/java/com/gitee/sop/adminserver/service/impl/RegistryServiceNacosImpl.java index 3e7e123d..0e9ace78 100644 --- a/sop-admin/sop-admin-server/src/main/java/com/gitee/sop/adminserver/service/impl/RegistryServiceNacosImpl.java +++ b/sop-admin/sop-admin-server/src/main/java/com/gitee/sop/adminserver/service/impl/RegistryServiceNacosImpl.java @@ -36,6 +36,9 @@ public class RegistryServiceNacosImpl implements RegistryService { @Value("${nacos.discovery.namespace:${spring.cloud.nacos.discovery.namespace:}}") private String nacosNamespace; + @Value("${nacos.discovery.group:${spring.cloud.nacos.discovery.group:DEFAULT_GROUP}}") + private String nacosGroup; + private NamingService namingService; @PostConstruct @@ -59,7 +62,7 @@ public class RegistryServiceNacosImpl implements RegistryService { for (String serviceName : serverList) { ServiceInfo serviceInfo = new ServiceInfo(); serviceInfo.setServiceId(serviceName); - List instanceList = namingService.getAllInstances(serviceName); + List instanceList = namingService.getAllInstances(serviceName, nacosGroup); if (CollectionUtils.isEmpty(instanceList)) { serviceInfo.setInstances(Collections.emptyList()); } else { diff --git a/sop-auth/pom.xml b/sop-auth/pom.xml index 6a9d40fc..916af6fc 100644 --- a/sop-auth/pom.xml +++ b/sop-auth/pom.xml @@ -5,7 +5,7 @@ com.gitee.sop sop-parent - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT ../pom.xml @@ -25,7 +25,7 @@ com.gitee.sop sop-service-common - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT @@ -37,7 +37,7 @@ com.gitee.sop sdk-java - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT diff --git a/sop-common/pom.xml b/sop-common/pom.xml index 54f01ea5..b47d704a 100644 --- a/sop-common/pom.xml +++ b/sop-common/pom.xml @@ -6,7 +6,7 @@ com.gitee.sop sop-parent - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT ../pom.xml diff --git a/sop-common/sop-bridge-eureka/pom.xml b/sop-common/sop-bridge-eureka/pom.xml index 5cef86a7..30da75c1 100644 --- a/sop-common/sop-bridge-eureka/pom.xml +++ b/sop-common/sop-bridge-eureka/pom.xml @@ -5,12 +5,12 @@ com.gitee.sop sop-parent - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT ../../pom.xml 4.0.0 - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT sop-bridge-eureka @@ -18,7 +18,7 @@ com.gitee.sop sop-gateway-common - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT diff --git a/sop-common/sop-bridge-nacos/pom.xml b/sop-common/sop-bridge-nacos/pom.xml index 010d518d..7e8a4e74 100644 --- a/sop-common/sop-bridge-nacos/pom.xml +++ b/sop-common/sop-bridge-nacos/pom.xml @@ -5,12 +5,12 @@ com.gitee.sop sop-parent - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT ../../pom.xml 4.0.0 - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT sop-bridge-nacos @@ -18,7 +18,7 @@ com.gitee.sop sop-gateway-common - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT diff --git a/sop-common/sop-bridge-nacos/src/main/java/com/gitee/sop/bridge/route/NacosRegistryListener.java b/sop-common/sop-bridge-nacos/src/main/java/com/gitee/sop/bridge/route/NacosRegistryListener.java index 48058ad4..84f6e4fb 100644 --- a/sop-common/sop-bridge-nacos/src/main/java/com/gitee/sop/bridge/route/NacosRegistryListener.java +++ b/sop-common/sop-bridge-nacos/src/main/java/com/gitee/sop/bridge/route/NacosRegistryListener.java @@ -13,6 +13,7 @@ import com.gitee.sop.gatewaycommon.route.ServiceHolder; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.math.NumberUtils; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; import org.springframework.context.ApplicationEvent; import org.springframework.util.CollectionUtils; @@ -34,6 +35,9 @@ public class NacosRegistryListener extends BaseRegistryListener { private volatile Set cacheServices = new HashSet<>(); + @Value("${nacos.discovery.group:${spring.cloud.nacos.discovery.group:DEFAULT_GROUP}}") + private String nacosGroup; + @Autowired private NacosDiscoveryProperties nacosDiscoveryProperties; @@ -95,7 +99,7 @@ public class NacosRegistryListener extends BaseRegistryListener { List allInstances; try { // 获取服务实例 - allInstances = namingService.getAllInstances(serviceName); + allInstances = namingService.getAllInstances(serviceName, nacosGroup); } catch (NacosException e) { log.error("namingService.getAllInstances(serviceName)错误，serviceName：{}", serviceName, e); return null; diff --git a/sop-common/sop-gateway-common/pom.xml b/sop-common/sop-gateway-common/pom.xml index db68858f..a3b7b0cc 100644 --- a/sop-common/sop-gateway-common/pom.xml +++ b/sop-common/sop-gateway-common/pom.xml @@ -5,13 +5,13 @@ com.gitee.sop sop-parent - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT ../../pom.xml 4.0.0 sop-gateway-common - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT jar diff --git a/sop-common/sop-service-common/pom.xml b/sop-common/sop-service-common/pom.xml index 25523f50..f8186814 100644 --- a/sop-common/sop-service-common/pom.xml +++ b/sop-common/sop-service-common/pom.xml @@ -6,13 +6,13 @@ com.gitee.sop sop-parent - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT ../../pom.xml 4.0.0 sop-service-common - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT jar diff --git a/sop-example/pom.xml b/sop-example/pom.xml index 97c868ff..0586602d 100644 --- a/sop-example/pom.xml +++ b/sop-example/pom.xml @@ -5,7 +5,7 @@ com.gitee.sop sop-parent - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT ../pom.xml diff --git a/sop-example/sop-springmvc/pom.xml b/sop-example/sop-springmvc/pom.xml index 2a13e736..fe0cda9e 100644 --- a/sop-example/sop-springmvc/pom.xml +++ b/sop-example/sop-springmvc/pom.xml @@ -5,7 +5,7 @@ com.gitee.sop sop-parent - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT ../../pom.xml @@ -26,7 +26,7 @@ com.gitee.sop sop-service-common - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT diff --git a/sop-example/sop-story/pom.xml b/sop-example/sop-story/pom.xml index 1e444184..1bc7278c 100644 --- a/sop-example/sop-story/pom.xml +++ b/sop-example/sop-story/pom.xml @@ -4,7 +4,7 @@ com.gitee.sop sop-parent - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT ../../pom.xml @@ -19,7 +19,7 @@ com.gitee.sop sop-service-common - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT diff --git a/sop-gateway/pom.xml b/sop-gateway/pom.xml index 053001fd..a667fbec 100644 --- a/sop-gateway/pom.xml +++ b/sop-gateway/pom.xml @@ -4,7 +4,7 @@ com.gitee.sop sop-parent - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT ../pom.xml diff --git a/sop-sdk/pom.xml b/sop-sdk/pom.xml index b9d68e7c..ae6a809c 100644 --- a/sop-sdk/pom.xml +++ b/sop-sdk/pom.xml @@ -6,13 +6,13 @@ com.gitee.sop sop-parent - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT ../pom.xml 4.0.0 sop-sdk - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT pom diff --git a/sop-sdk/sdk-java/pom.xml b/sop-sdk/sdk-java/pom.xml index 130ac0cf..0eb739d6 100644 --- a/sop-sdk/sdk-java/pom.xml +++ b/sop-sdk/sdk-java/pom.xml @@ -4,13 +4,13 @@ com.gitee.sop sop-parent - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT ../../pom.xml 4.0.0 sdk-java - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT diff --git a/sop-test/pom.xml b/sop-test/pom.xml index 9682e0a4..7708e12c 100644 --- a/sop-test/pom.xml +++ b/sop-test/pom.xml @@ -5,7 +5,7 @@ com.gitee.sop sop-parent - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT ../pom.xml diff --git a/sop-website/pom.xml b/sop-website/pom.xml index e6727e1e..d0b13c12 100644 --- a/sop-website/pom.xml +++ b/sop-website/pom.xml @@ -3,17 +3,17 @@ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> - - com.gitee.sop - sop-parent - 4.2.0-SNAPSHOT - ../pom.xml - + + com.gitee.sop + sop-parent + 4.2.1-SNAPSHOT + ../pom.xml + - 4.0.0 - sop-website - 4.2.0-SNAPSHOT - pom + 4.0.0 + sop-website + 4.2.1-SNAPSHOT + pom sop-website-server diff --git a/sop-website/sop-website-server/pom.xml b/sop-website/sop-website-server/pom.xml index 8ffaa151..afaaa449 100644 --- a/sop-website/sop-website-server/pom.xml +++ b/sop-website/sop-website-server/pom.xml @@ -5,7 +5,7 @@ com.gitee.sop sop-website - 4.2.0-SNAPSHOT + 4.2.1-SNAPSHOT ../pom.xml diff --git a/sop-website/sop-website-server/src/main/java/com/gitee/sop/websiteserver/service/impl/NacosServerService.java b/sop-website/sop-website-server/src/main/java/com/gitee/sop/websiteserver/service/impl/NacosServerService.java index 6d1bd69f..585dc988 100644 --- a/sop-website/sop-website-server/src/main/java/com/gitee/sop/websiteserver/service/impl/NacosServerService.java +++ b/sop-website/sop-website-server/src/main/java/com/gitee/sop/websiteserver/service/impl/NacosServerService.java @@ -29,6 +29,9 @@ public class NacosServerService implements ServerService { @Value("${nacos.discovery.namespace:${spring.cloud.nacos.discovery.namespace:}}") private String nacosNamespace; + @Value("${nacos.discovery.group:${spring.cloud.nacos.discovery.group:DEFAULT_GROUP}}") + private String nacosGroup; + private NamingService namingService; @PostConstruct @@ -49,7 +52,7 @@ public class NacosServerService implements ServerService { Objects.requireNonNull(serviceId, "serviceId can not be null"); List list = Collections.emptyList(); try { - List allInstances = namingService.getAllInstances(serviceId); + List allInstances = namingService.getAllInstances(serviceId, nacosGroup); list = allInstances.stream().map(instance -> instance.getIp() + ":" + instance.getPort()) .collect(Collectors.toList()); } catch (NacosException e) {