WCF的回调使用实例代码说明

很多时候我们会遇到,信息及时推送通知的情况，例如：监控设备时及时推送状态、报警信息等,我们就可以用WCF的回调机制来实现,下面以一个监控设备名字为例，如果设备名字发生改变，服务器就马上推送消息给客户端：
（一、）服务器端

1、建一个控制台应用程序：CallbackContractWCF
2、创建ISendMessage接口

namespace CallbackContractWCF
{
    [ServiceContract(CallbackContract = typeof(IMessageCallbackContract))]
   public interface ISendMessage
    {
        /// 
        /// 保存客户端回调的实例
        /// 
        [OperationContract]
        void Subscribe();
    }
}

3、创建用于推送消息回调的接口IMessageCallbackContract

namespace CallbackContractWCF
{
   public interface IMessageCallbackContract
    {
        [OperationContract(IsOneWay = true)]
        void ReportMes(string responseToGreeting);
    }
}

4、创建实现接口ISendMessage的类SendMessage

namespace CallbackContractWCF
{
    [ServiceBehavior(InstanceContextMode=InstanceContextMode.Single,ConcurrencyMode=ConcurrencyMode.Multiple,UseSynchronizationContext=false)]
    public class SendMessage:ISendMessage
    {
        private System.Timers.Timer _setValueTimer;
        private IMessageCallbackContract callerProxy = null;
        ~SendMessage()
        {
            _setValueTimer.Stop();
            Device.OnChange -= new Action(Student_OnChange);
        }
        public SendMessage()
        {
            Thread.Sleep(3000);
            _setValueTimer = new System.Timers.Timer();
            _setValueTimer.AutoReset = true;
            _setValueTimer.Elapsed += Timer_Elapsed;
            _setValueTimer.Interval = 10000;
            _setValueTimer.Start();
            Device.OnChange += new Action(Student_OnChange);
        }
        //保存客户端回调的实例
        public void Subscribe()
        {
            try
            {
                //获取当前调用的核心服务端实例的通道
                callerProxy = OperationContext.Current.GetCallbackChannel();
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }    
        private void Timer_Elapsed(object sender, ElapsedEventArgs e)
        {
            Random rand = new Random();
            string name = "路由器"+rand.Next(10);
            SetName(name);
        }  
        private void SetName(string greeting)
        {
            if (greeting != Device.Name)
            {
                Device.Name = greeting;
                Device.Change(greeting);
            } 
        }  
        void Student_OnChange(string name)
        {
            try
            {
                Console.Write("只要名字与当前的不同就向客户端推送通知
");
                callerProxy.ReportMes(name);                    
            }
            catch (Exception ex)
            {
                Console.Write(ex.Message);
            }
        }
    }
    //创建设备类
    public static class Device
    {
        public static string Name { get; set; }
        public static event Action OnChange;
        public static void Change(string name)
        {
            if (OnChange != null)
            {
                OnChange.Invoke(name);
            }
        }
    }
}

5、添加配置文件App.config

<configuration>
  <system.serviceModel>
    <behaviors>
      <serviceBehaviors>
        <behavior name="behavior1">
          <serviceMetadata httpGetEnabled="false"  />
          <serviceDebug includeExceptionDetailInFaults="false"  />
        </behavior>
      </serviceBehaviors>
    </behaviors>
    
    <bindings>
      <netTcpBinding>
        <binding name="BigBinding" closeTimeout="00:10:00" openTimeout="00:10:00" receiveTimeout="00:10:00"
                   sendTimeout="00:10:00" transactionFlow="false" transferMode="Buffered" transactionProtocol="OleTransactions"
                   hostNameComparisonMode="StrongWildcard" listenBacklog="10" maxBufferPoolSize="524288000"
                   maxBufferSize="65536000" maxConnections="10" maxReceivedMessageSize="65536000">

          <readerQuotas maxDepth="32000" maxStringContentLength="8192000"
                        maxArrayLength="16384000" maxBytesPerRead="4096000"
                        maxNameTableCharCount="16384000"/>
          <reliableSession ordered="true" inactivityTimeout="00:10:00" enabled="false"/>
          <security mode="None"/>
        </binding>
        <binding name="netTcpBinding_ISendMessage">
          <security mode="None"></security>
        </binding>
      </netTcpBinding>
    </bindings>
    
    <services>
      <service name="CallbackContractWCF.SendMessage" behaviorConfiguration="behavior1">
        <endpoint address="SendMessage"  binding="netTcpBinding" bindingConfiguration="BigBinding"  
                            contract="CallbackContractWCF.ISendMessage" name="netTcpBinding_ISendMessage" >
          <identity>
            <dns value="localhost" />
          </identity>
        </endpoint>
        <endpoint address="mex" binding="mexTcpBinding" contract="IMetadataExchange" />
        <host>
          <baseAddresses>
            <add baseAddress="net.tcp://localhost:8729/Design_Time_Addresses/CallbackContractWCF/SendMessage/" />
          </baseAddresses>
        </host>
      </service>
    </services>
  </system.serviceModel>
</configuration>

（二、）客户端
1、创建控制台应用程序CallbackContractClient
2、启动服务器，添加服务引用
3、创建一个实现服务器端回调接口的类MessageCallback

namespace CallbackContractClient
{
    [System.ServiceModel.CallbackBehavior(IncludeExceptionDetailInFaults = true, UseSynchronizationContext = false, ConcurrencyMode = ConcurrencyMode.Multiple)]
    public class MessageCallback : ISendMessageCallback
    {
        public event Action OnReportMes;
        
        //实现服务端的回调
        public void ReportMes(string responseMes)
        {
            if (OnReportMes != null)
            {
                OnReportMes.Invoke(responseMes);
            }
        }
    }
}

4、在控制台主程序Program.cs中挂载服务

namespace CallbackContractClient
{
    class Program
    {
        static void Main(string[] args)
        {
            MessageCallback callback=new MessageCallback ();
            callback.OnReportMes+=new Action(callback_OnReportMes);
            InstanceContext content = new InstanceContext(callback);
            SendMessageClient clicent = new SendMessageClient(content);
            clicent.Subscribe();

            Console.Write("监控设备");
            Console.ReadLine();
        }    

        public static void callback_OnReportMes(string res)
        {
            Console.Write("
设备的名称为：" + res);
            Console.ReadLine();
        }
    }
}

(三、)监测结果