开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Delphi控件源码 > 查看源码
ClientThread.pas
资源名称：delphi.rar　[点击查看]
上传用户：fh681027
上传日期：2022-07-23
资源大小：1959k
文件大小：3k
源码类别：

Delphi控件源码

开发平台：

Delphi

ClientThread.pas：源码内容
  1. unit ClientThread;
  3. interface
  5. uses
  6.   Classes, ScktComp, DBTables;
  8. type
  9.   TLogEvent = procedure(Sender: TObject; LogMsg: String) of object;
  11.   TSendThread = class(TThread)
  12.   private
  13.     ClientSocket: TClientSocket;
  14.     FTable: TTable;
  15.     FOnLog: TLogEvent;
  16.     FLogMsg: String;
  17.     FServerAddress: string;
  18.     procedure SetOnLog(const Value: TLogEvent);
  19.     procedure SetServerAddress(const Value: string);
  20.   protected
  21.     procedure Execute; override;
  22.     procedure DoLog;
  23.   public
  24.     constructor Create(ATable: TTable);
  25.     property OnLog: TLogEvent read FOnLog write SetOnLog;
  26.     property ServerAddress: string read FServerAddress write SetServerAddress;
  27.   end;
  29. implementation
  31. uses
  32.   ClientForm;
  34. constructor TSendThread.Create(ATable: TTable);
  35. begin
  36.   FTable := ATable;
  37.   inherited Create(True);
  38.   FreeOnTerminate := True;
  39. end;
  41. procedure TSendThread.DoLog;
  42. begin
  43.   if Assigned(FOnLog) then
  44.     FOnLog(self, FLogMsg);
  45. end;
  47. procedure TSendThread.Execute;
  48. var
  49.   I: Integer;
  50.   Data: TStringList;
  51.   Stream: TWinSocketStream;
  52.   Buf: String;
  53. begin
  54.   try
  55.     Data := TStringList.Create;
  56.     ClientSocket := TClientSocket.Create (nil);
  57.     Stream := nil;
  58.     try
  59.       ClientSocket.Address := ServerAddress;
  60.       ClientSocket.ClientType := ctBlocking;
  61.       ClientSocket.Port := 51;
  62.       ClientSocket.Active := True;
  63.       Stream := TWinSocketStream.Create(ClientSocket.Socket, 30000);
  65.       FTable.First;
  66.       while not FTable.Eof do
  67.       begin
  68.         // if the record is still not logged
  69.         if FTable.FieldByName('CompID').IsNull or (FTable.FieldByName('CompID').AsInteger = 0) then
  70.         begin
  71.           FLogMsg := 'Sending ' + FTable.FieldByName('Company').AsString;
  72.           Synchronize(DoLog);
  73.           Data.Clear;
  74.           // create strings with structure "FieldName=Value"
  75.           for I := 0 to FTable.FieldCount - 1 do
  76.             Data.Values [FTable.Fields[I].FieldName] :=
  77.               FTable.Fields [I].AsString;
  78.           // send the record
  79.           Buf := Data.Text + #10#13'.'#10#13;
  80.           ClientSocket.Socket.SendText(Buf);
  81.           // wait for reponse
  82.           if Stream.WaitForData(30000) then
  83.           begin
  84.             FTable.Edit;
  85.             SetLength(Buf, 256);
  86.             SetLength(Buf, Stream.Read(Buf[1], Length(Buf)));
  88.             FTable.FieldByName('CompID').AsString := Buf;
  89.             FTable.Post;
  90.             FLogMsg := FTable.FieldByName('Company').AsString +
  91.               ' logged as ' + FTable.FieldByName('CompID').AsString;
  92.           end
  93.           else
  94.             FlogMsg := 'No response for ' + FTable.FieldByName('Company').AsString;
  95.           Synchronize(DoLog);
  96.         end;
  97.         FTable.Next;
  98.       end;
  99.     finally
  100.       ClientSocket.Active := False;
  101.       ClientSocket.Free;
  102.       Stream.Free;
  103.       Data.Free;
  104.     end;
  105.   except
  106.     // trap exceptions
  107.   end;
  108. end;
  110. procedure TSendThread.SetOnLog(const Value: TLogEvent);
  111. begin
  112.   FOnLog := Value;
  113. end;
  115. procedure TSendThread.SetServerAddress(const Value: string);
  116. begin
  117.   FServerAddress := Value;
  118. end;
  120. end.