Delphi 2009, Indy 10, TIdTCPServer.OnExecute, cómo capturar todos los bytes en InputBuffer

delphi-2009

Question

Estoy jugando con el Indy 10 suministrado con Delphi 2009 y tengo problemas para obtener todos los datos del IOHandler cuando se activan los incendios ...

procedure TFormMain.IdTCPServerExecute(AContext: TIdContext);
var
RxBufStr: UTF8String;
RxBufSize: Integer;
begin
if AContext.Connection.IOHandler.Readable then
begin
RxBufSize := AContext.Connection.IOHandler.InputBuffer.Size;
if RxBufSize > 0 then
begin
SetLength(RxBufStr, RxBufSize);
AContext.Connection.IOHandler.ReadBytes(TBytes(RxBufStr), RxBufSize, False);
end;
end;
end;

AContext.Connection.IOHandler.InputBuffer.Size no parece confiable y a menudo devuelve 0, pero en la siguiente ejecución a través de OnExecute obtendrá el número correcto de bytes, pero eso es demasiado tarde.

Básicamente, quiero poder tomar todos los datos, rellenarlos en un UTF8String ( no en una cadena Unicode) y luego analizar un marcador especial. Entonces no tengo encabezados y los mensajes son de longitud variable. Parece que Indy 10 IOHandlers no están configurados para esto o solo lo estoy usando mal.

Sería bueno hacer algo así como pasar un buffer de cierto tamaño, llenarlo tanto como sea posible y devolver el número de bytes realmente llenos y luego continuar si hay más.

Como un aparte de lo que es el estado de TIdSchedulerOfFiber, esto se ve muy interesante, ¿funciona? ¿Alguien lo está usando? Noté que no está en la instalación estándar de Delphi 2009, sin embargo.

Actualización: Encontré Msg: = AContext.Connection.IOHandler.ReadLn (# 0, enUTF8); que funciona, pero aún me gustaría saber la respuesta a la pregunta anterior, ¿es porque se basa en bloquear IO? Lo que lo hace aún más entusiasta en este TIdSchedulerOfFiber.

Answer 1

No deberías estar usando Readable () así. Pruebe lo siguiente en su lugar:

procedure TFormMain.IdTCPServerExecute(AContext: TIdContext);
var
RxBuf: TIdBytes;
begin
RxBuf := nil;
with AContext.Connection.IOHandler do
begin
CheckForDataOnSource(10);
if not InputBufferIsEmpty then
begin
InputBuffer.ExtractToBytes(RxBuf);
// process RxBuf as needed...
end;
end;
end;

Alternativamente:

procedure TFormMain.IdTCPServerExecute(AContext: TIdContext);
var
RxBufStr: String; // not UTF8String
begin
with AContext.Connection.IOHandler do
begin
CheckForDataOnSource(10);
if not InputBufferIsEmpty then
begin
RxBufStr := InputBuffer.Extract(-1, enUtf8);
// Alternatively to above, you can set the
// InputBuffer.Encoding property to enUtf8
// beforehand, and then call TIdBuffer.Extract()
// without any parameters.
//
// Or, set the IOHandler.DefStringEncoding
// property to enUtf8 beforehand, and then
// call TIdIOHandler.InputBufferAsString()
// process RxBufStr as needed...
end;
end;
end;

En cuanto a TIdSchedulerOfFiber, el paquete SuperCore está realmente muerto en este momento. No se ha trabajado en mucho tiempo y no está actualizado con la última arquitectura de Indy 10. Podemos tratar de resucitarlo en una fecha posterior, pero no está en nuestros planes para el futuro cercano.

Answer 2

procedure TFormMain.IdTCPServerExecute(AContext: TIdContext);
var
RxBufStr: UTF8String;
RxBufSize: Integer;
begin
if AContext.Connection.IOHandler.Readable then
begin
AContext.Connection.IOHandler.ReadBytes(TBytes(RxBufStr),-1, False);
end;
end;