利用WCF双工模式实现即时通讯
更新时间：2016年09月22日 14:50:32 作者：会长
这篇文章主要介绍了利用WCF双工模式实现即时通讯的相关资料,具有一定的参考价值，感兴趣的小伙伴们可以参考一下
概述
WCF陆陆续续也用过多次，但每次都是浅尝辄止，以将够解决问题为王道，这几天稍闲，特寻了些资料看，昨晚尝试使用WCF的双工模式实现了一个简单的即时通讯程序，通过服务端转发实现客户端之间的通讯。这只是个Demo，没有考虑异常处理和性能问题。解决方案结构如下：
契约
using System;
using System.Collections.Generic;
using System.Linq;
using System.ServiceModel;
using System.Text;
using System.Threading.Tasks;
namespace Service.Interface
{
[ServiceContract(CallbackContract = typeof(ICallBack))]
public interface INoticeOperator
{
[OperationContract]
void Register(String id);
[OperationContract]
void UnRegister(String id);
[OperationContract]
void SendMessage(String from, String to, String message);
}
}
该接口定义了三个行为，分别是：
•注册
•注销
•发消息
其中，在特性[ServiceContract(CallbackContract = typeof(ICallBack))]中指定了用于服务端回调客户方法的契约ICallBack，其定义如下：
using System;
using System.Collections.Generic;
using System.Linq;
using System.ServiceModel;
using System.Text;
using System.Threading.Tasks;
namespace Service.Interface
{
public interface ICallBack
{
[OperationContract(IsOneWay = true)]
void Notice(String message);
}
}
实体
本Demo只有一个实体，用来表示已经注册用户的Id和对应的回调契约的具体实现的实例：
using Service.Interface;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Models
{
public class Client
{
public String Id { get; set; }
public ICallBack CallBack { get; set; }
}
}
契约的实现代码
using Models;
using Service.Interface;
using System;
using System.Collections.Generic;
using System.Linq;
using System.ServiceModel;
using System.Text;
using System.Threading.Tasks;
namespace Service
{
public class NoticeOperator : INoticeOperator
{
private static List<Client> clientList = new List<Client>();
public void Register(string id)
{
Console.WriteLine("register:" + id);
ICallBack callBack = OperationContext.Current.GetCallbackChannel<ICallBack>();
clientList.Add(new Client() { Id = id, CallBack = callBack });
}
public void UnRegister(string id)
{
Console.WriteLine("unRegister:" + id);
Client client = clientList.Find(c => c.Id == id);
if (client != null)
{
clientList.Remove(client);
}
}
public void SendMessage(string from, string to, string message)
{
Client client = clientList.Find(c => c.Id == to);
if (client != null)
{
String longMessage = String.Format("message from {0} to {1} at {2} : {3}", from, to, DateTime.Now.ToString("HH:mm:ss"), message);
Console.WriteLine(longMessage);
client.CallBack.Notice(longMessage);
}
}
}
}
Register方法用来把Client实体加入到一个列表中，模拟注册行为，Clinet实体包含了用户信息和实现了回调契约的一个实例对象。
UnRegister方法用来把一个Client从列表中移除，模拟注销行为。
SendMessage方法用来发送消息，第一个参数是发送者的Id，第二个参数是消息接受者的Id，第三个参数是发送内容，该方法先将消息在服务端打印出来，然后再回调消息接收者对应的回调契约的具体实现类的实例对象的Notice方法以达到服务端向客户端发送消息的目的。
宿主
using Service;
using Service.Interface;
using System;
using System.Collections.Generic;
using System.Linq;
using System.ServiceModel;
using System.ServiceModel.Description;
using System.Text;
using System.Threading.Tasks;
namespace Hosting
{
class Program
{
static void Main(string[] args)
{
using (ServiceHost host = new ServiceHost(typeof(NoticeOperator)))
{
host.AddServiceEndpoint(typeof(INoticeOperator), new NetTcpBinding(), "net.tcp://127.0.0.1:9527/NoticeOperator");
host.Opened += (s, e) => Console.WriteLine("service is running...");
host.Open();
Console.ReadLine();
}
}
}
}
宿主是一个控制台应用程序，使用的绑定类型为NetTcpBinding，端口是华安的华府的终生代号。
客户端代码
实现回调接口
using Service.Interface;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Test
{
class CallBack : ICallBack
{
public void Notice(string message)
{
Console.WriteLine(message);
}
}
}
模拟注册，发消息和注销
using Service.Interface;
using System;
using System.Collections.Generic;
using System.Linq;
using System.ServiceModel;
using System.Text;
using System.Threading.Tasks;
namespace Test
{
class Program
{
static void Main(string[] args)
{
InstanceContext context = new InstanceContext(new CallBack());
using (ChannelFactory<INoticeOperator> factory = new DuplexChannelFactory<INoticeOperator>(context, new NetTcpBinding(), "net.tcp://127.0.0.1:9527/NoticeOperator"))
{
INoticeOperator proxy = factory.CreateChannel();
String selfId = args[0];
String friendId = args[1];
proxy.Register(selfId);
Console.WriteLine("----------Register------------");
while(true)
{
String message = Console.ReadLine();
if (message == "q")
{
proxy.UnRegister(selfId);
break;
}
else
{
proxy.SendMessage(selfId, friendId, message);
}
}
}
}
}
}
在CMD中运行test.exe Joey Ross表示Joey注册，要给他的朋友Ross发送消息；再起一个进程test.exe Ross Joey表示Ross注册，要给他的朋友Joey发送消息。进程启动后输入一些字符按回车即发送至了对方，输入q回车注销并退出程序。如下图所示：
Ross：
Joey：
服务端：
参考资料
•无废话WCF入门教程五[WCF的通信模式]
•同事 @麦枫 的代码
•《WCF全面解析》
后记
这仅仅是个Demo，在实际项目中如果同时在线人数非常多，这样做的性能是否可行还需进一步对WCF双工模式的工作方式进行深入学习。
解决方案下载地址：WCFDemo
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
C#中不允许跨线程直接访问界面控件,即一个线程中如主线程创建的控件不允许被其他线程例如子线程直接访问,在一个线程中设置其他线程所有的控件属性通常有两种方法,本文将详细的给大家介绍一下,需要的朋友可以参考下2024-12-12
这篇文章主要为大家详细介绍了C#使用Aspose.Cells创建和读取Excel文件，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2018-10-10
Unity的IPostprocessBuild实用案例深入解析
这篇文章主要为大家介绍了Unity的IPostprocessBuild实用案例深入解析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2023-05-05
本文将介绍C#中常用的日期时间比较方法（CompareTo、Equals和比较运算符）以及日期时间格式化方法（ToString、自定义格式字符串和标准格式）,具有一定的参考价值,感兴趣的可以了解一下2023-10-10
C# 中可以将类、结构或接口的定义拆分到两个或多个源文件中，在类声明前添加partial关键字即可，通过本文给大家介绍C# partial关键字说明，需要的朋友参考下2016-02-02
在WPF（Windows Presentation Foundation）中,值转换器（Value Converter）是一种机制,允许你在绑定时转换绑定源和绑定目标之间的值,本文给大家介绍了WPF中值转换器的使用方法,需要的朋友可以参考下2024-02-02
这篇文章主要介绍了C#禁用双击窗体图标关闭窗体的方法,通过对窗体参数的简单设置实现C#禁用双击窗体图标关闭窗体的功能,非常简单实用,需要的朋友可以参考下2015-08-08
这篇文章主要介绍了C#动态生成DropDownList执行失败原因分析,以一个实例形式分析了C#动态生成DropDownList的相关注意要点与使用技巧,具有一定参考借鉴价值,需要的朋友可以参考下2015-03-03
这篇文章介绍了C#实现密码验证与输错密码账户锁定的方法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2022-04-04
本文将详细介绍C#关键字的应用，可供有需要的朋友参考2012-11-11
最新评论