I want to make a server/client application which transfer files using TCP protocol. I start with Indy library and, first I made my own protocol (because I need a progress feedback on the file transferred), and the transfer speed does not rise more than 2 MB/s. My internet bandwidth is 10 MB/s. I tried on a different ISP, the same thing... I can't get more than 2-3 MB/s. I thought maybe my protocol was to blame. Then I did as Remy recommended me in another question, with file streams. And the transfer speed is still unchanged. What happens ? Am I doing something wrong ? Is there some known limitation of Indy library, that it cannot use the whole network bandwidth ? Has anyone experienced this problem before ? I am using Indy from Delphi 10.3 Rio and Windows 10.
unit Unit1;
interface
uses
Winapi.Windows, Winapi.Messages, System.SysUtils, System.Variants, System.Classes, Vcl.Graphics,
Vcl.Controls, Vcl.Forms, Vcl.Dialogs, Vcl.StdCtrls, IdTCPConnection,
IdTCPClient, IdBaseComponent, IdComponent, IdCustomTCPServer, IdTCPServer,
IdContext, IdThreadComponent;
const
WM_LOGEVENT = WM_USER + 1;
type
TForm1 = class(TForm)
Server: TIdTCPServer;
Client: TIdTCPClient;
BStartServer: TButton;
ClientWriteThread: TIdThreadComponent;
Memo: TMemo;
BSendCommand: TButton;
ClientReadThread: TIdThreadComponent;
procedure BStartServerClick(Sender: TObject);
procedure ServerExecute(AContext: TIdContext);
procedure ClientWriteThreadRun(Sender: TIdThreadComponent);
procedure FormCreate(Sender: TObject);
procedure BSendCommandClick(Sender: TObject);
private
procedure LogEvent(var Msg: TMessage); message WM_LOGEVENT;
procedure SendEvent(const Msg: String);
end;
var
Form1: TForm1;
implementation
{$R *.dfm}
uses System.Diagnostics;
procedure TForm1.LogEvent(var Msg: TMessage);
var PStr: PString;
begin
PStr:= PString(Msg.WParam);
Memo.Lines.Add(Copy(PStr^, 1, Length(PStr^)));
end;
procedure TForm1.SendEvent(const Msg: String);
begin
SendMessage(Handle, WM_LOGEVENT, WPARAM(@Msg), 0);
end;
procedure TForm1.FormCreate(Sender: TObject);
begin
Server.Bindings.Clear;
Server.Bindings.Add.SetBinding('192.168.0.3', my_port);
Client.Host:= 'my domain here';
Client.Port:= my_port;
end;
procedure TForm1.BSendCommandClick(Sender: TObject);
begin
ClientWriteThread.Start;
end;
procedure TForm1.ClientWriteThreadRun(Sender: TIdThreadComponent);
var Cmd: Cardinal;
Strm: TFileStream;
Timer: TStopWatch;
Size: Int64;
begin
Timer:= TStopWatch.Create;
Client.Connect;
Client.IOHandler.LargeStream:= True;
Strm:= TFileStream.Create('G:\test.mp4', fmCreate);
Cmd:= 1234;
SendEvent('Start file transfer');
Client.IOHandler.Write(Cmd);
Timer.Start;
Client.IOHandler.ReadStream(Strm, -1, False);
Size:= Strm.Size;
Strm.Free;
SendEvent('Stop file transfer: '+FloatToStr((Size / Timer.ElapsedTicks) * 10)+' MB/s');
Sender.Terminate;
end;
procedure TForm1.BStartServerClick(Sender: TObject);
begin
Server.Active:= True;
Caption:= IntToStr(Byte(Server.Active));
end;
procedure TForm1.ServerExecute(AContext: TIdContext);
var FileStream: TFileStream;
begin
AContext.Connection.IOHandler.ReadUInt32;
FileStream:= TFileStream.Create('D:\test.mp4', fmOpenRead or fmShareDenyWrite);
AContext.Connection.IOHandler.LargeStream:= True;
AContext.Connection.IOHandler.Write(FileStream, 0, True);
end;
end.