利用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

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持服务器之家。

原文链接：http://www.cnblogs.com/zzy0471/p/5895849.html