Serveur java XMLSocket

Version imprimable

Bonjour à tous (et à toutes),

Je commence un peu à regarder ce qu'on peut faire avec flash et je voudrais faire un serveur java tout bête.
j'ai pris l'exemple d'adobe pour le côté serveur :

Code:

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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
import java.io.*; 
import java.net.*; 
 
class SimpleServer 
{ 
	private static SimpleServer server; 
    ServerSocket socket; 
    Socket incoming; 
    BufferedReader readerIn; 
    PrintStream printOut; 
 
    public static void main(String[] args) 
    { 
        int port = 8080; 
 
        try 
        { 
            port = Integer.parseInt(args[0]); 
        } 
        catch (ArrayIndexOutOfBoundsException e) 
        { 
            // Catch exception and keep going. 
        } 
 
        server = new SimpleServer(port); 
    } 
 
    private SimpleServer(int port) 
    { 
        System.out.println(">> Starting SimpleServer"); 
        try 
        { 
            socket = new ServerSocket(port); 
            incoming = socket.accept(); 
            readerIn = new BufferedReader(new InputStreamReader(incoming.getInputStream())); 
            printOut = new PrintStream(incoming.getOutputStream()); 
            out("Enter EXIT to exit.\r"); 
            boolean done = false; 
            while (!done) 
            { 
                String str = readerIn.readLine(); 
                if (str == null) 
                { 
                    done = true; 
                } 
                else 
                { 
                    out(str);
                    if(str.trim().equals("EXIT")) 
                    { 
                        done = true; 
                    } 
                } 
                incoming.close(); 
            }
            if(done == true)
            {
            	out("Déconnecté");
            }
        } 
        catch (Exception e) 
        { 
            System.out.println(e); 
        } 
    } 
 
    private void out(String str) 
    { 
        printOut.println(str.trim()+ (char)0x00);
        printOut.flush();
        System.out.println(str); 
    } 
}

et du côté client, j'ai cela :

Code:

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
package {
 
		import flash.net.XMLSocket;
		import flash.events.DataEvent;
		import flash.events.MouseEvent;
		import flash.events.Event;
		import flash.display.MovieClip;
 
	public class Main extends MovieClip {
 
		var _socket:XMLSocket;
 
		public function Main() {
			// constructor code
			this._socket = new XMLSocket();
			this._socket.connect('127.0.0.1',8080);
			this._socket.addEventListener(DataEvent.DATA, reponse);
			this._socket.addEventListener(Event.CLOSE, handlerDeConnexion);
			btnEnvoyer.addEventListener(MouseEvent.CLICK, envoyer);
 
		}
 
 
		private function reponse(event:DataEvent):void 
		{ 
			  txtReponse.text = event.data; 
 
 
		}
 
		private function handlerDeConnexion(event:Event):void{
 
			trace ("DECO !");
		}
 
		public function envoyer(event:MouseEvent):void{
 
 
			_socket.send(txtChaine.text+"/n");
		}
 
	}
 
}

Lorsque je lance l'application, mon textfield txtReponse se remplace bien par "Enter EXIT to exit." mais lorsque j'envoie une chaine de caractère au serveur à l'aide d'un input, il ne m'affiche rien.

Dans la console non plus, c'est au moment ou je ferme mon application que le serveur affiche (dans la console) "Echo :" et les chaines de caractères que j'ai envoyé suivi d'un espace (alors qu'il aurait dû mettre un "Echo : " par chaine de caractère).

Voilà, je ne comprends pas bien d'où ça vient et comment résoudre ce problème.

D'avance, merci =D

26/08/2010, 19h31
Pragmateek

Est-ce une faute de recopie dans le forum le "/n" dans :

Code:

_socket.send(txtChaine.text+"/n");

?

Si non essaye avec :

Code:

_socket.send(txtChaine.text+"\n");
26/08/2010, 19h47
Sladix

Merci, cela m'a un peu aidé ...

mais avec

Code:

_socket.send(txtChaine.text+"\n");

Il se déconnecte juste après, et dans la console il affiche

Citation:

java.net.SocketException: socket closed

.. ?!
26/08/2010, 20h49
Pragmateek
Sans doute que ce code :

Code:

incoming.close();

n'est pas au bon endroit.

Il serait plutôt à utiliser ainsi :
Code:

1 2 3 4 5 6 if(done == true) { out("Déconnecté"); incoming.close(); }
26/08/2010, 21h22
Sladix

Merci ...

Comme d'habitude je vais trop vite et je ne prend pas le temps de bien étudier la chose...

Sinon, je voulais savoir quelle solution adopter pour communiquer le plus simplement possible avec une base de données.

D'avance, merci.
26/08/2010, 22h10
Sladix
J'ai essayé d'installer mysql connector java, j'ai lu sur la documentation que pour avoir une connexion, il fallait faire de la sorte:
Code:

1 2 conn = DriverManager.getConnection("jdbc:mysql://localhost/test?" + "user=monty&password=greatsqldb");
Je ne vois pas à quoi le /test? après localhost correspond. Mysql est installé avec wamp.

=)
26/08/2010, 22h16
slim_java

Citation:

Envoyé par Sladix

Je ne vois pas à quoi le /test?

test est le nom de la base de données
26/08/2010, 22h55
Sladix

D'accord, ça fonctionne, merci beaucoup =D

J'aimerais savoir une chose ... comment on peu dire au serveur de renvoyer des données (pour mettre à jour sans que ce soit l'utilisateur qui le fasse) lorsque quelque chose a été changé dans la table ?

Je suis un peu embêtant avec mes questions mais ça a l'air tellement génial ce qu'on peut faire =D

D'avance, merci !
26/08/2010, 23h14
slim_java
Citation:

Envoyé par Sladix

D'accord, ça fonctionne,

bien =D

Citation:

Envoyé par Sladix

comment on peu dire au serveur de renvoyer des données

dans l'exemple que tu as donnée
Code:

1 2 3 4 5 6 7 private void out(String str) { printOut.println(str.trim()+ (char)0x00); printOut.flush(); System.out.println(str); }
tu peux utiliser l'objet printOut pour envoyer des données au client.
27/08/2010, 00h04
Pragmateek

Citation:

comment on peu dire au serveur de renvoyer des données (pour mettre à jour sans que ce soit l'utilisateur qui le fasse) lorsque quelque chose a été changé dans la table ?

Comme indiqué par slim_java tu peux réutiliser la socket.

Mais quant à la notification en cas de modification de la base c'est un sujet plus avancé, et d'ailleurs il ne me semble pas que MySQL le gère (à vérifier bien sûr).

Sinon, si seule une application modifie la base tu peux t'arranger, via des web-services par exemple, pour qu'elle notifie ton application de visualisation.
27/08/2010, 00h34
Sladix
Citation:
Envoyé par slim_java

bien =D

dans l'exemple que tu as donnée

Code:

1 2 3 4 5 6 7 private void out(String str) { printOut.println(str.trim()+ (char)0x00); printOut.flush(); System.out.println(str); }

tu peux utiliser l'objet printOut pour envoyer des données au client.
Moui mais ça va renvoyer ça qu'au client qui sera responsable du changement dans la base. Moi je voudrais que tous les clients connectés voient le changement en temps réel.

Quelle est la solution à adopter dans ce cas ?
Si c'est les web-service, pouvez vous m'en dire plus ?
27/08/2010, 01h57
slim_java

Citation:

Envoyé par Sladix

Moi je voudrais que tous les clients connectés voient le changement en temps réel.

Quelle est la solution à adopter dans ce cas ?

tu veux envoyer un message à tous les clients connectés ?
tu peux le faire si tu empile tes sockets crées suite à cet appel

Code:

incoming = socket.accept();

dans une collection (vecteur), par la suite tu fais un parcours de ta collection en ouvrant un flux par socket pour envoyer l'alerte... ca me rappelle les systèmes de t'chating :

Code:

" slim_java vient de se connecter "

pour le sujet des webservices, j'ai pas pratiqué cette technologie mais tu peux voir le forum Java :ccool:
28/08/2010, 20h17
Sladix

Donc si j'ai bien compris, je déclare un tableau dans la classe,
je lui ajoute le socket entrant à chaque fois et quand je fais une requête à une bdd par exemple, je renvoie le résultat à tous le tableau ?

Si c'est bien ça, comment je l'enlève du tableau lorsque l'utilisateur se déconnecte ?

Merci d'avance =)
29/08/2010, 02h59
slim_java
Citation:

Envoyé par Sladix

Si c'est bien ça, comment je l'enlève du tableau lorsque l'utilisateur se déconnecte ?

salut. en parcourant ton vecteur qui contient déjà des objets socket, tu fais un test pour chaque Socket pour voir s' il ya une connexion avec le client:
Exemple en pseudo code :
Code:

1 2 3 if( ! ( (Socket)(vecteur[i])).isConnected() ) vecteur[i].remove();
Il existe énormément de méthodes pour permettre la suppression d'un élément contenu dans un vecteur.

liens utiles

Sockets en java :
http://gfx.developpez.com/tutoriel/java/network/
http://humbert-florent.developpez.co...reseau/avance/
http://java.developpez.com/faq/java/?page=reseau
Collections en Java
http://fmora.developpez.com/tutoriel...intermediaire/
http://fmora.developpez.com/tutoriel.../introduction/

Bonjour,

Bon, j'utilise maintenant des threads.

Je bloque au niveau d'un login...

côté flash ça donne:

Code:

1
2
3
4
var xml:XML = <document><pseudo>{inputPseudo.text}</pseudo><pass>{inputPass.text}</pass></document>;
            _socket.send(xml);
            inputPass.text = "";
            inputPseudo.text = "";

Et côté serveur:

Code:

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
while (!done) {
    // ... read the next message ...
    String message = readerIn.readLine();
    printOut = new PrintStream(socket.getOutputStream());
    printOut.println(message);
    System.out.println(message);
    if (message == null) 
    { 
        System.out.println( "Elle est nulle");
        done = true; 
    } 
    else 
    { 
        if(this.logged)
        {
        // ... tell the world ...
        System.out.println( "Sending "+message );
        // ... and have the server send it to all clients
        String xml = message ; // tu récupères ta chaine.
        DocumentBuilder parser = DocumentBuilderFactory.newInstance().newDocumentBuilder();
        Document document = parser.parse(new InputSource(new StringReader(xml)));
        String texteMessage = document.getElementById("message").getAttribute("valeur");
        server.sendToAll( texteMessage );
        }else
        {
            System.out.println( "On est dans le else");
            printOut.println("On est dans le esle");
            String xml = message ; // tu récupères ta chaine.
            DocumentBuilder parser = DocumentBuilderFactory.newInstance().newDocumentBuilder();
            Document document = parser.parse(new InputSource(new StringReader(xml)));
            String pseudo = document.getElementById("pseudo").getAttribute("valeur");
            String pass = document.getElementById("pass").getAttribute("valeur");
            if(utilisateur.login(pseudo, pass))
            {
                this.logged = true;
                printOut.println("true"+ (char)0x00);
                printOut.flush();
            }else
            {
                printOut = new PrintStream(socket.getOutputStream());
                printOut.println("Mauvais identifiant/mot de passe"+ (char)0x00);
                printOut.flush();
            }
        }
    }
if(done == true)
{
    server.removeConnection( socket );
}
}

Mais lorsque j'envoie, il me met l'erreur:

Code:

1
2
3
4
5
6
7
8
<document>
On est dans le esle
[Fatal Error] :1:11: XML document structures must start and end within the same entity.
Removing connection to Socket[addr=/127.0.0.1,port=4584,localport=8080]
org.xml.sax.SAXParseException: XML document structures must start and end within the same entity.
    at com.sun.org.apache.xerces.internal.parsers.DOMParser.parse(Unknown Source)
    at com.sun.org.apache.xerces.internal.jaxp.DocumentBuilderImpl.parse(Unknown Source)
    at ServerThread.run(ServerThread.java:70)

Je ne comprends pas bien d'où ça vient ... =/

10/09/2010, 13h47
Pragmateek

Apparemment Flex envoie le flux XML en plusieurs lignes comme le prouve l'output de la variable "message" :

Code:

<document>

qui ne contient que la première balise.

La solution est sans doute de remplacer tous les "\n" générés par XML.toString() par "" via la méthode replace().

Merci de ta réponse... je m'en doutais un peu mais ...

quand j'essaye ça :

Code:

1
2
3
4
5
var xml:XML = <document><pseudo>{inputPseudo.text}</pseudo><pass>{inputPass.text}</pass></document>;
            var messageAEnvoyer:String;
            messageAEnvoyer = xml.toString();
            var pattern:RegExp = /\n/;
            trace(messageAEnvoyer.replace(pattern,""));

Il me trace :

Code:

1
2
3
<document>  <pseudo>uoi</pseudo>
  <pass>oiu</pass>
</document>

J'ai toujours été nul en RegExp -_-'

11/09/2010, 16h47
Pragmateek

Ça devrait être :

Code:

var pattern:RegExp = /\n/g;

Tsa ! Je savais que ça devait être un truc à là c** ...

Merci beaucoup.

Bon, je suis désolé de demander plein de choses mais je découvre et certains trucs m'échappent encore... ce qui me fait un peu dériver vers le java du coup ...

Donc j'envoie mon message :
Code:

1 2 3 messageAEnvoyer = xml.toString(); var pattern:RegExp = /\n/g; _socket.send(messageAEnvoyer.replace(pattern,""));
Que je réceptionne comme ceci en java:
Code:

1 2 3 4 DocumentBuilder parser = DocumentBuilder parser = DocumentBuilderFactory.newInstance().newDocumentBuilder(); Document document = parser.parse(new InputSource(new StringReader(xml))); String pseudo = document.getElementById("pseudo").getTextContent(); String pass = document.getElementById("pass").getTextContent();
Mais il me dit:
Code:

1 2 Exception in thread "Thread-0" java.lang.NullPointerException at ServerThread.run(ServerThread.java:69)
(la ligne 69 étant:

Code:

String pseudo = document.getElementById("pseudo").getTextContent();

)

je ne vois pas à quoi celà correspond...

Merci d'avance =)

12/09/2010, 15h37
Pragmateek

Pour récupérer une balise en fonction de son nom il faut utiliser la méthode getElementsByTagName, ça devrait donner quelque chose comme :

Code:

String pseudo = document.getElementsByTagName("pseudo").item(0).getNodeValue();

Il faudra peut-être une opération supplémentaire pour obtenir la valeur texte de la balise.
13/09/2010, 00h55
Sladix
Oh yeah, merci beaucoup !

Au final avec ça ça fonctionne:

Code:

document.getElementsByTagName("pseudo").item(0).getTextContent()

Je vous laisse donc sur mon problème du soir -_-

Avec
Code:

1 2 ResultSet rs = stmt.executeQuery( "SELECT * FROM rock_users WHERE user_password = "+hashString.toString()+" AND user_username = "+pseudo);
Pour aller chercher des données dans la bdd, il me sort:

Code:

com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Unknown column 'ab21a5286e538038cfa55ef6993e21dc' in 'where clause'

comme si j'avais marqué un truc du genre

Code:

"SELECT * FROM rock_users WHERE ab21a5286e538038cfa55ef6993e21dc = ..."

Je dois avouer ne pas bien comprendre ... j'ai pourtant fait des test pour voir si je pouvais me connecter et récupérer des données mais là ...

Merci d'avance ...
13/09/2010, 13h07
Pragmateek

D'une part essaye d'encadrer les valeurs littérales de la requête entre quotes '' :

Code:

"SELECT * FROM rock_users WHERE user_password = '"+hashString.toString()+"' AND user_username = '"+pseudo + "'"

D'autre part tu peux utiliser des requêtes paramétrées qui sont plus optimisées.

Et enfin, pour des raisons de sécurité, fais attention à bien échapper les paramètres de la requête.
13/09/2010, 18h23
Sladix

Je me suis en effet rendu compte qu'il manquait des guillemets 2 minutes après mon post. Ce que j'ai rectifié sur le champ.

j'ai fait quelques recherches sur "des requêtes paramétrées qui sont plus optimisées"

j'ai trouvé des trucs comme http://www.fobec.com/CMS/java/class/...ement_951.html

Mais du coup je suis totalement paumé sur les objets de requête et leur traitement ...
16/09/2010, 11h53
Sladix
Bien, j'ai pu avancer.

J'ai maintenant un autre problème d'xml avec flash ...

Mon serveur renvoie:

Code:

printOut.println("<logged>true</logged>"+ (char)0x00);

que je traite comme ceci:
Code:

1 2 3 4 var reponse:XML = <reponse>{event.data}</reponse>; trace(reponse.logged); if(reponse.logged == "true") {...
mais quand je fait le trace, il ne me renvoie rien... je suppose qu'il n'arrive pas à créer d'objet xml mais je ne comprend pas pourquoi ...
24/09/2010, 12h36
Sladix
Au final le problème n'est pas là.

Il vient de ce petit bout de code
Code:

1 2 3 4 5 boolean login = this.utilisateur.login(pseudo, pass); if(login == true) { System.out.println("on est dans le if"); ...
ma fonction login se termine comme suit:
Code:

1 2 3 this.isLogged = true; System.out.println("on est loggé put**n"); return true;
Et il m'affiche bien la phrase dans la console. Donc je suppose qu'il renvoie aussi true.
Mais dans le premier bout de code, il n'affiche pas "on est dans le if".
Je suppose que c'est mon login == true qui ne fonctionne pas mais j'ai aussi essayé avec un .equals(true) et le résultat est le même...

:aie::cry:

Bon, j'ai pu un peu avancer.

Au final, c'est du côté flash que ça foire, donc je reviens dans la bonne section =D

Voilà ce que j'ai testé:
Code:

1 2 3 4 5 var reponseXML:XML = <reponse>{event.data}</reponse>; var testXML:XML = <reponse><logged>ok</logged></reponse>; trace(event.data) trace(reponseXML.logged); trace(testXML.logged);
Et voilà ce qui sort de la console:
Code:

1 2 3 <logged>ok</logged> ok
Donc je me demandais si il y avait quelque chose que je puisse faire vu que logiquement, event.data est du type string ...