wcf双工通信 实例（wcf双工通信）

概述

wcf陆陆续续也用过多次，但每次都是浅尝辄止，以将够解决问题为王道，这几天稍闲，特寻了些资料看，昨晚尝试使用wcf的双工模式实现了一个简单的即时通讯程序，通过服务端转发实现客户端之间的通讯。这只是个demo，没有考虑异常处理和性能问题。解决方案结构如下：

契约

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22

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，其定义如下：

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15

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和对应的回调契约的具体实现的实例：

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16

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; } } }

契约的实现代码

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46

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方法以达到服务端向客户端发送消息的目的。

宿主

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27

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，端口是华安的华府的终生代号。

客户端代码

实现回调接口

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17

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); } } }

模拟注册，发消息和注销

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42

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