Sérialisation avec sockets

Version imprimable

Hello!

j'essaie de simuler un échange client-serveur à travers les sockets, et ce en utilisant la sérialisation. Je dois faire qqch de faux dans la transmission de mon objet, parce que quand je veux lire depuis le serveur un objet envoyé par le client, c'est comme si l'objet (en l'occurence un tableau de byte) n'existait pas.

La classe d'échange entre le client et le serveur.
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 import java.util.*; import java.io.*; public class Echange implements Serializable { private byte[] test; public void setTest(byte[] testTable) { this.test = testTable; } public byte[] getTest() { return test; } }
Le client, qui émet un objet à destination du serveur
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 import java.io.*; import java.net.*; import java.security.*; import java.security.spec.*; import javax.crypto.*; import javax.crypto.spec.*; import java.util.*; public class DHClient { public static void main(String[] args) throws Exception { Echange transfert = new Echange(); //la connexion entre le serveur est le client a été initialisée. Le but est maintenant de transmettre ce tableau de bytes au serveur. byte[] testNumber = new byte[150]; testNumber[0] = 4; transfert.setTest(testNumber); System.out.println("nb test = " + transfert.getTest()[0]); out.writeObject(transfert);
Le code du serveur, censé réceptionné le tableau du client.
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 import java.security.spec.*; import javax.crypto.*; import javax.crypto.spec.*; import java.util.*; public class DHServer { public static int port = 8080; public static void main(String[] args) throws Exception { Echange transfert = new Echange(); // la connexion a été créée byte[] test = new byte[10]; System.out.println("valeur test = " + transfert.getTest()[0] );
C'est ce dernier bout qui pose problème. Il ne doit pas reconnaître l'objet puisqu'il donne une "NullPointerException"... ce n'est pas un problème de socket ou de connexion, parce que des variables envoyées seules passent sans problème. C'est bien la sérialisation qui pose problème, j'ai l'impression... quelqu'un peut-il m'aider?

D'avance, merci à lui!

Sébastien

03/05/2004, 14h20
Debernad

Popur pouvoir t'aider, il nous manque des informations dans le code que tu nous as fournis ...

le code de Echange me paraît conforme ...
le code de DHClient me parait aussi complet , en partant du principe que la variable "out" est un ObjectOutputStream lié au flux de sortie de ta socket ...

Par contre, le code DHServer est trop incomplet, on ne voit null part de "in.readObject()" pour lire le flux d'entrée de la socket ..

Pourrais t'on avoir une version de DHServer plus explicite ?

Oups, en effet, à trop vouloir rendre le code lisible, je l'ai trop épuré... la classe Echange reste inchangée, mais je la remets par souci de lisibilité:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
 
import java.util.*;
import java.io.*;
 
public class Echange implements Serializable {
 
   private byte[] test;
 
   public void setTest(byte[] testTable) {
       this.test = testTable;
   }
 
   public byte[] getTest() {
      return test;
   }
}

Pour DHClient, out est en effet un ObjectOutputStream, déclaré comme suit (le reste ne change pas):

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
 
import java.io.*;
import java.net.*;
import java.security.*;
import java.security.spec.*;
import javax.crypto.*;
import javax.crypto.spec.*;
import java.util.*;
 
 
public class DHClient {
   public static void main(String[] args) throws Exception {
 
   //addr et DHServer.port sont préalablement définis
   Socket s = new Socket(addr, DHServer.port);
   ObjectOutputStream out = new ObjectOutputStream(s.getOutputStream());
 
   Echange transfert = new Echange();
 
   //la connexion entre le serveur est le client a été initialisée. Le but est maintenant de transmettre ce tableau de bytes au serveur.
   byte[] testNumber = new byte[150];
   testNumber[0] = 4;
   transfert.setTest(testNumber);
   System.out.println("nb test = " + transfert.getTest()[0]);
   out.writeObject(transfert); 
   }
}

Pour DHServer:

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
 
import java.security.spec.*;
import javax.crypto.*;
import javax.crypto.spec.*;
import java.util.*;
 
public class DHServer {
 public static void main(String[] args) throws Exception {
 
   Echange transfert = new Echange();
 
   //attends la connexion
   ServerSocket ss = new ServerSocket(port);
   System.out.println("Started: " + ss);
   Socket s = ss.accept();
   ObjectOutputStream out = new ObjectOutputStream(s.getOutputStream());
   ObjectInputStream in = new ObjectInputStream(s.getInputStream());
 
   transfert = (Echange)in.readObject();
 
   byte[] test = new byte[10];
   System.out.println("valeur test = " + transfert.getTest()[0] ); 
 }
}

Voilà, j'espère que cette fois c'est plus compréhensible!

Sébastien

J'ai repris les sources que tu m'as donné et les ai modifié pour en cela :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
 
import java.io.*; 
import java.net.*; 
import java.util.*; 
 
public class DHClient { 
   public static void main(String[] args) throws Exception { 
 
   //addr et DHServer.port sont préalablement définis 
   Socket s = new Socket(args[0], Integer.parseInt(args[1])); 
   ObjectOutputStream out = new ObjectOutputStream(s.getOutputStream()); 
 
   Echange transfert = new Echange(); 
 
   //la connexion entre le serveur est le client a été initialisée. Le but est maintenant de transmettre ce tableau de bytes au serveur. 
   byte[] testNumber = new byte[150]; 
   testNumber[0] = 4; 
   transfert.setTest(testNumber); 
   System.out.println("nb test = " + transfert.getTest()[0]); 
   out.writeObject(transfert); 
   } 
}

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
 
import java.net.*;
import java.util.*; 
import java.io.*;
 
public class DHServer { 
 public static void main(String[] args) throws Exception { 
 
   Echange transfert = new Echange(); 
 
   //attends la connexion 
   ServerSocket ss = new ServerSocket(Integer.parseInt(args[0])); 
   System.out.println("Started: " + ss); 
   Socket s = ss.accept(); 
   ObjectOutputStream out = new ObjectOutputStream(s.getOutputStream()); 
   ObjectInputStream in = new ObjectInputStream(s.getInputStream()); 
 
   transfert = (Echange)in.readObject(); 
 
   byte[] test = new byte[10]; 
   System.out.println("valeur test = " + transfert.getTest()[0] ); 
 } 
}

et le source de Echange identique au tien ...

Puis, aprés avoir compilé, j'ai executé le code en tapant les lignes suivantes sur 2 consoles différentes :

Code:

1
2
 
java DHServer 6000

Code:

1
2
 
java DHClient 127.0.0.1 6000

et je n'ai obtenu aucune exeception ... voici la sortie des 2 résultats obtenus :

Code:

1
2
3
 
Started: ServerSocket[addr=0.0.0.0/0.0.0.0,port=0,localport=6000]
valeur test = 4

Code:

1
2
 
nb test = 4

Peut tu essayer le même exemple que moi pour voir si tu as des disfonctionnements ou pas ?
Si tu n'en as pas, cela signifie que ton erreur ne vient pas de cette portion de code ...
Enfin peut tu nous donner l'exception compléte que tu as, c'est à dire le StackTrace ?

03/05/2004, 20h24
sebi77

J'ai recopié ton code et changé/rajouté petit à petit ce qu'il me fallait et ça marche maintenant! Merci bien!

Sébastien