Discussion :

[Skreo]

Bonjour

Pour des raisons d'optimisation (processus et ram), j'aimerais pouvoir compiler mon serveur xmlsocket en executable pour linux (red hat) pour l'executer directement par la suite sans avoir besoin de la JVM.
Je le dis pour certain : ne riez pas, j'ai très bien réussi à le faire sous Windows avec Excelsior JET. (mais celui-ci est payant et je n'ai pas réussi à l'installer sous linux).

Si vous savez comment faire merci de me le faire savoir ;-)

[FreshVic]

Moi perso j'ai jamais généré d'exe , mais tout les commentaires que j'ai pu lire sur ce sujet disent que sans JVM l'exe ne fonctionne pas !!

Ceci dit optimiser en generant un exe n'est peut etre pas la meilleur solution:
Voici des arguments difficilement discutable :
http://blog.developpez.com/index.php...&c=1&tb=1&pb=1

A+

[lunatix]

sous linux, tu peux essayer GCJ/gnu-classpath, mais ca ne supporte pas tout

[billou77]

moi je dis "attention", pour deux raisons :

- tu casses la logique java (compile once, run everywhere) (je suis un puriste java )
- rien ne te dis que ton executable sera plus performant qu'en JIT. les performances de ton executable vont dependre de la facon dont ton compilateur linux convertit les fonctionnalités critique java (garbage collection, threads, exceptions) en code natif executable linux.

si ca t'amuse de comparer du bytecode et du native executable, voila quelques compileurs natifs :

http://gcc.gnu.org/java/
(Free) The Java GNU Compiler (GCJ) is part of GCC. GCJ can compile Java source or Java bytecodes to either native code or Java class files.

http://www.excelsior-usa.com/jet.html
(Commercial) JET is an optimizing Java to native code compiler that statically compiles Java bytecodes directly into native code, just like traditional C, C++ compilers.

http://www.naturalbridge.com/bullettrain.html
(Commercial) NaturalBridge BulletTrain Java to native code compiler

http://www.windriver.com/products/html/fastj_compiler.html
(Commercial) Wind River Systems Diab FastJ Java to native code compiler

http://www.metrowerks.com/desktop/java/?features
(Commercial) Metroworks Codewarrior for Java, Java to native code compiler.

http://www.cs.vu.nl/manta/
(Free) Manta compiler with Fast RMI.

[Skreo]

Merci
Bon c'est vrai que c'est peut-être pas très utile que je compile en natif ^^''
Et pour éviter de relancer un nouveau topic, je relance une question en rapport avec mon serveur :
J'ai en moyenne dans les 90 connectés sur le serveur xmlsocket, et au bout de quelques heures (5 à 10 heures) il plante : les utilisateurs connectés restent connnectés mais ne peuvent plus ni recevoir ni envoyer de données, et personne ne peux plus se connecter ni se déconnecter.
Je l'ai fais avec pour code de départ celui de Blablaserv ( http://defaut.developpez.com/tutorie...r/multithread/ ), que j'ai beaucoup enrichi (connexion mysql, requêtes perso...).
De plus quand je lance le serveur, il utilise une dizaine de processus, je ne sais pas pourquoi, et à chaque fois qu'un utilisateur se connecte ça créé un nouveau processus. Donc 100 processus pour un serveur c'est ptètre pas top... surtout que le tout prend pas mal de ram : dans les 55 Mo (en ce moment même chaque processus indique 448172 kB !!)

Si quelqu'un pouvait m'aider sur au moins un de ces problème ça serait super car je suis obligé de le surveiller en permanence ...

[billou77]

c'est une nouvelle question que tu poses, et ca n'a rien à voir avec le sujet "Compiler du java en natif". ca ne serait pas mieux de faire un autre tropic ? :

[billou77]

est-ce que ces Mo ne sont vraiment pas utilisés par ton appli ? ce sont peut etre des données utilisées par ton appli, non ?

- quand un client se deconnecte, tu kill bien sa thread coté serveur ? (ou tu reutilises ce thread pour une nouvelle connection cliente ?)
- tu fermes bien le statement/preparedstatement apres chaque usage ?
- tu utilises un pool de connection sql ou non ?
- tu fais des trucs genre String tata="machin"+"toto"+"bidule"? tu utilises les + pour concatener les chaines de caracteres ?

[Skreo]

Alors...
- le thread se termine comme dans Blablaserv avec la fermeture du socket (je sais pas si c'est idéal
- J'utilise une seule connection mysql continue avec un seul Statement jamais fermé et pas de Preparedstatement
- un pool ? c'est quoi ? ^^''''
- oui je fais des trucs genre String tata="machin"+"toto"+"bidule"
c'est pas top je sais ^^

Comment je pourrais optimisé tout ça ?

[billou77]

- il faut fermer, apres chaque utilisation, ton statement

- un pool de connections, c'est un ensemble de connections pretes à etre utilisées. quand tu as besoin d'une connection, tu en prends une dans ce tas de connections, et tu le remets, apres son utilisation, dans ce tas.
http://webdevelopersjournal.com/columns/connection_pool.html
http://www.javaworld.com/jw-06-1998/jw-06-object-pool.html
http://www.theserverside.com/articles/article.tss?l=Prepared-Statments

- ton augmentation de mémoire utilisée pourrait s'expliquer par le fait que tu utilises des "machin"+"bidule". il faudrait que tu remplaces ca par un stringbuffer.

si tu as des questions n'hesite pas

[Skreo]

Merci ^^
comment on fait exactement avec un stringbuffer et en quoi c'est mieux pour la mémoire ?
Je vais essayer de voir les pool de connexion mysql.

Et sinon les threads correspondant à chaque client finissent comme ça (dans la fonction run):

Code :

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

1
2
3
4
5
6
7
}finally {
      try {
      	System.out.println("Le client no "+_numClient+" s'est deconnecte");
        _serv.delClient(_numClient); // on supprime le client de la liste
        _s.close(); // fermeture du socket si il ne l'a pas déjà été
      }catch (IOException e){ }
}

Je ne sais pas si ça kill bien le thread

[Pill_S]

pour moi: une seule réponse

refais tout en utilisant java.nio et 1 seul thread, ce sera bien plus performant. Ici, tu auras de quoi débuter dans cette techno: http://www.onjava.com/pub/a/onjava/2002/09/04/nio.html?page=2

pour la mémoire: utilise des StringBuffer/StringBuilder si tu dois faire de gros et fréquents traitements de chaînes, sinon laisse tomber ce genre de petites optimisations... surtout que le compilo java en fait certaines automatiquement sans te demander ton avis

et en dernier recours: affecte "null" à tes références dès qu'elles ne sont plus utilisées, pour forcer la libération d'un maximum de mémoire par le GC à chacun de ses passages

ps: 448172 KB c'est plus proche de 500Mo que de 55

[Skreo]

Ok je vais voir ça merci ^^
avec un seul thread on peux faire du multi-utilisateur ?

PS : je sais pas si c'est en kilobits ou kilobytes... mais sous windows ça me prend moins de 10 Mo le serveur donc ....

[nic58]

avec un seul thread on peux faire du multi-utilisateur ?

Oui.
Je te conseil d'ailleurs de jeter un oeil sur Mina qui est plus pratique à utiliser que le package java.nio directement.

[Skreo]

J'ai essayer le truc avec java.nio mais j'ai un problème : je ne vois pas comment :
- envoyer un message d'un utilisateur à un autre
- avoir une liste des utilisateurs et pouvoir accéder au socket de chacun d'entre eux par cette liste (avec un id pour chaque)
- gérer les déconnexion des utilisateurs

[Pill_S]

Hello,

je pense pouvoir répondre à tes questions:

envoyer un message d'un utilisateur à un autre

tu peux faire comme ceci:

Code :

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

1
2
 
((SocketChannel) aSelectionKey.channel()).write("Salut toto".getBytes());

avoir une liste des utilisateurs et pouvoir accéder au socket de chacun d'entre eux par cette liste (avec un id pour chaque)

il suffit de stocker les "SelectionKey" associée à chacun des clients (le "Selector" doit normalement permettre de récupérer des ensembles de SelectionKey, avec "selector.keys()" )

gérer les déconnexion des utilisateurs

tout simple :

Code :

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

aSelectionKey.cancel();

il sera supprimé du selector lors de la prochaine sélection

[Mister Nono]

J'ai eu le même genre de problèmes pour une appli qui devait rester toujours en fonctionnement.

La mémoire se remplissait lentement mais sûrement.

Après de multiples recherches et tests :

Fermeture des sockets dès qu'ils ne servaient plus (ou à intervalles réguliers avec ré-initialisation), déconnexion de la base de donnée dès qu'une requête était réalisée, vidage ou destruction des buffers in et out régulièrement.

Depuis, l'appli fonctionne très bien.

Salut.

[Skreo]

oki
Mais quand je dit gérer les déconnection des utilisateurs, c'est pas les faire se déconnecter ^^, c'est plutôt savoir quand ils se déconnectent et executer une fonction pour sauvegarder leurs données (c'est pour un jeu : http://www.murties.com)
Pour la liste des utilisateurs et les envois entre utilisateurs, je pense faire un ArrayList contenant les références des SocketChannel des utilisateurs, et les clés de ce tableau sera leurs id.

Pour l'instant voici la boucle (je ne sais pas si c'est bien) :

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
server = ServerSocketChannel.open();
server.configureBlocking(false);
server.socket().bind(new java.net.InetSocketAddress(port));
Selector selector = Selector.open();
SelectionKey acceptKey = server.register(selector, SelectionKey.OP_ACCEPT);
 
while (it.hasNext( )) {
	SelectionKey key = (SelectionKey) it.next();
	it.remove();
 
	if (key.isAcceptable()) {
		SocketChannel client = server.accept();
		client.configureBlocking(false);
		client.register(selector, SelectionKey.OP_READ | SelectionKey.OP_WRITE);
		System.out.println("Client Connected Successfully!");
		continue;
	}
 
	if (key.isReadable()) {
		SocketChannel client = (SocketChannel) key.channel();
		readMessage(client); // Fonction qui lit le buffer du client
	}
}

Une ptite question finale ^^ : quand on fait flush() sur un buffer, ça libère sa mémoire ?

[Skreo]

up

[Pill_S]

gérer les déconnection des utilisateurs, c'est pas les faire se déconnecter ^^, c'est plutôt savoir quand ils se déconnectent et executer une fonction pour sauvegarder leurs données

je viens de tomber la dessus:

http://javaalmanac.com/egs/java.nio/DetectClosed.html?l=rel

[Skreo]

Merci ^^

Hum je viens de reprogrammer mon serveur, mais j'ai l'impression que c'est pire : avant avec 100 connectés le serveur prennait moins de 1% du processeur, et là, même avec aucun connecté, ça prend entre 25 et 50% du processeur !! (avec 1 connecté c'est pareil)

Comment faire SVP ??

Voici le code de la fonction de démarrage du ServerSocketChannel :

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
public static void startServer() throws Exception {
        logErreur("Démarrage serveur");
        // Create the server socket channel
        server = ServerSocketChannel.open();
        // nonblocking I/O
        server.configureBlocking(false);
        server.socket().bind(new java.net.InetSocketAddress(port));
        // Create the selector
        Selector selector = Selector.open();
        SelectionKey acceptKey = server.register(selector, SelectionKey.OP_ACCEPT);
 
        while (true) {
            try {
                // Wait for an event
                selector.select();
            } catch (IOException e) {
                // Handle error with selector
                break;
            }
            // Get keys
            Set readyKeys = selector.selectedKeys();
            // iterate over the set of selected keys:
            Iterator it = readyKeys.iterator();
 
            // Look at each key in the selected set:
            while (it.hasNext()) {
                SelectionKey key = (SelectionKey) it.next();
                it.remove();
 
                if (key.isAcceptable()) {
                    SocketChannel client = server.accept();// get client socket channel
                    client.configureBlocking(false); // Non Blocking I/O
                    client.register(selector, SelectionKey.OP_READ | SelectionKey.OP_WRITE); // recording to the selector (reading & writing)
                    int idClient=addClient(client, key);
                    continue;
                }
 
                if (key.isReadable()) {
                    SocketChannel client = (SocketChannel) key.channel();
                    try {
                        readMessage(client);
                    }catch(Exception e){
                        System.out.println("ERROR in Server readMessage() " + e);
                    }
                }
            }
        }
    }