From 40f386e011d12b3a2e3a951c78daefa4f4af6e36 Mon Sep 17 00:00:00 2001 From: Yueng <14617246+YuengMeYuuer@user.noreply.gitee.com> Date: Fri, 9 Aug 2024 20:30:01 +0800 Subject: [PATCH] =?UTF-8?q?feat():=E5=A2=9E=E5=8A=A0nacosService=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../nacos/remote/NacosServiceRemote.java | 5 ++- .../nacos/remote/req/ServiceListReq.java | 8 ++-- .../nacos/service/NacosServiceService.java | 41 +++++++++++++++++++ 3 files changed, 48 insertions(+), 6 deletions(-) create mode 100644 src/main/java/com/muyu/common/nacos/service/NacosServiceService.java 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 b51d239..89d678b 100644 --- a/src/main/java/com/muyu/common/nacos/remote/NacosServiceRemote.java +++ b/src/main/java/com/muyu/common/nacos/remote/NacosServiceRemote.java @@ -6,6 +6,9 @@ import com.dtflys.forest.annotation.GetRequest; import com.muyu.common.core.constant.Constants; import com.muyu.common.nacos.remote.interceptor.NacosNamespaceInterceptor; import com.muyu.common.nacos.remote.req.ServiceListReq; +import com.muyu.common.nacos.remote.resp.ServiceListResp; + +import java.util.List; /** * @Author:yang @@ -23,5 +26,5 @@ public interface NacosServiceRemote { @GetRequest( url = "/list" ) - public void serviceList(@Body ServiceListReq serviceListReq); + public ServiceListResp serviceList(@Body ServiceListReq serviceListReq); } 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 e00e650..4514d78 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; /** @@ -28,7 +25,8 @@ public class ServiceListReq extends BaseReq{ /** * 分页大小 */ - private int pageSize = 10; + @Builder.Default + private int pageSize = 2; /** * 分组名 diff --git a/src/main/java/com/muyu/common/nacos/service/NacosServiceService.java b/src/main/java/com/muyu/common/nacos/service/NacosServiceService.java new file mode 100644 index 0000000..2f310fe --- /dev/null +++ b/src/main/java/com/muyu/common/nacos/service/NacosServiceService.java @@ -0,0 +1,41 @@ +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; + +/** + * @Author:yang + * @Package:com.muyu.common.nacos.service + * @Project:cloud-common-nacos-remote + * @name:NacosServiceService + * @Date:2024/8/9 20:08 + */ +public class NacosServiceService { + + @Resource + private NacosServiceRemote nacosServiceRemote; + + public List nacosServerAllList(){ + List serverList = new ArrayList<>(); + ServiceListResp serviceListResp = null; + int pageNo = 0 , pageSize = 2; + do{ + serviceListResp = nacosServiceRemote.serviceList( + ServiceListReq.builder() + .pageNo(++pageNo) + .pageSize(pageSize) + .build() + ); + serverList.addAll(serviceListResp.getDoms()); + }while (serviceListResp.getCount() > pageNo * pageSize); + return serverList; + + + } + +}