双工通信WCF

Question

每当我使用窗体窗体它工作正常但它总是给控制台应用程序错误。

错误 - 套接字连接被中止。这可能是由于处理您的消息时出现 错误或远程主机发生接收超时 或基础网络资源问题。本地套接字 超时时间为'00：01：00'。

这里是我的代码

合同

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Runtime.Serialization; 
using System.ServiceModel; 
using System.Text; 

namespace ClassLibrary1 
{ 
    // NOTE: You can use the "Rename" command on the "Refactor" menu to change the interface name "IReportService" in both code and config file together. 
    [ServiceContract(CallbackContract=typeof(IReportServiceCallbak))] 
    public interface IReportService 
    { 
     [OperationContract(IsOneWay=true)] 
     void ProcessReport(); 
    } 

    public interface IReportServiceCallbak 
    { 
     [OperationContract(IsOneWay=true)] 
     void Progress(int percentage); 
    } 
} 

服务

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Runtime.Serialization; 
using System.ServiceModel; 
using System.Text; 
using System.Threading; 

namespace ClassLibrary1 
{ 
    public class ReportService : IReportService 
    { 

     public void ProcessReport() 
     { 
      for (int i = 0; i < 100; i++) 
      { 
       Thread.Sleep(50); 
       OperationContext.Current.GetCallbackChannel<IReportServiceCallbak>().Progress(i); 
      } 
     } 
    } 
} 

客户

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 
using System.ServiceModel; 
using System.Threading.Tasks; 
using System.Threading; 

namespace DuplexClientsss 
{ 
    class Program 
    { 
     static void Main(string[] args) 
     { 
      new Tests(); 

     } } 

    class Tests : ReportService.IReportServiceCallback 
    { 
     ReportService.ReportServiceClient obj; 
     public Tests() 
     { 
      obj = new ReportService.ReportServiceClient(new InstanceContext(this)); 
      obj.ProcessReport(); 
     } 
       public void Progress(int percentage) 
     { 
      Console.WriteLine(percentage); 
     } 
    } 



} 

Answer 1

new Task 
(
()=> 
{ 
     obj.ProcessReport(); 
} 
).Start();