阅读内存映射文件或内存映射视图访问器的所有内容而不知道它的大小

Question

我需要类似于ReadToEnd或ReadAllBytes使用MappedViewAccessor读取MemoryMappedFile的所有内容，如果我不知道大小它，我该怎么做？

我已经寻找它

，我已经看到了这个问题，但它不是我要找的东西：

How can I quickly read bytes from a memory mapped file in .NET?

编辑：

有一个问题， （int）stream.Length没有给我正确的长度，而是给出了使用的内部缓冲区的大小！我需要刷新这个问题，因为它非常紧迫。

Answer 1

而是使用Stream：

public static Byte[] ReadMMFAllBytes(string fileName) 
{ 
    using (var mmf = MemoryMappedFile.OpenExisting(fileName)) 
    { 
     using (var stream = mmf.CreateViewStream()) 
     { 
      using (BinaryReader binReader = new BinaryReader(stream)) 
      { 
       return binReader.ReadBytes((int)stream.Length); 
      } 
     } 
    } 
} 

Answer 2

你不能做到这一点。

视图访问器是用系统页面的最小尺寸创建的，这意味着它可能比实际文件大。视图流只是访问者的流形式，所以它也会给出相同的行为。 “在系统页面的单位提供意见，并认为 的大小舍入到下一个系统页面大小”

http://msdn.microsoft.com/en-us/library/dd267577.aspx

访问者会很乐意阅读和在实际文件之外写入而不会抛出异常。读取时，文件外的任何字节将仅为零。写入时，写入文件外的字节被忽略。

要从具有原始文件的确切大小的内存映射文件中读取文件，您必须已经知道该大小。

Answer 3

这是很难回答的，因为还有你没有指定你的应用程序中的许多细节，但我认为这两个Guffa的和阿米尔的答案仍然是部分正确：

• 一个MemoryMappedFile比更多的内存文件;它是内存中一系列4Kb页面。因此，stream.Length实际上会给你所有的字节（没有“内部缓冲区大小”），但它可能会给你更多的字节比你期望的大，因为大小总是四舍五入到4Kb的边界。
• “文件”语义来自将MemoryMappedFile关联到真实文件系统文件。假设创建文件的进程总是调整文件大小，那么可以通过fileSystem获取文件的精确大小。

如果以上所有会适合你的应用程序，那么下面应该工作：

static byte[] ReadMemoryMappedFile(string fileName) 
    { 
     long length = new FileInfo(fileName).Length; 
     using (var stream = File.Open(fileName, FileMode.OpenOrCreate, FileAccess.Read, FileShare.ReadWrite)) 
     { 
      using (var mmf = MemoryMappedFile.CreateFromFile(stream, null, length, MemoryMappedFileAccess.Read, null, HandleInheritability.Inheritable, false)) 
      { 
       using (var viewStream = mmf.CreateViewStream(0, length, MemoryMappedFileAccess.Read)) 
       { 
        using (BinaryReader binReader = new BinaryReader(viewStream)) 
        { 
         var result = binReader.ReadBytes((int)length); 
         return result; 
        } 
       } 
      } 
     } 
    } 

要写入数据，您可以使用此：

private static void WriteData(string fileName, byte[] data) 
    { 
     using (var stream = File.Open(fileName, FileMode.OpenOrCreate, FileAccess.ReadWrite, FileShare.ReadWrite)) 
     { 
      using (var mmf = MemoryMappedFile.CreateFromFile(stream, null, data.Length, MemoryMappedFileAccess.ReadWrite, null, HandleInheritability.Inheritable, true)) 
      { 
       using (var view = mmf.CreateViewAccessor()) 
       { 
        view.WriteArray(0, data, 0, data.Length); 
       } 
      } 

      stream.SetLength(data.Length); // Make sure the file is the correct length, in case the data got smaller. 
     } 
    } 

但是，由当你完成上述所有操作时，你可以直接使用该文件并避免内存映射。如果将它映射到文件系统是不可接受的，那么Guffa对数据本身的长度（或结束标记）进行编码的答案可能是最好的。

Answer 4

就在@Amer空沙旺的解决方案转换为Vb.NET：

' Usage Example: 
' Dim ReadBytes As Byte() = ReadMemoryMappedFile(Name:="My MemoryMappedFile Name") ' Read the byte-sequence from memory. 
' Dim Message As String = System.Text.Encoding.ASCII.GetString(ReadBytes.ToArray) ' Convert the bytes to String. 
' Message = Message.Trim({ControlChars.NullChar}) ' Remove null chars (leading zero-bytes) 
' MessageBox.Show(Message, "", MessageBoxButtons.OK) ' Show the message. ' 
' 
''' <summary> 
''' Reads a byte-sequence from a <see cref="IO.MemoryMappedFiles.MemoryMappedFile"/> without knowing the exact size. 
''' Note that the returned byte-length is rounded up to 4kb, 
''' this means if the mapped memory-file was written with 1 byte-length, this method will return 4096 byte-length. 
''' </summary> 
''' <param name="Name">Indicates an existing <see cref="IO.MemoryMappedFiles.MemoryMappedFile"/> assigned name.</param> 
''' <returns>System.Byte().</returns> 
Private Function ReadMemoryMappedFile(ByVal Name As String) As Byte() 

    Try 
     Using MemoryFile As IO.MemoryMappedFiles.MemoryMappedFile = 
      IO.MemoryMappedFiles.MemoryMappedFile.OpenExisting(Name, IO.MemoryMappedFiles.MemoryMappedFileRights.ReadWrite) 

      Using Stream = MemoryFile.CreateViewStream() 

       Using Reader As New BinaryReader(Stream) 

        Return Reader.ReadBytes(CInt(Stream.Length)) 

       End Using ' Reader 

      End Using ' Stream 

     End Using ' MemoryFile 

    Catch exNoFile As IO.FileNotFoundException 
     Throw 
     Return Nothing 

    Catch ex As Exception 
     Throw 

    End Try 

End Function 

Answer 5

我想有从MemoryStream的.ToArray东西（）方法返回的所有字节，并在下面工作的代码对我来说：

using (MemoryMappedFile mmf = MemoryMappedFile.OpenExisting(MemoryMappedName)) 
{ 
    using (MemoryMappedViewStream stream = mmf.CreateViewStream()) 
    { 
     using (MemoryStream memStream = new MemoryStream()) 
     { 
      stream.CopyTo(memStream); 
      return memStream.ToArray(); 
     } 
    } 
} 

干杯！

Answer 6

使用FileInfo类获得长度如下图所示

public void WriteToMemoryMap(DataSet ds, string key, string fileName) 
    { 
     var bytes = CompressData(ds); 
     using (System.IO.MemoryMappedFiles.MemoryMappedFile objMf = System.IO.MemoryMappedFiles.MemoryMappedFile.CreateFromFile(fileName, System.IO.FileMode.OpenOrCreate, key, bytes.Length)) 
     { 
      using (System.IO.MemoryMappedFiles.MemoryMappedViewAccessor accessor = objMf.CreateViewAccessor()) 
      { 
       accessor.WriteArray(0, bytes, 0, bytes.Length); 
      } 
     } 
    } 
    public DataSet ReadFromMemoryMap(string fileName) 
    { 
     var fi = new FileInfo(fileName); 
     var length = (int)fi.Length; 
     var newBytes = new byte[length]; 
     using (System.IO.MemoryMappedFiles.MemoryMappedFile objMf = System.IO.MemoryMappedFiles.MemoryMappedFile.CreateFromFile(fileName, FileMode.Open)) 
     { 
      using (System.IO.MemoryMappedFiles.MemoryMappedViewAccessor accessor = objMf.CreateViewAccessor()) 
      { 
       accessor.ReadArray(0, newBytes, 0, length); 
      } 
     } 
     return DecompressData(newBytes); 
    } 
    public byte[] CompressData(DataSet ds) 
    { 
     try 
     { 
      byte[] data = null; 
      var memStream = new MemoryStream(); 
      var zipStream = new GZipStream(memStream, CompressionMode.Compress); 
      ds.WriteXml(zipStream, XmlWriteMode.WriteSchema); 
      zipStream.Close(); 
      data = memStream.ToArray(); 
      memStream.Close(); 
      return data; 
     } 
     catch (Exception ex) 
     { 
      return null; 
     } 
    } 
    public DataSet DecompressData(byte[] data) 
    { 
     try 
     { 
      var memStream = new MemoryStream(data); 
      var unzipStream = new GZipStream(memStream, CompressionMode.Decompress); 
      var objDataSet = new DataSet(); 
      objDataSet.ReadXml(unzipStream, XmlReadMode.ReadSchema); 
      unzipStream.Close(); 
      memStream.Close(); 
      return objDataSet; 
     } 
     catch (Exception ex) 
     { 
      return null; 
     } 
    }