Discussion :

[Dasson]

Bonjour

Je programme actuellement un service de messagerie instantannée multi-langue, j'ai un problème au niveau de l'envoie de certains caractères.

En effet je dois être capable d'envoyer n'importe quels types de caractères (grec, cyrilliques, caractères spéciaux, ...) seulement la JVM n'arrive pas à les traiter.

J'ai réussi à régler ce problèmes en mettant ces 2 lignes dans la boite de dialogue Eclipse au niveau du démarrage dans les arguments de la JVM :

Code :

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

1
2
-Dfile.encodinf=UTF-8
-Dsun.jnu.encoding=UTF-8

Mais le problème revient lorsque je crée mon .jar executable.

J'ai essayé en mettant ces 2 lignes de code en tout début de programme mais ça ne marche pas.

Code :

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

1
2
System.setProperty("file.encoding", "UTF-8");
		System.setProperty("sun.jnu.encoding", "UTF-8");

Quelqu'un aurait une petite idée ?

Merci bien

Dasson

[adiGuba]

Salut,


Ces deux lignes permettent de définir l'encodage par défaut du système. Il n'est pas vraiment conseillé de les utiliser.

Si tu veux que ton programme genère de l'UTF8 il est préférable de le préciser manuellement dans ton code (par exemple en utilisant un InputStreamReader() + le type d'encodage)

a++

[Dasson]

Ok donc je crée un new InputStreamReader(new InputStream(), "UTF-8");
et c'est tout ?

Dasson

[Dasson]

Je ne m'en sort pas vraiment avec les InputStreamReader, tu pourrais m'aider avec l'aide de code s'il te plait ?

Merci bien

Dasson

P.S. : Il s'agit d'un serveur et client Jabber donc il faut traiter tous les caractères aussi bien en entré qu'en sortie.

[adiGuba]

Ben la solution étant de spécifier l'encodage dans tous tes flux d'entrée/sortie afin de ne pas dépendre de l'encodage par défaut du système.


Donc lorsque tu lis tu utilises :

Code :

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

new InputStreamReader(in, "utf8")

Et pour écrire :

Code :

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

new OutputStreamWriter(out, "utf8")

Au pire montre un exemple de ton code actuel...

a++

[Dasson]

Voilà la classe principale du serveur Jabber

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
package main;
 
import java.io.InputStream;
import java.io.OutputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
 
import javax.swing.*;
 
public class InstantEUServer {
 
	private InputStream is;
	private OutputStream os;
 
	public InstantEUServer(){
		try{
			new InputStreamReader(is,"UTF-8");
			new OutputStreamWriter(os,"UTF-8");
		}
		catch(Exception e){
			e.printStackTrace();
		}
	}
 
	public static void main(String[] args){
		new InstantEUServer();
		SwingUtilities.invokeLater(new Runnable(){
			public void run(){
					FenetrePrincipale fenetre = new FenetrePrincipale();
					//fenetre.pack();
					fenetre.setVisible(true);
			}
		});
	}
}

En lançant l'application, j'ai un NullPointerException, je suppose que c'est à cause que je n'initialise pas mes InputStream et OutputStream.

Dasson

[adiGuba]

En lançant l'application, j'ai un NullPointerException, je suppose que c'est à cause que je n'initialise pas mes InputStream et OutputStream.

Ben oui !
Au passage ta gestion des flux est dangereuse (risque de laisser des flux ouvert) et ta classe InstantEUServer n'est pas utilisé !


Fais voir le code que tu utilisais avant les InputStreamReader...

a++

[Dasson]

Ben avant c'était comme ça :

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
package main;
 
import javax.swing.*;
 
public class InstantEUServer {
 
	public static void main(String[] args){
		SwingUtilities.invokeLater(new Runnable(){
			public void run(){
					FenetrePrincipale fenetre = new FenetrePrincipale();
					//fenetre.pack();
					fenetre.setVisible(true);
			}
		});
	}
}

Et dans l'ouverture de la boite de dialogue pour démarrer l'application dans l'onglet x=arguments dans la VM arguments

Code :

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

1
2
-Dfile.encoding=UTF-8
-Dsun.jnu.encoding=UTF-8

Dasson

[adiGuba]

C'est le code des entrée/sorties de ton programme qui m'intéresse... pas le code qui lance ta fenêtre principale

a++

[Dasson]

Heu bha alors à part le code de la classe serveur, je n'ai rien d'autre.

La voici :

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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
package main.instanteu.server;
 
import java.io.IOException;
import java.net.Socket;
import java.net.ServerSocket;
import java.sql.Connection;
import java.util.ArrayList;
 
import javax.swing.SwingWorker;
 
import main.instanteu.jabber.xml.*;
import main.instanteu.jabber.Session;
import main.instanteu.jabber.Authenticator;
 
import main.database.OracleConnexion;
import main.database.UsersDB;
 
/**
La principale classe du serveur Jabber.
 
On ecoute pour une connexion, ouvre un flux Jabber XML, 
regarde leurs flux et ferme la connexion ensuite
 
*/
public class Server {
 
	private final static int    JABBER_PORT = 5222;
	private final static String SERVER_NAME = "timelux.com";
 
	// Cree les structures de donnees globale pour que chacun puisse travailler avec
	private PacketQueue packetQueue = new PacketQueue();
	private UserIndex index = new UserIndex();
	private static ServerSocket serverSocket = null;
	private static boolean work = true;
 
	public Server(){
		Authenticator.randomToken();
		connectDB();
		new SwingWorker<String, Object>(){
			protected String doInBackground()throws Exception{
				createQueueThread();
				try {
					// Creation de la socket d'ecoute du serveur
					serverSocket = new ServerSocket(JABBER_PORT);
 
				} 
				catch (IOException ex){
					// This is likely an very bad problem...
					// ... probably can't use the port...
					// ... report the problem and quit
					ex.printStackTrace();
				}
 
				// We accept incoming sockets and start new threads forever
				while (work){
					try {
						//Attente de la connexion des utilisateurs
		        		Socket newSock = serverSocket.accept();
		        		Session session = new Session(newSock);
 
		        		// Spin off a new thread to handle the connection
		        		ProcessThread processor = new ProcessThread(packetQueue,session);
		        		processor.start();
		      		}	 
					catch (IOException ie){
		      			ie.printStackTrace();
					}
				}
				return null;
			}
 
		}.execute();
	}
 
	public static void destroyServer(){
		try{
			serverSocket.close();
			work = false;
		}
		catch(Exception e){
			e.printStackTrace();
		}
	}
 
	void createQueueThread(){
		// Create the Queue worker thread to process packets in the packet queue
		QueueThread qThread = new QueueThread(packetQueue);
		qThread.setDaemon(true);
		qThread.addListener(new OpenStreamHandler(index),"stream:stream");
		qThread.addListener(new CloseStreamHandler(index),"/stream:stream");
		qThread.addListener(new MessageHandler(index),"message");
		qThread.addListener(new PresenceHandler(index),"presence");
		qThread.addListener(new RegisterHandler(index),"jabber:iq:register");
		qThread.addListener(new AuthHandler(index),"jabber:iq:auth");
	    qThread.addListener(new RosterHandler(index),"jabber:iq:roster");
		qThread.start();
	}
 
	public void loadUsers(){
		ArrayList<UsersDB> listUsers = UsersDB.rechAgentUsersDB();
 
		for(int i=0;i<listUsers.size();i++){
			UsersDB userDB = listUsers.get(i);
			User user = new User(userDB.getUsername());
			user.setUsername(userDB.getUsername());
			user.setPassword(userDB.getPassword());
			index.addUser(user.getUsername(),user);
		}
	}
 
	public void connectDB(){
		try{
			Connection connection = OracleConnexion.getConnection();
			UsersDB.setConnection(connection);
			loadUsers();
		}
		catch(Exception e){
			e.printStackTrace();
		}
	}
 
	public static int getJABBER_PORT() {
		return JABBER_PORT;
	}
 
	public static String getSERVER_NAME() {
		return SERVER_NAME;
	}
}

Dasson

[adiGuba]

Déjà ton code n'est pas très propre et tu as de forte chance de laisser des flux ouvert (variable static, méthode destroyServer() pas appelé, ...)


Ensuite ce n'est toujours pas là que tu fais tes opérations de lecture/écriture...
C'est là que tu dois utiliser les InputStreamReader/OutputStreamWriter !


a++

[Dasson]

Ha voilà j'ai trouvé ce que tu me demandais, et en effet ça venait de là.

Code avant :

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
public Writer getWriter() throws IOException {
		if (writer == null){
			writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
		}
		return writer;
	}
 
	public Reader getReader() throws IOException {
		if (reader == null){
			reader = new XercesReader(socket.getInputStream());
		}
		return reader;
	}

Code après :

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
public Writer getWriter() throws IOException {
		if (writer == null){
			writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(),"UTF-8"));
		}
		return writer;
	}
 
	public Reader getReader() throws IOException {
		if (reader == null){
			reader = new XercesReader(new InputStreamReader(socket.getInputStream(),"UTF-8"));
		}
		return reader;
	}

Et maintenant le code cyrillique passe sans problème.

Je vais tester ça dans un .jar, je te tiens au courant

Dasson

[Dasson]

Merci ça marche très bien maintenant.

Dasson