概述
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
