synchronized java

synchronized java - Java - Programmation

Marsh Posté le 23-01-2013 à 09:57:47    

Bonjour, je vient vers vous car j'ai un soucis avec mon code java que je n'arrive pas à élucider.
C'est un code qui permet de faire un réseau client/serveur avec comme client as3 et le serveur en java.
Le soucis vient de facon aléatoire dans le temps mais toujours au meme endroit dans le code.
Voici en premier le code as3 :  

Code :
  1. var xmlSocket:XMLSocket = new XMLSocket();
  2. xmlSocket.addEventListener(Event.CONNECT , onConnected);
  3. xmlSocket.connect("1.2.3.4",5678);
  5. function onConnected(evt:Event)
  6. { xmlSocket.send("intel~est connecté(e)" );
  7. trace("connection = ok" );
  8. }


 
Puis le code lancement serveur:  

Code :
  1. package xsocketchatserver;
  3. import java.io.BufferedWriter;
  4. import java.io.File;
  5. import java.io.FileWriter;
  6. import java.text.SimpleDateFormat;
  7. import java.util.Date;
  8. import org.xsocket.connection.*;
  10. public class XSocketChatServer
  11. {   protected static IServer srv = null;
  12.    
  13.     // code servant a ecrire dans le fichier log
  14.     static BufferedWriter bw = null;
  15.     // code servant a ecrire dans le fichier log
  16.    
  17.     public static void main(String[] args)
  18.     {   try
  19.         {   // code servant a ecrire dans le fichier log
  20.             SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss" );
  21.             String monHeure = sdf.format(new Date());
  22.             String content = monHeure + " : main<br/>";
  23.             File file =new File("logChat.txt" );
  24.             if(!file.exists()){file.createNewFile();}
  25.             bw = new BufferedWriter(new FileWriter(file,true));
  26.             bw.write(content);
  27.             bw.flush();
  28.             bw.close();
  29.             // code servant a ecrire dans le fichier log
  30.            
  31.             srv = new Server(5678, new xSocketDataHandler());
  32.             srv.run();
  33.         }
  34.         catch(Exception ex)
  35.         {   System.out.println(ex.getMessage());
  36.         }
  37.     }
  39.     protected static void shutdownServer()
  40.     {   try
  41.         {   // code servant a ecrire dans le fichier log
  42.             SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss" );
  43.             String monHeure = sdf.format(new Date());
  44.             String content = monHeure + " : shutdownServer<br/>";
  45.             File file =new File("logChat.txt" );
  46.             if(!file.exists()){file.createNewFile();}
  47.             bw = new BufferedWriter(new FileWriter(file,true));
  48.             bw.write(content);
  49.             bw.flush();
  50.             bw.close();
  51.             // code servant a ecrire dans le fichier log
  52.                
  53.             srv.close();
  54.         }
  55.         catch(Exception ex)
  56.         {   System.out.println(ex.getMessage());
  57.         }
  58.     }
  59. }


 
Puis le code qui traite les connections :  

Code :
  1. package xsocketchatserver;
  3. import java.io.IOException;
  4. import java.nio.BufferOverflowException;
  5. import java.nio.BufferUnderflowException;
  6. import java.nio.channels.ClosedChannelException;
  7. import java.util.*;
  8. import org.xsocket.*;
  9. import org.xsocket.connection.*;
  11. // code servant a ecrire dans le fichier log
  12. import java.io.File;
  13. import java.io.BufferedWriter;
  14. import java.io.FileWriter;
  15. import java.net.InetAddress;
  16. import java.net.NetworkInterface;
  17. import java.text.SimpleDateFormat;
  18. // code servant a ecrire dans le fichier log
  20. public class xSocketDataHandler implements IDataHandler, IConnectHandler, IDisconnectHandler
  21. {   private Set<INonBlockingConnection> sessions = Collections.synchronizedSet(new HashSet<INonBlockingConnection>());
  22.    
  23.     // code servant a ecrire dans le fichier log
  24.     static BufferedWriter bw = null;
  25.     // code servant a ecrire dans le fichier log
  26.    
  27.     public boolean onData(INonBlockingConnection nbc) throws IOException, BufferUnderflowException, ClosedChannelException, MaxReadSizeExceededException
  28.     {   // code servant a ecrire dans le fichier log
  29.         SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss" );
  30.         String monHeure = sdf.format(new Date());
  31.         String content = monHeure + " : Incoming data A : "+nbc.getRemoteAddress()+"<br/>";
  32.         File file =new File("logChat.txt" );
  33.         if(!file.exists()){file.createNewFile();}
  34.         bw = new BufferedWriter(new FileWriter(file,true));
  35.         bw.write(content);//Start writing to the output stream
  36.         bw.flush();
  37.         bw.close();
  38.         // code servant a ecrire dans le fichier log
  39.                
  40.         try
  41.         {   String data = nbc.readStringByDelimiter("\0" );
  42.            
  43.             // code servant a ecrire dans le fichier log
  44.             String contentA = monHeure + " : Incoming data B: " + data + " : "+nbc.getRemoteAddress()+"<br/>";
  45.             File fileA =new File("logChat.txt" );
  46.             if(!fileA.exists()){fileA.createNewFile();}
  47.             bw = new BufferedWriter(new FileWriter(fileA,true));
  48.             bw.write(contentA);//Start writing to the output stream
  49.             bw.flush();
  50.             bw.close();
  51.             // code servant a ecrire dans le fichier log
  52.                
  53.             if(data.trim().length() > 0)
  54.             {   //System.out.println("Incoming data : " + data);
  55.                
  56.                 // code servant a ecrire dans le fichier log
  57.                 String contentB = monHeure + " : Incoming data C: " + data + " : "+nbc.getRemoteAddress()+"<br/>";
  58.                 File fileB =new File("logChat.txt" );
  59.                 if(!fileB.exists()){fileB.createNewFile();}
  60.                 bw = new BufferedWriter(new FileWriter(fileB,true));
  61.                 bw.write(contentB);//Start writing to the output stream
  62.                 bw.flush();
  63.                 bw.close();
  64.                 // code servant a ecrire dans le fichier log
  65.          
  66.                 if(data.equalsIgnoreCase("<policy-file-request/>" ))
  67.                 {   nbc.write("<cross-domain-policy><allow-access-from domain=\"*\" to-ports=\"5678\"/></cross-domain-policy>\0" );
  68.                     nbc.flush();
  69.                     return true;
  70.                 }
  72.                 String[] message = data.split("~" );
  73.                
  74.                 // code servant a ecrire dans le fichier log
  75.                 String contentC = monHeure + " : Incoming data D: " + message + " : "+nbc.getRemoteAddress()+"<br/>";
  76.                 File fileC =new File("logChat.txt" );
  77.                 if(!fileC.exists()){fileC.createNewFile();}
  78.                 bw = new BufferedWriter(new FileWriter(fileC,true));
  79.                 bw.write(contentC);//Start writing to the output stream
  80.                 bw.flush();
  81.                 bw.close();
  82.                 // code servant a ecrire dans le fichier log
  83.                
  84.                 sendMessageToAll(message[0], message[1]);
  86.                 if(message[1].equalsIgnoreCase("chutagobyfubewigoluka" ))
  87.                 {   XSocketChatServer a = new XSocketChatServer();
  88.                     a.shutdownServer();
  89.                 }
  90.             }
  91.         }
  92.         catch(IOException | BufferOverflowException ex)
  93.         {   //System.out.println("onData: " + ex.getMessage());
  94.            
  95.             // code servant a ecrire dans le fichier log
  96.             String contentD = monHeure + " : Incoming data error : " + ex.getMessage() + " : "+nbc.getRemoteAddress()+"<br/>";
  97.             File fileD =new File("logChat.txt" );
  98.             if(!fileD.exists()){fileD.createNewFile();}
  99.             bw = new BufferedWriter(new FileWriter(fileD,true));
  100.             bw.write(contentD);//Start writing to the output stream
  101.             bw.flush();
  102.             bw.close();
  103.             // code servant a ecrire dans le fichier log
  104.         }
  106.         return true;
  107.     }
  109.     private void sendMessageToAll(String user, String message) throws IOException
  110.     {   // code servant a ecrire dans le fichier log
  111.         SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss" );
  112.         String monHeure = sdf.format(new Date());
  113.         String content = monHeure + " : Outgoing data : <b>" + user + "</b>: " + message + "<br/>";
  114.         File file =new File("logChat.txt" );
  115.         if(!file.exists()){file.createNewFile();}
  116.         bw = new BufferedWriter(new FileWriter(file,true));
  117.         bw.write(content);//Start writing to the output stream
  118.         bw.flush();
  119.         bw.close();
  120.         // code servant a ecrire dans le fichier log
  121.            
  122.         try
  123.         {   synchronized(sessions)
  124.             {   Iterator<INonBlockingConnection> iter = sessions.iterator();
  125.                
  126.                 // code servant a ecrire dans le fichier log
  127.                 String contentC = monHeure + " : Outgoing data A : <b>" + user + "</b>: " + message + "<br/>";
  128.                 File fileC =new File("logChat.txt" );
  129.                 if(!fileC.exists()){fileC.createNewFile();}
  130.                 bw = new BufferedWriter(new FileWriter(fileC,true));
  131.                 bw.write(contentC);//Start writing to the output stream
  132.                 bw.flush();
  133.                 bw.close();
  134.                 // code servant a ecrire dans le fichier log
  135.            
  136.                 while(iter.hasNext())
  137.                 {   INonBlockingConnection nbConn = (INonBlockingConnection) iter.next();
  139.                     if(nbConn.isOpen())
  140.                     {   nbConn.write("<b>" + user + "</b>: " + message + "<br />\0" );
  141.                         nbConn.flush();
  142.                     }
  143.                 }
  144.             }
  146.             //System.out.println("Outgoing data: <b>" + user + "</b>: " + message + "<br />\0" );
  147.            
  148.             // code servant a ecrire dans le fichier log
  149.             String contentA = monHeure + " : Outgoing data B : <b>" + user + "</b>: " + message + "<br/>";
  150.             File fileA =new File("logChat.txt" );
  151.             if(!fileA.exists()){fileA.createNewFile();}
  152.             bw = new BufferedWriter(new FileWriter(fileA,true));
  153.             bw.write(contentA);//Start writing to the output stream
  154.             bw.flush();
  155.             bw.close();
  156.             // code servant a ecrire dans le fichier log
  157.         }
  158.         catch(IOException | BufferOverflowException ex)
  159.         {   //System.out.println("sendMessageToAll: " + ex.getMessage());
  160.            
  161.             // code servant a ecrire dans le fichier log
  162.             String contentB = monHeure + " : Outgoing data error : " + ex.getMessage() + "<br/>";
  163.             File fileB =new File("filename.txt" );
  164.             if(!fileB.exists()){fileB.createNewFile();}
  165.             bw = new BufferedWriter(new FileWriter(fileB,true));
  166.             bw.write(contentB);//Start writing to the output stream
  167.             bw.flush();
  168.             bw.close();
  169.             // code servant a ecrire dans le fichier log
  170.         }
  171.     }
  172.    
  173.     public boolean onConnect(INonBlockingConnection nbc) throws IOException, BufferUnderflowException, MaxReadSizeExceededException
  174.     {   // code servant a ecrire dans le fichier log
  175.         SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss" );
  176.         String monHeure = sdf.format(new Date());
  177.         String content = monHeure + " : onConnect : "+nbc.getRemoteAddress()+"<br/>";
  178.         File file =new File("logChat.txt" );
  179.         if(!file.exists()){file.createNewFile();}
  180.         bw = new BufferedWriter(new FileWriter(file,true));
  181.         bw.write(content);//Start writing to the output stream
  182.         bw.flush();
  183.         bw.close();
  184.         // code servant a ecrire dans le fichier log
  185.            
  186.         try
  187.         {   // code servant a ecrire dans le fichier log
  188.             String contentA = monHeure + " : onConnect A : "+nbc.getRemoteAddress()+"<br/>";
  189.             File fileA =new File("logChat.txt" );
  190.             if(!fileA.exists()){fileA.createNewFile();}
  191.             bw = new BufferedWriter(new FileWriter(fileA,true));
  192.             bw.write(contentA);//Start writing to the output stream
  193.             bw.flush();
  194.             bw.close();
  195.             // code servant a ecrire dans le fichier log
  196.            
  197.             synchronized(sessions)
  198.             { 
  199.                 // code servant a ecrire dans le fichier log
  200.                 String contentB = monHeure + " : onConnect B : "+nbc.getRemoteAddress()+"<br/>";
  201.                 File fileB =new File("logChat.txt" );
  202.                 if(!fileB.exists()){fileB.createNewFile();}
  203.                 bw = new BufferedWriter(new FileWriter(fileB,true));
  204.                 bw.write(contentB);//Start writing to the output stream
  205.                 bw.flush();
  206.                 bw.close();
  207.                 // code servant a ecrire dans le fichier log
  208.                
  209.                 sessions.add(nbc);
  210.             }
  212.             //System.out.println("onConnect" );
  213.          
  214.             // code servant a ecrire dans le fichier log
  215.             String contentC = monHeure + " : onConnect C : "+nbc.getRemoteAddress()+"<br/>";
  216.             File fileC =new File("logChat.txt" );
  217.             if(!fileC.exists()){fileC.createNewFile();}
  218.             bw = new BufferedWriter(new FileWriter(fileC,true));
  219.             bw.write(contentC);//Start writing to the output stream
  220.             bw.flush();
  221.             bw.close();
  222.             // code servant a ecrire dans le fichier log
  223.         }
  224.         catch(Exception ex)
  225.         {   //System.out.println("onConnect: " + ex.getMessage());
  226.            
  227.             // code servant a ecrire dans le fichier log
  228.             String contentD = monHeure + " : onConnect error : " + ex.getMessage() + " : "+nbc.getRemoteAddress()+"<br/>";
  229.             File fileD =new File("logChat.txt" );
  230.             if(!fileD.exists()){fileD.createNewFile();}
  231.             bw = new BufferedWriter(new FileWriter(fileD,true));
  232.             bw.write(contentD);//Start writing to the output stream
  233.             bw.flush();
  234.             bw.close();
  235.             // code servant a ecrire dans le fichier log
  236.         }
  237.         return true;
  238.     }
  240.     public boolean onDisconnect(INonBlockingConnection nbc) throws IOException
  241.     {   try
  242.         {   synchronized(sessions)
  243.             {
  244.                 sessions.remove(nbc);
  245.             }
  247.             //System.out.println("onDisconnect" );
  248.            
  249.             // code servant a ecrire dans le fichier log
  250.             SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss" );
  251.             String monHeure = sdf.format(new Date());
  252.             String content = monHeure + " : onDisconnect : "+nbc.getRemoteAddress()+"<br/>";
  253.             File file =new File("logChat.txt" );
  254.             if(!file.exists()){file.createNewFile();}
  255.             bw = new BufferedWriter(new FileWriter(file,true));
  256.             bw.write(content);//Start writing to the output stream
  257.             bw.flush();
  258.             bw.close();
  259.             // code servant a ecrire dans le fichier log
  260.         }
  261.         catch(Exception ex)
  262.         {   //System.out.println("onDisconnect: " + ex.getMessage());
  263.            
  264.             // code servant a ecrire dans le fichier log
  265.             SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss" );
  266.             String monHeure = sdf.format(new Date());
  267.             String content = monHeure + " : onDisconnect error : " + ex.getMessage() + " : "+nbc.getRemoteAddress()+"<br/>";
  268.             File file =new File("logChat.txt" );
  269.             if(!file.exists()){file.createNewFile();}
  270.             bw = new BufferedWriter(new FileWriter(file,true));
  271.             bw.write(content);//Start writing to the output stream
  272.             bw.flush();
  273.             bw.close();
  274.             // code servant a ecrire dans le fichier log
  275.         }
  276.         return true;
  277.     }
  278. }


 
Et enfin le fichier log :  

Code :
  1. 22:19:41 : onConnect : /5.4.3.2
  2. 22:19:41 : onConnect A : /5.4.3.2
  3. 22:19:41 : onConnect B : /5.4.3.2
  4. 22:19:41 : onConnect C : /5.4.3.2
  5. 22:19:41 : Incoming data A : /5.4.3.2
  6. 22:19:41 : Incoming data B: YYY~est connecté(e) : /5.4.3.2
  7. 22:19:41 : Incoming data C: YYY~est connecté(e) : /5.4.3.2
  8. 22:19:41 : Incoming data D: [Ljava.lang.String;@2350ad83 : /5.4.3.2
  9. 22:19:41 : Outgoing data : YYY: est connecté(e)
  10. 22:19:41 : Outgoing data A : YYY: est connecté(e)
  11. 22:19:41 : Outgoing data B : YYY: est connecté(e)
  13. 22:20:03 : onConnect : /9.8.7.6
  14. 22:20:03 : onConnect A : /9.8.7.6
  15. 22:20:03 : onConnect B : /9.8.7.6
  16. 22:20:03 : onConnect C : /9.8.7.6
  17. 22:20:03 : Incoming data A : /9.8.7.6
  18. 22:20:03 : Incoming data B: XXX~est connecté(e) : /9.8.7.6
  19. 22:20:03 : Incoming data C: XXX~est connecté(e) : /9.8.7.6
  20. 22:20:03 : Incoming data D: [Ljava.lang.String;@7224ccce : /9.8.7.6
  21. 22:20:03 : Outgoing data : XXX: est connecté(e)
  22. 22:20:03 : Outgoing data A : XXX: est connecté(e)
  23. 22:20:03 : Outgoing data B : XXX: est connecté(e)
  25. 22:20:26 : Incoming data A : /9.8.7.6
  26. 22:20:26 : Incoming data B: XXX~Je te vois YYY! : /9.8.7.6
  27. 22:20:26 : Incoming data C: XXX~Je te vois YYY! : /9.8.7.6
  28. 22:20:26 : Incoming data D: [Ljava.lang.String;@6e431d9d : /9.8.7.6
  29. 22:20:26 : Outgoing data : XXX: Je te vois YYY!
  30. 22:20:26 : Outgoing data A : XXX: Je te vois YYY!
  31. 22:20:26 : Outgoing data B : XXX: Je te vois YYY!
  33. 22:21:04 : Incoming data A : /5.4.3.2
  34. 22:21:04 : Incoming data B: YYY~Moi aussi ! : /5.4.3.2
  35. 22:21:04 : Incoming data C: YYY~Moi aussi ! : /5.4.3.2
  36. 22:21:04 : Incoming data D: [Ljava.lang.String;@6d552524 : /5.4.3.2
  37. 22:21:04 : Outgoing data : YYY: Moi aussi !
  38. 22:21:04 : Outgoing data A : YYY: Moi aussi !
  39. 22:21:04 : Outgoing data B : YYY: Moi aussi !
  41. 22:22:47 : Incoming data A : /5.4.3.2
  42. 22:22:47 : Incoming data B: YYY~je viens de partir !! : /5.4.3.2
  43. 22:22:47 : Incoming data C: YYY~je viens de partir !! : /5.4.3.2
  44. 22:22:47 : Incoming data D: [Ljava.lang.String;@41796abe : /5.4.3.2
  45. 22:22:47 : Outgoing data : YYY: je viens de partir !!
  46. 22:22:47 : Outgoing data A : YYY: je viens de partir !!
  48. 22:24:30 : onConnect : /5.4.3.2
  49. 22:24:30 : onConnect A : /5.4.3.2


 
Le probleme survient à 22:24:30 lorsque l'ip 5.4.3.2 tente de se connecter, la connection s'etablit correctement comme on peut le voir dans les log et dans le trace dans le fichier as3 mais bloque au niveau du synchronized(sessions){} dans la fonction public boolean onConnect(INonBlockingConnection nbc) throws IOException, BufferUnderflowException, MaxReadSizeExceededException.
 
Lorsque cela arrive, tout le systeme du d'echange de message du tchat est planté, je suis obligé de kill le processus (le serveur java etant sur une debian) et de le relancer. Cela provient au bout de 30 min ou au bout de 5h, qu'il y ai 10 ou 80 personnes dessus.
 
N'etant pas dev java de base, il y a surement une erreur dedans mais je ne la voit pas. Merci pour vos futures réponses.

Reply

Marsh Posté le 23-01-2013 à 09:57:47   

Reply

Sujets relatifs:

Leave a Replay

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