Chủ đề DataContractSerilaizer của WCF có an toàn không?

Question

Tôi đã chuyển đổi một hệ thống khá lớn từ Remoting sang WCF và mọi thứ dường như đang chạy tốt, ngoại trừ chúng tôi thường nhận được ngoại lệ sau: "System.InvalidOperationException: Bộ sưu tập đã được sửa đổi; hoạt động liệt kê có thể không thực thi." Tôi đã không có may mắn theo dõi nó xuống bởi vì nó chỉ xảy ra khi có hàng trăm cuộc gọi nhận được thông qua, và tôi chỉ có thể giả định đó là bởi vì một đối tượng đang được sửa đổi khi nó đang được serialized.

Các lớp học đều sử dụng: [DataContract(IsReference=true)].

Không có ngoại lệ tương tự khi sử dụng tính năng truy cập từ xa, vì vậy tôi tự hỏi liệu có ai có vấn đề tương tự trong WCF hay không hoặc có thể cho tôi biết rằng nó có thể là serializer - trong trường hợp này tôi giả sử tôi phải viết các serializers riêng để thực hiện locks khi cần thiết (đó là một công việc lớn mà tôi muốn tránh).

Sau đây là stack trace:

WCF Error: at System.Collections.Generic.List1.Enumerator.MoveNextRare() at WriteArrayOfLineToXml(XmlWriterDelegator , Object , XmlObjectSerializerWriteContext , CollectionDataContract) at System.Runtime.Serialization.CollectionDataContract.WriteXmlValue(XmlWriterDelegator xmlWriter, Object obj, XmlObjectSerializerWriteContext context) at System.Runtime.Serialization.XmlObjectSerializerWriteContext.InternalSerialize(XmlWriterDelegator xmlWriter, Object obj, Boolean isDeclaredType, Boolean writeXsiType, Int32 declaredTypeID, RuntimeTypeHandle declaredTypeHandle) at System.Runtime.Serialization.XmlObjectSerializerWriteContext.InternalSerializeReference(XmlWriterDelegator xmlWriter, Object obj, Boolean isDeclaredType, Boolean writeXsiType, Int32 declaredTypeID, RuntimeTypeHandle declaredTypeHandle) at WriteLineGroupToXml(XmlWriterDelegator , Object , XmlObjectSerializerWriteContext , ClassDataContract) at System.Runtime.Serialization.ClassDataContract.WriteXmlValue(XmlWriterDelegator xmlWriter, Object obj, XmlObjectSerializerWriteContext context) at System.Runtime.Serialization.XmlObjectSerializerWriteContext.SerializeWithoutXsiType(DataContract dataContract, XmlWriterDelegator xmlWriter, Object obj, RuntimeTypeHandle declaredTypeHandle) at System.Runtime.Serialization.XmlObjectSerializerWriteContext.InternalSerialize(XmlWriterDelegator xmlWriter, Object obj, Boolean isDeclaredType, Boolean writeXsiType, Int32 declaredTypeID, RuntimeTypeHandle declaredTypeHandle) at System.Runtime.Serialization.XmlObjectSerializerWriteContext.InternalSerializeReference(XmlWriterDelegator xmlWriter, Object obj, Boolean isDeclaredType, Boolean writeXsiType, Int32 declaredTypeID, RuntimeTypeHandle declaredTypeHandle) at WriteLineToXml(XmlWriterDelegator , Object , XmlObjectSerializerWriteContext , ClassDataContract) at System.Runtime.Serialization.ClassDataContract.WriteXmlValue(XmlWriterDelegator xmlWriter, Object obj, XmlObjectSerializerWriteContext context) at System.Runtime.Serialization.XmlObjectSerializerWriteContext.SerializeAndVerifyType(DataContract dataContract, XmlWriterDelegator xmlWriter, Object obj, Boolean verifyKnownType, RuntimeTypeHandle declaredTypeHandle, Type declaredType) at System.Runtime.Serialization.XmlObjectSerializerWriteContext.SerializeWithXsiTypeAtTopLevel(DataContract dataContract, XmlWriterDelegator xmlWriter, Object obj, RuntimeTypeHandle originalDeclaredTypeHandle, Type graphType) at System.Runtime.Serialization.DataContractSerializer.InternalWriteObjectContent(XmlWriterDelegator writer, Object graph, DataContractResolver dataContractResolver) at System.Runtime.Serialization.DataContractSerializer.InternalWriteObject(XmlWriterDelegator writer, Object graph, DataContractResolver dataContractResolver) at System.Runtime.Serialization.XmlObjectSerializer.WriteObjectHandleExceptions(XmlWriterDelegator writer, Object graph, DataContractResolver dataContractResolver) at System.Runtime.Serialization.XmlObjectSerializer.WriteObject(XmlDictionaryWriter writer, Object graph) at System.ServiceModel.Dispatcher.DataContractSerializerOperationFormatter.SerializeParameterPart(XmlDictionaryWriter writer, PartInfo part, Object graph) at System.ServiceModel.Dispatcher.DataContractSerializerOperationFormatter.SerializeParameter(XmlDictionaryWriter writer, PartInfo part, Object graph) at System.ServiceModel.Dispatcher.DataContractSerializerOperationFormatter.SerializeBody(XmlDictionaryWriter writer, MessageVersion version, String action, MessageDescription messageDescription, Object returnValue, Object[] parameters, Boolean isRequest) at System.ServiceModel.Dispatcher.OperationFormatter.SerializeBodyContents(XmlDictionaryWriter writer, MessageVersion version, Object[] parameters, Object returnValue, Boolean isRequest) at System.ServiceModel.Dispatcher.OperationFormatter.OperationFormatterMessage.OperationFormatterBodyWriter.OnWriteBodyContents(XmlDictionaryWriter writer) at System.ServiceModel.Channels.BodyWriter.WriteBodyContents(XmlDictionaryWriter writer) at System.ServiceModel.Channels.BodyWriterMessage.OnWriteBodyContents(XmlDictionaryWriter writer) at System.ServiceModel.Channels.Message.OnWriteMessage(XmlDictionaryWriter writer) at System.ServiceModel.Channels.Message.WriteMessage(XmlDictionaryWriter writer) at System.ServiceModel.Channels.BufferedMessageWriter.WriteMessage(Message message, BufferManager bufferManager, Int32 initialOffset, Int32 maxSizeQuota) at System.ServiceModel.Channels.BinaryMessageEncoderFactory.BinaryMessageEncoder.WriteMessage(Message message, Int32 maxMessageSize, BufferManager bufferManager, Int32 messageOffset) at System.ServiceModel.Channels.FramingDuplexSessionChannel.EncodeMessage(Message message) at System.ServiceModel.Channels.FramingDuplexSessionChannel.OnSend(Message message, TimeSpan timeout) at System.ServiceModel.Channels.OutputChannel.Send(Message message, TimeSpan timeout) at System.ServiceModel.Dispatcher.DuplexChannelBinder.DuplexRequestContext.OnReply(Message message, TimeSpan timeout) at System.ServiceModel.Channels.RequestContextBase.Reply(Message message, TimeSpan timeout) at System.ServiceModel.Dispatcher.ImmutableDispatchRuntime.Reply(MessageRpc& rpc)

Answer 1

Thật vậy, lỗi này có thể dễ dàng sao chép với DataContractSerializer. Nó không chỉ cho chủ đề an toàn của DataContractSerializer, đó là về chủ đề an toàn của một số bộ sưu tập, được sử dụng trong hợp đồng dữ liệu của bạn:

[DataContract] 
public class C 
{ 
    [DataMember] 
    public List<int> Values { get; set; } 
} 

class Program 
{ 
    static void Main(string[] args) 
    { 
     var c = new C 
     { 
      Values = new List<int>() 
     }; 

     var serializer = new DataContractSerializer(typeof(C)); 

     Task 
      .Factory 
      .StartNew(() => 
      { 
       while (true) 
       { 
        Console.WriteLine("Trying to add new item."); 
        c.Values.Add(DateTime.Now.Millisecond); 
       } 
      }, 
      TaskCreationOptions.LongRunning); 

     Task 
      .Factory 
      .StartNew(() => 
      { 
       while (true) 
       { 
        using (var stream = new MemoryStream()) 
        { 
         Console.WriteLine("Trying to serialize."); 
         serializer.WriteObject(stream, c); 
        } 
       } 
      }, 
      TaskCreationOptions.LongRunning); 

     Console.ReadLine(); 
    } 

Sau thời gian thực hiện ngắn, bạn sẽ nhận được IOE với stack trace tương tự:

at System.ThrowHelper.ThrowInvalidOperationException(ExceptionResource resource) at System.Collections.Generic.List`1.Enumerator.MoveNextRare() at System.Collections.Generic.List`1.Enumerator.MoveNext() at WriteArrayOfintToXml(XmlWriterDelegator , Object , XmlObjectSerializerWriteContext , CollectionDataContract) at System.Runtime.Serialization.CollectionDataContract.WriteXmlValue(XmlWriterDelegator xmlWriter, Object obj, XmlObjectSerializerWriteContext context) 

Có vẻ như bạn đang tiếp tục sửa đổi một số dữ liệu được chia sẻ, được lưu trữ cùng một lúc. Bạn có thể bật truy tìm WCF (xem câu hỏi this) để tìm ra thao tác nào gây ra lỗi này và xem xét cẩn thận dữ liệu nào được sử dụng bởi thao tác này.

Sau đó, tùy thuộc vào giá trị của InstanceContextMode và ConcurrencyMode tính chất của hành vi dịch vụ hiện tại, bạn có thể chọn con đường để đi:

• hoặc sử dụng một số khóa;
• hoặc sử dụng bất kỳ bộ sưu tập an toàn theo chủ đề nào;
• hoặc thay đổi hành vi dịch vụ;
• hoặc thay đổi bản thân dịch vụ (ví dụ: làm cho nó không trạng thái).

Answer 2

Nếu giả thuyết của Dennis là chính xác thì cách sạch nhất để giải quyết vấn đề này là sao chép bộ sưu tập và gửi bản sao qua dây. Tại thời điểm đó, nó không quan trọng nếu bản gốc được sửa đổi trong quá trình serialization