Discussion :

[Tigrounette]

Salut ici,

Je vous explique mon problème :

J'ai un jeu multijoueur qui utilise une application java comme serveur. Donc, à chaque fois qu'un joueur se connecte, un nouveau thread est créé.

Le problème, c'est que quand j'arrive vers 30-40 joueurs, de temps en temps le serveur n'envoie plus rien à personne pendant environs 10 secondes. Des gros coup de lag en gros ^^

Ca c'est quand je n'utilise pas le mot clef "synchronized".

Le problème, c'est quand je met synchronized devant toutes mes méthodes le serveur plante (sans message d'erreur) ou bout de 4-5 joueurs.

C'est un petit jeu de plateforme multijoueur en temps réel que vous pouvez trouvez ici : http://www.extinction.fr/aaaaah/. C'est assez dynamique et le serveur reçoit pas mal d'informations par secondes.

Je n'arrive pas à trouver où ça coince car le serveur ne m'envoie pas de message d'erreur.

J'ai l'impression que ça vas pas lorsque le serveur doit redistribuer un message à plusieurs client. Il procède de cette façon :

Cette méthode se trouve dans la classe principale, LS_JOUEUR correspondant à un ArrayList contenant le thread de chaque joueur. Cet objet est le seul que les threads se "partage".

Code :

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

1
2
3
4
5
6
7
 
public void Envoie(ArrayList<Joueur> LS_JOUEUR, String MESSAGE) {
	int NbJoueur = LS_JOUEUR.size();
	for (int i = 0; i < NbJoueur; i++) {
		LS_JOUEUR.get(i).Envoie(MESSAGE);
	}
}

Dans le thread de chaque joueur se trouve cette méthode, qui est appelée plus haut :

Code :

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

1
2
3
4
5
 
public void Envoie(String MESSAGE) {
	Socket_Out.print(MESSAGE + '\u0000');
	Socket_Out.flush();
}

Si quelqu'un peut m'indiquer comment placer mes mot clef synchronized, ça m'intéresse

[ep31]

Le problème, c'est quand je met synchronized devant toutes mes méthodes le serveur plante (sans message d'erreur) ou bout de 4-5 joueurs.

Disons que l'utilisation du mot-clé synchronized est coûteuse vu que le runtime bloque ce qui est synchronisé par tous les thread l'utilisant. Alors si toutes tes méthodes sont synchronisées et souvent appelées ; cela ne m'étonne pas que cela parte en choucroute.

Si quelqu'un peut m'indiquer comment placer mes mot clef synchronized, ça m'intéresse

Uniquement sur les objets qui sont partagés par plusieurs threads.

Si LS_JOUEUR est un ArrayList de Thread, ce n'est pas lui qu'il faut synchroniser mais les données que ces threads se partagent.

[natha]

Tes threads de joueurs font de l'attente active (while 1, ...) ? ou passive (sleep, wait, ...) ?
S'ils font de l'attente active ça peut poser des problèmes car ils sont tout le temps actif ce qui signifie que quand tu en a 40, il est plus difficile de "partager" leur activité.

[LeXo]

je pense que l'on préfère l'utilisation de l'API fournit par concurrent que l'utilisation du synchronized

[elmor]

Il est sympa ce petit jeu

Comment est-ce que les threads reçoivent les messages?

Si je comprends tu partages la structure LS_JOUEUR entre tous tes threads.

Et donc pour envoyer un message a un thread tu dois mettre ton message dans une liste et ton thread doit le lire non ?

Est-ce que tu peux nous fournir le code de envoie et le code de la lecture des messages par tes threads ?

Sinon pour eviter d'avoir à synchronizer ta liste LS_JOUEUR pourquoi ne pas avoir une queue de message par Joueur et lorsque le serveur veut envoyer un message à un client il le poste dans la queue de message?

[Tigrounette]

Alors, dans la méthode run() de chaque client j'ai ce code qui permet de recevoir et de lire les messages :

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
 
try {
	StringBuilder Compacteur = new StringBuilder(100);
	char Caractere[] = new char[1];
	while (Socket_In.read(Caractere, 0, 1) != -1) {
		char C = Caractere[0];
		if (C == 0) {
			if (Compacteur.length() != 0) {
				String Message = Compacteur.toString();
				Compacteur = new StringBuilder(100);
				Analyse_Message(Message);
			}
		} else {
			Compacteur.append(C);
		}
	}
	Deconnexion("Fermeture du client");
} catch (SocketTimeoutException ste) {
	Deconnexion("Connexion perdue");
} catch (Exception e) {
	Deconnexion("Deconnexion du client");
	//e.printStackTrace();
}

LS_JOUEUR fait en fait toujours référence au même arrayList qui se trouve dans la classe principale et qui contient tous les thread des clients.

En fait ça fonctionne comme ça :

Le serveur reçoit un message qu'il doit redistribuer à tous les clients. Il prend donc l'ArrayList qui contient tous les Clients, il parcourt cette liste et utilise cette méthode qui se trouve dans la classe de chaque client :

Code :

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

1
2
3
4
5
 
public void Envoie(String MESSAGE) {
	Socket_Out.print(MESSAGE + '\u0000');
	Socket_Out.flush();
}

Socket_Out est définie dans le constructeur de chaque client :

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
 
public Joueur(Socket SOCKET, Serveur SERVEUR) {
	Serveur = SERVEUR;
	Socket = SOCKET;
	AdresseIP = Socket.getInetAddress().toString();
	try {
		Socket.setSoTimeout(30000);
		Socket_Out = new PrintWriter(Socket.getOutputStream());
		Socket_In = new BufferedReader(new InputStreamReader(Socket.getInputStream(), Charset.forName("UTF-8")));
	} catch (Exception e) {
		e.printStackTrace();
	}
}

J'ai fait quelques test en local en essayant de surcharger le serveur de client et de message à recevoir et à renvoyer.

J'ai remarqué que lorsque je déconnecte un client, je me retrouve avec cette suite d'erreur et une partie des client sont déconnecté :

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
 
java.lang.IndexOutOfBoundsException: Index: 7, Size: 7
	at java.util.ArrayList.RangeCheck(Unknown Source)
	at java.util.ArrayList.get(Unknown Source)
	at Serveur.Envoie(Serveur.java:228)
	at Serveur.Quitter_Salon(Serveur.java:59)
	at Joueur.Deconnexion(Joueur.java:271)
	at Joueur.run(Joueur.java:68)
java.lang.IndexOutOfBoundsException: Index: 5, Size: 4
	at java.util.ArrayList.RangeCheck(Unknown Source)
	at java.util.ArrayList.get(Unknown Source)
	at Serveur.Envoie(Serveur.java:228)
	at Serveur.Quitter_Salon(Serveur.java:69)
	at Joueur.Deconnexion(Joueur.java:271)
	at Joueur.run(Joueur.java:68)
java.lang.IndexOutOfBoundsException: Index: 4, Size: 2
	at java.util.ArrayList.RangeCheck(Unknown Source)
	at java.util.ArrayList.get(Unknown Source)
	at Serveur.Envoie(Serveur.java:228)
	at Serveur.Quitter_Salon(Serveur.java:59)
	at Joueur.Deconnexion(Joueur.java:271)
	at Joueur.run(Joueur.java:68)
java.lang.IndexOutOfBoundsException: Index: 2, Size: 2
	at java.util.ArrayList.RangeCheck(Unknown Source)
	at java.util.ArrayList.get(Unknown Source)
	at Serveur.Envoie(Serveur.java:228)
	at Serveur.Quitter_Salon(Serveur.java:59)
	at Joueur.Deconnexion(Joueur.java:271)
	at Joueur.run(Joueur.java:68)
java.lang.IndexOutOfBoundsException: Index: 2, Size: 2
	at java.util.ArrayList.RangeCheck(Unknown Source)
	at java.util.ArrayList.get(Unknown Source)
	at Serveur.Envoie(Serveur.java:228)
	at Serveur.Quitter_Salon(Serveur.java:69)
	at Joueur.Deconnexion(Joueur.java:271)
	at Joueur.run(Joueur.java:68)

Ya donc un problème de ce côté là :

Code :

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

1
2
3
4
5
6
7
 
public void Envoie(ArrayList<Joueur> LS_JOUEUR, String MESSAGE) {
	int NbJoueur = LS_JOUEUR.size();
	for (int i = 0; i < NbJoueur; i++) {
		LS_JOUEUR.get(i).Envoie(MESSAGE);
	}
}

Si je remplace cette méthode par ça, ça ne bug plus :

Code :

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

1
2
3
4
5
6
 
public void Envoie(ArrayList<Joueur> LS_JOUEUR, String MESSAGE) {
	for (int i = 0; i < LS_JOUEUR.size(); i++) {
		LS_JOUEUR.get(i).Envoie(MESSAGE);
	}
}

Mais je pense pas que ça puisse régler tous les autres problèmes ^^

Sinon pour eviter d'avoir à synchronizer ta liste LS_JOUEUR pourquoi ne pas avoir une queue de message par Joueur et lorsque le serveur veut envoyer un message à un client il le poste dans la queue de message?

Je connais mal la programmation réseau, ça consiste en quoi exactement ? ^^