2、该从属装置通过渗返该网络识别资料与该主控装置建立联机
3、确认该主控装置内部是否有资料
4、若有资料则将枯喊贺该资料以点对没派点方式传送至该从属装置,反之,若无则进行下一步骤以及结束该主控装置与该从属装置的联机.
在两台计算机传输文件之前,必需得先有一台计算机建立套接字连接并绑定一个固定得端口,并在这个端口侦听另外一台计算机的连接请求。socket = new Socket(AddressFamily.InterNetwork,SocketType.Stream, ProtocolType.Tcp)
socket.Blocking = true
IPEndPoint computernode1 = new IPEndPoint(serverIpadress, 8080)
socket.Bind(computernode1)
socket.Listen(-1)
当有其他的计算机发出连接请求的时候,被请求的计算机将对每一个连接请求分配一个线程,用于处理文件传输和其他服务。
while ( true )
{
clientsock = socket.Accept()
if ( clientsock.Connected )
{
Thread tc = new Thread(new ThreadStart(listenclient))
tc.Start()
}
}
下面的代码展示了listenclient方启橡法是如何处理另外一台计算机发送过来的请求。首先并对发送过来的请求字符串作出判断,看看是何种请求,然后决定相应的处理方法。
void listenclient()
{
Socket sock = clientsock
try
{
while ( sock != null )
{
byte[] recs = new byte[32767]
int rcount = sock.Receive(recs,recs.Length,0)
string message = System.Text.Encoding.ASCII.GetString(recs)
//对message作出处理,解析处请求字符和参数存储在cmdList 中
execmd=cmdList[0]
sender = null
sender = new Byte[32767]
string parm1 = ""
//目橡哗录列举
if ( execmd == "LISTING" )
{
ListFiles(message)
continue
}
//文件传输
if ( execmd == "GETOK" )
{
cmd = "BEGINSEND " + filepath + " " + filesize
sender = new Byte[1024]
sender = Encoding.ASCII.GetBytes(cmd)
sock.Send(sender, sender.Length , 0 )
//转到文件下载处理
DownloadingFile(sock)
continue
}
}
}
catch(Exception Se)
{
string s = Se.Message
Console.WriteLine(s)
}
}
至此,基本的工作已经完成了,下面我们看看如何处理文件传输的。
while(rdby <total &&nfs.CanWrite)
{
//从要传输的文件读取指定长度的数据
len =fin.Read(buffed,0,buffed.Length)
//将读取的数据发送梁旁行到对应的计算机
nfs.Write(buffed, 0,len)
//增加已经发送的长度
rdby=rdby+len
}
从上面的代码可以看出是完成文件转换成FileStream 流,然后通过NetworkStream绑定对应的套节子,最后调用他的write方法发送到对应的计算机。
我们再看看接受端是如何接受传输过来的流,并且转换成文件的:
NetworkStream nfs = new NetworkStream(sock)
try
{
//一直循环直到指定的文件长度
while(rby <size)
{
byte[] buffer = new byte[1024]
//读取发送过来的文件流
int i = nfs.Read(buffer,0,buffer.Length)
fout.Write(buffer,0,(int)i)
rby=rby+i
}
fout.Close()
从上面可以看出接受与发送恰好是互为相反的过程,非常简单。
至此,单方向的文件传输就完成了,只需要在每个对等的节点上同时实现上面的发送和接受的处理代码就可以做到互相传输文件了。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)