c# - Azure CloudBlobStream 序列化(使用 Json.NET)

Question

我有一个小问题。我的环境是 .NET Core 2.1 中的控制台应用程序。

看看这段代码:

private static void Main(string[] args)
{
    try
    {
        Console.WriteLine($"Test starts: {DateTime.Now.ToString("o")}");

        string connectionString = "[My connection string]";
        string containerName = "mycontainer";

        CloudStorageAccount account = CloudStorageAccount.Parse(connectionString);
        CloudBlobClient serviceClient = account.CreateCloudBlobClient();
        CloudBlobContainer container = serviceClient.GetContainerReference(containerName);

        container.CreateIfNotExistsAsync().Wait();

        CloudBlockBlob cloudBlockBlob = container.GetBlockBlobReference($"{containerName}/Test.txt");
        CloudBlobStream cloudBlobStream = cloudBlockBlob.OpenWriteAsync().Result;

        string json = JsonConvert.SerializeObject(cloudBlobStream);

        Console.WriteLine($"Test ends: {DateTime.Now.ToString("o")}");
    }
    catch (Exception e)
    {
        string stackTrace = e.StackTrace;

        while(e != null)
        {
            Console.WriteLine(e.Message);
            e = e.InnerException;
        }
        Console.WriteLine(stackTrace);
    }
    Console.Write("Press any key to exit...");
    Console.ReadKey();
}

当我尝试序列化 CloudBlobStream使用命令 string json = JsonConvert.SerializeObject(cloudBlobStream); 的对象，我得到以下异常:

Error getting value from 'Length' on 'Microsoft.WindowsAzure.Storage.Blob.BlobWriteStream'. Specified method is not supported. at Newtonsoft.Json.Serialization.ExpressionValueProvider.GetValue(Object target) at Newtonsoft.Json.Serialization.JsonSerializerInternalWriter.CalculatePropertyValues(JsonWriter writer, Object value, JsonContainerContract contract, JsonProperty member, JsonProperty property, JsonContract& memberContract, Object& memberValue) at Newtonsoft.Json.Serialization.JsonSerializerInternalWriter.SerializeObject(JsonWriter writer, Object value, JsonObjectContract contract, JsonProperty member, JsonContainerContract collectionContract, JsonProperty containerProperty) at Newtonsoft.Json.Serialization.JsonSerializerInternalWriter.Serialize(JsonWriter jsonWriter, Object value, Type objectType) at Newtonsoft.Json.JsonSerializer.SerializeInternal(JsonWriter jsonWriter, Object value, Type objectType) at Newtonsoft.Json.JsonConvert.SerializeObjectInternal(Object value, Type type, JsonSerializer jsonSerializer) at AzureBlobStreamSerializationTest.Program.Main(String[] args) in C:\Projects\AzureBlobStreamSerializationTest\AzureBlobStreamSerializationTest\Program.cs:line 28

关于如何解决问题的任何想法？

问候，
阿蒂利奥

Answer 1

在您的代码中，看起来您实际上是在尝试序列化 Stream对象，就好像它是数据一样。这行不通。发生异常是因为序列化程序试图从 Stream 读取所有公共(public)属性。目的。这些属性之一是 Length ，在打开流进行写入时不可读。

我认为您误解了如何将流与 Json.Net 和 Azure 存储 blob 一起使用。 JsonConvert类实际上只是一个门面，不幸的是它的SerializeObject()方法没有支持流的重载。要使用 Json.Net 处理流，您需要使用 JsonSerializer实例以及 StreamWriter和 JsonTextWriter如果您要序列化到流，或 StreamReader和 JsonTextReader如果你正在反序列化它。

以下是一些扩展方法，您可能会觉得它们很有帮助和启发:

public static class BlobExtensions
{
    public static async Task SerializeObjectToBlobAsync(this CloudBlockBlob blob, object obj)
    {
        using (Stream stream = await blob.OpenWriteAsync())
        using (StreamWriter sw = new StreamWriter(stream))
        using (JsonTextWriter jtw = new JsonTextWriter(sw))
        {
            JsonSerializer ser = new JsonSerializer();
            ser.Serialize(jtw, obj);
        }
    }

    public static async Task<T> DeserializeObjectFromBlobAsync<T>(this CloudBlockBlob blob)
    {
        using (Stream stream = await blob.OpenReadAsync())
        using (StreamReader sr = new StreamReader(stream))
        using (JsonTextReader jtr = new JsonTextReader(sr))
        {
            JsonSerializer ser = new JsonSerializer();
            return ser.Deserialize<T>(jtr);
        }
    }
}

现在假设你有一个类(class) Item表示要序列化为 JSON 并存储到 Azure blob 中的一些数据:

class Item 
{
    public int Id { get; set; }
    public string Name { get; set; }
    public double Price { get; set; }
}

以下是使用第一种扩展方法的方法:

...
var item = new Item { Id = 1, Name = "Widget", Price = 2.5 };
cloudBlockBlob.SerializeObjectToBlobAsync(item).Wait();

相反，如果您想从 blob 中检索 JSON 并将其反序列化回 Item ，您可以使用其他扩展方法:

var item = cloudBlockBlob.DeserializeObjectFromBlobAsync<Item>().Result;

注意:如果您在 async 中使用这些方法方法，您应该使用 await语法而不是使用 Wait()和 .Result ， 分别:

await cloudBlockBlob.SerializeObjectToBlobAsync(item);

...

var item = await cloudBlockBlob.DeserializeObjectFromBlobAsync<Item>();