4

我已经实现了一个与基于云的存储交互的自定义​​ maven wagon。文件成功上传到云存储，校验和正确。

maven-metadata.xml 的 md5 与 maven-metadata.xml.md5 的内容匹配

jar 和 pom 文件也是如此

  1. jar 的 md5 匹配 *.jar.md5 的内容
  2. maven-metadata.xml 的 md5 匹配 maven-metadata.xml.md5 的内容
  3. pom 的 md5 匹配 *.pom.md5 的内容

当我通过 http 而不是使用自定义 wagon 检索文件时，它们会在没有任何校验和验证异常的情况下下载。

但是，当我使用自定义旅行车检索文件时，我会收到下载警告的完整性。

[WARNING] Could not validate integrity of download from gs://mavenbucket/snapshot/com/gkatzioura/storage/CloudStorageTest/1.0-SNAPSHOT/maven-metadata.xml
 org.eclipse.aether.transfer.ChecksumFailureException: Checksum validation failed, expected 7e0c3c33db781362483c0baed3ba175352945028 but is da39a3ee5e6b4b0d3255bfef95601890afd80709
at org.eclipse.aether.connector.basic.ChecksumValidator.validateExternalChecksums (ChecksumValidator.java:174)
at org.eclipse.aether.connector.basic.ChecksumValidator.validate (ChecksumValidator.java:103)
at org.eclipse.aether.connector.basic.BasicRepositoryConnector$GetTaskRunner.runTask (BasicRepositoryConnector.java:456)
at org.eclipse.aether.connector.basic.BasicRepositoryConnector$TaskRunner.run (BasicRepositoryConnector.java:360)
at org.eclipse.aether.util.concurrency.RunnableErrorForwarder$1.run (RunnableErrorForwarder.java:75)
at org.eclipse.aether.connector.basic.BasicRepositoryConnector$DirectExecutor.execute (BasicRepositoryConnector.java:583)
at org.eclipse.aether.connector.basic.BasicRepositoryConnector.get (BasicRepositoryConnector.java:232)

通过自定义旅行车成功下载工件后，我会检查从云存储下载的文件的 md5，它们与云存储中的 *.md5 文件匹配。

解决此问题的过程是什么？如何调试？

4

1 回答 1

1

发生这种情况的原因与未调用 TransferListeners 的 transferProgress 方法有关。

为此，您必须提供一种机制，以便当您的 OutputStream（下载时）和 InputStream（上传时）被复制时，也将调用 transferProgress 方法。

例如

import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;

import org.apache.maven.wagon.events.TransferEvent;
import org.apache.maven.wagon.events.TransferListener;

public class WrappedOutputStreamExample extends FileOutputStream {

    private TransferListener transferListener;

    public WrappedOutputStreamExample(File file,TransferListener transferListener) throws FileNotFoundException {
        super(file);
        this.transferListener = transferListener;
    }

    @Override
    public void write(int b) throws IOException {
        super.write(b);
        TransferEvent transferEvent = null; //provide corrent transfer event
        this.transferListener.transferProgress(transferEvent,new byte[]{(byte) b}, 1);
    }

    @Override
    public void write(byte b[]) throws IOException {
        super.write(b);
        TransferEvent transferEvent = null; //provide corrent transfer event
        this.transferListener.transferProgress(transferEvent,b, b.length);
    }

    @Override
    public void write(byte b[], int off, int len) throws IOException {
        TransferEvent transferEvent = null; //provide corrent transfer event

        super.write(b, off, len);
        if (off == 0) {
            this.transferListener.transferProgress(transferEvent,b, len);
        } else {
            byte[] bytes = new byte[len];
            System.arraycopy(b, off, bytes, 0, len);
            this.transferListener.transferProgress(transferEvent,bytes, len);
        }
    }

}
于 2018-03-30T21:32:18.193 回答