VPF::Размер принимающего буфера TTCPClient

TDelphi

Дата 30.9.2010, 23:06 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 8
Регистрация: 29.8.2010

Репутация: нет
Всего: нет

Необходимо, используя компонент 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 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 1027
Регистрация: 11.3.2006

Репутация: 24
Всего: 50

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

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

)

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

ioctlsocket() + FIONREAD
recv() + MSG_PEEK

TDelphi

Дата 1.10.2010, 13:59 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 8
Регистрация: 29.8.2010

Репутация: нет
Всего: нет

Цитата

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

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

Цитата

ioctlsocket() + FIONREAD
recv() + MSG_PEEK

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

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

Это сообщение отредактировал(а) TDelphi - 1.10.2010, 15:10

Matematik

Дата 1.10.2010, 15:45 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 1027
Регистрация: 11.3.2006

Репутация: 24
Всего: 50

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

)

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

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

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

)

PeekBuf

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

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

Код


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

Это сообщение отредактировал(а) Matematik - 1.10.2010, 15:56

TDelphi

Дата 1.10.2010, 17:08 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 8
Регистрация: 29.8.2010

Репутация: нет
Всего: нет

Цитата

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

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

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

Matematik

Дата 1.10.2010, 17:30 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 1027
Регистрация: 11.3.2006

Репутация: 24
Всего: 50

Исходник 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 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 3993
Регистрация: 14.6.2006

Репутация: 1
Всего: 50

Цитата

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

есть чему

Код


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

--------------------

C++ cross-platform library

TDelphi

Дата 1.10.2010, 17:44 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 8
Регистрация: 29.8.2010

Репутация: нет
Всего: нет

Цитата

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

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

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

Alca

Дата 1.10.2010, 17:47 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 3993
Регистрация: 14.6.2006

Репутация: 1
Всего: 50

Цитата

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

Цитата

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

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

--------------------

C++ cross-platform library

TDelphi

Дата 1.10.2010, 18:01 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 8
Регистрация: 29.8.2010

Репутация: нет
Всего: нет

Цитата

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

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

Код


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

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

Код


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

Это сообщение отредактировал(а) TDelphi - 1.10.2010, 18:07

Matematik

Дата 1.10.2010, 19:00 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 1027
Регистрация: 11.3.2006

Репутация: 24
Всего: 50

Код


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 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 8
Регистрация: 29.8.2010

Репутация: нет
Всего: нет

Цитата

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

Вооот!
А я уже скрин подготовил =)

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;

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

Это сообщение отредактировал(а) TDelphi - 1.10.2010, 20:46

Matematik

Дата 4.10.2010, 23:05 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 1027
Регистрация: 11.3.2006

Репутация: 24
Всего: 50

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

)

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

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

Цитата

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

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

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

Это сообщение отредактировал(а) Matematik - 4.10.2010, 23:06

1 Пользователей читают эту тему (1 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Delphi: Сети \| Следующая тема »