commit be7effd84f9f93c33571d8f8c336bb8901b71415
Author: Number7 <1845377266@qq.com>
Date: Wed Aug 7 22:08:26 2024 +0800
初始化
diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..3e403e3
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,35 @@
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### Eclipse ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/
+
+### Mac OS ###
+.DS_Store
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..0fc88bf
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,32 @@
+
+
+ 4.0.0
+
+
+
+ com.muyu
+ cloud-common
+ 3.6.3
+
+
+ cloud-common-nacos-remote
+ 1.0.0
+
+
+ 17
+ 17
+ UTF-8
+
+
+
+
+
+ com.muyu
+ cloud-common-core
+
+
+
+
+
diff --git a/src/main/java/com/muyu/common/nacos/remote/NacosServiceRemote.java b/src/main/java/com/muyu/common/nacos/remote/NacosServiceRemote.java
new file mode 100644
index 0000000..e15b8f7
--- /dev/null
+++ b/src/main/java/com/muyu/common/nacos/remote/NacosServiceRemote.java
@@ -0,0 +1,38 @@
+package com.muyu.common.nacos.remote;
+
+import com.dtflys.forest.annotation.Address;
+import com.dtflys.forest.annotation.BaseRequest;
+import com.dtflys.forest.annotation.Body;
+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;
+
+/**
+ * @Author:liuxinyue
+ * @Package:com.muyu.common.nacos.remote
+ * @Project:cloud-common-nacos-remote
+ * @name:NacosServiceRemote
+ * @Date:2024/8/7 20:36
+ */
+@BaseRequest(
+ baseURL = Constants.HTTP+"#{nacos.addr}/nacos/v1/service",
+ interceptor = {NacosNamespaceInterceptor.class}
+)
+public interface NacosServiceRemote {
+
+
+ @GetRequest(
+ url="/list"
+ )
+ public ServiceListResp serviceList(@Body ServiceListReq serviceListReq);
+
+
+
+
+
+
+
+
+}
diff --git a/src/main/java/com/muyu/common/nacos/remote/interceptor/NacosNamespaceInterceptor.java b/src/main/java/com/muyu/common/nacos/remote/interceptor/NacosNamespaceInterceptor.java
new file mode 100644
index 0000000..99f6baf
--- /dev/null
+++ b/src/main/java/com/muyu/common/nacos/remote/interceptor/NacosNamespaceInterceptor.java
@@ -0,0 +1,41 @@
+package com.muyu.common.nacos.remote.interceptor;
+
+import com.dtflys.forest.http.ForestRequest;
+import com.dtflys.forest.interceptor.Interceptor;
+
+import com.muyu.common.core.text.Convert;
+import com.muyu.common.core.utils.StringUtils;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.beans.factory.annotation.Value;
+
+@Log4j2
+public class NacosNamespaceInterceptor implements Interceptor {
+
+
+ @Value("${nacos.namespace}")
+ private String namespaceId;
+
+
+ /**
+ * 该方法在请求发送之前被调用, 若返回false则不会继续发送请求
+ * @Param request Forest请求对象
+ */
+ @Override
+ public boolean beforeExecute(ForestRequest req) {
+ if (StringUtils.isNotEmpty(namespaceId)){
+ String reqNamespaceId = Convert.utf8Str(req.getQuery("namespaceId"));
+ if(reqNamespaceId==null){
+ log.warn("本次请求nacos的namespaceId未携带,已添加[{}]",namespaceId);
+ req.addQuery("namespaceId", namespaceId);
+ }else {
+ if (StringUtils.equals(reqNamespaceId,namespaceId)){
+ log.warn("本次请求nacos的namespaceId和项目ID不符,现已更改:[{}->{}]",namespaceId,reqNamespaceId);
+ req.addQuery("namespaceId", namespaceId);
+ }
+ }
+ }
+ return true; // 继续执行请求返回true
+ }
+
+}
+
diff --git a/src/main/java/com/muyu/common/nacos/remote/req/BaseReq.java b/src/main/java/com/muyu/common/nacos/remote/req/BaseReq.java
new file mode 100644
index 0000000..4d213e3
--- /dev/null
+++ b/src/main/java/com/muyu/common/nacos/remote/req/BaseReq.java
@@ -0,0 +1,28 @@
+package com.muyu.common.nacos.remote.req;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+/**
+ * @Author:liuxinyue
+ * @Package:com.muyu.common.nacos.remote.req
+ * @Project:cloud-common-nacos-remote
+ * @name:BaseReq
+ * @Date:2024/8/7 21:23
+ */
+@Data
+@SuperBuilder
+@NoArgsConstructor
+@AllArgsConstructor
+public class BaseReq {
+
+ /**
+ * 命名空间
+ */
+ private String namespaceId;
+
+
+
+}
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
new file mode 100644
index 0000000..8d606e3
--- /dev/null
+++ b/src/main/java/com/muyu/common/nacos/remote/req/ServiceListReq.java
@@ -0,0 +1,42 @@
+package com.muyu.common.nacos.remote.req;
+
+import com.dtflys.forest.annotation.BaseRequest;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+/**
+ * @Author:liuxinyue
+ * @Package:com.muyu.common.nacos.remote.req
+ * @Project:cloud-common-nacos-remote
+ * @name:ServiceListReq 服务列表请求参数
+ * @Date:2024/8/7 21:27
+ */
+
+@Data
+@SuperBuilder
+@NoArgsConstructor
+@AllArgsConstructor
+@EqualsAndHashCode(callSuper = true)
+public class ServiceListReq extends BaseReq{
+
+ /**
+ * 当前页码
+ */
+ private int pageNo;
+
+ /**
+ * 分页大小
+ */
+ private int pageSize=10;
+
+ /**
+ * 分组名
+ */
+ private String groupName;
+
+
+
+}
diff --git a/src/main/java/com/muyu/common/nacos/remote/resp/ServiceListResp.java b/src/main/java/com/muyu/common/nacos/remote/resp/ServiceListResp.java
new file mode 100644
index 0000000..729f0d7
--- /dev/null
+++ b/src/main/java/com/muyu/common/nacos/remote/resp/ServiceListResp.java
@@ -0,0 +1,33 @@
+package com.muyu.common.nacos.remote.resp;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+/**
+ * @Author:liuxinyue
+ * @Package:com.muyu.common.nacos.remote.resp
+ * @Project:cloud-common-nacos-remote
+ * @name:ServiceListResp
+ * @Date:2024/8/7 21:33
+ */
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class ServiceListResp {
+
+ /**
+ * 总条数
+ */
+ private int count;
+
+ /**
+ * 服务列表
+ */
+ private List doms;
+
+}
diff --git a/src/main/resources/META-INFO/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports b/src/main/resources/META-INFO/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
new file mode 100644
index 0000000..78b1bee
--- /dev/null
+++ b/src/main/resources/META-INFO/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
@@ -0,0 +1 @@
+com.muyu.common.nacos.remote.interceptor.NacosNamespaceInterceptor