2

我在有状态服务结构应用程序中使用可靠队列。当我试图将一个项目入队时，入队方法抛出异常

使用的代码是

 protected override async Task RunAsync(CancellationToken cancellationToken)
        {
            ICommand myItem = new CreateCommand()
            {
                Data = "Sample Data",
                Id = Guid.NewGuid(),
                TenentName = "SampleTenant"
            };
            var myQueue = await this.StateManager.GetOrAddAsync<IReliableQueue<ICommand>>("CommandQueue");
            using (var tx = StateManager.CreateTransaction())
            {
                await myQueue.EnqueueAsync(tx, myItem, TimeSpan.FromSeconds(4), cancellationToken);
                await tx.CommitAsync();
            }
            using (var tx = StateManager.CreateTransaction())
            {
                var dq = await myQueue.TryDequeueAsync(tx);
                await tx.CommitAsync();
            }
        }
    }

    public interface ICommand
    {
        Guid Id { get; set; }
        string TenentName { get; set; }
    }


    public class CreateCommand : ICommand
    {
        public Guid Id { get; set; }
        public string TenentName { get; set; }
        public string Data { get; set; }
    }

在 myQueue.EnqueueAsync 上，它正在引发异常

不应使用数据合同名称“CreateCommand: http://schemas.datacontract.org/2004/07/TestService ”键入“TestService.CreateCommand”。如果您正在使用 DataContractSerializer 或将任何静态未知的类型添加到已知类型列表中，请考虑使用 DataContractResolver - 例如，通过使用 KnownTypeAttribute 属性或将它们添加到传递给序列化程序的已知类型列表中。

堆栈跟踪

在 System.Runtime.Serialization.XmlObjectSerializerWriteContext.SerializeAndVerifyType（DataContract 数据合同，XmlWriterDelegator xmlWriter，对象 obj，布尔 verifyKnownType，RuntimeTypeHandle 声明类型句柄，类型声明类型）在 System.Runtime.Serialization.XmlObjectSerializerWriteContext.SerializeWithXsiTypeAtTopLevel（DataContract 数据合同，XmlWriterDelegator objWriter xmlWriter originalDeclaredTypeHandle, Type graphType) 在 System.Runtime.Serialization.DataContractSerializer.InternalWriteObjectContent(XmlWriterDelegator writer, Object graph, DataContractResolver dataContractResolver) 在 System.Runtime.Serialization.DataContractSerializer.InternalWriteObject(XmlWriterDelegator writer, Object graph, DataContractResolver dataContractResolver) 在 System.Runtime。序列化。XmlObjectSerializer.WriteObjectHandleExceptions(XmlWriterDelegator writer, Object graph, DataContractResolver dataContractResolver) at System.Runtime.Serialization.XmlObjectSerializer.WriteObject(XmlDictionaryWriter writer, Object graph) at Microsoft.ServiceFabric.Replicator.DataContractStateSerializer1.Write(T value, BinaryWriter binaryWriter) at System.Fabric.Store.TStore5.GetValueBytes(TValue currentValue, TValue newValue) 在 System.Fabric.Store.TStore 5.<AddAsync>d__4.MoveNext() at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task) at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task) at Microsoft.ServiceFabric.Data.Collections.DistributedQueue1.d__9.MoveNext() 在 System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task 任务) 在 System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(任务任务）在 System.Runtime.CompilerServices.TaskAwaiter.GetResult()
的 TestService.TestService.d__2.MoveNext() 在 D:\Projects\Local\ReliableSerialization\Application1\TestService\TestService.cs：System.Runtime 的第 51 行。 CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task) at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task) at Microsoft.ServiceFabric.Services.Runtime.StatefulServiceReplicaAdapter.d__f.MoveNext()

当我更改代码以使用具体类型时，它工作正常。

就我而言IReliableQueue<CreateCommand>

它工作得很好。

我的代码参考：https ://github.com/Azure-Samples/service-fabric-dotnet-iot/blob/master/src/gateway/IoTProcessorManagement.Common/WorkManagement/WorkManager.cs

4

1 回答 1

3

您的类型缺少 DataContract 和 DataMember 属性，并且由于数据合同序列化工作方式的实现，您不能将 DataContract 属性放在接口上。缺少数据协定属性可能会导致难以追踪错误，因为 Service Fabric 将在内部存储对对象的引用并在您出队时返回该引用，但在提交时将对象发送到辅助节点时序列化该对象。当您忘记所说的属性时，您会看到它有时似乎可以工作，但是会在提交事务时抛出，或者在服务重新启动之前您将拥有看似很好的填充对象（对于升级，如果该节点关闭，或其他原因）然后将为空（缺少属性的字段将为空/默认）。

要利用数据协定中的多态性，您可以使用基类和 KnownType 属性。这就是您的示例添加删除命令后的样子。

[DataContract]
[KnownType(typeof(CreateCommand))]
[KnownType(typeof(DeleteCommand))]
public class BaseCommand
{
    [DataMember]
    public Guid Id { get; set; }

    [DataMember]
    public string TenentName { get; set; }
}

[DataContract]
public class CreateCommand : BaseCommand
{
    [DataMember]
    public string Data { get; set; }
}

[DataContract]
public class DeleteCommand : BaseCommand
{
    [DataMember]
    public string SomeOtherData { get; set; }
}

另请注意，已知类型属性支持传入函数以以编程方式发现子类型，但不要使用它，因为它会以奇怪且难以诊断的方式破坏可升级性。

于 2016-09-06T21:11:39.240 回答