nacos-remote的nacos接口模块

master
zhang chengzhi 2024-08-05 17:23:42 +08:00
commit 7cc884d3f0
6 changed files with 182 additions and 0 deletions

View File

@ -0,0 +1,32 @@
package com.muyu.common.nacos.remote;
import com.dtflys.forest.annotation.*;
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;
/**
* @Authorzhangchengzhi
* @Packagecom.muyu.common.nacos.remote
* @Projectcloud-common-nacos-remote
* @nameNacosServiceRemote
* @Date2024/8/4 16:21
*/
@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,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<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("本次请求nacos的namespace未携带,已添加[{}]",namespaceId);
req.addQuery("namespaceId",namespaceId);
}else {
if (StringUtils.equals(reqNamespaceId,namespaceId)){
log.warn("本次请求nacos的namespaceId和项目ID不相符,现在已更改:[{}->{}]",reqNamespaceId);
req.addQuery("namespaceId",namespaceId);
}
}
}
return true; // 继续执行请求返回true
}
}

View File

@ -0,0 +1,29 @@
package com.muyu.common.nacos.remote.req;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
/**
* @Authorzhangchengzhi
* @Packagecom.muyu.common.nacos.remote.req
* @Projectcloud-common-nacos-remote
* @nameBaseReq
* @Date2024/8/4 16:50
*/
@Data
@SuperBuilder
@NoArgsConstructor
@AllArgsConstructor
public class BaseReq {
/**
*
*/
private String namespaceId;
}

View File

@ -0,0 +1,43 @@
package com.muyu.common.nacos.remote.req;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
/**
* @Authorzhangchengzhi
* @Packagecom.muyu.common.nacos.remote.req
* @Projectcloud-common-nacos-remote
* @nameServiceListReq
* @Date2024/8/4 16:52
*/
@Data
@SuperBuilder
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode(callSuper = true)
public class ServiceListReq extends BaseReq{
/**
*
*/
private int pageNo=1;
/**
*
*/
private int pageSize=10;
/**
*
*/
private String groupName;
}

View File

@ -0,0 +1,36 @@
package com.muyu.common.nacos.remote.resp;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
/**
* @Authorzhangchengzhi
* @Packagecom.muyu.common.nacos.remote.resp
* @Projectcloud-common-nacos-remote
* @nameServiceListResp
* @Date2024/8/4 16:57
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class ServiceListResp {
/**
*
*/
private int count;
/**
*
*/
private List<String> doms;
}

View File

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