初始化

master
陈思豪 2024-08-08 00:08:43 +08:00
commit 758f6fe83e
9 changed files with 223 additions and 0 deletions

38
.gitignore vendored 100644
View File

@ -0,0 +1,38 @@
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### IntelliJ IDEA ###
.idea/modules.xml
.idea/jarRepositories.xml
.idea/compiler.xml
.idea/libraries/
*.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

31
pom.xml 100644
View File

@ -0,0 +1,31 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
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">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.muyu</groupId>
<artifactId>cloud-common</artifactId>
<version>3.6.3</version>
</parent>
<artifactId>cloud-common-nacos-remote</artifactId>
<version>1.0.0</version>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-core</artifactId>
</dependency>
</dependencies>
</project>

View File

@ -0,0 +1,22 @@
package com.muyu.common.nacos.remote;
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;
@BaseRequest(
baseURL = Constants.HTTP+"#{nacos.addr}/nacos/v1/ns/service",
interceptor = {NacosNamespaceInterceptor.class}
)
public interface NacosServiceRemote {
@GetRequest(url = "/list")
public ServiceListResp serviceList(@Body ServiceListReq serviceListReq);
}

View File

@ -0,0 +1,31 @@
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<T> implements Interceptor<T> {
@Value("${nacos.namespace}")
private String namespaceId;
@Override
public boolean beforeExecute(ForestRequest req){
if(StringUtils.isNotEmpty(namespaceId)){
String reqNamespaceId = Convert.str(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不相符现已更改[{}->{}]",reqNamespaceId,namespaceId);
req.addQuery("namespaceId",namespaceId);
}
}
}
return true;
}
}

View File

@ -0,0 +1,16 @@
package com.muyu.common.nacos.remote.req;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
public class BaseReq {
private String namespaceId;
}

View File

@ -0,0 +1,30 @@
package com.muyu.common.nacos.remote.req;
import lombok.*;
import lombok.experimental.SuperBuilder;
@Data
@SuperBuilder
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode(callSuper = true)
public class ServiceListReq extends BaseReq{
/**
*
*/
private int pageNo;
/**
*
*/
@Builder.Default
private int pageSize=2;
/**
*
*/
private String groupName;
}

View File

@ -0,0 +1,20 @@
package com.muyu.common.nacos.remote.resp;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class ServiceListResp {
private int count;
private List<String> doms;
}

View File

@ -0,0 +1,34 @@
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 lombok.extern.log4j.Log4j2;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
@Log4j2
public class NacosServerService {
@Resource
private NacosServiceRemote nacosServiceRemote;
public List<String> nacosServiceAllList(){
List<String> serverList = new ArrayList<>();
ServiceListResp serviceListResp = null;
int pageNo = 0 ,pageSize = 2;
do {
serviceListResp = nacosServiceRemote.serviceList(
ServiceListReq.builder()
.pageNo(++pageNo)
.pageSize(pageSize)
.build()
);
}while (serviceListResp.getCount() > pageNo * pageSize);
return serverList;
}
}

View File

@ -0,0 +1 @@
com.muyu.common.nacos.remote.interceptor.NacosNamespaceInterceptor