TCPServer и TCPClient - как работать?

[3D Hunter]

Здравствуйте, коллеги. Такой вопрос: как работать с этими компонентами в блокирующем многопоточном режиме? Инфы в инете перерыл море, кругом вода и полезного мизер.
Вот код, который я мучаю. Здесь есть клиент, отсылающий каждую секунду пакет данных. Если ответа от сервера не приходит, он пишет данные в черный ящик, и только когда пришел ответ от сервера о получении, то клиент сбрасывает все содержимое ящика.
http://3dh.nm.ru/0.rar

Люди, подскажите или киньте ссылки на их использование. Пожалуйста! Очень нужно!

[3D Hunter]

Люди, ну если неохота код шарить, хоть линками ткните мне про эти компоненты или книги, где про них есть хоть что-нить. Хочу построить клиент-сервер именно на них, ибо знаю, что вещь мощная и можно с лихвой обойтись без винсока

[3D Hunter]

ладно, тогда конкретные вопросы. Говорю сразу: TCPClient в режиме bmBlocking, TCPServer - bmBlockThreading.
1) как корректно завершить сервер, разорвав все потоки соединения? Просто TCPServer.Close в событии вормы onDestroy?
2) у клиента в тайсере идет передача и прием данных. Сначала клиент получает данные от сервера. И если получена строка-сигнал, то клиент отправляет дальше в этом же таймере, т.е. здесь вызовы ReciveLn и SendLn
код:

procedure TFAGEmul.timer_sendTimer(Sender: TObject);
begin
  timer_send.Enabled:=False;
  BBPacket:=tcp_Autograph.Receiveln;
  Application.ProcessMessages;
  if BBPacket='d' then
  begin
    tcp_AutographDisconnect(Application);
    Application.ProcessMessages;
    Exit;
  end;
  AllowSend:=BBPacket=AuReceive;}
  if BlackBox=#0 then BlackBox:=AuFullPacket
  else BlackBox:=BlackBox+AuPartPacket;
  if AllowSend then
  begin
    AllowSend:=False;
    tcp_Autograph.Sendln(BlackBox);
    Application.ProcessMessages;
    BlackBox:=#0;
  end;
  mm_box.Text:=BlackBox;
  timer_send.Enabled:=True;
end;

[mss]

> Просто TCPServer.Close в событии вормы onDestroy?

TCPServer.Free;

Но следует принять алгоритмические меры к тому чтобы треды клиентских соединений максимально оперативно реагировали на флаг Terminated.

[3D Hunter]

хорошо, более подробно.
Такой код будет корректен?

procedure TFParser.FormCreate(Sender: TObject);
begin
  MaxDev:=1;
  DevCount:=0;
  tcp_parser.Open;
end;
procedure TFParser.FormDestroy(Sender: TObject);
var i:Integer;
begin
  for i:=0 to tcp_parser.ServerSocketThread.ThreadPool.Count-1 do
  TAuThread(tcp_parser.ServerSocketThread.ThreadPool[i]^).Terminate;
  while tcp_parser.ServerSocketThread.ThreadPool.Count<>0 do Sleep(55);
  tcp_parser.Close;
end;

procedure TFParser.tcp_parserGetThread(Sender: TObject;
  var ClientSocketThread: TClientSocketThread);
begin
  ClientSocketThread:=TAuThread.Create(tcp_parser.ServerSocketThread);
  ClientSocketThread.FreeOnTerminate:=True;
  ClientSocketThread.Priority:=tpLowest;
end;

procedure TFParser.tcp_parserAccept(Sender: TObject;
  ClientSocket: TCustomIpClient);
begin
  with (ClientSocket.GetThreadObject as TAuThread) do
  begin
    atPacket:='c';
    ExecuteSyncProc;
    while not Terminated do
    begin
      atPacket:=ClientSocket.Receiveln;
      Application.ProcessMessages;
      if atPacket<>'c' then ExecuteSyncProc;
    end;
  end;
end;

procedure TAuThread.SyncProc;
begin
  if atPacket='c' then//connect
  begin
    Inc(DevCount);
    FParser.status_dev.SimpleText:='Connected Devices: '+IntToStr(DevCount);
    Application.ProcessMessages;
  end;
  if atPacket='d' then//disconnect
  begin
    Terminate;
    Dec(DevCount);
    FParser.status_dev.SimpleText:='Connected Devices: '+IntToStr(DevCount);
    Application.ProcessMessages;
  end;
  if atPacket[1]='#' then
  begin
    FParser.Memo1.Lines.Add(atPacket);
    Application.ProcessMessages;
  end
end;

проверил, закрывается тихо, без ошибок. Кто что думает?

[3D Hunter]

Не, ну так не пойдет. Народ, не спим. Первый вопрос остается в силе.
Теперь о втором вопросе. Код, представленный во 2м посте, заставляет приложение сдохнуть. Оно подвисает и ниуя не делает. Есть предположение, что после приема ReceiveLn клиент не может отослать данные. Может использовать свойство Receiving? Т.е. проверять вайлом, пока клиент в режиме приема, то нельзя отсылать пакеты. Или я не прав и на блокирующие сокеты это свойство не пашет?

Исходники в первом посте. Ссылка прямая. Жду подсказок и советов. Пожалуйста

Кстати, Свойство TCPServer.Close заставляет умереть переменную касса TServerSocketThread. Но не факт, что при уничтожении этого потока уничтожатся все его нити-сокеты. По крайней мере, в коде vcl такого не нашел

[mss]

procedure TFParser.tcp_parserAccept(Sender: TObject;
ClientSocket: TCustomIpClient);
begin
.. Application.ProcessMessages;


Это что за ересь ?
Какого черта ты в доп.треде обращаешься к потоконебезопасному объекту Application ?

> Свойство TCPServer.Close заставляет умереть переменную касса TServerSocketThread.

Не "умереть", а "разрушить объеат классаTServerSocketThread, ссылка на который хранится в приватном поле объекта".


> не факт, что при уничтожении этого потока уничтожатся все его нити-сокеты

Не факт. Особенно если поточные процедуры нитей реализованы криво.

[3D Hunter]

к примеру, каждый сокетный поток должен записывать всю приходящую информацию в текстовый файл. Проблема возникает при выходе из программы. Метод TCPServer.ClearThreadPool сигнализирует всем потокам, что пора завершаться, и каждый поток не дописывает пришедший последний пакет до конца в файл, а только часть! Но ведь свойство Terminated проверяется в цикле, а этот метод устанавливает его в тру. А в цикле как раз и происходит запись в файл. Вроде должно все записываться.
mss, если вы знаете решение этой проблемы, укажите пожалуйста в приведенном коде на мои ошибки. А так только критикуете.
Про Application.ProcessMessages учту.

[mss]

> свойство Terminated проверяется в цикле

Оно у тебя проверяется до/после блокирующего вызова ReceiveLn(), так что ничто не мешает после обнаружения Terminated = True прервать цикл с опросом флага Terminated и ДО выхода из поточной процедуры "дочитать" остаток доступной для чтения инф-ции циклическим вызовом ReceiveLn(), пока он не вернет пустую строку.

Хотя здесь ждет засада - партнер по инф.обмену на другом конце соединения может уйти "покурить" на неопред.время, не разорвав соединение и не послав терминатор строки, что приведет к блокировке принимающего сокетного потока сервера на очер.вызове ReceiveLn на неопред.время. Что, в свою очередь, сделает невозможным корректное завершение работы TCPServer в ожидаемое время.

[3D Hunter]

патртнер по соединению - прибор, посылающий пакет раз в секунду и ждущий ответа сервера определенной строки 'ACCEPT r/n/'. Если прибор не получает подтверждения более 2 мин, то разрывает связь, после чего через 5мин стучится заново. При этом за время оффлайна он копит все данные приходящие раз в секунду. Т.е. при следующем соединении он перешлет инфу 1м пакетом за 7 мин.