Server multithread java socket

Server multithread java socket - Java - Programmation

Marsh Posté le 13-05-2012 à 12:28:56    

Bonjour à tous j'ai un probléme c'est que quand il ya un seul client le serveur marche trés bien jenvoi des fichier, une fois qu'il ya un autre client qui s'ajoute le nouveau client envoi des fichiers mais il n'arrivent pas. Voici mon code java merci.
 
Serveur
 

Code :
  1. public class server implements Runnable {
  3.     Socket socket;
  4. server(Socket csocket) {
  5.         this.socket = csocket;
  6.     }
  8.     public static void main(String args[]) throws Exception {
  9.         ServerSocket ssock = new ServerSocket(1234);
  10.         System.out.println("Listening" );
  11.         int a = 0;
  12.         while (true) {
  13.             Socket sock = ssock.accept();
  14.             a++;
  15.             InetAddress addr = sock.getInetAddress();
  16.             System.out.println("Connection made to " + addr.getHostName() + " (" + addr.getHostAddress() + " ) ID: " + a);
  17.             new Thread(new bokal(sock)).start();
  18.         }
  19.     }
  21.     public void run() {
  22.         try {
  23.             InputStream in =socket.getInputStream();
  24.             DataInputStream dis = new DataInputStream(socket.getInputStream());
  25.             String file = dis.readUTF();
  26.             String file1 = dis.readUTF();
  27.             String file2 = dis.readUTF();
  28.             int i=dis.readInt();
  29.             if(i==1)
  30.             {
  32.             File directorio = new File("c:\\dossier\\"+file1+"\\"+file2+"\\" );
  33.             directorio.mkdirs();
  34.             }
  35.             if(file != null)
  36.             {
  37.                BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("C:\\dossier\\"+file1+"\\"+file2+"\\"+ file));
  38.                 byte buf[] = new byte[1024];
  39.                 int len;
  40.                 while((len = in.read(buf)) > 0)
  41.                 {
  42.                     bos.write(buf, 0, len);
  43.                 }
  44.               in.close();
  45.           //    bos.flush();
  46.              
  47.             bos.close();
  48.             }
  49.        
  50.             socket.close();
  51.         } catch (IOException e) {
  52.             System.out.println(e);
  53.         }
  54.     }
  55. }


 
Client
 
 

Code :
  1. public  void Client()
  2. {
  3.  
  4.       int in;
  5.       byte[] byteArray;
  6.       File archivo = null;
  7.       String direccionArchivo = null;
  8.       String IP = null;
  9.       int i=0;
  10.       try
  11.       {
  12.           IP = JOptionPane.showInputDialog(null,"Entrez Lip du pc distant","Cliente",JOptionPane.CANCEL_OPTION);
  13.           Socket via = new Socket(IP, 1234);
  14.           if(via.isConnected())
  15.           {
  16.             JOptionPane.showMessageDialog(null, "Conectado al servidor: " + IP);
  17.        
  19.             JFileChooser selector = new JFileChooser();
  20.             selector.setDialogTitle("Selecciona el archivo a enviar" );
  21.             int resultado = selector.showOpenDialog(null);
  22.             if (resultado == JFileChooser.APPROVE_OPTION)
  23.             {
  24.                 archivo = selector.getSelectedFile();
  25.                 direccionArchivo = archivo.getPath().toString();
  26.             }else{
  27.          
  28.              via.close();
  29.            
  30.             }
  32.             BufferedInputStream bis = new BufferedInputStream(new FileInputStream(direccionArchivo));
  33.             BufferedOutputStream bos = new BufferedOutputStream(via.getOutputStream());
  35.             //Enviamos el nombre del archivo
  36.             DataOutputStream dos = new DataOutputStream(via.getOutputStream());
  37.             dos.writeUTF(archivo.getName());
  38.             dos.writeUTF(s);
  39.             dos.writeUTF(s1);
  40.             dos.writeInt(1);
  41.             dos.writeInt(2);
  42.            
  44.             byteArray = new byte[8192];
  45.             while ((in = bis.read(byteArray)) != -1)
  46.             {
  47.                 bos.write(byteArray,0,in);
  48.             }
  49.  via.close();       
  50.  bis.close();
  51. bos.close();
  54.      
  55.         }
  57.       }catch (Exception e) {//JOptionPane.showMessageDialog(null,e,"Error",JOptionPane.ERROR_MESSAGE);
  58.        }
  60.       }


 
 
Merci à tous.

Reply

Marsh Posté le 13-05-2012 à 12:28:56   

Reply

Marsh Posté le 13-05-2012 à 16:56:29    

balise "code=java".

Reply

Sujets relatifs:

Leave a Replay

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