CommunicationObjectFaultedException - System.ServiceModel.Channels.ServiceChannel не может использоваться для связи, поскольку он находится в состоянии сбоя

Question

Im работает над интеграцией EConnect в C#. Я работаю над функцией, которая проверяет строку соединения GP. В основном строка состоит из имени Dataserver для GP и имени базы данных. Если имя базы данных неверно, генерируется исключение eConnect, и это достаточно легко поймать и отслеживать. Когда имя сервера ошибочно, функция getentity Im, использующая для проверки соединения, будет просто вращаться и время ожидания. Поэтому я использую IAsyncResult и дескриптор wait для проверки того, не истекает ли время приложения. Если приложение выполняет тайм-аут, я перезапускаю службу и позволяю пользователю повторно вводить имя сервера. Теперь проблема Im get - после проверки ввода неправильного сервера, и все сбрасывается. Im получает System.ServiceModel.CommunicationObjectFaultedException.

Вот информация я получаю от исключения:

An exception of type 'System.ServiceModel.CommunicationObjectFaultedException' occurred in System.ServiceModel.dll but was not handled in user code 

Additional information: The communication object, System.ServiceModel.Channels.ServiceChannel, cannot be used for communication because it is in the Faulted state. 

System.ServiceModel.CommunicationObjectFaultedException was unhandled by user code 
    HResult=-2146233087 
    Message=The communication object, System.ServiceModel.Channels.ServiceChannel, cannot be used for communication because it is in the Faulted state. 
    Source=System.ServiceModel 
    StackTrace: 
    at System.ServiceModel.Channels.CommunicationObject.Close(TimeSpan timeout) 
    at System.ServiceModel.Channels.ServiceChannelFactory.OnClose(TimeSpan timeout) 
    at System.ServiceModel.Channels.ServiceChannelFactory.TypedServiceChannelFactory`1.OnClose(TimeSpan timeout) 
    at System.ServiceModel.Channels.CommunicationObject.Close(TimeSpan timeout) 
    at System.ServiceModel.ChannelFactory.OnClose(TimeSpan timeout) 
    at System.ServiceModel.Channels.CommunicationObject.Close(TimeSpan timeout) 
    at Microsoft.Dynamics.GP.eConnect.ServiceProxy.Dispose() 
    at Microsoft.Dynamics.GP.eConnect.eConnectMethods.Dispose() 
    at GP_Import___Sylectus.UpdateGPConnection.TestGPConnection() in C:\GP Import - Sylectus\GP Import - Sylectus\UpdateGPConnection.cs:line 265 
    at System.Runtime.Remoting.Messaging.StackBuilderSink._PrivateProcessMessage(IntPtr md, Object[] args, Object server, Object[]& outArgs) 
    at System.Runtime.Remoting.Messaging.StackBuilderSink.AsyncProcessMessage(IMessage msg, IMessageSink replySink) 
    InnerException: 

Вот мой код:

namespace GP_Import___Sylectus 
{ 
    public partial class UpdateGPConnection : Form 
    { 
     Task task; 
     AsyncCallback cb; 
     public delegate string startProcessToCall(); 
     startProcessToCall sp2c; 
     bool test = false; 
     string testResult = "";    

     public UpdateGPConnection() 
     { 
      InitializeComponent(); 
      this.txtDatasourceName.Text = ConfigurationManager.AppSettings.Get("GPDataServer"); 
      this.txtDatabaseName.Text = ConfigurationManager.AppSettings.Get("GPDatabase");       

      cb = new AsyncCallback(startProcessCallback); 
      sp2c = new startProcessToCall(TestGPConnection); 
     } 

     public void startProcessCallback(IAsyncResult iar) 
     { 
      startProcessToCall mc = (startProcessToCall)iar.AsyncState; 
      //bool result = mc.EndInvoke(iar); 
      //Console.WriteLine("Function value = {0}", result); 
     } 

     private void btnUpdate_Click(object sender, EventArgs e) 
     { 
      var config = ConfigurationManager.OpenExeConfiguration(ConfigurationUserLevel.None); 
      config.AppSettings.Settings["GPDataServer"].Value = txtDatasourceName.Text.ToUpper(); 
      config.AppSettings.Settings["GPDatabase"].Value = txtDatabaseName.Text.ToUpper(); 
      config.Save(ConfigurationSaveMode.Modified); 

      ConfigurationManager.RefreshSection("appSettings"); 

      GPCongfigSettings.GPConnectionString = @"data source=" + txtDatasourceName.Text.ToUpper() + ";initial catalog=" + txtDatabaseName.Text.ToUpper() + ";integrated security=SSPI;persist security info=False;packet size=4096"; 

      IAsyncResult asyncResult = null; 
      asyncResult = sp2c.BeginInvoke(cb, null); 


      Thread.Sleep(0); 

      Cursor.Current = Cursors.WaitCursor; 
      test = asyncResult.AsyncWaitHandle.WaitOne(15000); 

      if (test) 
      { 
       try 
       { 
        testResult = sp2c.EndInvoke(asyncResult); 
       } 
       catch (Exception exc) 
       { 
        Console.WriteLine(exc.Message); 
       } 
      } 

      bool result = asyncResult.IsCompleted; 

      string eConnectServiceName = ConfigurationManager.AppSettings.Get("eConnectServiceName"); 

      string eConnectProcess = ConfigurationManager.AppSettings.Get("eConnectProcess"); 

      Process[] process = Process.GetProcessesByName(eConnectProcess); 

      if (!test) 
      {       

       foreach (Process tempProcess in process) 
       { 
        tempProcess.Kill(); 
       } 
       RestartService(eConnectServiceName, 20000); 

       RestartService(eConnectServiceName, 20000); 
      } 

      asyncResult.AsyncWaitHandle.Close(); 


      Cursor.Current = Cursors.Default;     

      if (test == false) 
      { 
       MessageBox.Show("Dataserver Name is Incorrect", "Connection String Error", MessageBoxButtons.OK, MessageBoxIcon.Stop); 
      } 
      else 
      { 
       if (testResult == "Correct Connection") 
       { 
        MessageBox.Show("Connection String Successfully Updated", "", MessageBoxButtons.OK); 
        this.Close(); 
       } 
       else if (testResult.Contains("eConnect Exception")) 
       { 
        MessageBox.Show("Database Name is Incorrect", "Connection String Error", MessageBoxButtons.OK, MessageBoxIcon.Stop); 
       } 
       else 
       { 
        MessageBox.Show(testResult, "Error", MessageBoxButtons.OK, MessageBoxIcon.Error); 
        RestartService(eConnectServiceName, 20000); 
       } 
      }    
     }   

     public string TestGPConnection() 
     { 

      eConnectMethods requester = new eConnectMethods(); 
      try 
      {     

       // Create an eConnect document type object 
       eConnectType myEConnectType = new eConnectType(); 

       // Create a RQeConnectOutType schema object 
       RQeConnectOutType myReqType = new RQeConnectOutType(); 

       // Create an eConnectOut XML node object 
       eConnectOut myeConnectOut = new eConnectOut(); 

       // Populate the eConnectOut XML node elements 
       myeConnectOut.ACTION = 1; 
       myeConnectOut.DOCTYPE = "GL_Accounts"; 
       myeConnectOut.OUTPUTTYPE = 2; 
       myeConnectOut.FORLIST = 1; 
       myeConnectOut.WhereClause = "(ACTNUMST = '99-9999-99-999')"; 

       // Add the eConnectOut XML node object to the RQeConnectOutType schema object 
       myReqType.eConnectOut = myeConnectOut; 

       // Add the RQeConnectOutType schema object to the eConnect document object 
       RQeConnectOutType[] myReqOutType = { myReqType }; 
       myEConnectType.RQeConnectOutType = myReqOutType; 

       // Serialize the eConnect document object to a memory stream 
       MemoryStream myMemStream = new MemoryStream(); 
       XmlSerializer mySerializer = new XmlSerializer(myEConnectType.GetType()); 
       mySerializer.Serialize(myMemStream, myEConnectType); 
       myMemStream.Position = 0; 

       // Load the serialized eConnect document object into an XML document object 
       XmlTextReader xmlreader = new XmlTextReader(myMemStream); 
       XmlDocument myXmlDocument = new XmlDocument(); 
       myXmlDocument.Load(xmlreader); 

       var tokenSource = new CancellationTokenSource(); 
       CancellationToken token = tokenSource.Token; 
       int timeOut = 20000; //20 seconds 

       try 
       { 
        string reqDoc = requester.GetEntity(GPCongfigSettings.GPConnectionString, myXmlDocument.OuterXml); 
       } 
       catch (CommunicationObjectFaultedException cofe) 
       { 
        return "Communication Exception - " + cofe.Message; 
       } 

       //connection string is correct 
       return "Correct Connection"; 


      } 
      catch (FaultException fe) 
      { 
       return "Fault Exception - " + fe.Message; 
      } 
      catch (eConnectException exc) 
      { 
       Console.WriteLine(exc.Message); 
       return "eConnect Exception - " + exc.Message; 
      }    
      catch (CommunicationObjectFaultedException cofe) 
      { 
       return "Communication Exception - " + cofe.Message; 
      } 
      catch (Exception ex) 
      { 
       return "Exception - " + ex.Message; 
      } 
      finally 
      { 
       // Release the resources of the eConnectMethods object 
       requester.Dispose(); 
      } 
     } 

     private void btnExit_Click(object sender, EventArgs e) 
     { 
      this.Close(); 
     } 

     public static void RestartService(string serviceName, int timeoutMilliseconds) 
     { 
      ServiceController service = new ServiceController(serviceName); 
      try 
      { 

       int millisec1 = Environment.TickCount; 
       TimeSpan timeout = TimeSpan.FromMilliseconds(timeoutMilliseconds); 

       if (!service.Status.Equals(ServiceControllerStatus.Stopped)) 
       { 
        service.Stop(); 
        service.WaitForStatus(ServiceControllerStatus.Stopped, timeout); 
       } 


       // count the rest of the timeout 
       int millisec2 = Environment.TickCount; 
       timeout = TimeSpan.FromMilliseconds(timeoutMilliseconds - (millisec2 - millisec1)); 

       if (service.Status.Equals(ServiceControllerStatus.Stopped) || service.Status.Equals(ServiceControllerStatus.StopPending)) 
       { 
        service.Start(); 
        service.WaitForStatus(ServiceControllerStatus.Running, timeout); 
       } 
      } 
      catch (Exception ex) 
      { 
       // ... 
      } 
     }   


    } 

} 

ошибка всегда, кажется, происходит, когда я пытаюсь избавиться метод реквестера в TestGPConnection ,

Любые идеи, что я должен делать? Я все время гулял по всему миру, и я очень смущен тем, что Im нашел, как это исправить.

Answer 1

Попробуйте изменить код:

     public string TestGPConnection() 
     { 
      try 
      {     
       using (eConnectMethods requester = new eConnectMethods()) 
       { 
       // Create an eConnect document type object 
       eConnectType myEConnectType = new eConnectType(); 

       // Create a RQeConnectOutType schema object 
       RQeConnectOutType myReqType = new RQeConnectOutType(); 

       // Create an eConnectOut XML node object 
       eConnectOut myeConnectOut = new eConnectOut(); 

       // Populate the eConnectOut XML node elements 
       myeConnectOut.ACTION = 1; 
       myeConnectOut.DOCTYPE = "GL_Accounts"; 
       myeConnectOut.OUTPUTTYPE = 2; 
       myeConnectOut.FORLIST = 1; 
       myeConnectOut.WhereClause = "(ACTNUMST = '99-9999-99-999')"; 

       // Add the eConnectOut XML node object to the RQeConnectOutType schema object 
       myReqType.eConnectOut = myeConnectOut; 

       // Add the RQeConnectOutType schema object to the eConnect document object 
       RQeConnectOutType[] myReqOutType = { myReqType }; 
       myEConnectType.RQeConnectOutType = myReqOutType; 

       // Serialize the eConnect document object to a memory stream 
       MemoryStream myMemStream = new MemoryStream(); 
       XmlSerializer mySerializer = new XmlSerializer(myEConnectType.GetType()); 
       mySerializer.Serialize(myMemStream, myEConnectType); 
       myMemStream.Position = 0; 

       // Load the serialized eConnect document object into an XML document object 
       XmlTextReader xmlreader = new XmlTextReader(myMemStream); 
       XmlDocument myXmlDocument = new XmlDocument(); 
       myXmlDocument.Load(xmlreader); 

       var tokenSource = new CancellationTokenSource(); 
       CancellationToken token = tokenSource.Token; 
       int timeOut = 20000; //20 seconds 

       try 
       { 
        string reqDoc = requester.GetEntity(GPCongfigSettings.GPConnectionString, myXmlDocument.OuterXml); 
       } 
       catch (CommunicationObjectFaultedException cofe) 
       { 
        return "Communication Exception - " + cofe.Message; 
       } 

       //connection string is correct 
       return "Correct Connection"; 
       } 
      } 
      catch (FaultException fe) 
      { 
       return "Fault Exception - " + fe.Message; 
      } 
      catch (eConnectException exc) 
      { 
       Console.WriteLine(exc.Message); 
       return "eConnect Exception - " + exc.Message; 
      }    
      catch (CommunicationObjectFaultedException cofe) 
      { 
       return "Communication Exception - " + cofe.Message; 
      } 
      catch (Exception ex) 
      { 
       return "Exception - " + ex.Message; 
      } 
      //finally 
      //{ 
      // // Release the resources of the eConnectMethods object 
      // requester.Dispose(); 
      //} 
     }