背景
Nexus是一个强大的Maven仓库管理器。项目迭代中，会产生很多版本的maven组件上传至Nexus私服。对于不需要的组件，需要删除。如果在页面上逐个删除对于组件众多、版本众多的项目来说无疑是灾难
Nexus提供的API
页面访问 {nexus_host}/service/rest/swagger.json ，可以看到Nexus提供的所有API
image.png
截图并不是所有的接口，可以自己访问接口查看返回的json
image.png
接口详情中包含接口的描述、参数、响应状态码等
需要使用的接口
根据我的需求，我需要使用两个接口，组件查询接口与组件删除接口，如下图所示：
组件查询：
image.png
组件删除：
image.png
详细代码
依赖
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.76</version>
</dependency>
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
</dependency>
Entity
public class Checksum {
private String sha1;
private String md5;
public String getSha1() {
return sha1;
}
public Checksum setSha1(String sha1) {
this.sha1 = sha1;
return this;
}
public String getMd5() {
return md5;
}
public Checksum setMd5(String md5) {
this.md5 = md5;
return this;
}
}
public class Asset {
private String downloadUrl;
private String path;
private String id;
private String repository;
private String format;
private Checksum checksum;
public String getDownloadUrl() {
return downloadUrl;
}
public Asset setDownloadUrl(String downloadUrl) {
this.downloadUrl = downloadUrl;
return this;
}
public String getPath() {
return path;
}
public Asset setPath(String path) {
this.path = path;
return this;
}
public String getId() {
return id;
}
public Asset setId(String id) {
this.id = id;
return this;
}
public String getRepository() {
return repository;
}
public Asset setRepository(String repository) {
this.repository = repository;
return this;
}
public String getFormat() {
return format;
}
public Asset setFormat(String format) {
this.format = format;
return this;
}
public Checksum getChecksum() {
return checksum;
}
public Asset setChecksum(Checksum checksum) {
this.checksum = checksum;
return this;
}
}
public class Module {
private String id;
private String repository;
private String format;
private String group;
private String name;
private String version;
private List<Asset> assets;
public String getId() {
return id;
}
public Module setId(String id) {
this.id = id;
return this;
}
public String getRepository() {
return repository;
}
public Module setRepository(String repository) {
this.repository = repository;
return this;
}
public String getFormat() {
return format;
}
public Module setFormat(String format) {
this.format = format;
return this;
}
public String getGroup() {
return group;
}
public Module setGroup(String group) {
this.group = group;
return this;
}
public String getName() {
return name;
}
public Module setName(String name) {
this.name = name;
return this;
}
public String getVersion() {
return version;
}
public Module setVersion(String version) {
this.version = version;
return this;
}
public List<Asset> getAssets() {
return assets;
}
public Module setAssets(List<Asset> assets) {
this.assets = assets;
return this;
}
}
public class Service {
private String groupId;
private String artifactId;
public String getGroupId() {
return groupId;
}
public Service setGroupId(String groupId) {
this.groupId = groupId;
return this;
}
public String getArtifactId() {
return artifactId;
}
public Service setArtifactId(String artifactId) {
this.artifactId = artifactId;
return this;
}
}
主要代码
public class Clean {
private static final OkHttpClient HTTP_CLIENT = new OkHttpClient.Builder().connectTimeout(10, TimeUnit.SECONDS).readTimeout(10, TimeUnit.SECONDS).build();
private static final Logger LOGGER = LoggerFactory.getLogger(Clean.class);
private static final String NEXUS_HOST = "http://nexus.demo.com";
// 账户需要有查询和删除权限
private static final String NEXUS_USERNAME = "admin";
private static final String NEXUS_PASSWORD = "admin";
private static final String NEXUS_REPOSITORY = "demo-release";
public static void main(String[] args) {
// 需要删除的组件坐标信息
List<Service> serviceList = new ArrayList<>();
serviceList.add(new Service().setGroupId("org.demo").setArtifactId("demo-service"));
// 需要删除的组件版本
List<String> versionList = new ArrayList<>();
versionList.add("0.1.0.RELEASE");
for(Service service : serviceList) {
List<Module> moduleList = new ArrayList<>();
search(NEXUS_HOST, NEXUS_USERNAME, NEXUS_PASSWORD, NEXUS_REPOSITORY, service.getGroupId(), service.getArtifactId(), null, moduleList);
for (Module module : moduleList) {
if (versionList.contains(module.getVersion())) {
// 版本匹配执行删除
delete(NEXUS_HOST, NEXUS_USERNAME, NEXUS_PASSWORD, module);
}
}
}
}
private static void search(String host, String username, String password, String repository, String groupId, String artifactId, String token, List<Module> list) {
String url = String.format("%s/service/rest/v1/search?repository=%s&group=%s&name=%s", host, repository, groupId, artifactId);
if (StringUtils.hasText(token)) {
// 拼接上次查询返回的continuationToken，查询下一页
url = url + "&continuationToken=" + token;
}
Request request = new Request.Builder()
.addHeader("Authorization", getToken(username, password))
.addHeader("Connection", "keep-alive")
.url(url)
.get()
.build();
Call call = HTTP_CLIENT.newCall(request);
try (Response response = call.execute()) {
if (response.code() == 200 && response.body() != null) {
JSONObject jsonObject = JSONObject.parseObject(response.body().string());
List<Module> result = jsonObject.getObject("items", new TypeReference<List<Module>>() {
});
if (CollectionUtils.isEmpty(result)) {
return;
}
list.addAll(result);
String conToken = jsonObject.getString("continuationToken");
if (!StringUtils.hasText(conToken) || "null".equals(conToken)) {
return;
}
// 携带continuationToken递归查询下一页
search(host, username, password, repository, groupId, artifactId, conToken, list);
} else {
LOGGER.error("组件搜索出错，http响应：{}", response.body());
}
} catch (Exception e) {
e.printStackTrace();
}
}
public static void delete(String host, String username, String password, Module module) {
LOGGER.info("执行删除: {}", module.getVersion());
String url = String.format("%s/service/rest/v1/components/%s", host, module.getId());
Request request = new Request.Builder()
.addHeader("Authorization", getToken(username, password))
.addHeader("Connection", "keep-alive")
.url(url)
.delete()
.build();
Call call = HTTP_CLIENT.newCall(request);
try (Response response = call.execute()) {
if (response.code() == 204) {
LOGGER.info("删除成功！");
} else {
LOGGER.error("删除失败! 状态码：{}", response.code());
}
} catch (Exception e) {
e.printStackTrace();
}
}
private static String getToken(String name, String password) {
String authString = name + ":" + password;
byte[] authEncBytes = Base64.getEncoder().encode(authString.getBytes(StandardCharsets.UTF_8));
return "Basic " + new String(authEncBytes);
}
}
