Возникли проблемы со службой WCF со статическими данными.

Question

Обновление: с помощью Henk определил, что вызывается public Dispose (), который, в свою очередь, вызывает private Dispose (true).Это моя первая реализация интерфейса IDisposable, поэтому не уверен, что он правильный.Я нигде не называю Dispose явно.Кажется, что архитектура WCF вызывает его при выходе из каждого члена OperationContract.

На данный момент удален неуправляемый код очистки из Dispose, и несколько вызовов могут получить доступ к статическим данным.Похоже, что Dispose () вызывается для всех локально размещенных объектов при возврате из вызовов, даже если в статическом хранилище есть ссылка на объект.Не уверен в мире .net, как обойти это так, чтобы интерфейс IDisposable вызывался правильно.Я предполагаю, что эти объекты также будут собирать мусор в некоторый момент.

Вот стек вызовов при возврате из первого вызова при вызове Dispose:

BossISeriesCwbxService.dll! BossISeriesCwbxServices.DataContracts.ISeriesSystem.Dispose (bool bDisposing = true) Строка 119 C #
BossISeriesCwbxService.dll! BossISeriesCwbxServices.DataContracts.ISeriesSystem.Dispose () Строка 107 + 0xdМодуль_сервисных файлов.System.ServiceModel.Dispatcher.MessageRpc.DisposeParametersCore () + 0x56 байтref System.ServiceModel.Dispatcher.MessageRpc rpc = {System.ServiceModel.Dispatcher.MessageRpc}) + 0x135 байт{System.ServiceModel.Dispatcher.MessageRpc}) + 0x1bf bytes System.ServiceModel.dll! System.ServiceModel.Dispatcher.ImmutableDispatchRuntime.ProcessMessage4 (ref System.ServiceModel.Dispatcher.MessageRpc 080p.dll) 080s.service_MServer_Server_Server_Server_Server_Server_Server_Server_Server_Server_Server_1_1_0.dll.dll! System.ServiceModel.Dispatcher.ImmutableDispatchRuntime.ProcessMessage3 (ref System.ServiceModel.Dispatcher.MessageRpc rpc) + 0x36 байт.MessageRpc rpc) + 0x43 байта
System.ServiceModel.dll! System.ServiceModel.Dispatcher.ImmutableDispatchRuntime.ProcessMessage1 (ref System.ServiceModel.Dispatcher.MessageRpc rpc) + 0xd7 байт системы * 101l..Dispatcher.perationContextSet) + 0x2d байт

System.ServiceModel.dll! System.ServiceModel.Dispatcher.ChannelHandler.DispatchAndReleasePump (System.ServiceModel.Channels.RequestContextSecuritySecuritySecuritySodeSecuritySodeSecuritySodeSecuritySodeSecuritySodeMode), bool cleanThread, System.ServiceModel.OperationContext currentOperationContext) + 0x20c байт
System.ServiceModel.dll! System.ServiceModel.Dispatcher.ChannelHandler.HandleRequest (System.ServiceModel.Channels.Reodel.0xdf байтов

System.ServiceModel.dll! System.ServiceModel.Dispatcher.ChannelHandler.AsyncMessagePump (результат System.IAsyncResult) + 0x43 байта
System.ServiceModel.dll! System.ServiceModel.DynHan(состояние объекта) + 0x45 байт
System.ServiceModel.dll! System.ServiceModel.Channels.IOThreadScheduler.CriticalHelper.WorkItem.Invoke2 ()+ 0x46 байт System.ServiceModel.dll! System.ServiceModel.Channels.IOThreadScheduler.CriticalHelper.WorkItem.OnSecurityContextCallback (объект o) + 0x28 байт
mscorlib.dll! System.Security.SecurityContextSecurityContext., Обратный вызов System.Threading.ContextCallback, состояние объекта) + 0x55 байт

System.ServiceModel.dll! System.ServiceModel.Channels.IOThreadScheduler.CriticalHelper.WorkItem.Invoke () + 0x4d байт

* 1028System.ServiceModel.dll! System.ServiceModel.Channels.IOThreadScheduler.CriticalHelper.ProcessCallbacks () + 0x180 байт.ServiceModel.dll! System.ServiceModel.Channels.IOThreadScheduler.CriticalHelper.ScheduledOverlapped.IOCallback (uint errorCode, uint numBytes, System.Threading.NativeOverlapped * nativeOverlapped) + 0xf.Utility.IOCompletionThunk.UnhandledExceptionFrame (ошибка uint, байты uadRead, System.Threading.pOVERLAP) + 0x54 байта

Я прочитал несколько сообщений о кэшировании статических данных в классе реализации службы WCF, и у меня возникла проблема с вызовом GC dispose для объектов в статическом словаре.Я ссылаюсь на некоторые объекты activex из IBM iSeries Access, поэтому я реализовал интерфейс IDisposable для очистки соединения с iSeries.Моя проблема в том, что GC удаляет объекты в статических членах класса Service.Не уверен, что весь код был необходим, но здесь это все равно.Проблема в том, что при возврате из каждого метода OperationContract GC вызывает Dispose для объекта ISeriesSystem или Queue, который был добавлен в связанный словарь, но словарь ISeriesSystem является статическим, поэтому я подумал, что он содержит ссылку на объект, поэтомуGC не будет выполнен, пока он не будет удален из Словаря.

Интерфейс службы:

[ServiceContract(Namespace="BossISeriesCwbxServices")]
public interface IDataQueueService
{
     [OperationContract]
     ISeriesSystem SystemInitialize(string sISeriesName);

     [OperationContract(Name="FinalizeSystemByName")]
     void SystemFinalize(string sISeriesName);

     [OperationContract]
     void SystemFinalize(ISeriesSystem oISeriesSystem);

     [OperationContract]
     Queue QueueInitialize(string sQueueName, string sLibrary, string sISeriesName);

     [OperationContract(Name="FinalizeQueueByName")]
     void QueueFinalize(string sQueueName, string sLibrary, string sISeriesName);

     [OperationContract]
     void QueueFinalize(Queue oDataQueue);

     [OperationContract (Name="QueueWriteByName")]
     void QueueWrite(string sQueueName, string sLibrary, string sISeriesName, string sMessage);

     [OperationContract]
     void QueueWrite(Queue oDataQueue, string sMessage);

     [OperationContract (Name="QueueReadByName")]
     string QueueRead(string sQueueName, string sLibrary, string sISeriesName);

     [OperationContract]
     string QueueRead(Queue oDataQueue);    
}

Реализация службы:

[ServiceBehavior(InstanceContextMode = InstanceContextMode.Single, ConcurrencyMode = ConcurrencyMode.Single)] 
public class DataQueueService : IDataQueueService
{
    private static Dictionary<string, ISeriesSystem> mdictISeriesSystems = new Dictionary<string, ISeriesSystem>();
    public static IDictionary<string, ISeriesSystem> ISeriesDict
    {
       get { return mdictISeriesSystems; }
    } 

  public ISeriesSystem SystemInitialize(string sISeriesName)
  {
     ISeriesSystem oISeriesSystem = AddSystem(sISeriesName);
     return oISeriesSystem;
  }

  public void SystemFinalize(string sISeriesName)
  {
  }

  public void SystemFinalize(ISeriesSystem oISeriesSystem)
  {
     SystemFinalize(oISeriesSystem.Name);
  }


  public Queue QueueInitialize(string sQueueName, string sLibrary, string sISeriesName)
  {
     ISeriesSystem oISeriesSystem = null;
     Queue oDataQueue = null;

     try
     {
        oISeriesSystem = AddSystem(sISeriesName);
        oDataQueue = oISeriesSystem.AddQueue(sQueueName, sLibrary);
     }
     catch (Exception ex)
     {
        // ToDo: Log ex to WCF service log and remove from Console.
        Console.WriteLine(ex.ToString());
        oDataQueue = null;
     }

     return oDataQueue;
  }

  public Queue QueueInitialize(string sQueueName, string sLibrary, ISeriesSystem oISeriesSystem)
  {
     return QueueInitialize(sQueueName, sLibrary, oISeriesSystem.Name);
  }

  public void QueueFinalize(string sQueueName, string sLibrary, string sISeriesName)
  {
     string sISeriesKey = sISeriesName.Trim();
     string sDataQueueKey = sLibrary.Trim() + sQueueName.Trim();

     ISeriesSystem oISeriesSystem = null;
     Queue oDataQueue = null;


     if (DataQueueService.ISeriesDict.TryGetValue(sISeriesKey, out oISeriesSystem))
     {
        if (oISeriesSystem.DataQueueDict.TryGetValue(sDataQueueKey, out oDataQueue))
        {
           oDataQueue.Dispose();
           oDataQueue = null;
           oISeriesSystem.DataQueueDict.Remove(sDataQueueKey);
        }

        if (oISeriesSystem.DataQueueDict.Count == 0)
        {
           oISeriesSystem.Dispose();
           oISeriesSystem = null;
        }
     }
  }

  public void QueueFinalize(Queue oDataQueue)
  {
     QueueFinalize(oDataQueue.Name, oDataQueue.Library, oDataQueue.ISeriesName);
  }

  public void QueueWrite(string sQueueName, string sLibrary, string sISeriesName, string sMessage)
  {
     string sISeriesKey = sISeriesName.Trim();
     string sDataQueueKey = sLibrary.Trim() + sQueueName.Trim();

     ISeriesSystem oISeriesSystem = null;
     Queue oDataQueue = null;


     if (DataQueueService.ISeriesDict.TryGetValue(sISeriesKey, out oISeriesSystem))
     {
        if (oISeriesSystem.DataQueueDict.TryGetValue(sDataQueueKey, out oDataQueue))
        {
           oDataQueue.Write(sMessage);
        }
     }
  }

  public void QueueWrite(Queue oDataQueue, string sMessage)
  {
     QueueWrite(oDataQueue.Name, oDataQueue.Library, oDataQueue.ISeriesName, sMessage);
  }

  public string QueueRead(string sQueueName, string sLibrary, string sISeriesName)
  {
     string sISeriesKey = sISeriesName.Trim();
     string sDataQueueKey = sLibrary.Trim() + sQueueName.Trim();

     ISeriesSystem oISeriesSystem = null;
     Queue oDataQueue = null;


     if (DataQueueService.ISeriesDict.TryGetValue(sISeriesKey, out oISeriesSystem))
     {
        if (oISeriesSystem.DataQueueDict.TryGetValue(sDataQueueKey, out oDataQueue))
        {
           return oDataQueue.Read();
        }
     }

     return "";
  }

  public string QueueRead(Queue oDataQueue)
  {
     return QueueRead(oDataQueue.Name, oDataQueue.Library, oDataQueue.ISeriesName);

  }

  ISeriesSystem AddSystem(string sISeriesName)
  {
     ISeriesSystem oISeriesSystem = null;
     string sISeriesKey = sISeriesName.Trim();

     if (!DataQueueService.ISeriesDict.TryGetValue(sISeriesKey, out oISeriesSystem))
     {
        oISeriesSystem = new ISeriesSystem(sISeriesName);
        DataQueueService.ISeriesDict[sISeriesKey] = oISeriesSystem;
     }

     return oISeriesSystem;
  }

ISeriesSystem DataContract:

using System;
using System.Collections.Generic;
using System.Text;

using System.ServiceModel;
using System.Runtime.Serialization;

using cwbx;

namespace BossISeriesCwbxServices.DataContracts
{
   public class ISeriesSystem : IDisposable
   {

      private string msName;
      [DataMember]
      public string Name
      {
         get { return msName; }
         set { msName = value; }
      }

      private Dictionary<string, Queue> mdictDataQueues = new Dictionary<string, Queue>();
      public IDictionary<string, Queue> DataQueueDict
      {
         get { return mdictDataQueues; }
      }

      private cwbx.AS400System mcwbxISeriesSystem = new AS400System();
      private cwbx.AS400System CwbxISeriesSystem
      {
         get { return mcwbxISeriesSystem; }
         set { mcwbxISeriesSystem = value; }
      }


      private bool bDisposed = false;


      public ISeriesSystem()
      {

      }

      public ISeriesSystem(string sISeriesName)
      {
         try
         {
            // Set DataContract properties.
            this.Name = sISeriesName;

            // Connect to iSeries, Logon and connect to iSeries services that may be used.
            this.CwbxISeriesSystem.Define(sISeriesName);
            this.CwbxISeriesSystem.UserID = "APP1DAK";
            this.CwbxISeriesSystem.Password = "DONNA99";
            this.CwbxISeriesSystem.Signon();
            this.CwbxISeriesSystem.Connect(cwbcoServiceEnum.cwbcoServiceDataQueues);
            this.CwbxISeriesSystem.Connect(cwbcoServiceEnum.cwbcoServiceSecurity);
            this.CwbxISeriesSystem.Connect(cwbcoServiceEnum.cwbcoServiceRemoteCmd);
         }
         catch (Exception ex)
         {
            // ToDo: Log ex to WCF service log and remove from Console.
            Console.WriteLine(ex.ToString());
            foreach (cwbx.Error cwbxError in this.CwbxISeriesSystem.Errors)
            {
               Console.WriteLine(cwbxError.Text);
               Console.WriteLine(cwbxError.ToString());
            }
         }
      }

      ~ISeriesSystem()
      {
         Dispose(false);
      }

      public void Dispose()
      {
         Dispose(true);
         GC.SuppressFinalize(this);
      }

      private void Dispose(bool bDisposing)
      {
         // Only Dispose of the object 1 time.
         if (!this.bDisposed)
         {
            // If disposing equals true, Dispose() was called by GC, so dispose all managed resources.
            if (bDisposing)
            {
               // Dispose managed resources, calling object Dispose method for objects
               // that implement IDisposable interface.
            }

            try
            {
               if (this.CwbxISeriesSystem.IsConnected(cwbcoServiceEnum.cwbcoServiceAny) == 1)
               {
                  this.CwbxISeriesSystem.Disconnect(cwbcoServiceEnum.cwbcoServiceAll);
               }
            }
            catch (Exception ex)
            {
               // ToDo: Log ex to WCF service log and remove from Console.
               Console.WriteLine(ex.ToString());
               foreach (cwbx.Error cwbxError in this.CwbxISeriesSystem.Errors)
               {
                  Console.WriteLine(cwbxError.Text);
                  Console.WriteLine(cwbxError.ToString());
               }
            }

            // Mark disposing as being done.
            bDisposed = true;
         }
      }

      public Queue AddQueue(string sQueueName, string sLibrary)
      {
         Queue oDataQueue = null;
         string sDataQueueKey = sLibrary.Trim() + sQueueName.Trim();

         if (!this.DataQueueDict.TryGetValue(sDataQueueKey, out oDataQueue))
         {
            oDataQueue = new Queue(sQueueName, sLibrary, this.CwbxISeriesSystem);
            this.DataQueueDict[sDataQueueKey] = oDataQueue;
         }

         return oDataQueue;
      }
   }
}

Очередь DataContract:

using System;
using System.Collections.Generic;
using System.Text;

using System.ServiceModel;
using System.Runtime.Serialization;

using cwbx;

namespace BossISeriesCwbxServices.DataContracts
{
   [DataContract]
   public class Queue : IDisposable
   {
      private string msName;
      [DataMember]
      public string Name
      {
         get { return msName; }
         set { msName = value; }
      }

      private string msLibrary;
      [DataMember]
      public string Library
      {
         get { return msLibrary; }
         set { msLibrary = value; }
      }

      private string msISeriesName;
      [DataMember]
      public string ISeriesName
      {
         get { return msISeriesName; }
         set { msISeriesName = value; }
      }

      private short miWaitTime = 10;
      [DataMember]
      public short WaitTime
      {
         get { return miWaitTime; }
         set { miWaitTime = value; }
      }

      private short miNumberOfAttempts = 1;
      [DataMember]
      public short NumberOfAttempts
      {
         get { return miNumberOfAttempts; }
         set { miNumberOfAttempts = value; }
      }

      private short miMaxQueueIndex = 1;
      public short MaxQueueIndex
      {
         get { return miMaxQueueIndex; }
         set { miMaxQueueIndex = value; }
      }

      private short miCurrentQueueIndex = 1;
      public short CurrentQueueIndex
      {
         get { return miCurrentQueueIndex; }
         set { miCurrentQueueIndex = value; }
      }



      private cwbx.DataQueue mcwbxDataQueue = new cwbx.DataQueue();
      private cwbx.DataQueue CwbxDataQueue
      {
         get { return mcwbxDataQueue; }
         set { mcwbxDataQueue = value; }
      }

      private bool bDisposed = false;


      public Queue()
      {
      }

      public Queue(string sQueueName, string sLibrary, cwbx.AS400System cwbxISeriesSystem)
      {
         this.Name = sQueueName;
         this.Library = sLibrary;
         this.ISeriesName = cwbxISeriesSystem.SystemName;

         this.CwbxDataQueue.QueueName = sQueueName;
         this.CwbxDataQueue.LibraryName = sLibrary;
         this.CwbxDataQueue.system = cwbxISeriesSystem;
      }

      ~Queue()
      {
         Dispose(false);
      }

      public void Dispose()
      {
         Dispose(true);
         GC.SuppressFinalize(this);
      }

      private void Dispose(bool bDisposing)
      {
         // Only Dispose of the object 1 time.
         if (!this.bDisposed)
         {
            // If disposing equals true, Dispose() was called by GC, so dispose all managed resources.
            if (bDisposing)
            {
               // Dispose managed resources, calling object Dispose method for objects
               // that implement IDisposable interface.
            }

            // Call the appropriate methods to clean up unmanaged resources here.
            try
            {
               this.CwbxDataQueue = null;
            }
            catch (Exception ex)
            {
               // ToDo: Log ex to WCF service log and remove from Console.
               Console.WriteLine(ex.ToString());
               foreach (cwbx.Error cwbxError in this.CwbxDataQueue.Errors)
               {
                  Console.WriteLine(cwbxError.Text);
                  Console.WriteLine(cwbxError.ToString());
               }
            }
            // Mark disposing as being done.
            bDisposed = true;
         }
      }


      public void Write(string sMessage)
      {
         try
         {
            cwbx.StringConverter cwbxStringConverter = new cwbx.StringConverter();
            Object oBytes = cwbxStringConverter.ToBytes(sMessage);
            this.CwbxDataQueue.Write(oBytes, false);
         }
         catch (Exception ex)
         {
            // ToDo: Log ex to WCF service log and remove from Console.
            Console.WriteLine(ex.ToString());
            foreach (cwbx.Error cwbxError in this.CwbxDataQueue.Errors)
            {
               Console.WriteLine(cwbxError.Text);
               Console.WriteLine(cwbxError.ToString());
            }
         }
      }

      public string Read()
      {
         try
         {
            Object oObject = null;
            return (new cwbx.StringConverter()).FromBytes(this.CwbxDataQueue.Read(this.WaitTime * this.NumberOfAttempts, out oObject));
         }
         catch (Exception ex)
         {
            Console.WriteLine(ex.ToString());
            foreach (cwbx.Error cwbxError in this.CwbxDataQueue.Errors)
            {
               Console.WriteLine(cwbxError.Text);
               Console.WriteLine(cwbxError.ToString());
            }

            return "";
         }
      }
   }
}

Код клиента:

ISeriesSystem oISeriesSystem = null;
Queue oDataQueue = null;

oISeriesSystem = DQService.SystemInitialize("A2029D2.AS400.US.UPS.COM");
oDataQueue = DQService.QueueInitialize("SMTLST020", "IB5EXE", oISeriesSystem.Name);
oISeriesSystem.DataQueueDict.Add(oDataQueue.Library + oDataQueue.Name, oDataQueue);
ISeriesSystemDict.Add(oISeriesSystem.Name, oISeriesSystem);

DQService.QueueWrite(oDataQueue, "Testing cwbx.DataQueue WCF service");
string sMessage = DQService.QueueRead(oDataQueue);

Exe Hosted Service:

Uri baseAddress = new Uri("http://localhost:8080/BossISeriesCwbxServices");

//Instantiate new ServiceHost 
moServiceHost = new ServiceHost(typeof(BossISeriesCwbxServices.DataQueueService), baseAddress);

// Add Endpoint
moServiceHost.AddServiceEndpoint(typeof(BossISeriesCwbxServices.IDataQueueService), new WSHttpBinding(), "IDataQueueService");
// Enable metadata exchange.
ServiceMetadataBehavior smb = new ServiceMetadataBehavior();
smb.HttpGetEnabled = true;
moServiceHost.Description.Behaviors.Add(smb);

//Open moServiceHost
moServiceHost.Open();
Console.WriteLine("The IDataQueueService is ready.");
Console.WriteLine("Press <ENTER> to terminate service.");
Console.WriteLine();

Answer 1

Это происходит регулярно или время от времени?Это происходит в процессе разработки или только (через некоторое время) на рабочем сервере?

Когда вы размещаете это в IIS, сервер может решить «перезапустить» ваше приложение.Основной совет: не используйте static в серверных приложениях.Это не надежно и не масштабируемо.

---

Редактировать
ОК, я прочитал немного больше (но не все).

Проблема в том, что при возврате из каждого метода OperationContract ГХ вызывает Dispose для объекта ISeriesSystem или Queue

Вы должны проверить это очень подробно.Действительно ли GC вызывает ваш финализатор (ы) (он же деструктор)?Вы должны использовать ведение журнала или отладку, чтобы убедиться, что перегрузка Dispose (false) вызывается.Если вызывается Dispose (true) (и я вижу много кода, вовлеченного в это), вы должны найти в стеке фактическую причину.

Answer 2

Я знаю, что уже немного поздно, но вы пытались добавить атрибут [OperationBehavior(AutoDisposeParameters = false)]?

Ссылка на MSDN Forum

Answer 3

Можете ли вы добавить следующий код:

[ServiceContract(SessionMode = SessionMode.Required)]

в контракт на обслуживание, чтобы убедиться, что создается транспортный сеанс?Если это не так, выдается ошибка.

WSHttpBinding не создает транспортный сеанс без безопасности и надежного сеанса.

РЕДАКТИРОВАТЬ:

Кроме этого,поскольку вы создаете сервис Single Instance, зачем вам статические члены?Будет только один живой экземпляр, поэтому все члены этого экземпляра будут жить с ним и будут статичными.Вы думали об этом или есть особая причина для использования статических членов?