Mon socket reçoit des données, répond, puis après... chais pas...

Marsh Posté le 28-12-2005 à 16:41:35

Salut,

Vu que j'ai rien à foutre au taff, j'essaie de faire de la veille techno histoire de me constituer des librairies de softs à utiliser...

J'ai décidé de tenter de me faire une DLL qui me permette d'accéder à des fichiers sur un serveur distant, sans utiliser le protocole NETBIOS ni FTP. Le but, c'est de pouvoir travailler sur n'importe quel port, et utiliser un format d'échange basé sur du XML passant par HTTP 1.1 (et peut-être d'autres protocoles si besoin).

Pour le moment, je suis en train d'écrire le début du service serveur, c'est à dire la partie qui va tourner sur le PC qui doit partager ses fichiers.
Je suis loin d'avoir commencé le début du commencement ma bon...

J'ai trouvé sur un site comment écrire une appli serveur utilisant des connections asychrones. Je pense que c'est ce que je peux faire de mieu pour ce qui est des performances, non ?

Ensuite, je suis allé sur la MSDN et j'ai transformé le schmilblik en service.

Bon, ça marche, c'est super.

Sauf que j'ai un problème et une question :
- Lorsque je me connecte en telnet sur le service, je tape quelques trucs plus la suite de caractère idiquant la fin d'échange. Jusque là, pas de problème.
- Le service me répond alors ce qu'il est censé me répondre, c'est à dire "yo" suivi de la chaîne "^^" indiquant la fin d'un échange.

Sauf que là, la connection du côté serveur n'écoute plus, et telnet ne s'en rend apparement pas compte : je peux taper n'importe quoi dans ma fenêtre et ça fait plus jamais rien. D'où vient le problème ?

Ensuite, lorsque j'ai demandé l'arrêt du service, j'ai pas tout compris à ce qui s'est passé d'après le log...
En effet, le truc s'arrête, puis se remet à écouter, et reçoit même une demande de connection... avant de s'arrêter comme un bourrin !

Bref, c'est pas gagné

Ci-dessous le projet (enfin, les), ainsi que le log correspondant au test que j'ai effectué.

Les sources et les EXE testés :
http://www.bci-logs.fr/magictalk.zip

Le test :

net start magictalkserver
telnet localhost 1000
prout^^
(kill de la fenêtre cause telnet parti en live après réception de "yo^^" )
net stop magictalkserver

Le log (pour ceux que ça intéresse, le projet "logFile" est standalone et bien pratique ) :

################################################################################
MagicTalkServer is starting on 28/12/2005 16:06:27
Service MagicTalk Server version 1.0 debug
Legend :
PP : Application parameter (see INI file)
II : Informal message
EE : Blocking error
ee : Non-blocking error
WW : Warning message
################################################################################

28/12/2005 II : Démarrage du service
28/12/2005 II : Début de l'écoute sur le port 1000
28/12/2005 II : Apparement, on vient de se connecter à moi
28/12/2005 II : J'ai de la lecture
28/12/2005 II : J'ai pas encore tout reçu, j'attends encore
28/12/2005 II : J'ai de la lecture
28/12/2005 II : J'ai pas encore tout reçu, j'attends encore
28/12/2005 II : J'ai de la lecture
28/12/2005 II : J'ai pas encore tout reçu, j'attends encore
28/12/2005 II : J'ai de la lecture
28/12/2005 II : J'ai pas encore tout reçu, j'attends encore
28/12/2005 II : J'ai de la lecture
28/12/2005 II : J'ai pas encore tout reçu, j'attends encore
28/12/2005 II : J'ai de la lecture
28/12/2005 II : J'ai pas encore tout reçu, j'attends encore
28/12/2005 II : J'ai de la lecture
28/12/2005 II : J'ai pas encore tout reçu, j'attends encore
28/12/2005 II : J'ai de la lecture
28/12/2005 II : J'ai pas encore tout reçu, j'attends encore
28/12/2005 II : J'ai de la lecture
28/12/2005 II : Je crois que j'ai reçu tout ce qu'il y avait à recevoir
28/12/2005 II : J'envoie de la lecture
28/12/2005 II : J'émet des données
28/12/2005 II : Nettoyage des sockets
28/12/2005 II : Socket mort détecté : on le vire
28/12/2005 II : Destruction d'un socket
28/12/2005 II : Tiens, j'ai planté
28/12/2005 II : Fin du nettoyage des sockets
28/12/2005 II : Nettoyage des sockets
28/12/2005 II : Fin du nettoyage des sockets
28/12/2005 II : Nettoyage des sockets
28/12/2005 II : Fin du nettoyage des sockets
28/12/2005 II : Arrêt du service
28/12/2005 II : Arrêt demandé, destruction de tous les sockets
28/12/2005 II : Apparement, on vient de se connecter à moi
28/12/2005 II : OK, normalement je dois pouvoir recevoir des connections

################################################################################
MagicTalkServer is ending...
Process summary :
Readen application parameters : 0
Informal messages 36
Blocking errors 0
Non-blocking errors 0
Warning messages 0
################################################################################

-- Edit : Correction de l'url du fichier ZIP car Lycos ne permet pas de télécharger un fichier

Message édité par Arjuna le 29-12-2005 à 11:10:41

Reply

Marsh Posté le 28-12-2005 à 16:41:35

Reply

Marsh Posté le 28-12-2005 à 16:42:13

Voilà, si qq1 pouvait me dire ce qu'il se passe et m'indiquer comme résoudre ces problème, ce serait super sympa

Reply

Marsh Posté le 28-12-2005 à 16:43:59

Ah, aussi, je veux bien qu'on m'explique pourquoi la ligne "Tiens, j'ai planté" Parceque je ne pense pas que ce soit normal que cette exception se lance alors que j'ai rien fait de mal...

Reply

Marsh Posté le 28-12-2005 à 17:39:13

Ca passionne les foules, c'est fou.

Pour reprendre le problème du telnet (le principal problème en fait) : lorsque j'ai terminé de recevoir les données, le code laisse la connection ouverte, mais il n'affiche plus.
On le voit d'ailleurs, puisqu'à ce moment telnet se contente d'afficher les infos qu'on tape, alors que lorsque le serveur écoute, il n'affiche rien, puisque tout est aussitôt consommé par le serveur.
Par contre, la connection reste ouverte, sinon telnet afficherait un message comme quoi il est déconnecté, et ce n'est pas le cas.

Reply

Marsh Posté le 28-12-2005 à 17:40:49

Exemple : telnet www.google.com 80

On tapes 2 fois <entrée>

On retourne à l'invite car le site web a fermé la connection, voyant qu'il n'avait rien à traîter.

Reply

Marsh Posté le 28-12-2005 à 17:43:13

Et ça, c'est si je tape :

telnet www.google.com 80
GET / HTTP/1.0

Retour :

Code :

HTTP/1.0 302 Found
Location: http://www.google.fr/
Set-Cookie: PREF=ID=14fcab8f82ffce4c:TM=1135788126:LM=1135788126:S=c9zvbMIdzfk9g
1zU; expires=Sun, 17-Jan-2038 19:14:07 GMT; path=/; domain=.google.com
Content-Type: text/html
Server: GWS/2.1
Content-Length: 221
Date: Wed, 28 Dec 2005 16:42:06 GMT
Connection: Keep-Alive
<HTML><HEAD><meta http-equiv="content-type" content="text/html;charset=us-ascii"
>
<TITLE>302 Moved</TITLE></HEAD><BODY>
<H1>302 Moved</H1>
The document has moved
<A
HREF="http://www.google.fr/">here</A>.
</BODY></HTML>
Perte de la connexion à l'hôte.

Telnet reste ouvert histoire de montrer le résultat, mais il indique bien que la connection est perdue.

Message édité par Arjuna le 28-12-2005 à 17:45:09

Reply

Marsh Posté le 29-12-2005 à 10:52:55

Ca inspire toujours les foules, c'est fou

J'ai fait quelques modifs au niveau des logs, et j'ai plus d'infos sur ce qu'il se passe.

Apparement :
- Après émission de données, mon socket part bel et bien en live : pour le service, il est toujours en train d'écouter, alors que ce n'est pas le cas
- Lorsque je cherche à détruire mon socket, j'ai un problème de parcours de la collection dans laquelle il est stocké, et c'est ça qui fait l'erreur durant le nettoyage
- Lorsque j'arrête le service, on socket qui n'est plu censé être actif reprends la main puis s'arrêté.

Log :

29/12/2005 09:33:20 II : Données reçues
29/12/2005 09:33:20 II : Lecture des données reçues
29/12/2005 09:33:20 II : Données reçues trouvées, on les stocke dans un coin
29/12/2005 09:33:20 II : Il n'y a plus rien à recevoir
29/12/2005 09:33:20 II : Je réponds un A/R
29/12/2005 09:33:20 II : Envoie d'un message
29/12/2005 09:33:20 II : J'efface le buffer de réception
29/12/2005 09:33:20 II : Emission de données
29/12/2005 09:37:46 II : Nettoyage des sockets inactifs
29/12/2005 09:37:46 II : Socket dans un état de timeout trouvé : on le détruit (ID=)
29/12/2005 09:37:46 II : Destruction d'un socket
29/12/2005 09:37:46 II : Etat du socket détruit
29/12/2005 09:37:46 II : Socket en cours de travail, on le kill
29/12/2005 09:37:46 II : Socket killé
29/12/2005 09:37:46 II : Socket détruit
29/12/2005 09:37:46 II : Socket détruit
29/12/2005 09:37:46 ee : Plantate durant le nettoyage des sockets inactifs
29/12/2005 09:37:46 ee : La collection a été modifiée ; l'opération d'énumération peut ne pas s'exécuter.
29/12/2005 09:37:46 ee : at System.Collections.ArrayListEnumeratorSimple.MoveNext()
at MagicTalkServer.Server.CheckSockets(Object eventState)
29/12/2005 09:37:46 II : Fin du nettoyage des sockets
29/12/2005 09:42:46 II : Nettoyage des sockets inactifs
29/12/2005 09:42:46 II : Fin du nettoyage des sockets
29/12/2005 09:43:07 II : Arrêt du service
29/12/2005 09:43:07 II : Arrêt demandé, destruction de tous les sockets
29/12/2005 09:43:08 II : Demande de connection reçue
29/12/2005 09:43:08 II : Socket a terminé l'écoute
29/12/2005 09:43:08 II : Fin d'écoute
29/12/2005 09:43:08 II : Etablissement de la connection
29/12/2005 09:43:08 II : Connection établie, début de l'écoute

Fonctions incriminée :

Code :

///
/// Decription: Call back method to handle incoming data.
///
/// <param name="ar">Status of an asynchronous operation.</param>
protected void ReadCallback(IAsyncResult ar)
{
log.AddMessage("Données reçues" );
String content = String.Empty;
// Retrieve the state object and the handler socket
// from the async state object.
StateObject state = (StateObject) ar.AsyncState;
Socket handler = state.workSocket;
try
{
log.AddMessage("Lecture des données reçues" );
// Read data from the client socket.
int bytesRead = handler.EndReceive(ar);
if (bytesRead > 0)
{
log.AddMessage("Données reçues trouvées, on les stocke dans un coin" );
// There might be more data, so store the data received so far.
Monitor.Enter(state);
state.sb.Append(Encoding.ASCII.GetString(state.buffer, 0, bytesRead));
Monitor.Exit(state);
// Check for end-of-file tag.
// If it is not there, read more data.
content = state.sb.ToString();
if (content.IndexOf("^^" ) > -1)
{
log.AddMessage("Il n'y a plus rien à recevoir" );
// All the data has been read from the
// client. Display it on the console.
//Console.WriteLine("Read {0} bytes from socket.\nData: {1}",
// content.Length, content);
// Process the received message
state.TimeStamp = DateTime.Now;
log.AddMessage("Je réponds un A/R" );
Send(state.workSocket, "yo\n" );
//HandleMessages(state, content);
// Echo the data back to the client.
// Send(state, content);
log.AddMessage("J'efface le buffer de réception" );
state.sb.Length = 0;
}
else
{
log.AddMessage("J'ai pas encore tout reçu, j'attends encore" );
// Not all data received. Get more.
handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, new AsyncCallback(this.ReadCallback), state);
}
}
else
{ // Disconnected
log.AddBlockingError("Déconnection avant la fin de la transmission." );
RemoveSocket(state);
}
}
catch (System.Net.Sockets.SocketException es)
{
log.AddBlockingError("Erreur réseau", es);
RemoveSocket(state);
if (es.ErrorCode != 64)
{
log.AddBlockingError(string.Format("ReadCallback Socket Exception: {0}, {1}.", es.ErrorCode, es.ToString()));
}
}
catch (Exception e)
{
log.AddBlockingError("Erreur inconnue", e);
RemoveSocket(state);
if (e.GetType().FullName != "System.ObjectDisposedException" )
{
log.AddMessage(string.Format("ReadCallback Exception: {0}.", e.ToString()));
}
}
}
///
/// Description: Check for dormant sockets and close them.
///
/// <param name="eventState">Required parameter for a timer call back
/// method.</param>
private void CheckSockets(object eventState)
{
log.AddMessage("Nettoyage des sockets inactifs" );
lostTimer.Change(System.Threading.Timeout.Infinite,
System.Threading.Timeout.Infinite);
try
{
foreach (StateObject state in connectedSocks)
{
if (state.workSocket == null)
{ // Remove invalid state object
log.AddWarning(string.Format("Socket dans un état invalide trouvé : on le détruit (ID={0})", state.id));
Monitor.Enter(connectedSocks);
if (connectedSocks.Contains(state))
{
log.AddWarning("Le socket à détruire est bien trouvé" );
connectedSocks.Remove(state);
Interlocked.Decrement(ref sockCount);
log.AddWarning("Le socket à détruire est bien détruit" );
}
else
{
log.AddNonBlockingError("On ne trouve plus le socket à détruire !" );
}
Monitor.Exit(connectedSocks);
log.AddWarning(string.Format("Socket {0} détruit", state.id));
}
else
{
if (DateTime.Now.AddTicks(-state.TimeStamp.Ticks).Minute > timeoutMinutes)
{
log.AddMessage(string.Format("Socket dans un état de timeout trouvé : on le détruit (ID={0})", state.id));
RemoveSocket(state);
log.AddMessage(string.Format("Socket {0} détruit", state.id));
}
}
}
}
catch (Exception e)
{
log.AddNonBlockingError("Plantate durant le nettoyage des sockets inactifs", e);
}
finally
{
log.AddMessage("Fin du nettoyage des sockets" );
lostTimer.Change(Server.timerTimeout, Server.timerTimeout);
}
}
///
/// Decription: Stop the threads for the port listener.
///
public void Stop()
{
log.AddMessage("Arrêt demandé, destruction de tous les sockets" );
int lcv;
lostTimer.Dispose();
lostTimer = null;
for (lcv = 0; lcv < numThreads; lcv++)
{
if (!serverThread[lcv].IsAlive)
threadEnd[lcv].Set(); // Set event if thread is already dead
}
ShuttingDown = true;
// Create a connection to the port to unblock the listener thread
Socket sock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
IPEndPoint endPoint = new IPEndPoint(IPAddress.Loopback, this.portNumber);
sock.Connect(endPoint);
//sock.Close();
sock = null;
// Check thread end events and wait for up to 5 seconds.
for (lcv = 0; lcv < numThreads; lcv++)
threadEnd[lcv].WaitOne(5000, false);
}
///
/// Decription: Call back method to accept new connections.
///
/// <param name="ar">Status of an asynchronous operation.</param>
private void AcceptCallback(IAsyncResult ar)
{
log.AddMessage("Demande de connection reçue" );
// Signal the main thread to continue.
allDone.Set();
// Get the socket that handles the client request.
Socket listener = (Socket) ar.AsyncState;
Socket handler = listener.EndAccept(ar);
// Create the state object.
StateObject state = new StateObject();
state.workSocket = handler;
state.TimeStamp = DateTime.Now;
try
{
log.AddMessage("Etablissement de la connection" );
Interlocked.Increment(ref sockCount);
Monitor.Enter(connectedSocks);
connectedSocks.Add(state);
Monitor.Exit(connectedSocks);
log.AddMessage("Connection établie, début de l'écoute" );
handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,new AsyncCallback(this.ReadCallback), state);
if (sockCount > this.maxSockets)
{
log.AddBlockingError("Trop de connections, on détruit la connection" );
RemoveSocket(state);
//handler.Shutdown(SocketShutdown.Both);
//handler.Close();
handler = null;
state = null;
}
}
catch (SocketException es)
{
log.AddBlockingError("Impossible d'établir la connection", es);
RemoveSocket(state);
}
catch (Exception e)
{
log.AddBlockingError("Impossible d'établir la connection (2)", e);
RemoveSocket(state);
}
}

D'après le log, c'est la dernière fonction qui était restée blockée (certainement sur le allDone.Set()) et qui se débloque lors de l'arrêt du service.

Reply

Marsh Posté le 29-12-2005 à 11:07:10

Bon, j'ai résolu le premier problème : l'exception qui empêche la destruction de tous les sockets inactifs.

Code :

///
/// Description: Check for dormant sockets and close them.
///
/// <param name="eventState">Required parameter for a timer call back
/// method.</param>
private void CheckSockets(object eventState)
{
log.AddMessage("Nettoyage des sockets inactifs" );
lostTimer.Change(System.Threading.Timeout.Infinite,
System.Threading.Timeout.Infinite);
try
{
bool mustContinue = true;
while(mustContinue)
{
mustContinue = false;
foreach (StateObject state in connectedSocks)
{
if (state.workSocket == null)
{ // Remove invalid state object
mustContinue = true;
log.AddWarning(string.Format("Socket dans un état invalide trouvé : on le détruit (ID={0})", state.id));
Monitor.Enter(connectedSocks);
if (connectedSocks.Contains(state))
{
log.AddWarning("Le socket à détruire est bien trouvé" );
connectedSocks.Remove(state);
Interlocked.Decrement(ref sockCount);
log.AddWarning("Le socket à détruire est bien détruit" );
}
else
{
log.AddNonBlockingError("On ne trouve plus le socket à détruire !" );
}
Monitor.Exit(connectedSocks);
log.AddWarning(string.Format("Socket {0} détruit", state.id));
break;
}
else
{
if (DateTime.Now.AddTicks(-state.TimeStamp.Ticks).Minute > timeoutMinutes)
{
mustContinue = true;
log.AddMessage(string.Format("Socket dans un état de timeout trouvé : on le détruit (ID={0})", state.id));
RemoveSocket(state);
log.AddMessage(string.Format("Socket {0} détruit", state.id));
break;
}
}
}
}
}
catch (Exception e)
{
log.AddNonBlockingError("Plantate durant le nettoyage des sockets inactifs", e);
}
finally
{
log.AddMessage("Fin du nettoyage des sockets" );
lostTimer.Change(Server.timerTimeout, Server.timerTimeout);
}
}

Par contre, pour le reste, je ne comprends pas...

Reply

Marsh Posté le 29-12-2005 à 11:13:56

Et j'aimerais bien que mon socket continue à écouter après émission d'une info... Ou se détruire à la limite, mais faire un truc quoi...

Parceque là, je vais rapidement arriver à saturation si j'ai 1 socket mort par échange, vu que je ne flush les socket qu'au bout des 5 minutes de timeout...

Reply

Marsh Posté le 29-12-2005 à 12:13:09

Là, je reste sur mon derrière... Je suis quand même pas le seul à vouloir faire un serveur Socks asynchrone...

Message édité par Arjuna le 29-12-2005 à 12:13:28

Reply

Marsh Posté le 29-12-2005 à 12:13:09

Reply

Marsh Posté le 09-01-2006 à 11:29:45

Question : c'est quoi la différence entre ton code et ça :
http://msdn.microsoft.com/library/ [...] socket.asp

Ou bien : c'est quoi qui va pas ou que tu capte pas, par rapport à la solution MS ?

Désolé, j'ai pas le temps de lire tout ton post, mais comme j'ai déjà joué avec des sockets je peux ptet te filer un coup de pouce.

---------------
Tout est normal, suffit de comprendre pourquoi.

Reply

Mon socket reçoit des données, répond, puis après... chais pas...

Sujets relatifs:

Leave a Replay