Форум программистов [Powered by Invision Power Board]

Версия для печати темы
Нажмите сюда для просмотра этой темы в оригинальном формате

Форум программистов > Delphi: Сети > Размер принимающего буфера TTCPClient

Автор: TDelphi 30.9.2010, 23:06

Необходимо, используя компонент TCPClient, принять данные (байты, непечатаемые символы т.е. содержимое файла).
Если попытаться прочитать бОльшое количество байт, чем есть в буфере, то программа зависнет, в ожидании порции данных.
Отсюда вопрос: Как узнать какое количество данных пришло, которое можно прочитать?

Код


function TMyClass.GetFile(): TMemoryStream;
var
  TCP: TTCPClient;
  AStream: TMemoryStream;
  ABuffer: array of Byte;
  AIntSize: integer;
begin
  AStream := TMemoryStream.Create;
  TCP := TTCPClient.Create(nil);
  TCP.RemoteHost := FHost;
  TCP.RemotePort := FPort;
  TCP.Open;
  TCP.Sendln('GET_FILE --name="FILE.ZIP"');
  // Нужно задать переменную AIntSize
  SetLength(ABuffer, AIntSize);
  TCP.ReceiveBuf(ABuffer, SizeOf(ABuffer));
  AStream.WriteBuffer(ABuffer, AIntSize);
  TCP.Close;
  TCP.Free;
  Result := AStream;
end;

Автор: Matematik 1.10.2010, 13:06

Вообще-то ReceiveBuf не ждет, а сразу возвращает кол-во прочитанных байт.

Цитата(TDelphi @ 30.9.2010, 23:06

)

Как узнать какое количество данных пришло, которое можно прочитать?

ioctlsocket() + FIONREAD
recv() + MSG_PEEK

Автор: TDelphi 1.10.2010, 13:59

Цитата

Вообще-то ReceiveBuf не ждет, а сразу возвращает кол-во прочитанных байт.

При трассировке программа затыкается на этом месте.
Если читать через ReceiveBuf частями (например в цикле по 128 байт), то программа застопорится когда в буфере будет меньше данных, чем 128 байт.

Цитата

ioctlsocket() + FIONREAD
recv() + MSG_PEEK

Спасибо за новодку, но можно ли узнать размер стандартными средствами компонента?

UPD. Что делает команда PeekBuf?

Автор: Matematik 1.10.2010, 15:45

Цитата(TDelphi @ 1.10.2010, 13:59

)

При трассировке программа затыкается на этом месте.

Посмотри исходник, там цикла ожидания нет, только один вызов recv().

Цитата(TDelphi @ 1.10.2010, 13:59

)

PeekBuf

Тоже самое что и ReceiveBuf(), разница лишь в том PeekBuf не удаляет данные из буфера сокета

PS
читать надо так

Код


  AIntSize := TCP.ReceiveBuf(ABuffer[0], AIntSize);

Автор: TDelphi 1.10.2010, 17:08

Цитата

Посмотри исходник, там цикла ожидания нет, только один вызов recv().

Исходник чего?

Поставлю вопрос немного по другому: Почему зависает программа?

Автор: Matematik 1.10.2010, 17:30

Исходник TTCPClient в файле Sockets.pas

Код


function TBaseSocket.ReceiveBuf(var Buf; BufSize: Integer; Flags: Integer): Integer;
begin
  Result := ErrorCheck(recv(FSocket, Buf, BufSize, Flags));
  if Result <> SOCKET_ERROR then
    DoReceive(pchar(@Buf), Result);
end;

Нечему тут зависать.

Автор: Alca 1.10.2010, 17:41

Цитата

Нечему тут зависать.

есть чему

Код


Result := ErrorCheck(recv(FSocket, Buf, BufSize, Flags));

Автор: TDelphi 1.10.2010, 17:44

Цитата

Нечему тут зависать.

Хм, проверил еще раз - действительно не зависает. Спасибо.

А какой размер указывать, если изначально неизвестно сколько данных там?
Указать в AIntSize 999999 как-то не кошерно.

Автор: Alca 1.10.2010, 17:47

Цитата

Поставлю вопрос немного по другому: Почему зависает программа?

Цитата

действительно не зависает

Ну ты определись

Автор: TDelphi 1.10.2010, 18:01

Цитата

Ну ты определись

Код имел место зависать, когда была конструкция этого вида:

Код


while (true) do
begin
AIntSize := TCP.ReceiveBuf(ABuffer, 512);
if AIntSize <= 0 then break;
end;

Так как все таки узнать размер буфера?
Может есть сорцы, с реализацией на этом компоненте?

Код


TCP.ReceiveBuf(ABuffer[0], {Что здесь поставить? =)});

Автор: Matematik 1.10.2010, 19:00

Код


const
  bufsize = 1024;
  readtimeout = 1000;
var
  TCP: TTCPClient;
  ABuffer: array[0..bufsize-1] of AnsiChar;
  Stream: TStringStream;
  readsize: integer;
begin
  Stream := TStringStream.Create('');
  TCP := TTCPClient.Create(nil);
  TCP.RemoteHost := '127.0.0.1';
  TCP.RemotePort := '21';
  TCP.Open;
  while TCP.WaitForData(readtimeout) do
  begin
    readsize := TCP.ReceiveBuf(ABuffer[0], sizeof(ABuffer));
    if readsize > 0 then
    begin
      Stream.WriteBuffer(ABuffer[0], readsize);
    end
    else
    begin
      Break
    end;
  end;
  ShowMessage(stream.DataString);
end;

Добавлено через 3 минуты и 1 секунду

Цитата(Alca @ 1.10.2010, 17:41

)

есть чему

Кстати да.
Если в буфере сокета нет данных, recv() будет ждать получения.

Автор: TDelphi 1.10.2010, 19:39

Цитата

Кстати да.
Если в буфере сокета нет данных, recv() будет ждать получения.

Вооот!
А я уже скрин подготовил =)
http://ipicture.ru/Gallery/Viewfull/1384414.html

UPD. Может это компонент такой несуразный, что не позволяет стандартными средствами узнать кол-во байт?
Есть еще мысль, что нужно принимать через событие OnReceive(Sender: TObject; Buf: pchar; var DataLen: Integer);
Или получать сколько в буфере, через команду PeekBuf:

Код


  AIntSize := 2048;
  SetLength(ABuffer, AIntSize);
  while (true) do
    begin
    AReadSize := TCP.PeekBuf(TempBuf[0], AIntSize);
    if AReadSize > 0 then AStream.WriteBuffer(ABuffer[0], AReadSize)
    else break;
  end;

Просьба помочь!

Автор: Matematik 4.10.2010, 23:05

Цитата(TDelphi @ 1.10.2010, 19:39

)

Может это компонент такой несуразный, что не позволяет стандартными средствами узнать кол-во байт?

Похоже что не умеет.

Цитата

Или получать сколько в буфере, через команду PeekBuf:

Можно, но имхо изврат, во-первых надо иметь свой временный массив (буфер) больший чем данных в сокете, т.к. PeekBuf вернет кол-во записаных в TempBuf байт. Да еще потом придется вызывать ReceiveBuf() чтоб удалить данные из сокета. Получается два раза копировать одно и тоже.

А нужно ли знать кол0во байт?
Читаешь из сокета кусками, пишешь в стрим.