using System.ServiceModel; namespace MyWCF.WCFSimpleDuplex.Interface
{/// <summary>/// 定义协议的时候, 同时需要定义一个回调接口/// 示例中定义服务契约的同时定义一个回调接口ICallBack/// 双工中的函数不能带返回值/// 如果你实在想要返回值, 那么自己用out/// </summary>[ServiceContract(CallbackContract = typeof(ICallBack))]public interface ICalculatorService{/// <summary>/// 添加isoneway属性表示, 这个函数是不是返回应答信息 ; /// </summary>/// <param name="x"></param>/// <param name="y"></param>[OperationContract(IsOneWay = true)]void Plus(int x, int y);//建立了一个Icalculator服务的协议//这个协议带有一个回调接口ICallBack//注意WCF的双工, 不能全靠配置, 在建立服务的时候, 就要开始处理了}
}

using System.ServiceModel;namespace MyWCF.WCFSimpleDuplex.Interface
{/// <summary>/// 不需要协议, 因为它不是一个服务契约, 它只是一个约束，这个约束由客户端实现/// </summary>public interface ICallBack{/// <summary>/// 这里就是回调的时候完成的函数, 这个接口也要加上Isoneway=true  /// </summary>/// <param name="m"></param>/// <param name="n"></param>/// <param name="result"></param>[OperationContract(IsOneWay = true)]void Show(int m, int n, int result);}//要发布一个双工协议 ,首先在服务的建立WCF服务, 服务的契约上面指定callbackContract回调的类型//建立回调接口, 回调接口就是等下要执行的接口
}

using System.Runtime.Serialization;namespace MyWCF.WCFSimpleDuplex.Model
{[DataContract]public class WCFUser{//[DataMember]public int Id { get; set; }[DataMember]public int Age { get; set; }[DataMember]public int Sex { get; set; }[DataMember]public string Name { get; set; }[DataMember]public string Description { get; set; }}public enum WCFUserSex{Famale,Male,Other}
}

using System.ServiceModel;
using MyWCF.WCFSimpleDuplex.Interface;namespace MyWCF.WCFSimpleDuplex.Service
{/// <summary>/// 对ICalculatorService的一个实现类; 实现的时候, 除了要完成自己的计算, 还要完成, 对接口的回调/// </summary>public class CalculatorService : ICalculatorService{/// <summary>/// 完成计算，然后去回调/// </summary>/// <param name="x"></param>/// <param name="y"></param>public void Plus(int x, int y){int result = x + y;System.Threading.Thread.Sleep(3000);//OperationContext表示当前操作的上下文//OperationContext.Current.GetCallbackChannel<ICallBack>();这里有点像IOC, 给你一个接口然后生成一个实例; 注意哦, 这里的ICallBack还有没有任何实现, 而这个实现是在客户端(client)处去完成的ICallBack callBack =OperationContext.Current.GetCallbackChannel<ICallBack>();callBack.Show(x, y, result);}}
} 

<?xml version="1.0" encoding="utf-8" ?>
<configuration><startup> <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5" /></startup><system.serviceModel>  <!--WCF的配置文件 , WCF的配置文件一个是基于TCP的, 一个是基于http的; 可以添加多个; 如果添加多个就是下面的配置格式 --><behaviors> <serviceBehaviors><!--<behavior name="MathServicebehavior"> --><!--这里配置第一个Behavior的节点--><!--<serviceDebug httpHelpPageEnabled="false"/><serviceMetadata httpGetEnabled="false"/><serviceTimeouts transactionTimeout="00:10:00"/><serviceThrottling maxConcurrentCalls="1000" maxConcurrentInstances="1000" maxConcurrentSessions="1000"/></behavior>--><behavior name="CalculatorServicebehavior">  <!--这里配置第二个Behavior的节点--><serviceDebug httpHelpPageEnabled="false"/><serviceMetadata httpGetEnabled="false"/><serviceTimeouts transactionTimeout="00:10:00"/><serviceThrottling maxConcurrentCalls="1000" maxConcurrentInstances="1000" maxConcurrentSessions="1000"/></behavior></serviceBehaviors></behaviors><!--在tcp中上面几行和http的配置都是一样的-->  <bindings><netTcpBinding><binding name="tcpbinding">   <!--指定为tcp的协议类型-->  <security mode="None"><!--clientCredentialType="None" → 表示加密类型  protectionLevel="None"  表示安全级别--><transport clientCredentialType="None" protectionLevel="None"/></security></binding></netTcpBinding></bindings><services> <service name="MyWCF.WCFSimpleDuplex.Service.CalculatorService" behaviorConfiguration="CalculatorServicebehavior"><host> <!--这里配置第一个服务的名称和服务的具体指向类--><baseAddresses><add baseAddress="net.tcp://localhost:9999/CalculatorService"/><!--指定的协议为net tcp协议--></baseAddresses></host><endpoint address="" binding="netTcpBinding" bindingConfiguration="tcpbinding" contract="MyWCF.WCFSimpleDuplex.Interface.ICalculatorService"/><endpoint address="mex" binding="mexTcpBinding" contract="IMetadataExchange"/></service><!--<service name="MyWCF.WCFSimpleDuplex.Service.MathService" behaviorConfiguration="MathServicebehavior"><host>--><!--这里配置第二个服务的名称和服务的具体指向类--><!--<baseAddresses><add baseAddress="net.tcp://localhost:9999/MathService"/></baseAddresses></host><endpoint address="" binding="netTcpBinding" bindingConfiguration="tcpbinding" contract="MyWCF.WCFSimpleDuplex.Interface.IMathService"/><endpoint address="mex" binding="mexTcpBinding" contract="IMetadataExchange"/></service>--></services></system.serviceModel>
</configuration>

using System;
using System.ServiceModel;
using MyWCF.WCFSimpleDuplex.Service;namespace MyWCF.WCFSimpleDuplex.ConsoleTest
{class Program{static void Main(string[] args){try{Console.WriteLine("开始挂起服务");ServiceInit.Process();}catch (Exception ex)//如果报无法注册. . ., 则说明需要管理员权限, 启动这个程序{//服务“SOA.WCF.Service.CalculatorService”有零个应用程序(非基础结构)终结点。这可能是因为未找到应用程序的配置文件，或者在配置文件中未找到与服务名称匹配的服务元素，或者服务元素中未定义终结点。//没有配置文件//另一应用程序已使用 HTTP.SYS 注册了该 URL。//端口 9999 被其它应用程序占用了, 找到并将其停止Console.WriteLine(ex.Message);}Console.Read();}}/// <summary>/// WCF寄宿到控制台/// </summary>public class ServiceInit{public static void Process(){//ServiceHost →表示提供服务的主机,使用服务的类型及其指定的基址初始化 System.ServiceModel.ServiceHost 类的新实例。Type type = typeof(CalculatorService);ServiceHost host =  new ServiceHost(type);host.Opening += (s, e) => Console.WriteLine($"{type} 准备打开");//已经打开事件host.Opened += (s, e) => Console.WriteLine($"{type} 已经正常打开");//开启服务; 注意当这里需要Open的时候, 会去配置文件中检查是否有配置了MathService这个类的behavior(行为)host.Open();Console.WriteLine("输入任何字符，就停止");Console.Read();host.Close();Console.Read();}}}

using System;namespace MyWCF.WCFSimpleDuplexConsoleTest.CTest
{/// <summary>/// 具体实现的回调/// </summary>public class CallBackService : MyDuplexConsoleTest.ICalculatorServiceCallback{public void Show(int m, int n, int result){Console.WriteLine($"回调操作展示, 这个操作发生在两秒之后：{m}+{n}={result}");}}
}

using System;
using System.ServiceModel;namespace MyWCF.WCFSimpleDuplexConsoleTest.CTest
{class Program{static void Main(string[] args){MyDuplexConsoleTest.CalculatorServiceClient client = null;try{Console.WriteLine("客户端来测试双工!~~");//创建一个需要回调的实例, 等会服务端进行回调的InstanceContext context = new InstanceContext(new CallBackService());client = new MyDuplexConsoleTest.CalculatorServiceClient(context);client.Plus(123, 234);client.Close();}catch (Exception ex){if (client != null)client.Abort();Console.WriteLine(ex.Message);}Console.Read();}}
}