概述
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://HdhCmsTestcnblogs测试数据/zzy0471/p/5895849.html
dy("nrwz");