Discussion :

[matrix1233]

Bonjour,
J'ai un IdTCPServer avec plusieurs client connectés. La communication fonctionne normallement mais quand je depasse un certain nombre de readstream le serveur ne peut plus lire la data et ceci seulement dans l'événement OnExecute. Je n'arrive pas a trouver une solution .. Pouvez vous me suggerer une solution svp ? Merci .

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
type TInfPacket  = record
       info1 : String[10];
       info2 : String[10];
       Password         : String[10];
       Type          : string[15];
       Authorized       : Boolean;
 
 
 
function ReceiveStream(AContext: TIdContext; var AStream: TStream)
  : Boolean; overload;
var
  LSize: LongInt;
begin
  Result := True;
  try
     LSize := AContext.Connection.IOHandler.ReadLongInt();
     AContext.Connection.IOHandler.ReadStream(AStream,LSize, False)
     AStream.Seek(0,soFromBeginning);
  except
    Result := False;
  end;
end;
 
 
 
procedure TForm1.IdTCPServerExecute(AContext: TIdContext);
var
   AStream: TmemoryStream;
begin
 
 AStream:=TMemoryStream.Create;
 try
  AStream.Clear;
  ReceiveStream(AContext,TStream(AStream));
  AStream.Read(InfPacket,SizeOf(TInfoPacketDest));   // ===> Ca fonctionne ici
 
  if InfPacket.Type='Send'
   then 
     begin
      Astream.Clear;
      AStream.Write(InfPacket,SizeOf(TInfoPacketDest));
      SendStream(AContextClient1,TStream(AStream));            //ca fonctionne ici
 
      Astream.Clear;
      ReceiveStream(AContextClient2,TStream(AStream));  // ici ca ne fonctionne pas ! ( a noter que si j'utilise cette meme ligne dans l'événement OnConnect ca fonctionne trés bien 
      AStream.SaveToFile('test.bmp');     
 
end;
Finally
 Astream.free;
end;

[ShaiLeTroll]

le var sur AStream n'est pas utile, modifier les propriétés de l'objet via la référence ne nécessite pas de var
le var c'est pour modifier la référence elle-même

Gérez-vous bien les divisions de buffer et reliquats ?
le client envoie un paquet de 64Ko mais le serveur reçoit 8 paquet de 8Ko, faut bien reconstituer la donnée,
même si avec le TInfPacket déclaré, je suppose que vous ne recevez pas de buffer splitté mais cela se compliquer de faire évoluer votre protocole si vous variez le "Type"

Si j'ai utilisé le TIdHTTPServer, je préfère pour le TCP/IP, le bon vieux TServerSocket avec un Thread (ou Pool) par WinSocketStream
De plus, je ne fais JAMAIS d'envoie dans le OnExecute de Indy ou dans le Execute du Thread

La structure classique de mon programme
Thread de Listen - invisible c'est TIdTCPServer qui le gère
Threads de Read - ne fait que lire et gérer la fragmentation
Thread(s) de Traitement - Reçoit un message défragmenté et génération de la réponse
Thread d'Envoi - Tous les envois sont dans ce thread et uniquement celui-ci

le Thread de Traitement et d'Envoi expose une méthode Add() pour ajouter à une ThreadList interne les éléments à traiter ou envoyer

Ceci est important, lorsqu'un client envoie beaucoup de donnée, traiter la donnée dans le même thread que la lecture peut être trop lent, résultat, les paquets s'accumulent dans le tampon TCP et débordent, il est important de vider le tampon, le plus vite que possible pour recevoir les données.

Il faut tout penser de façon asynchrone, ne pensez pas que cela sera un ping pong parfait, le client peut envoyer 2 requêtes de façon rapproché, du coup penser que dans le buffer contiendra le retour à votre réponse à la première requete est faux.

Tient un exemple en code du principe ci-dessus