批量将现有Jar包上传到Maven私服
基本信息
适用环境:内网环境下的 Maven 私服,无法连接外网(或者需要翻墙),需要通过其他手段下载完依赖后导入到内网私服的情况。
功能描述:
单个依赖包含的pom,jar等文件应该在一个单独的目录中,可以指定下面的路径,上传 gson 到私服。
还可以指定到f:\\.m2\\repository\\Gson\\gson
,上传gson的多个版本。
也可以直接f:\\.m2\\repository
,将整个仓库下面的所有jar包的所有版本都上传到私服。
注意:上传前,如果允许重复上传到私服,就需要在私服配置,允许 redeploy,否则已经存在的会报错。
下载Jar 包
如果是下载单个的jar包,可以从 http://mvnrepository.com/ 搜素下载,下载的时候(根据连接打开一个地址,下载pom,jar,source,javadoc)。
如果是针对项目,可以先配置一个新的本地仓库路径(避免和已有jar搅和一起不好区分)。
为了可以下载source和javadoc,在 settings.xml 中增加下面的配置:
<profiles> <profile> <id>downloadSources</id> <properties> <downloadSources>true</downloadSources> <downloadJavadocs>true</downloadJavadocs> </properties> </profile> </profiles> <activeProfiles> <activeProfile>downloadSources</activeProfile> </activeProfiles>
在项目下面执行:mvn clean install
命令。
执行完成后,再次执行:mvn dependency:sources
下载源码。
如果需要 javadoc ,可以执行命令:mvn dependency:resolve -Dclassifier=javadoc
需要在 settings.xml 中设置好账号密码,参考如下。
<server> <id>thirdpart</id> <username>admin</username> <password>123456</password> </server>
上传命令
使用下面的命令可以上传依赖到私服。
mvn deploy:deploy-file -Durl=file:///home/me/m2-repo -DrepositoryId=some.repo.id -Dfile=./path/to/artifact-name-1.0.jar -DpomFile=./path/to/pom.xml -Dsources=./path/to/artifact-name-1.0-sources.jar -Djavadoc=./path/to/artifact-name-1.0-javadoc.jar
自动化
手动使用这个命令上传时,还不如直接通过nexus的前台进行上传,为了可以自动批量上传,我们可以写个小程序来利用这个命令进行批量操作。
当写一个可以批量上传依赖的程序时,还需要考虑如果packaging=pom或者packaging=bundle时,需要特殊处理。pom时,Dfile DpomFile两个参数都指定为pom文件即可,bundle时,需要指定-Dpackaging=jar,由于jar时这个参数也没问题,所以无论bundle还是jar都带上这个命令。
下面开始代码。
/** * 上传依赖到 Maven 私服 * @author * @since */ public class Deploy { /** * mvn -s F:\.m2\settings.xml * deploy:deploy-file * -Durl=http://IP:PORT/nexus/content/repositories/thirdpart * -DrepositoryId=thirdpart * -Dfile=antlr-2.7.2.jar * -DpomFile=antlr-2.7.2.pom * -Dpackaging=jar * -DgeneratePom=false * -Dsources=./path/to/artifact-name-1.0-sources.jar * -Djavadoc=./path/to/artifact-name-1.0-javadoc.jar */ public static final String BASE_CMD = "cmd /c mvn " + "-s F:\\.m2\\settings.xml " + "deploy:deploy-file " + "-Durl=http://IP:PORT/nexus/content/repositories/thirdpart " + "-DrepositoryId=thirdpart " + "-DgeneratePom=false"; public static final Pattern DATE_PATTERN = Pattern.compile("-[\\d]{8}\\.[\\d]{6}-"); public static final Runtime CMD = Runtime.getRuntime(); public static final Writer ERROR; public static final ExecutorService EXECUTOR_SERVICE = Executors.newFixedThreadPool(10);
先看第一部分,BASE_CMD 是基础的命令部分。
- cmd /c 可以保证使用 Java 的runtime 执行命令时,可以找到命令。
- -s F:\\.m2\\settings.xml 参数指定了配置文件的路径(避免多个配置的时候不知道配置那个)。
- deploy:deploy-file 是上传文件的命令。
- -Durl=xxx指定了上传的位置,从nexus中可以找到这个地址。
- -DrepositoryId=thirdpart必须和上面指定的地址一致,从nexus仓库配置可以看到这个id,另外上面提到的settings.xml中的用户密码要和这个id匹配。
- -DgeneratePom=false因为我们会传pom文件,所以禁用自动生成。
后面的DATE_PATTERN
主要是存在快照版时,忽略日期形式的版本,只保留SNAPSHOT
形式的。
再后面获取了一个CMD
和一个线程池。
继续代码。
static { Writer err = null; try { err = new OutputStreamWriter(new FileOutputStream("deploy-error.log"), "utf-8"); } catch (Exception e) { e.printStackTrace(); System.exit(0); } ERROR = err; } public static void error(String error){ try { System.err.println(error); ERROR.write(error + "\n"); ERROR.flush(); } catch (IOException e) { e.printStackTrace(); } }
创建了一个文件来记录错误信息,并且提供了一个静态方法方便使用。
下面是参数校验和提示信息。
public static boolean checkArgs(String[] args){ if (args.length != 1) { System.out.println("用法如: java -jar Deploy D:\\some\\path\\"); return false; } File file = new File(args[0]); if (!file.exists()) { System.out.println(args[0] + " 目录不存在!"); return false; } if (!file.isDirectory()) { System.out.println("必须指定为目录!"); return false; } return true; }
下面方法判断pom文件的packaging 是否为 pom:
public static boolean packingIsPom(File pom){ BufferedReader reader = null; try { BufferedReader reader = new BufferedReader(new InputStreamReader(new FileInputStream(pom))); String line; while((line = reader.readLine()) != null){ if(line.trim().indexOf("<packaging>pom</packaging>")!=-1){ return true; } } } catch (Exception e) { e.printStackTrace(); } finally { try{reader.close();}catch(Exception e){} } return false; }
当为pom类型时,只需要上传pom。
public static void deployPom(final File pom) { EXECUTOR_SERVICE.execute(new Runnable() { @Override public void run() { StringBuffer cmd = new StringBuffer(BASE_CMD); cmd.append(" -DpomFile=").append(pom.getName()); cmd.append(" -Dfile=").append(pom.getName()); try { final Process proc = CMD.exec(cmd.toString(), null, pom.getParentFile()); InputStream inputStream = proc.getInputStream(); InputStreamReader inputStreamReader = new InputStreamReader(inputStream); BufferedReader reader = new BufferedReader(inputStreamReader); String line; StringBuffer logBuffer = new StringBuffer(); logBuffer.append("\n\n\n=====================================\n"); while((line = reader.readLine()) != null){ if (line.startsWith("[INFO]") || line.startsWith("Upload")) { logBuffer.append( Thread.currentThread().getName() + " : " + line + "\n"); } } System.out.println(logBuffer); int result = proc.waitFor(); if(result != 0){ error("上传失败:" + pom.getAbsolutePath()); } } catch (IOException e) { error("上传失败:" + pom.getAbsolutePath()); e.printStackTrace(); } catch (InterruptedException e) { error("上传失败:" + pom.getAbsolutePath()); e.printStackTrace(); } } }); }
注意DpomFile和Dfile都指定的pom文件。
当上传的文件包含 jar 时,使用下面的方式。
public static void deploy( final File pom, final File jar, final File source, final File javadoc) { EXECUTOR_SERVICE.execute(new Runnable() { @Override public void run() { StringBuffer cmd = new StringBuffer(BASE_CMD); cmd.append(" -DpomFile=").append(pom.getName()); if(jar != null){ //当有bundle类型时,下面的配置可以保证上传的jar包后缀为.jar cmd.append(" -Dpackaging=jar -Dfile=").append(jar.getName()); } else { cmd.append(" -Dfile=").append(pom.getName()); } if(source != null){ cmd.append(" -Dsources=").append(source.getName()); } if(javadoc != null){ cmd.append(" -Djavadoc=").append(javadoc.getName()); } try { final Process proc = CMD.exec(cmd.toString(), null, pom.getParentFile()); InputStream inputStream = proc.getInputStream(); InputStreamReader inputStreamReader = new InputStreamReader(inputStream); BufferedReader reader = new BufferedReader(inputStreamReader); String line; StringBuffer logBuffer = new StringBuffer(); logBuffer.append("\n\n\n=====================================\n"); while((line = reader.readLine()) != null){ if (line.startsWith("[INFO]") || line.startsWith("Upload")) { logBuffer.append( Thread.currentThread().getName() + " : " + line + "\n"); } } System.out.println(logBuffer); int result = proc.waitFor(); if(result != 0){ error("上传失败:" + pom.getAbsolutePath()); } } catch (IOException e) { error("上传失败:" + pom.getAbsolutePath()); e.printStackTrace(); } catch (InterruptedException e) { error("上传失败:" + pom.getAbsolutePath()); e.printStackTrace(); } } }); }
必须有pom和jar,source和javadoc可选。
下面是一个对上面代码封装后的方法,这个方法用于迭代查找包含pom,jar,source和javadoc的目录和文件。
public static void deploy(File[] files) { if (files.length == 0) { //ignore } else if (files[0].isDirectory()) { for (File file : files) { if (file.isDirectory()) { deploy(file.listFiles()); } } } else if (files[0].isFile()) { File pom = null; File jar = null; File source = null; File javadoc = null; //忽略日期快照版本,如 xxx-mySql-2.2.6-20170714.095105-1.jar for (File file : files) { String name = file.getName(); if(DATE_PATTERN.matcher(name).find()){ //skip } else if (name.endsWith(".pom")) { pom = file; } else if (name.endsWith("-javadoc.jar")) { javadoc = file; } else if (name.endsWith("-sources.jar")) { source = file; } else if (name.endsWith(".jar")) { jar = file; } } if(pom != null){ if(jar != null){ deploy(pom, jar, source, javadoc); } else if(packingIsPom(pom)){ deployPom(pom); } } } }
在main方法中,有两种调用方式。
public static void main(String[] args) { deploy(new File("F:\\.m2\\repository").listFiles()); EXECUTOR_SERVICE.shutdown(); try { ERROR.close(); } catch (IOException e) { e.printStackTrace(); } }
直接指定一个仓库的目录即可。
还可以是更具体的目录:
deploy(new File("F:\\.m2\\repository\\org\\apache\\tomcat\\xxx\\1.0.0\\").listFiles());
如果想通过命令行调用时指定目录,可以用下面的main方法。
public static void main(String[] args) { if(checkArgs(args)){ File file = new File(args[0]); deploy(file.listFiles()); } EXECUTOR_SERVICE.shutdown(); try { ERROR.close(); } catch (IOException e) { e.printStackTrace(); } }
通过上面这种方式可以很轻易的将依赖传到私服中。如果修改上面url参数为-Durl=E:\\.m2\\repository
,还可以打包到本地仓库中。
虽然内网使用私服的情况不常见,如果遇到这种情况,使用这个代码批量传多少jar包都会变得很容易。
完整代码
import java.io.*; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.regex.Pattern; /** * 上传依赖到 Maven 私服 * @author * @since */ public class Deploy { /** * mvn -s F:\.m2\settings.xml * org.apache.maven.plugins:maven-deploy-plugin:2.8.2:deploy-file * -Durl=http://IP:PORT/nexus/content/repositories/thirdpart * -DrepositoryId=thirdpart * -Dfile=antlr-2.7.2.jar * -DpomFile=antlr-2.7.2.pom * -Dpackaging=jar * -DgeneratePom=false * -Dsources=./path/to/artifact-name-1.0-sources.jar * -Djavadoc=./path/to/artifact-name-1.0-javadoc.jar */ public static final String BASE_CMD = "cmd /c mvn " + "-s F:\\.m2\\settings.xml " + "deploy:deploy-file " + "-Durl=http://IP:PORT/nexus/content/repositories/thirdpart " + "-DrepositoryId=thirdpart " + "-DgeneratePom=false"; public static final Pattern DATE_PATTERN = Pattern.compile("-[\\d]{8}\\.[\\d]{6}-"); public static final Runtime CMD = Runtime.getRuntime(); public static final Writer ERROR; public static final ExecutorService EXECUTOR_SERVICE = Executors.newFixedThreadPool(10); static { Writer err = null; try { err = new OutputStreamWriter(new FileOutputStream("deploy-error.log"), "utf-8"); } catch (Exception e) { e.printStackTrace(); System.exit(0); } ERROR = err; } public static void main(String[] args) { deploy(new File("F:\\.m2\\repository").listFiles()); // if(checkArgs(args)){ // File file = new File(args[0]); // deploy(file.listFiles()); // } EXECUTOR_SERVICE.shutdown(); try { ERROR.close(); } catch (IOException e) { e.printStackTrace(); } } public static void error(String error){ try { System.err.println(error); ERROR.write(error + "\n"); ERROR.flush(); } catch (IOException e) { e.printStackTrace(); } } public static boolean checkArgs(String[] args){ if (args.length != 1) { System.out.println("用法如: java -jar Deploy D:\\some\\path\\"); return false; } File file = new File(args[0]); if (!file.exists()) { System.out.println(args[0] + " 目录不存在!"); return false; } if (!file.isDirectory()) { System.out.println("必须指定为目录!"); return false; } return true; } public static void deploy(File[] files) { if (files.length == 0) { //ignore } else if (files[0].isDirectory()) { for (File file : files) { if (file.isDirectory()) { deploy(file.listFiles()); } } } else if (files[0].isFile()) { File pom = null; File jar = null; File source = null; File javadoc = null; //忽略日期快照版本,如 xxx-mySql-2.2.6-20170714.095105-1.jar for (File file : files) { String name = file.getName(); if(DATE_PATTERN.matcher(name).find()){ //skip } else if (name.endsWith(".pom")) { pom = file; } else if (name.endsWith("-javadoc.jar")) { javadoc = file; } else if (name.endsWith("-sources.jar")) { source = file; } else if (name.endsWith(".jar")) { jar = file; } } if(pom != null){ if(jar != null){ deploy(pom, jar, source, javadoc); } else if(packingIsPom(pom)){ deployPom(pom); } } } } public static boolean packingIsPom(File pom){ BufferedReader reader = null; try { BufferedReader reader = new BufferedReader(new InputStreamReader(new FileInputStream(pom))); String line; while((line = reader.readLine()) != null){ if(line.trim().indexOf("<packaging>pom</packaging>")!=-1){ return true; } } } catch (Exception e) { e.printStackTrace(); } finally { try{reader.close();}catch(Exception e){} } return false; } public static void deployPom(final File pom) { EXECUTOR_SERVICE.execute(new Runnable() { @Override public void run() { StringBuffer cmd = new StringBuffer(BASE_CMD); cmd.append(" -DpomFile=").append(pom.getName()); cmd.append(" -Dfile=").append(pom.getName()); try { final Process proc = CMD.exec(cmd.toString(), null, pom.getParentFile()); InputStream inputStream = proc.getInputStream(); InputStreamReader inputStreamReader = new InputStreamReader(inputStream); BufferedReader reader = new BufferedReader(inputStreamReader); String line; StringBuffer logBuffer = new StringBuffer(); logBuffer.append("\n\n\n==================================\n"); while((line = reader.readLine()) != null){ if (line.startsWith("[INFO]") || line.startsWith("Upload")) { logBuffer.append(Thread.currentThread().getName() + " : " + line + "\n"); } } System.out.println(logBuffer); int result = proc.waitFor(); if(result != 0){ error("上传失败:" + pom.getAbsolutePath()); } } catch (IOException e) { error("上传失败:" + pom.getAbsolutePath()); e.printStackTrace(); } catch (InterruptedException e) { error("上传失败:" + pom.getAbsolutePath()); e.printStackTrace(); } } }); } public static void deploy(final File pom, final File jar, final File source, final File javadoc) { EXECUTOR_SERVICE.execute(new Runnable() { @Override public void run() { StringBuffer cmd = new StringBuffer(BASE_CMD); cmd.append(" -DpomFile=").append(pom.getName()); if(jar != null){ //当有bundle类型时,下面的配置可以保证上传的jar包后缀为.jar cmd.append(" -Dpackaging=jar -Dfile=").append(jar.getName()); } else { cmd.append(" -Dfile=").append(pom.getName()); } if(source != null){ cmd.append(" -Dsources=").append(source.getName()); } if(javadoc != null){ cmd.append(" -Djavadoc=").append(javadoc.getName()); } try { final Process proc = CMD.exec(cmd.toString(), null, pom.getParentFile()); InputStream inputStream = proc.getInputStream(); InputStreamReader inputStreamReader = new InputStreamReader(inputStream); BufferedReader reader = new BufferedReader(inputStreamReader); String line; StringBuffer logBuffer = new StringBuffer(); logBuffer.append("\n\n\n=======================================\n"); while((line = reader.readLine()) != null){ if (line.startsWith("[INFO]") || line.startsWith("Upload")) { logBuffer.append(Thread.currentThread().getName() + " : " + line + "\n"); } } System.out.println(logBuffer); int result = proc.waitFor(); if(result != 0){ error("上传失败:" + pom.getAbsolutePath()); } } catch (IOException e) { error("上传失败:" + pom.getAbsolutePath()); e.printStackTrace(); } catch (InterruptedException e) { error("上传失败:" + pom.getAbsolutePath()); e.printStackTrace(); } } }); } }
使用方式
1.导入项目直接运行 main 方法。
2.使用 javac 编译为class后运行,由于代码存在中文,java代码需要使用utf8格式保存,编译时通过-encoding utf8参数指定。
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对脚本之家的支持。如果你想了解更多相关内容请查看下面相关链接
相关文章
在deepin上如何使用Fleet开发SpringBoot 3.0.0项目
这篇文章主要介绍了在deepin上使用Fleet开发SpringBoot 3.0.0项目的过程,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2023-09-09spring cloud gateway中配置uri三种方式
gateway 组件是SpringCloud 组件中的网关组件,主要是解决路由转发的问题,跟nginx有点类似,区别是nginx多用在前端上,gateway用在后端上,本文给大家介绍的非常详细,需要的朋友参考下吧2023-08-08java.lang.Runtime.exec的左膀右臂:流输入和流读取详解
这篇文章主要介绍了java.lang.Runtime.exec的左膀右臂:流输入和流读取详解,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教2021-11-11
最新评论