用Visual C#实现P2P应用程序

namespace P2PTest
{
　using System;
　using System.Net.Sockets;
　using System.Threading;

　public class Listener
　{
　　private Thread th;
　　private TcpListener tcpl;
　　public bool listenerRun = true;
　　//listenerRun为true，表示可以接受连接请求，false则为结束程序

　　public Listener()//构造函数
　　{
　　　th = new Thread(new ThreadStart(Listen));
   //新建一个用于监听的线程
　　　th.Start();//打开新线程
　　}

　　public void Stop()
　　

　　private void Listen()
　　{
　　　try
　　　{
　　　　tcpl = new TcpListener(5656);//在5656端口新建一个TcpListener对象
　　　　tcpl.Start();
　　　　Console.WriteLine("started listening..");

　　　　while(listenerRun)//开始监听
　　　　{
　　　　　Socket s = tcpl.AcceptSocket();
　　　　　string remote = s.RemoteEndPoint.ToString();
　　　　　Byte[] stream = new Byte[80];
　　　　　int i=s.Receive(stream);//接受连接请求的字节流
　　　　　string msg = "<" + remote + ">" + System.Text.Encoding.UTF8.GetString(stream);
　　　　　Console.WriteLine(msg);//在控制台显示字符串
　　　　}
　　　}
　　　catch(System.Security.SecurityException)
　　　{
　　　　Console.WriteLine("firewall says no no to application - application cries..");
　　　}
　　　catch(Exception)
　　　{
　　　　Console.WriteLine("stoped listening..");
　　　}
　　}
　}
} 

namespace P2PTest 
{ 
　using System; 
　using System.IO; 
　using System.Net.Sockets; 

　public class Sender 
　{ 
　　public void Send(string[] aInput) 
　　{ 
　　　string stream = ""; 
　　　//获得要发送的信息 
　　　for(int i=2; i　　　{ 
　　　　stream += aInput[i] + " "; 
　　　} 

　　try 
　　{ 
　　　TcpClient tcpc = new TcpClient(aInput[1], 5656); 
　　　//在5656端口新建一个TcpClient对象 
　　　NetworkStream tcpStream = tcpc.GetStream(); 

　　　StreamWriter reqStreamW = new StreamWriter(tcpStream); 
　　　reqStreamW.Write(stream); 
　　　reqStreamW.Flush();//发送信息 
　　　tcpStream.Close(); 
　　　tcpc.Close(); 
　　} 
　　catch(Exception) 
　　{ 
　　　Console.WriteLine("connection refused by target computer"); 
　　} 
　　} 
　} 
}

namespace P2PTest 
{ 
　using System; 

　public class InputHandler 
　{ 
　　public bool appRun = true;//当appRun为false时，程序结束 
　　public InputHandler() 
　　{ 
　　　Console.WriteLine("type help for a list of commands."); 
　　　Input(); 
　　} 

　　private static Listener li;//一个静态的Listener对象 
　　private string inparam; 
　　private string[] aInput;//数组aInput用于接受用户输入的信息 

　　public void Input() 
　　{ 
　　　while(appRun) 
　　　{ 
　　　　inparam = Console.ReadLine(); 
　　　　aInput = inparam.Split(' '); 
　　　　//将inparam分割的目的是为了获得字符串中的第一个字，从而执行以下不同的命令 
　　　　switch(aInput[0]) 
　　　　{ 
　　　　　case "send"://如果是"send"，则新建一个Sender对象并发送信息 
　　　　　　Sender se = new Sender(); 
　　　　　　se.Send(aInput); 
　　　　　　break; 
　　　　　case "start"://如果是"start"，则新的开始监听 
　　　　　　try 
　　　　　　{ 
　　　　　　　li.listenerRun = false; 
　　　　　　　li.Stop(); 
　　　　　　} 
　　　　　　catch(NullReferenceException) 
　　　　　　{ 
　　　　　　　　; 
　　　　　　} 
　　　　　　finally 
　　　　　　{　　 
　　　　　　　li = new Listener(); 
　　　　　　} 
　　　　　　break; 
　　　　　case "stop"://如果是"stop"，则停止监听 
　　　　　　try 
　　　　　　{ 
　　　　　　　li.listenerRun = false; 
　　　　　　　li.Stop(); 
　　　　　　} 
　　　　　　catch(NullReferenceException) 
　　　　　　{ 
　　　　　　　; 
　　　　　　} 
　　　　　　break; 
　　　　　case "exit"://退出程序 
　　　　　　try 
　　　　　　{ 
　　　　　　　li.listenerRun = false; 
　　　　　　　li.Stop(); 
　　　　　　} 
　　　　　　catch(NullReferenceException) 
　　　　　　{ 
　　　　　　　; 
　　　　　　} 
　　　　　　finally 
　　　　　　{ 
　　　　　　　appRun = false; 
　　　　　　} 
　　　　　　break; 
　　　　　case "help"://显示帮助信息 
　　　　　　　Console.WriteLine("Commands:"); 
　　　　　　　Console.WriteLine("start: starts the listener"); 
　　　　　　　Console.WriteLine("stop: stops the listener if started"); 
　　　　　　　Console.WriteLine("send: send   sends a message"); 
　　　　　　　Console.WriteLine("exit: exits the application"); 
　　　　　　　Console.WriteLine("help: you already know"); 
　　　　　　　break; 
　　　　　default: 
　　　　　　Console.WriteLine("Invalid command"); 
　　　　　　break; 
　　　　} 
　　　} 
　　} 
　} 
} 

namespace P2PTest 
{ 
　using System; 

　public class Init 
　{ 
　　public static void Main() 
　　{ 
　　　InputHandler ih = new InputHandler();//新建一个InputHandler对象 
　　　while(ih.appRun);//直到ih.appRun为false，程序退出 
　　　　Console.WriteLine("exiting.."); 
　　} 
　} 
}