WCF中双工协议

服务端配置文件

 <system.serviceModel>
    <behaviors>
      <serviceBehaviors>
        <behavior name="CallBackContractServicebehavior">
          <serviceDebug httpHelpPageEnabled="false"/>
          <serviceMetadata httpGetEnabled="false"/>
          <serviceTimeouts transactionTimeout="00:10:00"/>
          <serviceThrottling maxConcurrentCalls="1000" maxConcurrentInstances="1000" maxConcurrentSessions="1000"/>
        </behavior>
      </serviceBehaviors>
    </behaviors>

    <bindings>
      <netTcpBinding>
        <binding name="tcpbinding">
          <security mode="None">
            <transport clientCredentialType="None" protectionLevel="None"/>
          </security>
        </binding>
      </netTcpBinding>
    </bindings>
    <services>
      <service name="MyWCF.CallBack.Service.CallBackContractService" behaviorConfiguration="CallBackContractServicebehavior">
        <host>
          <baseAddresses>
            <add baseAddress="net.tcp://localhost:12475/CalculatorService"/>
          </baseAddresses>
        </host>
        <endpoint address="" binding="netTcpBinding" bindingConfiguration="tcpbinding" contract="MyWCF.CallBack.Interfac.ICallBackContract"/>
        <endpoint address="mex" binding="mexTcpBinding" contract="IMetadataExchange"/>
      </service>
    </services>
    <!--<behaviors>
      <serviceBehaviors>
        <behavior name="MathServicebehavior">
          <serviceDebug httpHelpPageEnabled="false"/>
          <serviceMetadata httpGetEnabled="false"/>
          <serviceTimeouts transactionTimeout="00:10:00"/>
          <serviceThrottling maxConcurrentCalls="1000" maxConcurrentInstances="1000" maxConcurrentSessions="1000"/>
        </behavior>
      </serviceBehaviors>
    </behaviors>
    <bindings>
      <basicHttpBinding>
        <binding name="httpbinding"/>
      </basicHttpBinding>
    </bindings>
    <services>
      <service name="SOA.WCF.Service.MathService" behaviorConfiguration="MathServicebehavior">
        <host>
          <baseAddresses>
            <add baseAddress="http://localhost:11113/MathService"/>
          </baseAddresses>
        </host>
        <endpoint address="" binding="basicHttpBinding" bindingConfiguration="httpbinding" contract="SOA.WCF.Interface.IMathService"/>
        <endpoint address="mex" binding="mexHttpBinding" contract="IMetadataExchange"/>
      </service>
    </services>-->

  </system.serviceModel>

服务端双工协议执行类接口注明回调约束ICallBack

[ServiceContract(CallbackContract =typeof(ICallBack))]
    public interface ICallBackContract
    {
        [OperationContract]
        int Plus(int x,int y);  
    }

服务端设置回掉类库

  public interface ICallBack
    {
        /// <summary>
        /// 回调
        /// </summary>
        /// <param name="x"></param>
        /// <param name="y"></param>
        /// <param name="iResult"></param>
        [OperationContract(IsOneWay =true)]
        void Show(int x,int y,int iResult);
    }

服务端实现方法

public class CallBackContractService : ICallBackContract
    {
        public int Plus(int x, int y)
        {
            int result = x + y;
            Thread.Sleep(2000);
            ICallBack callBack = OperationContext.Current.GetCallbackChannel<ICallBack>();
            callBack.Show(x, y, result);
            return result;
        }
    }

客服端实现调用继承服务端的实现类库

 public class CallBackService : MyCallBack.ICallBackContractCallback
    {
        public void Show(int x, int y, int iResult)
        {
            Console.WriteLine($"回调显示:{x}+{y}={iResult}");
        }
    }

客户端调用代码

 static void Main(string[] args)
        {
            MyCallBack.CallBackContractClient client = null;
            try
            {
                
                InstanceContext instanceContext = new InstanceContext(new CallBackService());
                client = new MyCallBack.CallBackContractClient(instanceContext);
                int a=client.Plus(1, 2);
                client.Close();
            }
            catch (Exception ex)
            {
                if (client != null)
                    client.Abort();
                Console.WriteLine(ex);
            }
            
            Console.Read();

        }