具有双工通信的 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();