TreeMap Serialisation -> socket -> deserialisation

TreeMap Serialisation -> socket -> deserialisation - Java - Programmation

Marsh Posté le 13-04-2007 à 07:52:46    

J'ai fait un simple client/serveur pour expliquer mon probleme parceque là je seche.
Le serveur a une treeMap<Integer, Square> avec quelques valeurs dedans.
Le client interroge le serveur pour qu'il lui renvoit le contenu du TreeMap, tout ca en utilisant la serialisation d'objet.
 
Probleme : Bien que le serveur modifie le contenue de la treemap avant chaque reponse, le client recoit toujours la meme reponse  :cry:  
 
Quelqu'un a une idée de la raison ?
 
Merci
 
 
Code du client :

Code :
  1. import java.io.ObjectInputStream;
  2. import java.io.ObjectOutputStream;
  3. import java.net.Socket;
  4. import java.util.Iterator;
  5. import java.util.Timer;
  6. import java.util.TreeMap;
  8. public class TestClient {
  10. public TreeMap<Integer, Square> squares;
  12. ObjectOutputStream oos;
  13. ObjectInputStream ois;
  15. public void DoIt() throws Exception  {
  16.  Socket socket = new Socket("localhost", 4000);
  17.  oos = new ObjectOutputStream(socket.getOutputStream());
  18.  ois  = new ObjectInputStream(socket.getInputStream());
  20.  System.out.println("Connected" );
  22.  GetSquares();
  23.  GetSquares();
  24.  GetSquares();
  26. }
  27.     private void GetSquares() throws Exception {
  28.      RequestInfo ri = new RequestInfo();
  29.      ri.function = RequestInfoFunction.rifInit;
  30.      ri.posX = 3;
  31.        
  32.      oos.writeObject(ri);
  33.      squares = (TreeMap<Integer, Square> )ois.readObject();
  34.    
  35.      System.out.println("---" );
  36.  Iterator<Square> i = squares.values().iterator();
  37.         while(i.hasNext()){
  38.          Square aSquare = i.next();
  39.          System.out.println(String.format("%d %d %d", aSquare.id, aSquare.posX, aSquare.posY));
  40.         }
  41.     }
  43. /**
  44.  * @param args
  45.  */
  46. public static void main(String[] args) throws Exception {
  47.   TestClient testClient = new TestClient();
  48.   testClient.DoIt();
  50. }
  52. }


 
Code du serveur :

Code :
  1. import java.awt.Color;
  2. import java.io.*;
  3. import java.net.*;
  4. import java.util.Iterator;
  5. import java.util.TreeMap;
  7. public class TestServer extends Thread {
  9. private ServerSocket serverSocket;
  11. public TreeMap<Integer, Square> squares;
  13. public static void main(String argv[]) throws Exception {
  14.  new SquareServer();
  15. }
  17. public TestServer() throws Exception {
  18.  squares = new TreeMap<Integer, Square>();
  19.  int i = 0;
  20.  for (i = 0; i < 3; i++) {
  21.   Square curSquare = new Square();
  22.   curSquare.id = i;
  23.   curSquare.posX = i * 20;
  24.   curSquare.posY = i * 20;
  25.   curSquare.color = new Color(255, i * 20, 255);
  26.   squares.put(i, curSquare);
  27.  }
  28.  serverSocket = new ServerSocket(4000);
  29.  System.out.println("Server listening on port 4000." );
  30.  this.start();
  31. }
  33. public void run() {
  34.  while (true) {
  35.   try {
  36.    System.out.println("Waiting for connections." );
  37.    Socket client = serverSocket.accept();
  38.    System.out.println("Accepted a connection from: "
  39.      + client.getInetAddress());
  40.    ConnectTest c = new ConnectTest(client);
  41.    c.squares = squares;
  42.   } catch (Exception e) {
  43.    System.out.println(e.getMessage());
  44.   }
  45.  }
  46. }
  47. }
  49. class ConnectTest extends Thread {
  50. private Socket client = null;
  52. private ObjectInputStream ois = null;
  54. private ObjectOutputStream oos = null;
  56. public TreeMap<Integer, Square> squares = null;
  58. public ConnectTest(Socket clientSocket) throws Exception {
  59.  client = clientSocket;
  60.  ois = new ObjectInputStream(client.getInputStream());
  61.  oos = new ObjectOutputStream(client.getOutputStream());
  63.  this.start();
  64. }
  66. public void run() {
  67.  try {
  68.   while (client.isConnected()) {
  69.    RequestInfo ri = (RequestInfo) ois.readObject();
  70.    System.out.println("New request" );
  71.    squares.get(0).posX = squares.get(0).posX + 1;
  72.    oos.writeObject(squares);
  73.    oos.flush();
  74.    Iterator<Square> i = squares.values().iterator();
  75.    System.out.println("---" );
  76.    while (i.hasNext()) {
  77.     Square aSquare = i.next();
  78.     System.out.println(String.format("%d %d %d", aSquare.id,
  79.       aSquare.posX, aSquare.posY));
  80.    }
  82.   }
  84.   ois.close();
  85.   oos.close();
  87.  } catch (Exception e) {
  88.   System.out.println(e.getMessage());
  89.  }
  90. }
  91. }


 
Classe Square

Code :
  1. import java.awt.Color;
  2. import java.io.Serializable;
  5. public class Square implements Serializable, Comparable<Square> {
  7. static final long serialVersionUID = 0;
  9. public int id;
  10. public int posX, posY;
  11. public Color color;
  12. boolean locked = false;
  14. public int compareTo(Square square){
  15.  return square.id - this.id;
  16. }
  18. }


Reply

Marsh Posté le 13-04-2007 à 07:52:46   

Reply

Marsh Posté le 13-04-2007 à 16:49:46    

up :)

Reply

Marsh Posté le 16-04-2007 à 14:10:52    

un p'ti up

Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed