CyberX8/Framework/Common/WCF/ServiceClientWrapper.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.ServiceModel;
using Aitex.Core.RT.Log;
using System.Windows;
using Aitex.Core.Utilities;
using System.Threading;
using System.Reflection;

namespace Aitex.Core.WCF
{
    public class ServiceClientWrapper<T>
    {
        ChannelFactory<T> _factory;
        T _proxy;
        bool _isInError = false;
        string _serviceName;

        Retry _retryConnect = new Retry();

        public ServiceClientWrapper(string endpointConfigurationName, string name)
        {
            _serviceName = name;
            try
            {
                _factory = new ChannelFactory<T>(endpointConfigurationName);
            }
            catch (Exception ex)
            {
                MessageBox.Show("不能创建Service " + name + "，检查配置：" + endpointConfigurationName);

                LOG.WriteExeption("不能创建Service "+name+"，检查配置："+endpointConfigurationName, ex);
            }
        }

        public ServiceClientWrapper(string endpointConfigurationName, string name, EndpointAddress address)
        {
            _serviceName = name;
            try
            {
                _factory = new ChannelFactory<T>(endpointConfigurationName, address);
            }
            catch (Exception ex)
            {
                MessageBox.Show("不能创建Service " + name + "，检查配置：" + endpointConfigurationName);

                LOG.WriteExeption("不能创建Service " + name + "，检查配置：" + endpointConfigurationName, ex);
            }
        }

        public void Invoke(Action<T> action)
        {
            if (_factory == null)
                return;

            if (_proxy == null)
            {
                _proxy = _factory.CreateChannel();
            }
            
            for (int i = 0; i < 2; i++)
            {
                if (Do(action))
                    break;

                Thread.Sleep(10);
            }

        }

        bool Do(Action<T> action)
        {
            if (_proxy != null && ((IClientChannel)_proxy).State == CommunicationState.Faulted)
            {
                ((IClientChannel)_proxy).Abort();
                _proxy = _factory.CreateChannel();
            }
            DateTime dateTime = DateTime.Now;
            string method = "";
            try
            {
                MethodInfo methodInfo= action.GetMethodInfo();
                method = methodInfo.Name;
                action(_proxy);

                if (_isInError)
                {
                    _isInError = false;
                    //LOG.Info(_serviceName + " 服务恢复");
                }

                return true;
            }
            catch (EndpointNotFoundException ex)
            {
                if (!_isInError)
                {
                    _isInError = true;
                    LOG.WriteExeption(_serviceName + " disconnect。", ex);
                }
            }
            catch (ProtocolException ex)
            {
                if (!_isInError)
                {
                    _isInError = true;
                    LOG.WriteExeption($"{_serviceName} service method {method} start {dateTime.ToString("yyyy-MM-dd HH:mm:ss.fff")} process exception。", ex);
                }
            }
            catch (Exception ex)
            {
                if (!_isInError)
                {
                    _isInError = true;
                    LOG.WriteExeption($"{_serviceName} service method {method} start {dateTime.ToString("yyyy-MM-dd HH:mm:ss.fff")} exception", ex);
                }
            }

            ((IClientChannel)_proxy).Abort();
            _proxy = _factory.CreateChannel();

            return false;
        }
    }
}