Delphi7:TServerSocket - скорость передачи

[Air]

Доброго времени суток.
На базе TServerSocket и TClientSocket создано простейшее приложение Клиент-Сервер.
Передаём файл в 200Мб одним потоком.
Клиент и Сервер находятся на одном компьютере.
Через Файрвол смотрю скорость; она с 20Мб/с плавно падает до 200Кб/с
Почему?
Как управлять скоростью? (если это возможно)
Или как удерживать скорость на каком-то одном значении?

[Slym]

без кода никак... может у тебя processmessages после каждого чиха

[Air]

Server

procedure TForm1.ServerSocket1ClientRead(Sender: TObject;
  Socket: TCustomWinSocket);
var
  ms:TMemoryStream;
begin
if Socket.ReceiveText='send' then
 begin
  ms:=TMemoryStream.Create;
  try
   ms.LoadFromFile('C:\123.exe');
   ms.Position:=0;
   Socket.SendText(IntToStr(ms.Size)+#0);
   Socket.SendStream(ms);
  except
   ms.Free;
  end;
 end;
end;

Client

procedure TForm1.ClientSocket1Connect(Sender: TObject; 
  Socket: TCustomWinSocket); 
begin
Socket.SendText('send');
end;

procedure TForm1.ClientSocket1Read(Sender: TObject;
  Socket: TCustomWinSocket);
var
  s, sl: string;
begin
s:= Socket.ReceiveText;
if not Reciving then
 begin
  SetLength(sl,StrLen(PChar(s))+1);
  StrLCopy(@sl[1],PChar(s),Length(sl)-1);
  DataSize:=StrToInt(sl);
  Data:=TMemoryStream.Create;
  Delete(s,1,Length(sl));
  Reciving:=true;
 end;

try
 Data.Write(s[1],length(s));
 if Data.Size=DataSize then
  begin
   Data.Position:=0;
   data.SaveToFile('D:\123.exe');
   Data.Free;
   Reciving:=false;
   Socket.Close;
  end;
except
 Data.Free;
end;

end;

Этот метод передачи взят с просторов нэта давным давно, использую во многих своих программах, но на больших объёмах видимо не подходит...

[Slym]

Забудь ReceiveText!

клиент и сервер в блоке, качается 3 сек

unit Unit1;

interface

uses
  Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
  Dialogs, ScktComp, StdCtrls;

type
  TForm1 = class(TForm)
    ServerSocket1: TServerSocket;
    ClientSocket1: TClientSocket;
    Button1: TButton;
    Button2: TButton;
    procedure FormCreate(Sender: TObject);
    procedure Button2Click(Sender: TObject);
    procedure ServerSocket1GetThread(Sender: TObject;
      ClientSocket: TServerClientWinSocket;
      var SocketThread: TServerClientThread);
  private
    { Private declarations }
  public
  end;

var
  Form1: TForm1;

implementation

{$R *.dfm}

type
  TMySocketThread=class(TServerClientThread)
  protected
    procedure ClientExecute; override;
  end;

{ TMySocketThread }

procedure TMySocketThread.ClientExecute;
var
  s:string;
  Stream:TFileStream;
begin
  SetLength(s,256);
  SetLength(s,ClientSocket.ReceiveBuf(s[1],length(s)));
  if s<>'send' then exit;
  Stream:=TFileStream.Create('d:\notes_v_.rar',fmOpenRead);
  ClientSocket.SendText(IntToStr(Stream.Size)+#0);
  ClientSocket.SendStream(Stream);
end;

procedure TForm1.ServerSocket1GetThread(Sender: TObject;
  ClientSocket: TServerClientWinSocket;
  var SocketThread: TServerClientThread);
begin
  SocketThread:=TMySocketThread.Create(false,ClientSocket);
end;

procedure TForm1.FormCreate(Sender: TObject);
begin
  ServerSocket1.Active:=true;
end;

procedure TForm1.Button2Click(Sender: TObject);
var
  Socket: TClientSocket;
  s,sl:string;
  DataSize:integer;
  Data:TFileStream;
  t:dword;
begin
  t:=GetTickCount;
  Socket:=TClientSocket.Create(nil);
  try
    Socket.ClientType:=ctBlocking;
    Socket.Host:='127.0.0.1';
    Socket.Port:=3333;
    Socket.Open;
    Socket.Socket.SendText('send');

    SetLength(s,256);
    SetLength(s,Socket.Socket.ReceiveBuf(s[1],length(s)));
    SetLength(sl,StrLen(PChar(s))+1);

    StrLCopy(@sl[1],PChar(s),Length(sl)-1);
    DataSize:=StrToInt(sl);
    Delete(s,1,Length(sl));

    Data:=TFileStream.Create('d:\notes_v_.rar___',fmCreate);
    try
      Data.WriteBuffer(s[1],length(s));
      SetLength(s,1024*16);
      while Data.Size<DataSize do
        Data.WriteBuffer(s[1],Socket.Socket.ReceiveBuf(s[1],length(s)));
    finally
      Data.Free;
    end;
  finally
    Socket.Free;
  end;
  t:=GetTickCount-t;
  Application.MessageBox(PChar(IntToStr(t)),'',0);
end;

end.

[Air]

Slym
Ух ты)
Стабильно на 9-12 Мб/с в три прихода передал 209Мб. Благодарю за предоставленный метод.
Никогда не задумывался о типе ctBlocking в чём отличие?

_
ThreadCacheSize установил в 512, так скорость вообще 32Мб/с была))

[Slym]

Сообщение от Air

Slym
Ух ты)
Стабильно на 9-12 Мб/с в три прихода передал 209Мб. Благодарю за предоставленный метод.
Никогда не задумывался о типе ctBlocking в чём отличие?

_
ThreadCacheSize установил в 512, так скорость вообще 32Мб/с была))

твоя скорость соответствует 100мбит...
ThreadCacheSize оставь в покое... это кеш созданных TMySocketThread (чтоб не пересоздавать постоянно) и должно примерно равняться среднему количеству одновременных подключений по дефолту 10 что достаточно, а зачастую даже избыточно

[Air]

Slym
Ммм, ясно, значит случайное совпадение.