import org.sonatype.aether.repository.LocalRepository; //导入依赖的package包/类
public static RepositorySystemSession newRepositorySystemSession(
    RepositorySystem system, String localRepoPath) {
  Validate.notNull(localRepoPath, "localRepoPath should have a value");

  MavenRepositorySystemSession session = new MavenRepositorySystemSession();

  LocalRepository localRepo = new LocalRepository(resolveLocalRepoPath(localRepoPath));
  session.setLocalRepositoryManager(system.newLocalRepositoryManager(localRepo));

  if (logger.isDebugEnabled()) {
    session.setTransferListener(new TransferListener());
    session.setRepositoryListener(new RepositoryListener());
  }
  // uncomment to generate dirty trees
  // session.setDependencyGraphTransformer( null );

  return session;
}
 

import org.sonatype.aether.repository.LocalRepository; //导入依赖的package包/类
private static String format( LocalRepository localRepository, List<RemoteRepository> remoteRepositories )
{
    String repos = "[";

    if ( localRepository != null )
    {
        repos += localRepository.getId() + " (" + localRepository.getBasedir() + ")";
    }

    if ( remoteRepositories != null && !remoteRepositories.isEmpty() )
    {
        for ( RemoteRepository repository : remoteRepositories )
        {
            repos += ", ";

            if ( repository != null )
            {
                repos += repository.getId() + " (" + repository.getUrl() + ")";
            }
        }
    }

    repos += "]";

    return repos;
}
 

import org.sonatype.aether.repository.LocalRepository; //导入依赖的package包/类
public static RepositorySystemSession newRepositorySystemSession(
    RepositorySystem system, String localRepoPath) {
  MavenRepositorySystemSession session = new MavenRepositorySystemSession();

  // find homedir
  String home = System.getenv("ZEPPELIN_HOME");
  if (home == null) {
    home = System.getProperty("zeppelin.home");
  }
  if (home == null) {
    home = "..";
  }

  String path = home + "/" + localRepoPath;

  LocalRepository localRepo =
      new LocalRepository(new File(path).getAbsolutePath());
  session.setLocalRepositoryManager(system.newLocalRepositoryManager(localRepo));

  // session.setTransferListener(new ConsoleTransferListener());
  // session.setRepositoryListener(new ConsoleRepositoryListener());

  // uncomment to generate dirty trees
  // session.setDependencyGraphTransformer( null );

  return session;
}
 

import org.sonatype.aether.repository.LocalRepository; //导入依赖的package包/类
public static RepositorySystemSession newRepositorySystemSession( RepositorySystem system, File localRepoDir )
{
    MavenRepositorySystemSession session = new MavenRepositorySystemSession();

    LocalRepository localRepo = new LocalRepository(localRepoDir);
    session.setLocalRepositoryManager( system.newLocalRepositoryManager( localRepo ) );

    session.setTransferListener( new TransferListener() );
    session.setRepositoryListener( new RepositoryListener() );

    return session;
}
 

import org.sonatype.aether.repository.LocalRepository; //导入依赖的package包/类
public static RepositorySystemSession newMavenRepositorySystemSession( RepositorySystem system )
{
    MavenRepositorySystemSession session = new MavenRepositorySystemSession( true );

    LocalRepository localRepo = new LocalRepository( "target/local-repo" );
    session.setLocalRepositoryManager( system.newLocalRepositoryManager( localRepo ) );

    session.setTransferListener( new ConsoleTransferListener() );
    session.setRepositoryListener( new ConsoleRepositoryListener() );

    return session;
}
 

import org.sonatype.aether.repository.LocalRepository; //导入依赖的package包/类
public PluginVersionResolutionException( String groupId, String artifactId, LocalRepository localRepository,
                                         List<RemoteRepository> remoteRepositories, String baseMessage )
{
    super( "Error resolving version for plugin \'" + groupId + ":" + artifactId + "\' from the repositories "
        + format( localRepository, remoteRepositories ) + ": " + baseMessage );

    this.groupId = groupId;
    this.artifactId = artifactId;
    this.baseMessage = baseMessage;
}
 

import org.sonatype.aether.repository.LocalRepository; //导入依赖的package包/类
private LegacyLocalRepositoryManager( ArtifactRepository delegate )
{
    if ( delegate == null )
    {
        throw new IllegalArgumentException( "local repository delegate missing" );
    }
    this.delegate = delegate;

    ArtifactRepositoryLayout layout = delegate.getLayout();
    repo =
        new LocalRepository( new File( delegate.getBasedir() ),
                             ( layout != null ) ? layout.getClass().getSimpleName() : "legacy" );

    /*
     * NOTE: "invoker:install" vs "appassembler:assemble": Both mojos use the artifact installer to put an artifact
     * into a repository. In the first case, the result needs to be a proper local repository that one can use for
     * local artifact resolution. In the second case, the result needs to precisely obey the path information of the
     * repository's layout to allow pointing at artifacts within the repository. Unfortunately,
     * DefaultRepositoryLayout does not correctly describe the layout of a local repository which unlike a remote
     * repository never uses timestamps in the filename of a snapshot artifact. The discrepancy gets notable when a
     * remotely resolved snapshot artifact gets passed into pathOf(). So producing a proper local artifact path
     * using DefaultRepositoryLayout requires us to enforce usage of the artifact's base version. This
     * transformation however contradicts the other use case of precisely obeying the repository's layout. The below
     * flag tries to detect which use case applies to make both plugins happy.
     */
    realLocalRepo = ( layout instanceof DefaultRepositoryLayout ) && "local".equals( delegate.getId() );
}
 

import org.sonatype.aether.repository.LocalRepository; //导入依赖的package包/类
public static void main(String[] args) throws DependencyResolutionException {
    Injector injector = Guice.createInjector(
        new RepositorySystemModule() {
            @Override
            public List<RemoteRepository> getRemoteRepositories(ExtensionList<RemoteRepositoryDecorator> decorators) {
                try {
                    List<RemoteRepository> repos = super.getRemoteRepositories(decorators);

                    // use our real local repository as one of the remote repositories,
                    // so that this process runs quickly.
                    File local = new File(new File(System.getProperty("user.home")), ".m2/repository");
                    repos.add(0,new RemoteRepository("local","default",local.toURL().toExternalForm()));

                    repos.add(new RemoteRepository("repo.jenkins-ci.org","default","http://repo.jenkins-ci.org/public/"));
                    return repos;
                } catch (MalformedURLException e) {
                    throw new Error(e);
                }
            }
        }
    );

    // we tell Aether that our local repository is elsewhere, so that we can capture everything
    File dir = new File(args[0]);
    dir.mkdirs();
    injector.getInstance(LocalRepositorySetting.class).set(
            new LocalRepository(dir));

    // resolve away
    RepositoryService rs = injector.getInstance(RepositoryService.class);
    DependencyResult result = rs.resolveDependencies(
            new GAV(BeesLoader.MAIN.groupId, BeesLoader.MAIN.artifactId, args[1]));

    // generate maven-metadata.xml files. necessary for resolving LATEST version label.
    for (ArtifactResult ar : result.getArtifactResults()) {
        writeMetadata(ar.getArtifact(),dir);
    }
}
 

import org.sonatype.aether.repository.LocalRepository; //导入依赖的package包/类
@Override
protected void configure() {
    // NettyAsyncHttpProvider prints some INFO-level messages. suppress them
    Logger.getLogger("com.ning.http.client.providers.netty.NettyAsyncHttpProvider").setLevel(Level.WARNING);
    LoggerFactory.getLogger(NettyAsyncHttpProvider.class);

    bind(LocalRepository.class).toProvider(LocalRepositorySetting.class);
    bind(MavenRepositorySystemSession.class).toProvider(MavenRepositorySystemSessionFactory.class);
}
 

import org.sonatype.aether.repository.LocalRepository; //导入依赖的package包/类
private Versioning readVersions( RepositorySystemSession session, RequestTrace trace, Metadata metadata,
                                 ArtifactRepository repository, VersionResult result )
{
    Versioning versioning = null;

    FileInputStream fis = null;
    try
    {
        if ( metadata != null )
        {
            SyncContext syncContext = syncContextFactory.newInstance( session, true );

            try
            {
                syncContext.acquire( null, Collections.singleton( metadata ) );

                if ( metadata.getFile() != null && metadata.getFile().exists() )
                {
                    fis = new FileInputStream( metadata.getFile() );
                    org.apache.maven.artifact.repository.metadata.Metadata m =
                        new MetadataXpp3Reader().read( fis, false );
                    versioning = m.getVersioning();

                    /*
                     * NOTE: Users occasionally misuse the id "local" for remote repos which screws up the metadata
                     * of the local repository. This is especially troublesome during snapshot resolution so we try
                     * to handle that gracefully.
                     */
                    if ( versioning != null && repository instanceof LocalRepository)
                    {
                        if ( versioning.getSnapshot() != null && versioning.getSnapshot().getBuildNumber() > 0 )
                        {
                            Versioning repaired = new Versioning();
                            repaired.setLastUpdated( versioning.getLastUpdated() );
                            Snapshot snapshot = new Snapshot();
                            snapshot.setLocalCopy( true );
                            repaired.setSnapshot( snapshot );
                            versioning = repaired;

                            throw new IOException( "Snapshot information corrupted with remote repository data"
                                + ", please verify that no remote repository uses the id '" + repository.getId()
                                + "'" );
                        }
                    }
                }
            }
            finally
            {
                syncContext.release();
            }
        }
    }
    catch ( Exception e )
    {
        invalidMetadata( session, trace, metadata, repository, e );
        result.addException( e );
    }
    finally
    {
        IOUtil.close(fis);
    }

    return ( versioning != null ) ? versioning : new Versioning();
}
 

import org.sonatype.aether.repository.LocalRepository; //导入依赖的package包/类
private Versioning readVersions( RepositorySystemSession session, RequestTrace trace, Metadata metadata,
                                 ArtifactRepository repository, VersionResult result )
{
    Versioning versioning = null;

    FileInputStream fis = null;
    try
    {
        if ( metadata != null )
        {
            SyncContext syncContext = syncContextFactory.newInstance( session, true );

            try
            {
                syncContext.acquire( null, Collections.singleton( metadata ) );

                if ( metadata.getFile() != null && metadata.getFile().exists() )
                {
                    fis = new FileInputStream( metadata.getFile() );
                    org.apache.maven.artifact.repository.metadata.Metadata m =
                        new MetadataXpp3Reader().read( fis, false );
                    versioning = m.getVersioning();

                    /*
                     * NOTE: Users occasionally misuse the id "local" for remote repos which screws up the metadata
                     * of the local repository. This is especially troublesome during snapshot resolution so we try
                     * to handle that gracefully.
                     */
                    if ( versioning != null && repository instanceof LocalRepository )
                    {
                        if ( versioning.getSnapshot() != null && versioning.getSnapshot().getBuildNumber() > 0 )
                        {
                            Versioning repaired = new Versioning();
                            repaired.setLastUpdated( versioning.getLastUpdated() );
                            Snapshot snapshot = new Snapshot();
                            snapshot.setLocalCopy( true );
                            repaired.setSnapshot( snapshot );
                            versioning = repaired;

                            throw new IOException( "Snapshot information corrupted with remote repository data"
                                + ", please verify that no remote repository uses the id '" + repository.getId()
                                + "'" );
                        }
                    }
                }
            }
            finally
            {
                syncContext.release();
            }
        }
    }
    catch ( Exception e )
    {
        invalidMetadata( session, trace, metadata, repository, e );
        result.addException( e );
    }
    finally
    {
        IOUtil.close( fis );
    }

    return ( versioning != null ) ? versioning : new Versioning();
}
 

import org.sonatype.aether.repository.LocalRepository; //导入依赖的package包/类
public NoPluginFoundForPrefixException( String prefix, List<String> pluginGroups, LocalRepository localRepository,
                                        List<RemoteRepository> remoteRepositories )
{
    super( "No plugin found for prefix '" + prefix + "' in the current project and in the plugin groups "
        + pluginGroups + " available from the repositories " + format( localRepository, remoteRepositories ) );
}
 

import org.sonatype.aether.repository.LocalRepository; //导入依赖的package包/类
public LocalRepository getRepository()
{
    return repo;
}
 

import org.sonatype.aether.repository.LocalRepository; //导入依赖的package包/类
public void set(LocalRepository localRepository) {
    this.localRepository = localRepository;
}