TserverSocket und TclientSocket

[Briand]

Hallo,

Ich bin mal wieder dabei mit delphi herumzuspielen. Im moment versuche ich mich an einem Dateitransfer mit server/client.

Ich benutze TServerSocket und TClientServer. Soweit funktioniert alles ganz gut.

Kleine Frage kommt aber auf.

Wenn ich eine Datei am runterladen bin dann reagiert mein Fenster nicht mehr bis der DL abgeschlossen ist.
Ich hab schon mit Google gesucht und Foren gefunden wo darauf hingewiesen wurde man solle das mit einem Thread machen.
Habe auch schon paar Thread beispiele angeschaut aber keines gefunden das Threading mit den Socket Komponenten erklährt.

hier ein Beispiel von meinem Server.

Delphi-Quellcode:

 
unit Unit1;

interface

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

type
  TForm1 = class(TForm)
    ImageList1: TImageList;
    memLog: TMemo;
    ServerSock: TServerSocket;
    TransferSock: TServerSocket;
    Button1: TButton;
    ProgressBar: TProgressBar;
    procedure ServerSockClientDisconnect(Sender: TObject;
      Socket: TCustomWinSocket);
    procedure ServerSockClientError(Sender: TObject;
      Socket: TCustomWinSocket; ErrorEvent: TErrorEvent;
      var ErrorCode: Integer);
    procedure ServerSockClientRead(Sender: TObject;
      Socket: TCustomWinSocket);
    procedure TransferSockClientRead(Sender: TObject;
      Socket: TCustomWinSocket);
    procedure FormCreate(Sender: TObject);
    procedure Button1Click(Sender: TObject);
  private
    { Private declarations }
    IncommingStream: TFileStream;
    Size: integer;
  public
    { Public declarations }
    TransferName: String;
  end;

var
  Form1: TForm1;

implementation

uses Unit6;

{$R *.dfm}


procedure TForm1.Button1Click(Sender: TObject);
begin
ServerSock.Socket.Connections[0].SendText('000' + 'c:\meinedatei.txt');
TransferName := 'meinedatei.txt';
end;

procedure TForm1.ServerSockClientDisconnect(Sender: TObject; Socket: TCustomWinSocket);
begin
memLog.Lines.Add(' .:: Client ' + Socket.RemoteAddress + ' Disconnected');
end;

procedure TForm1.ServerSockClientError(Sender: TObject; Socket: TCustomWinSocket; ErrorEvent: TErrorEvent; var ErrorCode: Integer);
begin
memLog.Lines.Add(' .:: Error ' + IntToStr(ErrorCode));
end;

procedure TForm1.ServerSockClientRead(Sender: TObject;Socket: TCustomWinSocket);
var
  ReceivedText, cmd, data: string;
  i: integer;
  Item: TListItem;
  StrLst: TStringList;
begin
  ReceivedText := Socket.ReceiveText;
  cmd := Copy(ReceivedText, 0, 3);
  data := Copy(ReceivedText, 4, Length(ReceivedText));

  if cmd = '000' then
  begin
    memLog.Lines.Add(data);
  end;

  if cmd = '001' then
  begin
    memLog.Lines.Add(' .:: Client connected: ' + data + ' on ' + socket.RemoteAddress);
  end;

  if cmd = '002' then
  begin
    Size := StrToInt(Data);
    Form1.ProgressBar.Min := 0;
    Form1.ProgressBar.Max := Size;
    memLog.Lines.Add(' .:: Receiving file of size ' + Data + ' bytes');
    IncommingStream := TFileStream.Create(Form1.TransferName, fmCREATE or fmOPENWRITE and fmsharedenywrite);

    TransferSock.Open;
  end;

end;

procedure TForm1.TransferSockClientRead(Sender: TObject;
  Socket: TCustomWinSocket);

  var
  Buffer: array [0..9999] of Char;
  IncommingLen, RecievedLen: integer;

  begin

  IncommingLen := socket.ReceiveLength;

  while IncommingLen > 0 do
  begin
    RecievedLen := socket.ReceiveBuf(Buffer, Sizeof(Buffer));

    if RecievedLen <= 0 then
      Break
    else
      IncommingStream.Write(Buffer, RecievedLen);

    Form1.ProgressBar.StepBy(RecievedLen);

    if IncommingStream.Size >= Size then
    begin
      IncommingStream.Free;
      ServerSock.Socket.Connections[0].SendText('002');
      Form1.ProgressBar.Position := 0;
      if Form1.TransferName = 'Desktop.bmp' then;
      Break;
    end;
  end;
end;

procedure TForm1.FormCreate(Sender: TObject);
begin
memLog.Lines.Add('Listening on Port ' + '21');
ServerSock.Port := 21;
ServerSock.Open;
end;

end.

Bin für jede Hilfe dankbar oder auch kleine Beispile.

Danke im Vorraus
Briand

[Medium]

Willkommen in der DP!

1) Quellcode bitte immer in [ delphi] [ /delphi] Tags (ohne Leerzeichen) einschließen, dadurch wird der ordentlich formatiert und erheblich lesbarer.

2) Wo ist hier der Thread?

3) Was genau ist dein Problem bzgl. Threads?

[Briand]

Danke Medium für die Info mit dem [ delphi] [ /delphi] Tags

Also da ist mom noch kar kein Thread drin da ich mom nicht weis wie ich das da anstellen soll.
Mein Problem ist ja wie gesagt das eben meine Form beim Dateitransfer einfriert bis der Transfer abgeschlossen ist.

Wo und wie ich da den Thread machen soll ist mir noch schleierhaft.

Denke mal beim ServerOnRead weil ja sobald der socket daten empfängt die Form erst einfriet.

[sx2008]

Du musst einfach nur die markierte Zeile einfügen.
Ausserdem solltest du innerhalb der Klasse TForm1 niemals auf Form1 referenzieren.
Lass das Form1 einfach weg.

Delphi-Quellcode:

procedure TForm1.TransferSockClientRead(Sender: TObject;
  Socket: TCustomWinSocket);
var
  Buffer: array [0..9999] of Char;
  IncommingLen, RecievedLen: integer;
begin
...
    ProgressBar.StepBy(RecievedLen);
    Application.ProcessMessages;   // <== neue Zeile
...
end;

Zusätzlich solltest du verhindern, dass wenn ein Download läuft, der Benutzer einen weiteren Download starten kann.
Dazu einfach das Property Enabled des Button auf False setzen.

[Bummi]

Ich hatte das seinerzeit wenn ich mich recht entsinne mit einem Thread gelöste dem der Socket mitgegeben wurde. Der Code liegt leider in einer VM in der Firma, aber vielleicht helfen folgende Links weiter
http://www.marcocantu.com/code/md6ht...erDbThread.htm
http://www.delphipraxis.net/144300-a...em-thread.html

[Briand]

Zitat von sx2008:

Du musst einfach nur die markierte Zeile einfügen.
Ausserdem solltest du innerhalb der Klasse TForm1 niemals auf Form1 referenzieren.
Lass das Form1 einfach weg.

Delphi-Quellcode:

procedure TForm1.TransferSockClientRead(Sender: TObject;
  Socket: TCustomWinSocket);
var
  Buffer: array [0..9999] of Char;
  IncommingLen, RecievedLen: integer;
begin
...
    ProgressBar.StepBy(RecievedLen);
    Application.ProcessMessages;   // <== neue Zeile
...
end;

Zusätzlich solltest du verhindern, dass wenn ein Download läuft, der Benutzer einen weiteren Download starten kann.
Dazu einfach das Property Enabled des Button auf False setzen.

Danke sx2008

Habe die Zeie

Application.ProcessMessages;

mal da eingefügt wie Du gesagt hast. Leider bekomme ich dann einen 10053 Socketfehler.

[Aphton]

Delphi-Quellcode:

procedure TForm1.ServerSockClientRead(Sender: TObject;Socket: TCustomWinSocket);
var
  ReceivedText, cmd, data: string;
  i: integer;
  Item: TListItem;
  StrLst: TStringList;
begin
  ReceivedText := Socket.ReceiveText;
  cmd := Copy(ReceivedText, 0, 3);
  data := Copy(ReceivedText, 4, Length(ReceivedText));

  if cmd = '000' then
  begin
    memLog.Lines.Add(data);
  end;

  if cmd = '001' then
  begin
    memLog.Lines.Add(' .:: Client connected: ' + data + ' on ' + socket.RemoteAddress);
  end;

In den folgenden zwei Zeilen steckt ein fataler Fehler:

Delphi-Quellcode:

  ReceivedText := Socket.ReceiveText;
  cmd := Copy(ReceivedText, 0, 3);
  data := Copy(ReceivedText, 4, Length(ReceivedText));

Denn du gehst davon aus, dass immer genausoviel ankommt, wie auch gesendet wird. Das muss aber nicht sein.

Wenn du 10 Bytes an Daten (seien wir mal minimalistisch, da es einfacher zum Erklären ist) schicken willst, und vorhast, diese jeweils in 5 Byte Paketen zu schicken mit 3 Bytes "cmd", dann müssten immer 5 Bytes kommen bei ReceiveText.
Das ist aber nicht der Fall. Lokal wird das problemlos gehen, denn da müssen die Pakete nicht so häufig fragmentiert werden und können wirklich in abgeschickter Größe ankommen.. (kann aber auch hier passieren)
Über das Internet wird es so sein, dass zB. zuerst 2 Bytes kommen, dann evt 1 Byte, dann ne Zeit lang nichts, dann plötzlich 7 usw..

Dh du musst ein anderes System verwenden. Puffere die Daten in nen Stream, wenn du ne bestimmte Größe empfangen hast, liest du deine "Cmd" aus und schaust, ob der Datenteil lang genug ist um damit etwas anfangen zu können. Anschließend löscht du aus diesem Puffer dieses "Paket" (= Cmd + Daten)

[Briand]

hmmmm also irgendwie krig ich das nicht hin
was mach ich da blos falsch ?

[Jumpy]

Hallo,

lese dir doch mal die 2-3 Tutorials zu Netzwerkprotokollen von Narses durch. Hat hier neulich mal jemand verlinkt und ich fand die recht informativ:

http://www.entwickler-ecke.de/topic_...s_54269,0.html

[Furtbichler]

Zitat von Aphton:

In den folgenden zwei Zeilen steckt ein fataler Fehler:

Delphi-Quellcode:

  ReceivedText := Socket.ReceiveText;
  cmd := Copy(ReceivedText, 0, 3);
  data := Copy(ReceivedText, 4, Length(ReceivedText));

Seit wann sind Delphi-Strings 0-basiert?

Die Pufferung geht im Prinzip so:

Delphi-Quellcode:

  ReceivedText := Socket.ReceiveText;
  fBuffer := fBuffer + ReceivedText;
  if CompleteCommandInBuffer (fBuffer) Then begin
     myCommand := ExtractCommandStructureFromBuffer (fBuffer);
     fBuffer := RemoveCommandDataFromBuffer (fBuffer);
     myCommandResult := ProcessCommand (myCommand);
     myCommandResult.SendAnswer(Socket); // Nur nötig, wenn das Kommando bestätigt werden muss
  end

Problem hierbei: Während das Kommando ausgeführt wird, sind keine weiteren Operationen möglich. Das wäre ok, sofern ein query-response implementiert wird.