WCF與P2P   

    WCF是用來實現數據通信的，這篇文章中。我將帶領大家進入WCF的P2P的世界。通過一個實例，說明WCF中使用P2P。

    首先讓我們了解一下什么是P2P。詳細見：P2P。這里根據我的理解，結合WCF簡單的敘述一下。一般使用WCF，客戶端與客戶端交互都要使用一個服務端作為中間站?？蛻舳藢祿鬟f給服務端，服務端再轉發給其他的客戶端。很明顯，這顯然加重了服務端的負擔。P2P是解決這個問題的。每一個客戶端既可以是接受數據的客戶端，又是上傳數據的服務端。用過PPS和迅雷的童鞋就能很容易的理解了，這兩個軟件既要上傳數據，又要下載數據。看下面兩幅圖：

圖一：圍繞中心服務器打轉

圖二：P2P分布

實例的功能

    我實現的這個例子的功能是：在一個局域網內，有很多臺電腦。當其中一臺電腦實現了復制或者剪貼，在其他的電腦上將顯示復制和剪貼的數據。你可以實現Ctrl+C或者Ctrl+X進行數據復制或者剪貼。在其他的電腦上有一個窗體專門顯示你復制或者剪貼的數據（限定了文本數據）。

    實現這個程序有兩個難點：

    1、如何監聽Ctrl+C或者Ctrl+X等事件

    2、不需要特定的服務端（不通過WCF的雙工通信），如果通過P2P去實現數據通信。

實例的實現：

    下面根據這兩個難點來展開去實現。

   一、事件監聽：

    1、在WindowsForm應用程序中，protected override void WndProc(ref System.Windows.Forms.Message m)方法可以供我們去重載來實現事件的監聽。判斷Message的編號，如果是復制或者剪貼事件。我們就去通過WCF的P2P服務來廣播剪貼板中的信息。代碼如下：

protected override void WndProc(ref System.Windows.Forms.Message m)
{
// defined in winuser.h
const int WM_DRAWCLIPBOARD = 0x308;
const int WM_CHANGECBCHAIN = 0x030D;

switch (m.Msg)
{
case WM_DRAWCLIPBOARD:
DisplayClipboardData();
SendMessage(nextClipboardViewer, m.Msg, m.WParam, m.LParam);
break;

case WM_CHANGECBCHAIN:
if (m.WParam == nextClipboardViewer)
nextClipboardViewer = m.LParam;
else
SendMessage(nextClipboardViewer, m.Msg, m.WParam, m.LParam);
break;

default:
base.WndProc(ref m);
break;
}
}

2、然后提交給User32.dll處理：

[DllImport("User32.dll")]
protected static extern int SetClipboardViewer(int hWndNewViewer);

[DllImport("User32.dll", CharSet = CharSet.Auto)]
public static extern bool ChangeClipboardChain(IntPtr hWndRemove, IntPtr hWndNewNext);

[DllImport("user32.dll", CharSet = CharSet.Auto)]
public static extern int SendMessage(IntPtr hwnd, int wMsg, IntPtr wParam, IntPtr lParam);

    通過上面的代碼，我們解決了第一個問題：如何監聽Ctrl+C或者Ctrl+X等事件。

     二、在WCF中，我們要通過NetPeerTcpBinding實現P2P。

     下面我就一步一步的實現這個P2P的應用服務。

   1、定義契約和實現契約：

[ServiceContract(CallbackContract = typeof(IShare))]
public interface IShare
{
[OperationContract(IsOneWay = true)]
void ShareClipboard(string type,string message);
}
public class ShareImplementation : IShare
{

private static Form m_receiverForm;
private static ClipEventHandler m_OnClipReceive;
public void ShareClipboard(string type,string message)
{
try
{

m_receiverForm.Invoke(m_OnClipReceive, type, message);
}
catch (Exception e)
{
MessageBox.Show(e.ToString());
}
}

public void SetForm(Form form,ClipEventHandler theCallback)
{
m_receiverForm = form;

m_OnClipReceive = theCallback;
}
}
使用一個類來管理這個服務: public class Peer
{
public string Id { get; private set; }

public IShare Channel;
public ShareImplementation Host;
public ClipEventHandler clipeventhandler;
public Form form;
public Peer(string id)
{
Id = id;
}

private DuplexChannelFactory<IShare> _factory;
public void StartService()
{
var binding = new NetPeerTcpBinding();
binding.Security.Mode = SecurityMode.None;

var endpoint = new ServiceEndpoint(
ContractDescription.GetContract(typeof(IShare)),
binding,
new EndpointAddress("net.p2p://SimpleP2P"));

Host = new ShareImplementation();
Host.SetForm(form,clipeventhandler);
_factory = new DuplexChannelFactory<IShare>(new InstanceContext(Host), endpoint);

var channel = _factory.CreateChannel();

((ICommunicationObject)channel).Open();

// wait until after the channel is open to allow access.
Channel = channel;
}

public void StopService()
{
((ICommunicationObject)Channel).Close();
if (_factory != null)
_factory.Close();
}

private readonly AutoResetEvent _stopFlag = new AutoResetEvent(false);
public void Run()
{
Console.WriteLine("[ Starting Service ]");
StartService();

Console.WriteLine("[ Service Started ]");
_stopFlag.WaitOne();

Console.WriteLine("[ Stopping Service ]");
StopService();

Console.WriteLine("[ Service Stopped ]");
}

public void Stop()
{
_stopFlag.Set();
}
} 在WindowsForm中，通過DisplayClipboardData()方法來調用此服務，代碼如下。 void DisplayClipboardData()
{
try
{
IDataObject iData = new DataObject();

string type = "",message="";

iData = Clipboard.GetDataObject();

if (Clipboard.ContainsText())
{
message = (string)iData.GetData(DataFormats.Text);
}

if (peer != null && peer.Channel != null)
{
peer.Channel.ShareClipboard("text", message);
}
}
catch (Exception e)
{
MessageBox.Show(e.ToString());
}
}

還有就是一個方法來接受信息方法AddToClip，代碼如下： public void AddToClip(string type, string message)
{

if (type == "rtf")
{
IDataObject iData = new DataObject(DataFormats.Rtf, message);
richTextBox1.Rtf = (string)iData.GetData(DataFormats.Rtf);
//richTextBox1.Rtf = message;
}
else if (type == "text")
richTextBox1.Text = message;
else
 richTextBox1.Text = "[Clipboard data is not RTF or ASCII Text]&quot;;

richTextBox1.Text = message;
}由于WCF得回調和WindowsForm的主線程不是一個，故使用了一個委托：

public delegate void ClipEventHandler(string type ,string clipData);其他詳細見代碼。

實例的效果：

    在電腦zhuqilin上復制文本數據

   在電腦Colin上顯示zhuqilin上復制的數據：

總結：

      上星期用WCF的雙工實現了一個音頻聊天室的程序。有園友提出點對點的視頻、語音、聊天用P2P去實現效率和性能更好，故研究了一下WCF的P2P。本文就是一個簡單的WCF的P2P的例子。

擴展：

　　 這篇文章只實現了文字剪貼板的共享功能。如果你有興趣，可以進一步擴展。

        擴展1：數據直接傳遞到其他電腦的剪貼板上，可以直接Ctrl+V粘貼。

        擴展2：現在只是實現文字剪貼板的共享。擴展成文件、視頻、圖片都可以。

　　效果可以是：如果局域網的兩個端點機器通過共享自己的剪貼板。在A機器上復制文件，在B機器上可以直接粘貼。

　　寫這個例子的靈感來自RealVNC。用過RealVNC的童鞋都知道，無論局域網還是外網，只要兩臺pc建立連接，就能共享剪貼板上的數據了。

最后：建立P2P和打開P2P管道需要時間，故在運行這個程序的之后，需要等上一段時間才能共享你的剪貼板。