稳扎稳打Silverlight(23) - 2.0通信之调用WCF的双向通信(Duplex Service)

  [索引页]
[源码下载]


作者： webabcd
介绍
Silverlight 2.0 调用 WCF 的双向通信服务(Duplex servicE) 。开发一个服务端主动向客服端发送股票信息的程序，首先客户端先向服务端发送需要监控的股票的股票代码，然后服务端在该股信息发生变化的时候将信息推送到客户端。
    服务端：
        定义服务契约及回调接口
        从当前上下文获取回调的客户端信道
        需要的话则向客户端信道“推”消息
    客户端：
        构造 PollingDuplexhttpBinding 并在其上创建 IDuplexSessionChAnnel 的信道工厂
        异步方式打开信道工厂
        异步方式打开信道
        构造需要发送到服务端的消息 System.serviceModel.ChAnnels.message
        异步向服务端发送消息
        监听指定信道，用于异步方式接收服务端返回的消息
        不需要再接收服务端的消息则关闭信道
在线DEMO
http://www.cnblogs.com/webabcd/archive/2008/10/09/1307486.html  
示例 
服务端：
IDuplexservice.cs

Duplexservice.cs

using  System;

using  System.Collections.Generic;

using  System.Linq;

using  System.Runtime.serialization;

using  System.serviceModel;

using  System.Text;

using  System.serviceModel.ChAnnels;

using  System.Threading;

using  System.serviceModel.Activation;

using  System.IO;

/// <sumMary>

/// Duplex 服务的服务端的实现

/// 本文以客户端向服务端提交股票代码，服务端定时向客户端发送股票信息为例

/// </sumMary>

public   class  Duplexservice : IDuplexservice

{

    IDuplexClient _client;

    bool _status = true;

    /// <sumMary>

    /// 客户端向服务端发送股票代码的方法

    /// </sumMary>

    /// <param NAME="receivedmessage">包含股票代码的 System.serviceModel.ChAnnels.message </param>

    public void SendStockCode(message receivedmessagE)

    {

        // 获取当前上下文的回调信道

        _client = OperationContext.Current.GetCallBACkChAnnel<IDuplexClient>();

        // 如果发生错误则不再执行

        OperationContext.Current.ChAnnel.Faulted += new EventHandler(delegate { _status = false; });

        // 获取用户提交的股票代码

        String stockCode = receivedmessage.GetBody<String>();

        // 每3秒向客户端发送一次股票信息

        while (_status)

        {

            // 构造需要发送到客户端的 System.serviceModel.ChAnnels.message

            // Duplex 服务仅支持 Soap11 ， Action 为请求的目的地（需要执行的某行为的路径）

            message stockmessage = message.Createmessage(

                messageVersion.soap11,

                "Silverlight20/IDuplexservice/ReceiveStockmessage",

                String.Format("StockCode: {0}; StockPrice: {1}; CurrentTime: {2}",

                    stockCode,

                    new random().Next(1, 200),

                    datetiR_605_11845@e.Now.ToString()));

            try

            {

                // 向客户端“推”数据

                _client.ReceiveStockmessage(stockmessagE);

            }

            catch (Exception eX)

            {

                // 出错则记日志

                using (StreamWriter sw = new StreamWriter(@"C:\Silverlight_Duplex_Log.txt", true))

                {

                    sw.Write(ex.ToString());

                    sw.WriteLine();

                }

            }

            System.Threading.Thread.Sleep(3000);

        }

    }

}