silverlight中Wcf双工通信

一.创建WCF应用程序

       接口文件：

 

 
 

[ServiceContract(Namespace = "Silverlight", CallbackContract = @H_404_22@typeof(IDuplexClient))]  
  
  

    @H_404_22@public @H_404_22@interface IDuplexService  

  
  
    {  
  
  

         /// <summary>  

  
  

        /// 登陆的时候调用  

  
  

        /// </summary>  

  
  

        /// <param name="name">名字</param>  

  
  

        /// <param name="quantity">id</param>  

  
  

        [OperationContract(IsOneWay = @H_404_22@true)]  

  
  

        @H_404_22@void Login(@H_404_22@string name, @H_404_22@int id);  

  
  

        /// <summary>  

  
  

        /// 发送消息  

  
  

        /// </summary>  

  
  

        /// <param name="message">消息内容</param>  

  
  

        /// <param name="id">大于0为私聊</param>  

  
  

        /// <param name="id">自己的ID</param>  

  
  

        [OperationContract(IsOneWay = @H_404_22@true)]  

  
  

        @H_404_22@void Say(@H_404_22@string message, @H_404_22@int id,@H_404_22@int uid);  

  
  
    }  
  
  
 
  
  
   
  
  
 
  
  
   
  
  
 
  
  

///客服端调用  

  
  
 
  
  

    //[ServiceContract]  

  
  

    @H_404_22@public @H_404_22@interface IDuplexClient  

  
  
    {  
  
  
 
  
  

         //返回登陆人员  

  
  

         [OperationContract(IsOneWay = @H_404_22@true)]  

  
  

        @H_404_22@void rFriendList(List<UserInfo> friendList);  

  
  

        /// <summary>  

  
  

        /// 系统消息  

  
  

        /// </summary>  

  
  

        /// <param name="message">返回消息</param>  

  
  

        /// <param name="type">0代表异地登陆，-1代表用户异常，-2用户上线，-3用户下线</param>  

  
  

        [OperationContract(IsOneWay = @H_404_22@true)]  

  
  

        @H_404_22@void rSysMessage(@H_404_22@string message, @H_404_22@int type,@H_404_22@int id);  

  
  
    }  
  
  
 
  
  

//封装要传送的数据  

  
  
 
  
  
 [DataContract]  
  
  

    @H_404_22@public @H_404_22@class UserInfo  

  
  
    {  
  
  

        @H_404_22@public UserInfo(@H_404_22@string name,@H_404_22@int id)  

  
  
        {  
  
  
            _id = id;  
  
  
            _name = name;  
  
  
        }  
  
  
        [DataMember]  
  
  

       @H_404_22@public  @H_404_22@int _id { @H_404_22@get; @H_404_22@set; }  

  
  
        [DataMember]  
  
  

       @H_404_22@public   @H_404_22@string _name { @H_404_22@get; @H_404_22@set; }  

  
  
    }  
 
 

 二. 实现接口

 

 
 

@H_404_22@public @H_404_22@class OrderService : IDuplexService  
  
  
    {  
  
  

        IDuplexClient client = OperationContext.Current.GetCallbackChannel<IDuplexClient>();//构建用户通道  

  
  

        List<UserInfo> lst = @H_404_22@new List<UserInfo>();//存放登录用户  

  
  

        @H_404_22@private @H_404_22@static Dictionary<IDuplexClient, UserInfo> onlineUser = @H_404_22@new Dictionary<IDuplexClient, UserInfo>();//用每个用户通道和用户信息组成字典存储当前用户列表  
  
  
         
  
  
         #region IDuplexService 成员  
  
  
 
  
  
 
  
  

        @H_404_22@public @H_404_22@void Login(@H_404_22@string name, @H_404_22@int id)  

  
  
        {  
  
  

            //判断是否已经登陆  

  
  
 
  
  

            @H_404_22@if (onlineUser.Values.Where(h => h._name == name).Count() > 0)  

  
  
            {  
  
  
                IDuplexClient repertClient = onlineUser.Where(f => f.Value._name == name).First().Key;  
  
  

                //返回给此客户端重复登陆信息，强迫其下线  

  
  
                onlineUser.Remove(repertClient);  
  
  

                repertClient.rSysMessage("帐号在异地登录，被迫下线。", -1,0);  

  
  

                //通知好友你上线了  

  
  

                @H_404_22@foreach (var ou @H_404_22@in onlineUser)  

  
  
                {  
  
  

                    ou.Key.rSysMessage(name + ":下线了", -3, id);//回调接收方  

  
  
                }      
  
  
            }  
  
  
            loginChat(name, id);  
  
  
 
  
  
        }  
  
  
 
  
  

        @H_404_22@public @H_404_22@void Say(@H_404_22@string message,@H_404_22@int uid)  

  
  
        {  
  
  

            IDuplexClient client = @H_404_22@null;  

  
  

            @H_404_22@if (id == 0)//群聊        

  
  
            {  
  
  

                @H_404_22@foreach (var ou @H_404_22@in onlineUser)  

  
  
                {  
  
  

                    ou.Key.rSysMessage(message, id, uid);//回调接收方  

  
  
                }  
  
  
            }  
  
  

            @H_404_22@else 

  
  
            {  
  
  

                client = channel(id);//获取接收方通道  

  
  
 
  
  

                @H_404_22@if (client != @H_404_22@null)//如果接收方在线  

  
  
                {  
  
  

                    client.rSysMessage(message, uid);//回调接收方  

  
  
                }  
  
  
            }  
  
  

        }  
  
  
 
  
  
        #endregion  
  
  

        @H_404_22@public @H_404_22@void loginChat(@H_404_22@string userName, @H_404_22@int id)//登陆聊天模块  

  
  
        {  
  
  

            lst.Add(@H_404_22@new UserInfo(userName, id));  

  
  
 
  
  

            client.rFriendList(lst);//返回好友列表  

  
  

            //通知好友你上线了  

  
  

            @H_404_22@foreach (var ou @H_404_22@in onlineUser)  

  
  
            {  
  
  

                 ou.Key.rSysMessage(userName + ":上线了", -2, id);//回调接收方  

  
  
            }      
  
  

            onlineUser.Add(client, @H_404_22@new UserInfo(userName, id));//新用户添加到在线用户列表  

  
  
        }  
  
  

        @H_404_22@private IDuplexClient channel(@H_404_22@int id)//获取通道  

  
  
        {  
  
  

            IDuplexClient client = @H_404_22@null;  

  
  

            //确定接收人在线  

  
  

            @H_404_22@if (onlineUser.Values.Where(f => f._id == id).Count() > 0)  

  
  
            {  
  
  

                @H_404_22@return onlineUser.Where(f => f.Value._id == id).First().Key;//找到此通道  

  
  
            }  
  
  

            @H_404_22@return client;  

  
  
        }  
  
  
    }  
 
 

 

参考文献：http://codeadmin.blog.163.com/blog/static/1158046532011626111624369/