批量将现有Jar包上传到Maven私服

湛蓝之海

今天小编就为大家分享一篇关于批量将现有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参数指定。
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对CodeAE代码之家的支持。如果你想了解更多相关内容请查看下面相关链接
原文链接：https://blog.csdn.net/isea533/article/details/77197017

[Java] 批量将现有Jar包上传到Maven私服

相关帖子

定时关电脑操作方法

autorun.inf怎么删除不掉

路由器的作用与功能

电脑@怎么打出来的

电脑里的tencent可以删除吗

win7对cpu要求高

怎么换背景色一寸照片

【分享】Linux系统下3种常用的网络测速工具!

WordPress显示当前文章分类下的最新文章

H5+JS+CSS3实现七夕言情源码分享

湛蓝之海 LV3