| Printable Version
P2P And C#
By Shripad Kulkarni
This article describes the simple approach to design a peer to peer network.
The figure1 shown below gives a general idea how p2p works. Although there
are many other types where index server or central servers are not required
, or can be eliminated so client talk directly to other clients.
The P2P concept generally consists of a central Index server. This server
does not contain any files, physically. It only maintains the information
about the users who are logged on to the network, the IP address of the
client and the list of files shared at any given moment by a user. The
client and the server communicate with each other over a socket connection
using simple commands.
When a client "A" wants to search for files shared by other
clients on the P2P network
· The Client "A"logs into the index server with a userid and
the folder information that the client is willing to share.
· The Client "A" registers all the files with the server so
that other clients can search for these files.
· The Client "A" makes a request to the index server to search
files matching a given input pattern.
· The index server searches files names in its repository and returns
to the Client "A"
- The user sharing
the file eg Client "B"
- IP address of
the user
- Files names that
it found.
Once the Client "A"
selects the download option, Client "A" makes a socket connection
to the Client "B" using the IP address returned by search.
You can define any
port that you wish to listen at. For a list of TCP ports and what port
numbers that can be used click here
- If
there is a successful connection is establised, inform the other client
to begin sending the file.
- Once
the download is complete, register this file with the index server as
your copy of the shared file.
Such a P2P network can be used to share any type of file. It can be used
for your local network or a global network.
For more information about Firewall and SOCKS click here
|
|
The C# language make life very easy with the help of the TCPListener and the TCPClient classes.
Here is a listing of the transfer class ..
public MyTcpListener(int port) : base(port)
{
}
public void StopMe()
{
if ( this.Server != null )
{
this.Server.Close();
}
}
}
///
/// Summary description for Transfer.
///
public class Transfer
{
MyTcpListener tcpl;
public Transfer()
{
OptionsLoader ol = new OptionsLoader();
int port = 8081;
if (ol.Port > 0)
{
port = ol.Port;
}
else
{
// The default in case nothing else is set
port = 8081;
}
this.tcpl = new MyTcpListener(port);
}
public void TransferShutdown()
{
tcpl.StopMe();
}
public void ListenForPeers()
{
try
{
Encoding ASCII = Encoding.ASCII;
tcpl.Start();
while (true)
{
// Accept will block until someone connects
Socket s = tcpl.AcceptSocket();
NetworkStream DataStream = new NetworkStream(s);
String filename;
Byte[] Buffer = new Byte[256];
DataStream.Read(Buffer, 0, 256);
filename = Encoding.ASCII.GetString(Buffer);
StringBuilder sbFileName = new StringBuilder(filename);
StringBuilder sbFileName2 = sbFileName.Replace("\", "\\");
FileStream fs = new FileStream(sbFileName2.ToString(), FileMode.Open, FileAccess.Read);
BinaryReader reader = new BinaryReader(fs);
byte[] bytes = new byte[1024];
int read;
while((read = reader.Read(bytes, 0, bytes.Length)) != 0)
{
DataStream.Write(bytes, 0, read);
}
reader.Close();
DataStream.Flush();
DataStream.Close();
}
}
catch(SocketException ex)
{
MessageBox.Show(ex.ToString());
}
}
public void DownloadToClient(String server, string remotefilename, string localfilename)
{
try
{
TcpClient tcpc = new TcpClient();
Byte[] read = new Byte[1024];
OptionsLoader ol = new OptionsLoader();
int port = 0;
if (ol.Port > 0)
{
port = ol.Port;
}
else
{
// The default in case nothing else is set
port = 8081;
}
// Try to connect to the server
IPHostEntry IPHost = Dns.Resolve(server);
string []aliases = IPHost.Aliases;
IPAddress[] addr = IPHost.AddressList;
IPEndPoint ep = new IPEndPoint(addr[0], port);
tcpc.Connect(ep);
// Get the stream
Stream s = tcpc.GetStream();
Byte[] b = Encoding.ASCII.GetBytes(remotefilename.ToCharArray());
s.Write( b, 0, b.Length );
int bytes;
FileStream fs = new FileStream(localfilename, FileMode.OpenOrCreate);
BinaryWriter w = new BinaryWriter(fs);
// Read the stream and convert it to ASII
while( (bytes = s.Read(read, 0, read.Length)) != 0)
{
w.Write(read, 0, bytes);
read = new Byte[1024];
}
tcpc.Close();
w.Close();
fs.Close();
}
catch(Exception ex)
{
throw new Exception(ex.ToString());
}
}
}
} |
|
