D6中用Socket编写文件的传输!?各位老鸟,小弟这边磕头了!!(100分)

  • 主题发起人 主题发起人 草在墙头
  • 开始时间 开始时间

草在墙头

Unregistered / Unconfirmed
GUEST, unregistred user!
主题:1.各终端将文件(可能奇大-1G)传到主服务器的制定目录下;
2.各终端发送下载命令(要下载的文件,制定目录等)到主服务器,服务器再将文件发送到各终端。
我采用的是线程来收发文件,向服务器传送已搞定(ClientSocket1的ClientType为ctBlocking,ServerSocket1的severtype为stThreadBlocking),
但服务器向各终端传输始终搞不定,因为ClientSocket1和ServerSocket1有制约。我也晕了!!
望各位大哥给我点意见,有原程最好了。
 
别磕了。最近老是看到有磕头的。
不懂就问,没什么大不了的事。
-----------------------------------------
> 但服务器向各终端传输始终搞不定,因为ClientSocket1和ServerSocket1有制约
什么意思?
 
另用一个套接字行不行?
 
to wlmmlw:
客户端向服务器:ClientSocket 的Clienttype为ctBlocking,serversocket的servertype为stThreadBlocking,
按上面的设置在文件传送时没有问题,但发送不了信息,也就是说:客户端没法将发送信息到服务器,那么服务器也就不能接受信息并将文件转化发给客户端。
信息传送时:ClientSocket 的Clienttype为ctnonBlocking,serversocket的servertype为stNonBlocking,是吧?
我也想过通过serversocket的servertype属性的变换来实现这个功能,但客户机有若干台,若同时有传送和下载,那是否有冲突?
 
http://expert.csdn.net/expert/Topicview2.asp?id=1093894

只有上传,下载得自己写。。。
 
用Delphi编写点对点传文件程序
Delphi功能强大,用Delphi写软件,可以大大缩短软件的开发周期。关于点对点传文件的基本思路,就是一个服务器软件,一个客户端软件,使用同一个端口,待连接上以后,客户端给服务器发送一个请求,包括待传的文件的文件名,大小等,如果服务器接受,就开始传文件。当然,文件传输的时候可以有两种模式,ASCII码和Bin,不过一般通用Bin 就可以了。基于上面的讨论,本来用Delphi4的NMStrm,NMStrmServ 控件就可以完成,但是我测试过了,NMStrm控件对于较小的文件还可以使用,而且很方便,但是如果文件一大(1M)就会出错。所以接下来我们利用Delphi中TServerSocket和TClientSocket写这个程序由于以太包大小的限制以及DelphiSocket的处理机制(Delphi中,当你用一个Socket发送一个较大的Stream,接受方会激发多次OnRead事件,Delphi她只保证多次OnRead事件中每次数据的完整,而不会自己收集数据并返回给用户。所以不要以为你把待传文件在一个Socket中Send一次,另一个中Recv一次就可以了。你必须自己收集数据或自己定义协议。),所以我们采用自定义协议的方法。定义协议的规范方法是利用Record End。如:

TMyFileProtocol=Record
sSendType=(ST_QUERY,ST_REFUSE,ST_DATA,ST_ABORT,...);
iLength:integer;
bufSend:Buffer;
End;
  我曾试过这个办法,但失败了,而且我一直认为我的方法是正确的,但程序一直编译通不过,估计是Delphi有问题:) 所以我在下列的范例程序中利用另外一种办法。Socket 类中有两属性ReceiveText和ReceiveBuf,在一个OnRead事件中,只能使用一次该两属性,所以我们可以利用一个全程变量来保存是该读Text还是Buf,也就是说读一次Text,再都一次Buf,这就模拟了TMyFileProtocol。


开始程序:
写一个最简单的,主要用于讲解方法。
定义协议:
Const
MP_QUERY =’1’;
MP_REFUSE =’2’;
MP_ACCEPT =’3’;
MP_NEXTWILLBEDATA=’4’;
MP_DATA =’5’;
MP_ABORT =’6’;
MP_OVER =’7’;
MP_CHAT =’8’;

协议简介:
首先由Client发送MP_QUERY,Server接受到后发送MP_ACCEPT或MP_FEFUESE;
Client接受到MP_ACCEPT发送MP_FILEPROPERTY,Server接受到后发送MP_NEXTWILLBEDATA;
Client接受到发送MP_NEXTWILLBEDATA,Server接受到后发送MP_DATA;
Client接受到MP_DATA,发送数据,Server接受数据,并发送MP_NEXTWILLBEDATA;
循环,直到Client发送MP_OVER;
中间可以互相发送MP_CHAT+String;

Server程序:
放上以下控件:SaveDialog1,btnStartServer,
ss,(TServerSocket)

btnStartServer.OnClick(Sender:TObject);
begin
ss.Port:=2000;
ss.Open;
end;

ss.OnClientRead(Sender: TObject;Socket: TCustomWinSocket);
var
sTemp:string;
bufRecv:Pointer;
iRecvLength:integer;
begin
if bReadText then
begin
sTemp:=Socket.ReceiveText;
case sTemp[1] of
MP_QUERY:
begin
//在这里拒绝
SaveDialog1.FileName:=Copy(sTemp,2,Length(STemp));
if SaveDialog1.Execute then
begin
Socket.SendText(MP_ACCEPT);
fsRecv:=TFileStream.Create(SaveDialog1.FileName,fmCreate);
end
else Socket.SendText(MP_REFUSE+’去死’);
end;
MP_FILEPROPERTY:
begin
//要发送StrToInt(Copy(sTemp,2,Length(sTemp))) 次
//时间进度显示。。。
Socket.SendText(MP_NEXTWILLBEDATA);
end;
MP_NEXTWILLBEDATA:
begin
Socket.SendText(MP_DATA);
bReadText:=false;
end;
MP_END:
begin
fsRecv.Free
bReadText:=true;
end;
MP_ABORT:
begin
fsRecv.Free;
bReadText:=true;
end;
MP_CHAT:
begin
//Chat Msg
end;
end;{of case}
end
else begin
try
GetMem(bufRecv,2000);//2000 must >iBYTESEND
Socket.ReceiveBuf(bufRecv^,iRecvLength);
fsRecv.WriteBuffer(bufRecv^,iRecvLength);
finally
FreeMem(bufRecv,2000);
end;{of try}
bReadText:=true;
Socket.SendText(MP_NEXTWILLBEDATA);
end;
end;

Client程序:
放上以下控件:edtIPAddress,OpenDialog1,btnConnect,btnSendFile,
cs. (TClientSocket)

btnConnect.OnClick(Sender:TObject);
begin
cs.Address:=edtIPAddress.Text;
cs.Port:=2000;
cs.Connect;
end;

btnSendFile.OnClick(Sender:TObject);
begin
if OpenDialog1.Execute then
Begin
cs.Socket.SendText(MP_QUERY+OpenDialog1.FileName);//FileSize???
end;
end;

cs.OnRead(Sender: TObject;Socket: TCustomWinSocket);
var
sTemp:string;
bufSend:pointer;
begin
sRecv:=Socket.ReceiveText;
Case sRecv[1] of
MP_REFUSE:
ShowMessage(’Faint,be refused!’);
MP_ACCEPT:
begin
fsSend:=TFileStream.Create(OpenDialog1.FileName,fmOpen);
//iBYTEPERSEND是个常量,每次发送包的大小。
Socket.SendText(MP_FILEPROPERTY+Trunc(fsSend.Size/iBYTEPERSEND)+1);
end;
MP_NEXTWILLBEDATA:
begin
Socket.SendText(MP_NEXTWILLBEDATA);
end;
MP_DATA:
begin
try
GetMem(bufSend,iBYTEPERSEND+1);
if (fsSend.Position+1+iBYTEPERSEND) < fsSend.Size then
begin
fsSend.Read(bufSend^,iBYTEPERSEND);
Socket.SendBuf(bufSend^,iBYTEPERSEND);
fsSend.Free;
end//普通的发送,大小为iBYTEPERSEND
else begin
fsSend.Read(bufSend^,fsSend.Size-fsSend.Position-1);
Socket.SendBuf(bufSend^,fsSend.Size-fsSend.Position-1);
end;//最后一次发送,发送剩余的数据
finally
FreeMem(bufSend,iBYTEPERSEND+1);
end;{of try}
end;
MP_ABORT:
begin
//被取消了:(
fsSend.Free;
end;
end;{of case}
end;
 
强烈关注
 
怎么会呢?
你客->服已搞定,
那你服->客可用相同机制啊?
只要传送前发个判别字符判断一个传送方向不就行了吗?
 
谢谢各位了
 
多人接受答案了。
 
后退
顶部