Mars200/FrameworkLocal/Common/WCF/DuplexChannelServiceClientWrapper.cs

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

namespace Aitex.Core.WCF
{
    public class DuplexChannelServiceClientWrapper<T>
    {
        DuplexChannelFactory<T> _factory;
        T _proxy;
        bool _isInError = false;
        string _serviceName;
        InstanceContext _callbackInstance;

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

                LOG.Error("不能创建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();
            }

            try
            {
                action(_proxy);

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

                return true;
            }
            catch (EndpointNotFoundException ex)
            {
                if (!_isInError)
                {
                    _isInError = true;
                    LOG.Error(_serviceName + " 连接已经断开.", ex);
                }
            }
            catch (ProtocolException ex)
            {
                if (!_isInError)
                {
                    _isInError = true;
                    LOG.Error(_serviceName + " 服务程序异常.", ex);
                }
            }
            catch (Exception ex)
            {
                if (!_isInError)
                {
                    _isInError = true;
                    LOG.Error(_serviceName + " 服务异常", ex);
                }
            }

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

            return false;
        }
    }
}