初始化
commit
eb5290d55d
|
@ -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
|
|
@ -0,0 +1,30 @@
|
|||
<?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>
|
||||
|
||||
<groupId>com.bwie</groupId>
|
||||
<artifactId>cloud-common-nacos-remote</artifactId>
|
||||
<version>1.0-SNAPSHOT</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>
|
|
@ -0,0 +1,13 @@
|
|||
package com.bwie;
|
||||
|
||||
/**
|
||||
* @Author:zhangzhihao
|
||||
* @name:${NAME}
|
||||
* @Date:2024/8/4 14:06
|
||||
* 不准抄代码,添加注释,清楚每一行代码意思
|
||||
*/
|
||||
public class Main {
|
||||
public static void main(String[] args) {
|
||||
System.out.println("Hello world!");
|
||||
}
|
||||
}
|
|
@ -0,0 +1,28 @@
|
|||
package com.bwie.nacos.remote;
|
||||
|
||||
import com.bwie.nacos.remote.interceptor.NacosNamespaceInterceptor;
|
||||
import com.bwie.nacos.remote.req.ServiceListReq;
|
||||
import com.bwie.nacos.remote.resp.ServiceListResp;
|
||||
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;
|
||||
|
||||
/**
|
||||
* @Author:zhangzhihao
|
||||
* @name:NacosServiceApi
|
||||
* @Date:2024/8/4 14:15
|
||||
* 不准抄代码,添加注释,清楚每一行代码意思
|
||||
*/
|
||||
@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);
|
||||
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
package com.bwie.nacos.remote.interceptor;
|
||||
|
||||
|
||||
import com.dtflys.forest.http.ForestRequest;
|
||||
import com.dtflys.forest.interceptor.Interceptor;
|
||||
import com.muyu.common.core.text.Convert;
|
||||
import lombok.extern.log4j.Log4j2;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.springframework.beans.factory.annotation.Value;
|
||||
|
||||
@Log4j2
|
||||
public class NacosNamespaceInterceptor<T> implements Interceptor<T> {
|
||||
|
||||
|
||||
@Value("${nacos.namespace}")
|
||||
private String namespaceId;
|
||||
|
||||
/**
|
||||
* 该方法在请求发送之前被调用, 若返回false则不会继续发送请求
|
||||
* @Param request Forest请求对象
|
||||
*/
|
||||
@Override
|
||||
public boolean beforeExecute(ForestRequest req) {
|
||||
if (StringUtils.isNotEmpty(namespaceId)){
|
||||
String reqNamespaceId = Convert.str(req.getQuery("namespaceId"), "");
|
||||
if (reqNamespaceId==null){
|
||||
log.warn("本次请求nccos的namespaceId未携带,已添加[{}]",namespaceId);
|
||||
req.addQuery("namespaceId",namespaceId);
|
||||
}else {
|
||||
if (StringUtils.equals(reqNamespaceId,namespaceId)){
|
||||
log.warn("本次请求nccos的namespaceId和项目ID不相符,现已更改[{}->{}]",reqNamespaceId,namespaceId);
|
||||
req.addQuery("namespaceId",namespaceId);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
|
||||
return true; // 继续执行请求返回true
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
|
@ -0,0 +1,23 @@
|
|||
package com.bwie.nacos.remote.req;
|
||||
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
import lombok.experimental.SuperBuilder;
|
||||
|
||||
/**
|
||||
* @Author:zhangzhihao
|
||||
* @name:BaseReq
|
||||
* @Date:2024/8/4 15:03
|
||||
* 不准抄代码,添加注释,清楚每一行代码意思
|
||||
*/
|
||||
@Data
|
||||
@SuperBuilder
|
||||
@NoArgsConstructor
|
||||
@AllArgsConstructor
|
||||
public class BaseReq {
|
||||
/**
|
||||
* 命名空间
|
||||
*/
|
||||
private String namespaceId;
|
||||
}
|
|
@ -0,0 +1,36 @@
|
|||
package com.bwie.nacos.remote.req;
|
||||
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Data;
|
||||
import lombok.EqualsAndHashCode;
|
||||
import lombok.NoArgsConstructor;
|
||||
import lombok.experimental.SuperBuilder;
|
||||
|
||||
/**
|
||||
* @Author:zhangzhihao
|
||||
* @name:ServiceListReq
|
||||
* @Date:2024/8/4 15:04
|
||||
* 不准抄代码,添加注释,清楚每一行代码意思
|
||||
*/
|
||||
@Data
|
||||
@SuperBuilder
|
||||
@NoArgsConstructor
|
||||
@AllArgsConstructor
|
||||
@EqualsAndHashCode(callSuper = true)
|
||||
public class ServiceListReq extends BaseReq{
|
||||
|
||||
/**
|
||||
* 当前页码
|
||||
*/
|
||||
private int pageNo;
|
||||
|
||||
/**
|
||||
* 分页大小
|
||||
*/
|
||||
private int pageSize=10;
|
||||
|
||||
/**
|
||||
* 分组名
|
||||
*/
|
||||
private String groupName;
|
||||
}
|
|
@ -0,0 +1,31 @@
|
|||
package com.bwie.nacos.remote.resp;
|
||||
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Builder;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @Author:zhangzhihao
|
||||
* @name:ServiceListResp
|
||||
* @Date:2024/8/4 15:08
|
||||
* 不准抄代码,添加注释,清楚每一行代码意思
|
||||
*/
|
||||
@Data
|
||||
@Builder
|
||||
@NoArgsConstructor
|
||||
@AllArgsConstructor
|
||||
public class ServiceListResp {
|
||||
/**
|
||||
* 总条数
|
||||
*/
|
||||
private int count;
|
||||
|
||||
/**
|
||||
* 服务列表
|
||||
*/
|
||||
private List<String> doms;
|
||||
|
||||
}
|
|
@ -0,0 +1 @@
|
|||
com.bwie.nacos.remote.interceptor.NacosNamespaceInterceptor
|
Loading…
Reference in New Issue