Как обрабатывать исключения WCF (сводный список с кодом)

РЕДАКТИРОВАТЬ: Кажется, есть некоторая неэффективность при закрытии и повторном открытии клиента несколько раз. Я изучаю здесь решения и буду обновлять и расширять этот код, если он будет найден. (или если Давид Хайкин отправит ответ, я отмечу его как принятый)

После того, как я возился с этим в течение нескольких лет, я предпочитаю приведенный ниже код (после просмотра этого сообщения в блоге с машины обратного пути) для обработки повторных попыток WCF и обработки исключений.

Я исследовал каждое исключение, что бы я хотел делать с этим исключением, и заметил общую черту; каждое исключение, требующее повторной попытки, унаследованное от общего базового класса. Я также заметил, что каждое исключение permFail, которое переводит клиента в недопустимое состояние, также исходит из общего базового класса.

В следующем примере перехватывается каждое исключение WCF, через которое может пройти клиент, и его можно расширить для ошибок вашего собственного пользовательского канала.

Пример использования клиента WCF

После создания прокси на стороне клиента это все, что вам нужно для его реализации.

Service<IOrderService>.Use(orderService=>
{
  orderService.PlaceOrder(request);
}

ServiceDelegate.cs

Добавьте этот файл в свое решение. Никаких изменений в этот файл не требуется, если вы не хотите изменить количество повторных попыток или какие исключения вы хотите обрабатывать.

public delegate void UseServiceDelegate<T>(T proxy);

public static class Service<T>
{
    public static ChannelFactory<T> _channelFactory = new ChannelFactory<T>(""); 

    public static void Use(UseServiceDelegate<T> codeBlock)
    {
        IClientChannel proxy = null;
        bool success = false;


       Exception mostRecentEx = null;
       int millsecondsToSleep = 1000;

       for(int i=0; i<5; i++)  // Attempt a maximum of 5 times 
       {
           // Proxy cann't be reused
           proxy = (IClientChannel)_channelFactory.CreateChannel();

           try
           {
               codeBlock((T)proxy);
               proxy.Close();
               success = true; 
               break;
           }
           catch (FaultException customFaultEx)
           {
               mostRecentEx = customFaultEx;
               proxy.Abort();

               //  Custom resolution for this app-level exception
               Thread.Sleep(millsecondsToSleep * (i + 1)); 
           }

           // The following is typically thrown on the client when a channel is terminated due to the server closing the connection.
           catch (ChannelTerminatedException cte)
           {
              mostRecentEx = cte;
               proxy.Abort();
               //  delay (backoff) and retry 
               Thread.Sleep(millsecondsToSleep  * (i + 1)); 
           }

           // The following is thrown when a remote endpoint could not be found or reached.  The endpoint may not be found or 
           // reachable because the remote endpoint is down, the remote endpoint is unreachable, or because the remote network is unreachable.
           catch (EndpointNotFoundException enfe)
           {
              mostRecentEx = enfe;
               proxy.Abort();
               //  delay (backoff) and retry 
               Thread.Sleep(millsecondsToSleep * (i + 1)); 
           }

           // The following exception that is thrown when a server is too busy to accept a message.
           catch (ServerTooBusyException stbe)
           {
              mostRecentEx = stbe;
               proxy.Abort();

               //  delay (backoff) and retry 
               Thread.Sleep(millsecondsToSleep * (i + 1)); 
           }
           catch (TimeoutException timeoutEx)
           {
               mostRecentEx = timeoutEx;
               proxy.Abort();

               //  delay (backoff) and retry 
               Thread.Sleep(millsecondsToSleep * (i + 1)); 
           } 
           catch (CommunicationException comException)
           {
               mostRecentEx = comException;
               proxy.Abort();

               //  delay (backoff) and retry 
               Thread.Sleep(millsecondsToSleep * (i + 1)); 
           }


           catch(Exception e)
           {
                // rethrow any other exception not defined here
                // You may want to define a custom Exception class to pass information such as failure count, and failure type
                proxy.Abort();
                throw e;  
           }
       }
       if (success == false && mostRecentEx != null) 
       { 
           proxy.Abort();
           throw new Exception("WCF call failed after 5 retries.", mostRecentEx );
       }

    }
}

Я начал проект на Codeplex, который имеет следующие функции

• Обеспечивает эффективное повторное использование клиентского прокси
• Очищает все ресурсы, включая обработчики событий
• Работает на дуплексных каналах
• Работает на услугах Per-call
• Поддерживает конструктор конфигурации или фабрику

http://smartwcfclient.codeplex.com/

Работа над ней еще не завершена, и ее очень много комментируют. Буду признателен за любые отзывы относительно его улучшения.

Пример использования в режиме экземпляра:

 var reusableSW = new LC.Utils.WCF.ServiceWrapper<IProcessDataDuplex>(channelFactory);

 reusableSW.Reuse(client =>
                      {
                          client.CheckIn(count.ToString());
                      });


 reusableSW.Dispose();

у нас есть клиент WCF, который справляется практически с любым типом сбоев на сервере. Список уловов очень длинный, но не обязательно. Если вы присмотритесь, вы увидите, что многие исключения являются дочерними определениями класса Exception (и нескольких других классов).

Таким образом, вы можете значительно упростить работу, если захотите. Тем не менее, вот несколько типичных ошибок, которые мы выявляем:

Тайм-аут сервера
Сервер слишком занят
Сервер недоступен.

Ссылки ниже могут помочь в обработке исключений WCF:

http://www.codeproject.com/KB/WCF/WCFErrorHandling.aspx

http://msdn.microsoft.com/en-us/library/cc949036.aspx