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 { DuplexChannelFactory _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(_callbackInstance, endpointConfigurationName); } catch (Exception ex) { MessageBox.Show("Cannot create Service " + name + ",Check configuration:" + endpointConfigurationName + ex.Message); LOG.Error("Cannot create Service " + name + ",Check configuration:" + endpointConfigurationName, ex); } } public void Invoke(Action 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 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 + " service recovery"); } return true; } catch (EndpointNotFoundException ex) { if (!_isInError) { _isInError = true; LOG.Error(_serviceName + " The connection has been disconnected。", ex); } } catch (ProtocolException ex) { if (!_isInError) { _isInError = true; LOG.Error(_serviceName + " Service program exception。", ex); } } catch (Exception ex) { if (!_isInError) { _isInError = true; LOG.Error(_serviceName + " Service exception", ex); } } ((IClientChannel)_proxy).Abort(); _proxy = _factory.CreateChannel(); return false; } } }