Разговор по аське:
- Что замолчал?
- Пальцы устали.
Итак, рассмотрим механизм приема FLAP-пакетов. Прием пакетов - это обработчик события onReadData нашего ClientSocket. Задача этого обработчика сводится только к приему FLAP-пакетов и формировании из них связного списка типа FIFO (первым пришел, первым и ушел). Главное корректно отработать границы пакетов.
Каждый пакет принимается в два захода:
сначала принимаем только заголовок FLAP-пакета (всего 6 байт);
затем, узнав из заголовка длину блока данных, принимаем последний (ни байтом больше, ни байтом меньше).
Приняв полный пакет, формируем из него элемент списка FIFO и присоединяем его к списку. Смотрим, как это сделано у меня. Для прима заголовка и блока данных FLAP-пакета объявлены два массива: FLAP и FLAP_DATA соответственно.
procedure TForm1.CLI_ReadData(Sender:TObject; Socket:TCustomWinSocket);
var num,Bytes,fact : integer;
pFIFO,CurrFIFO : PFLAP_Item;
buf : array[0..100] of byte;
begin// узнаем, сколько всего данных уже есть в буфере ClientSocketa
num := Socket.ReceiveLength;
// в icq_Login мы установили isHdr, т.к. сначала ожидаем заголовокif isHDR thenbegin// если есть как минимум 6 байт, то читаем 6 байт заголовка в FLAPif num>=6 thenbegin
Socket.ReceiveBuf(FLAP,6);
// из заголовка узнаем длину блока данных FLAP-пакета
NeedBytes := swap(FLAP.Len);
// сбрасываем в начало индекс массива FLAP_DATAindex := 0;
// сбпасываем, чтобы следующее чтение было в FLAP_DATA// и выходим из обработчика
isHDR := false;
endelsebegin// вообще-то ситуация, когда в Sockete меньше 6-и байт// пока никак не контролируется (возникает очень редко :)// отмечаю этот факт только в окне отладки
M(Memo,'!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!');
Socket.ReceiveBuf(buf,num);
M(Memo,Dim2Hex(@(buf),num));
M(Memo,'!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!');
end;
// if not isHDR then чтение в FLAP_DATAendelsebegin// сколько байт читать уже известно: NeedBytes
Bytes := NeedBytes;
// читаем их в FLAP_DATA[Index]
fact := Socket.ReceiveBuf(FLAP_DATA[index],Bytes);
// если в Sockete было данных меньше чем нужно, // педвинем Index и NeedBytes для следующего входа в обработчик
inc(index,fact);
dec(NeedBytes,fact);
if NeedBytes = 0 thenbegin// если весь блок данных FLAP-пакета уже в FLAP_DATA,// тогда выделаем память для элемента списка FIFO (PFLAP_Item)
New(pFIFO);
// копируем заголовок
pFIFO^.FLAP := FLAP;
pFIFO^.Next := nil;
// выделяем память для блока данных и копируем его
GetMem(pFIFO^.DATA,index);
move(FLAP_DATA,PFIFO^.Data^,swap(FLAP.Len));
// добавляем указатель на PFLAP_Item в список
CurrFIFO:=HeadFIFO;
if HeadFIFO<>nilthenbeginwhile CurrFIFO<>nildoif CurrFIFO^.Next=nilthenbegin
CurrFIFO^.Next:=pFIFO;
break;
endelse CurrFIFO:=CurrFIFO^.Next;
endelse HeadFIFO:=pFIFO;
// устанавливаем isHDR (в true) уже для прима заголовка// последующих FLAP-пакетов
isHDR := true;
end;
end;
end;
Дальнейшая обработка списка FIFO - это задача уже другой процедуры.
Статья ICQ2000 сделай сам 3 раздела Интернет и Сети ICQ может быть полезна для разработчиков на Delphi и FreePascal.
Комментарии и вопросы
Материалы статей собраны из открытых источников, владелец сайта не претендует на авторство. Там где авторство установить не удалось, материал подаётся без имени автора. В случае если Вы считаете, что Ваши права нарушены, пожалуйста, свяжитесь с владельцем сайта.