解压缩的GZPRIPPPRECT READONLYMEMORY＆lt; byte＆gt;在我做jsondocument.parse之前

Question

WebSocket客户端正在返回 readonlymemory＆lt; byte＆gt; 。

问题是 jsondocument.parse 由于已压缩缓冲区而失败。在解析之前，我必须以某种方式对其进行解压缩。我该怎么做？我无法真正更改Websocket库代码。

我想要的是 public func＆lt; readonlymemory＆lt; byte＆gt;＆gt; datainterPreterBytes =（）=＆gt; 可选地将这些字节解压缩在此类中。我该怎么做？是否可以解压缩 readonlyMemory＆lt; ，并且如果处理程序未使用，则基本上什么都不做。

private static string DecompressData(byte[] byteData)
{
    using var decompressedStream = new MemoryStream();
    using var compressedStream = new MemoryStream(byteData);
    using var deflateStream = new GZipStream(compressedStream, CompressionMode.Decompress);
    deflateStream.CopyTo(decompressedStream);
    decompressedStream.Position = 0;

    using var streamReader = new StreamReader(decompressedStream);
    return streamReader.ReadToEnd();
}

片段

private void OnMessageReceived(object? sender, MessageReceivedEventArgs e)
{
    var timestamp = DateTime.UtcNow;

    _logger.LogTrace("Message was received. {Message}", Encoding.UTF8.GetString(e.Message.Buffer.Span));

    // We dispose that object later on
    using var document = JsonDocument.Parse(e.Message.Buffer);
    var tokenData = document.RootElement;

Answer 1

因此，如果您有一个字节数组，则将执行此操作：

private static JsonDocument DecompressData(byte[] byteData)
{
    using var compressedStream = new MemoryStream(byteData);
    using var deflateStream = new GZipStream(compressedStream, CompressionMode.Decompress);
    return JsonDocument.Parse(deflateStream);
}

这类似于上面的摘要，但不需要中间副本：只需直接从 gzipstream 中读取即可。 jsondocument.parse 还具有一个接管流的过载，因此您可以使用它并避免另一个无用的副本。

不幸的是，您没有字节数组，您有一个 readonlymemory＆lt; byte＆gt; 。没有办法从 readonlymemory＆lt; byte＆gt; 中创建内存流。老实说，感觉就像是一种监督，就像他们忘了将该功能放入.NET中。

因此，这是您的选择。

第一个选项是只需转换 readonlyMemory＆lt; byte＆gt; 对象与 toArray（）>：

// assuming e.Message.Buffer is a ReadOnlyMemory<byte>
using var document = DecompressData(e.Message.Buffer.ToArray());

这确实很简单，但请记住它实际上复制了数据，因此适用于数据，因此大型文档，如果您想避免使用过多的内存，那可能不是一个好主意。

第二个是尝试从内存中提取基础数组。这可以通过 MemoryMarshal.trygetArray 来实现，它为您提供 arrayseggentemenseggenseggenseggensegensegensegensegensegensegensegensegensegray （但是，如果内存实际上不是托管数组）。

private static JsonDocument DecompressData(ReadOnlyMemory<byte> byteData)
{
    if(MemoryMarshal.TryGetArray(byteData, out var segment))
    {
        using var compressedStream = new MemoryStream(segment.Array, segment.Offset, segment.Count);
        // rest of the code goes here
    }
    else
    {
        // Welp, this memory isn't actually an array, so... tough luck?
    } 
}

第三种方式可能会感到肮脏，但是如果您可以使用不安全的代码，可以固定内存的跨度，然后使用 unmanagedMemorystream ：

private static unsafe JsonDocument DecompressData(ReadOnlyMemory<byte> byteData)
{
    fixed (byte* ptr = byteData.Span)
    {
        using var compressedStream = new UnmanagedMemoryStream(ptr, byteData.Length);
        using var deflateStream = new GZipStream(compressedStream, CompressionMode.Decompress);
        return JsonDocument.Parse(deflateStream);
    }       
}

另一个解决方案是编写您自己的 stream < /代码>支持此的类。 流包装器 目的。如果您不为此使用整个第三方库，那么您可能只能滚动自己的代码太多。