20181102_WCF简单双工

Posted 2021-01-16 wxylog

1. 使用管理员权限打开VS2017

　　2. 创建一个空白解决方案:

3. 创建几个基于.net  framework的类库项目和一个基于.net Framework 的控制台项目, 然后将类库项目的class1.cs文件删除, 整体如下图:

　　 

4. 为每个类库添加对应的类文件:

　　a)         MyWCF.WCFSimpleDuplex.Interface添加两个接口, ICalculatorService和ICallBack, 其中ICalculatorService表示要启动的服务接口, 而ICallBack表示要回调客户端时, 访问的接口

　　b)         ICalculatorService 代码如下:

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的双工, 不能全靠配置, 在建立服务的时候, 就要开始处理了
    }
}

　　

c)         ICallBack代码如下

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回调的类型
    //建立回调接口, 回调接口就是等下要执行的接口
}

　　

5. 接下来处理 MyWCF.WCFSimpleDuplex.Model 的代码, 它就一个类:

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
    }
}

　　

6. 关于服务类MyWCF.WCFSimpleDuplex.Service的处理如下:

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);
        }
    }
} 

7.       接下来是控制台MyWCF.WCFSimpleDuplex.ConsoleTest的代码实现, 首先是他的配置文件

a)         初始时的配置文件如下图:　

b)         在configuration节点添加如下配置:

 

<?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>

c)         Program代码如下:

　

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();
        }

    }
  
}

　

8. 完成以上步骤就可以启动试试看了:

9. 可以使用  cmd 命令 netstat -ano | find "9999", 查看下端口9999是否被监听

 

10. 双工的服务端已经处理完毕, 接下来开始处理客户端, 当然客户端首先就要对刚才的ICallBack进行实现, 这个毋容置疑的

11. 再新打开一个VS2017, 创建一个控制台测试项目:

 

12. 接下来不用多想, 第一件事, 添加服务引用, 第二件事实现服务端的那个ICallBack接口

a)         添加服务引用

 

b)         实现ICallBack接口, 注意这个类里的Show 方法, 在客户端没有任何代码调用

 

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}");
        }
    }
}

　　

c)         整体client截图:

 

13. 然后在program中的代码, 建议单步调试看看代码的运行过程:

 

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();
        }
    }
}

14. 结果截图

　　

15. 结束