具体要求:用ClientSocket和ServerSocket来实现。
或用IdTCPClient和IdTCPServer1来实现。
如果两者都有给足200分。发至 收到后马上给分。
或用IdTCPClient和IdTCPServer1来实现。
如果两者都有给足200分。发至 收到后马上给分。
解决方案 »
- win2003上dcom拒绝访问! 急
- 关于定时器运行一段时间后,程序反应很慢的问题。
- 【求助】尚未调用CoInitialize的错误怎么恢复?
- 请问大侠:我用的是microsoft jet 4.0 ole db provider连接方式,如何动态设置运行路径!
- 关于TxDBGrid控件
- delph+SQL Server2000,增加入库单如何实现库存的实时更新?
- 如何获取类成员函数入口地址
- 百思不得其解的问题,关于TRegistry和webservice
- 求助!怎样不能DBGRID上的记录显示出来!
- 可执行文件的图标可以更改么?
- delphi如何将dbchart生产的图像输出为bmp或jpg格式啊?!
- 不知道DELPHI能不能做关于硬件方面的东西
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;
整理程序:
加入错误判断,优化程序,把Server和Client联合在一起,加入剩余时间进度显示,做成能一次传多个文件,加入聊天功能,就成了一个很好的点对点传文件的程序
Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
Dialogs, ScktComp, StdCtrls;type
TForm1 = class(TForm)
CheckBox1: TCheckBox;
ServerSocket1: TServerSocket;
procedure CheckBox1Click(Sender: TObject);
procedure ServerSocket1Accept(Sender: TObject;
Socket: TCustomWinSocket);
private
{ Private declarations }
public
{ Public declarations }
end;var
Form1: TForm1;implementation{$R *.dfm}procedure TForm1.CheckBox1Click(Sender: TObject);
begin
ServerSocket1.Active:=checkbox1.Checked;
end;procedure TForm1.ServerSocket1Accept(Sender: TObject;
Socket: TCustomWinSocket);
var
nid:integer;
nsize:integer;
n:integer;
p:pbyte;
data:Tmemorystream;
begin
data:=Tmemorystream.Create;
getmem(p,8192);
try
if(socket.ReceiveBuf(nid,sizeof(nid))<>sizeof(nid)) then
raise exception.Create('');
if((socket.ReceiveBuf(nsize,sizeof(nsize))<>sizeof(nsize))or(nsize<=0)) then
raise Exception.Create(''); while(nsize>0) do
begin
n:=nsize;
if(n>8192) then
n:=8192;
n:=socket.ReceiveBuf(p^,n);
if(n<=0) then
raise exception.Create('');
data.Write(p^,n);
dec(nsize,n);
end; data.SaveToFile('e:\test'2Binttostr(nid)+'.data');
except
end;
freemem(p);
data.Free;
end;end.--------------------------------------------------------------------------------unit Unit1;interfaceuses
Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
Dialogs, ScktComp, Buttons, StdCtrls, ExtCtrls;type
TForm1 = class(TForm)
Edit1: TLabeledEdit;
Edit2: TLabeledEdit;
SpeedButton1: TSpeedButton;
ClientSocket1: TClientSocket;
procedure SpeedButton1Click(Sender: TObject);
private
{ Private declarations }
public
{ Public declarations }
end;var
Form1: TForm1;implementation{$R *.dfm}procedure TForm1.SpeedButton1Click(Sender: TObject);
var
nid:integer;
data:Tmemorystream;
nsize:integer;
n:integer;
p:pbyte;
begin
data:=Tmemorystream.Create;
try
nid:=strtoint(edit1.Text);
data.LoadFromFile(edit2.Text);
with clientsocket1 do
begin
open;
if(socket.SendBuf(nid,sizeof(nid))<>sizeof(nid)) then
raise exception.Create('sending id error');
nsize:=data.Size;
if(socket.SendBuf(nsize,sizeof(nsize))<>sizeof(nsize)) then
raise exception.Create('sending data size error');
p:=data.Memory;
while(nsize>0) do
begin
n:=nsize;
if(n>8192) then n:=8192;
n:=socket.SendBuf(p^,n);
if(n<=0) then raise exception.Create('sending data error');
inc(p,n);
dec(nsize,n);
end;
close;
end;
except
on e:exception do
showmessage(e.Message);
end;
data.Free;
end;end.
我只会瞎说