From aa920fc0e3e91a07013a3620bf732b57f0e8bc3a Mon Sep 17 00:00:00 2001 From: Cui YongXing <2835316714@qq.com> Date: Sun, 4 Aug 2024 15:21:24 +0800 Subject: [PATCH] 1 --- .../muyu/common/nacos/NacosRemoteConfig.java | 16 ++++++++ .../nacos/remote/NacosServiceRemote.java | 6 +-- .../nacos/remote/req/ServiceListReq.java | 6 +-- .../nacos/service/NacosServerService.java | 37 +++++++++++++++++++ ...ot.autoconfigure.AutoConfiguration.imports | 2 +- 5 files changed, 58 insertions(+), 9 deletions(-) create mode 100644 src/main/java/com/muyu/common/nacos/NacosRemoteConfig.java create mode 100644 src/main/java/com/muyu/common/nacos/service/NacosServerService.java diff --git a/src/main/java/com/muyu/common/nacos/NacosRemoteConfig.java b/src/main/java/com/muyu/common/nacos/NacosRemoteConfig.java new file mode 100644 index 0000000..f24d3b3 --- /dev/null +++ b/src/main/java/com/muyu/common/nacos/NacosRemoteConfig.java @@ -0,0 +1,16 @@ +package com.muyu.common.nacos; + +import com.dtflys.forest.springboot.annotation.ForestScan; +import com.muyu.common.nacos.remote.interceptor.NacosNamespaceInterceptor; +import com.muyu.common.nacos.service.NacosServerService; +import org.springframework.context.annotation.Configuration; +import org.springframework.context.annotation.Import; + +@Configuration +@ForestScan(basePackages = "com.muyu.common.nacos.remote") +@Import(value = { + NacosNamespaceInterceptor.class, + NacosServerService.class +}) +public class NacosRemoteConfig { +} diff --git a/src/main/java/com/muyu/common/nacos/remote/NacosServiceRemote.java b/src/main/java/com/muyu/common/nacos/remote/NacosServiceRemote.java index 125d85f..7f67a8f 100644 --- a/src/main/java/com/muyu/common/nacos/remote/NacosServiceRemote.java +++ b/src/main/java/com/muyu/common/nacos/remote/NacosServiceRemote.java @@ -13,11 +13,9 @@ import com.muyu.common.nacos.remote.resp.ServiceListResp; baseURL = Constants.HTTP+"#{nacos.addr}/nacos/v1/ns/service", interceptor = {NacosNamespaceInterceptor.class} ) -public class NacosServiceRemote { +public interface NacosServiceRemote { @GetRequest( url = "/list" ) - public ServiceListResp serviceList(@Body ServiceListReq req){ - return null; - } + public ServiceListResp serviceList(@Body ServiceListReq req); } diff --git a/src/main/java/com/muyu/common/nacos/remote/req/ServiceListReq.java b/src/main/java/com/muyu/common/nacos/remote/req/ServiceListReq.java index 7debd36..83cf98b 100644 --- a/src/main/java/com/muyu/common/nacos/remote/req/ServiceListReq.java +++ b/src/main/java/com/muyu/common/nacos/remote/req/ServiceListReq.java @@ -1,9 +1,6 @@ package com.muyu.common.nacos.remote.req; -import lombok.AllArgsConstructor; -import lombok.Data; -import lombok.EqualsAndHashCode; -import lombok.NoArgsConstructor; +import lombok.*; import lombok.experimental.SuperBuilder; @Data @@ -13,6 +10,7 @@ import lombok.experimental.SuperBuilder; @EqualsAndHashCode(callSuper = true) public class ServiceListReq extends BaseReq{ private int pageNum; + @Builder.Default private int pageSize = 10; private String groupName; } diff --git a/src/main/java/com/muyu/common/nacos/service/NacosServerService.java b/src/main/java/com/muyu/common/nacos/service/NacosServerService.java new file mode 100644 index 0000000..316e2f8 --- /dev/null +++ b/src/main/java/com/muyu/common/nacos/service/NacosServerService.java @@ -0,0 +1,37 @@ +package com.muyu.common.nacos.service; + + +import com.muyu.common.nacos.remote.NacosServiceRemote; +import com.muyu.common.nacos.remote.req.ServiceListReq; +import com.muyu.common.nacos.remote.resp.ServiceListResp; + +import javax.annotation.Resource; +import java.util.ArrayList; +import java.util.List; + +public class NacosServerService { + + + @Resource + private NacosServiceRemote nacosServiceRemote; + + + public List nacosServerAllList() { + List serverList = new ArrayList<>(); + ServiceListResp serviceListResp = null; + int pageNum =1,pageSize=2; + do { + serviceListResp = nacosServiceRemote.serviceList( + ServiceListReq.builder() + .pageNum(++pageNum) + .pageSize(pageSize) + .build() + ); + serverList.addAll(serviceListResp.getDoms()); + } while (serviceListResp.getCount()>pageNum* pageSize ); + return serverList; + + } + + +} diff --git a/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports b/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports index 78b1bee..08c9e27 100644 --- a/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports +++ b/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports @@ -1 +1 @@ -com.muyu.common.nacos.remote.interceptor.NacosNamespaceInterceptor +com.muyu.common.nacos.NacosRemoteConfig