进程无法访问该文件，因为第二次调用时其他进程正在使用该文件-Java 学习之路

我有一个Azure函数（HttpTrigger），它在我的Azure存储中创建一个tar.gz文件 .

当我触发它一次时，文件就会成功创建 . 但如果我再次点击它我有一个错误：

[Info]进程无法访问文件'D：\ local \ Temp \ myDir \ tarArchive.tar.gz'，因为它正由另一个进程使用 .

我必须重新启动Azure门户中的功能才能创建另一个文件 .

这是我的代码：

FileStream fs = new FileStream(myDir+"/firstFile", FileMode.Create);
fs.Write(bytesToCompress, 0, bytesToCompress.Length);
fs.Dispose();
FileStream sfs = new FileStream(myDir + "/secondfile", FileMode.Create);
sfs.Dispose();

DirectoryInfo DirectoryOfFilesToBeTarred = new DirectoryInfo(myDir);
FileInfo[] filesInDirectory = DirectoryOfFilesToBeTarred.GetFiles();

string tarArchiveName = myDir + "/tarArchive.tar.gz";

using (Stream targetStream = new GZipOutputStream(File.Create(tarArchiveName)))
 {
    using (TarArchive tarArchive = TarArchive.CreateOutputTarArchive(targetStream, TarBuffer.DefaultBlockFactor))
    {
        foreach(FileInfo fileToBeTarred in filesInDirectory)
        {
           log.Info(fileToBeTarred.FullName);
           TarEntry entry = TarEntry.CreateEntryFromFile(fileToBeTarred.FullName);                            
           tarArchive.WriteEntry(entry, true); // Error thrown here

        }
    }
 }

我认为当再次调用该函数时，fileToBeTarred仍在使用（我错了吗？）但是我试图从这个FileInfo创建一个流来Dispose（）它，但是没有解决我的问题 . 我也尝试删除（）它，没有任何影响 .

有人看到我看不到的东西吗？

谢谢你的帮助

UPDATE

这是Wim Coenen给出的核心代码

using (Stream fileStream = File.Create(tarArchiveName))
using (Stream targetStream = new GZipOutputStream(fileStream))
using (TarArchive tarArchive = TarArchive.CreateOutputTarArchive(targetStream, TarBuffer.DefaultBlockFactor))
 {
   foreach (FileInfo fileToBeTarred in filesInDirectory)
   {
     log.Info(fileToBeTarred.FullName);
     TarEntry entry = TarEntry.CreateEntryFromFile(fileToBeTarred.FullName);
     tarArchive.WriteEntry(entry, true); // Error thrown here 
   }
}

并且错误的日志（e =异常对象）e.message =>

2018-08-01T11：59：46.887 [Info]进程无法访问文件'D：\ local \ Temp \ myDir \ tarArchive.tar.gz'，因为它正被另一个进程使用 .

e.ToString（）=>

2018-08-01T11：59：47.152 [Info] System.IO.IOException：进程无法访问文件'D：\ local \ Temp \ myDir \ tarArchive.tar.gz'，因为它正由另一个进程使用 . 在System.IO .__ Error.WinIOError（Int32 errorCode，String maybeFullPath）at System.IO.FileStream.Init（String path，FileMode mode，FileAccess access，Int32 rights，Boolean useRights，FileShare share，Int32 bufferSize，FileOptions options，SECURITY_ATTRIBUTES secAttrs），String msgPath，Boolean bFromProxy，Boolean useLongPath，Boolean checkHost）at System.SIO.FileStream..ctor（String path，FileMode mode，FileAccess access，FileShare share）at ICSharpCode.SharpZipLib.Tar.TarArchive.WriteEntryCore（TarEntry sourceEntry，Boolean recurse）at UploadFileFromFromBCText.Function1.d__4.MoveNext（）的ICSharpCode.SharpZipLib.Tar.TarArchive.WriteEntry（TarEntry sourceEntry，Boolean recurse）

3 回答

0

看起来您不是在Azure存储中创建它，而是在Function App实例的本地磁盘上创建它 . 这可能不是一个好主意，因为实例是短暂的，并且不会长时间保存您的文件 .

相反，请查看Azure Blob Storage Output binding - 其目的是在不使用低级文件API或SDK的情况下将文件存储在Azure存储中 .

回复于 2024-04-19T19:13:42+08:00

问题是您没有处理 File.Create(tarArchiveName)) 返回的流 . 固定版本：

using (Stream fileStream = File.Create(tarArchiveName))
using (Stream targetStream = new GZipOutputStream(fileStream))
using (TarArchive tarArchive = TarArchive.CreateOutputTarArchive(targetStream, TarBuffer.DefaultBlockFactor))
{
    foreach(FileInfo fileToBeTarred in filesInDirectory)
    {
        log.Info(fileToBeTarred.FullName);
        TarEntry entry = TarEntry.CreateEntryFromFile(fileToBeTarred.FullName);                            
        tarArchive.WriteEntry(entry, true);
    }
 }

回复于 2024-04-19T19:13:42+08:00

我刚刚发现问题所在：

事实上，当我第一次触发触发器时，myDir是空的 . 所以我此时创建了两个文件

FileStream fs = new FileStream(myDir+"/firstFile", FileMode.Create);
fs.Write(bytesToCompress, 0, bytesToCompress.Length);
fs.Dispose();
FileStream sfs = new FileStream(myDir + "/secondfile", FileMode.Create);
sfs.Dispose();

使用这些文件，我创建了一个tar.gz存档，其中包含目录中尚未存在的文件 .

第二次触发触发器时，tar.gz文件存在，属于该目录 . 所以，当我这样做

foreach(FileInfo fileToBeTarred in filesInDirectory)
    {
        log.Info(fileToBeTarred.FullName);
        TarEntry entry = TarEntry.CreateEntryFromFile(fileToBeTarred.FullName);                            
        tarArchive.WriteEntry(entry, true);
    }

在某一时刻，它适用于tar.gz文件..！

filesInDiretory由此方法填充：

FileInfo[] filesInDirectory = DirectoryOfFilesToBeTarred.GetFiles();

所以我解决了这个问题：

检查文件是否存在 . 如果是，我删除它 .
填写filesInDirectory后

所以我的完整代码现在看起来像这样：

DirectoryInfo DirectoryOfFilesToBeTarred = new DirectoryInfo(myDir);
        string tarArchiveName = myDir + "/tarArchive.tar.gz";
        if (File.Exists(tarArchiveName))
        {
            log.Info("file exists");
            File.Delete(tarArchiveName);

        }
        FileInfo[] filesInDirectory = DirectoryOfFilesToBeTarred.GetFiles();

        using (Stream fileStream = File.Create(tarArchiveName))
        using (Stream targetStream = new GZipOutputStream(fileStream))
        using (TarArchive tarArchive = TarArchive.CreateOutputTarArchive(targetStream, TarBuffer.DefaultBlockFactor))
        {
            foreach (FileInfo fileToBeTarred in filesInDirectory)
            {
                Directory.SetCurrentDirectory(Path.GetTempPath() + "/myDir");
                log.Info(fileToBeTarred.Name);
                log.Info(fileToBeTarred.FullName);
                TarEntry entry = TarEntry.CreateEntryFromFile(fileToBeTarred.FullName);

                tarArchive.WriteEntry(entry, true);


            }

        }

回复于 2024-04-19T19:13:42+08:00

进程无法访问该文件，因为第二次调用时其他进程正在使用该文件

3 回答

相关问题