Serveur web java multithread

Serveur web java multithread - Java - Programmation

Marsh Posté le 04-03-2013 à 17:49:40    

Bonjour, voilà je dois mettre en place un client qui va faire une requête http, un proxy qui va rediriger la requête du client sur le port 8000 et le serveur web qui doit lui répondre. J'ai réussi à faire un client autonome (il faire la requête http et récupère le résultat dans un fichier .html). J'attaque donc maintenant le serveur web mais j'ai des problèmes au niveau de l'objet Thread donc voici l'erreur : no suitable thread for Application.
Je m'explique le serveur web se divise en 2 script :  
 
- Le 1er Socket_Serveur.java : créer une socket d'ecoute sur un port donné (8000 est un exemple :)) une fois la requête reçu, le serveur va créer un Thread après avoir accepter la connexion et faire appel à la classe Application.
 
- Application.java : cette classe va permettre au serveur de trier la requête http et envoyer bloc par bloc la réponse à la requête http.
 
Pour faire simple :  
 
- le client on va lui créer une requête http static : www.google.fr:80
- le proxy va rediriger la requête sur le port 8000 (port d'ecoute du serveur web)
- le serveur répond au proxy, ce dernier va stocker la réponse dans un fichier html et l'envoyer au client
 
Mon problème : Le Thread
 
voilà les 2 scripts :
 
Socket_Serveur.java :

Code :
  1. package socket_serveur;
  3. //~--- JDK imports ------------------------------------------------------------
  5. import java.io.*;
  7. import java.net.*;
  9. /**
  10. *
  11. * @author Furil
  12. */
  13. public class Socket_Serveur {
  15.     /**
  16.      * @param args the command line arguments
  17.      */
  18.     public static void main(String[] args) {
  20.         // TODO code application logic here
  21.         ServerSocket ecoute = null;
  23.         try {
  24.             ecoute = new ServerSocket(Integer.parseInt(args[0]));
  25.         } catch (IOException e) {
  26.             System.err.println("Impossible d'ecouter sur le port indiqué" );
  27.             System.exit(1);
  28.         }
  30.         Socket client = null;
  32.         while (true) {
  33.             try {
  34.                 client = ecoute.accept();
  36.                
  37.                 Thread fils = new Thread(new Application(client));   //  l'erreur se trouve ici no suitable thread for application //
  39.                 System.out.println("Thread " + fils.getName() + "cree" );
  40.                 fils.start();
  41.             } catch (IOException e) {
  42.                 System.err.append("Erreur d'accept()'." );
  43.                 System.exit(1);
  44.             }
  45.         }
  46.     }
  47. }


 
 
et la classe Application :
 

Code :
  1. package socket_serveur;
  2. import java.io.*;
  3. import java.net.*;
  4. import java.util.regex.*;
  6. /**
  7. *
  8. * @author Furil
  9. */
  10. public class Application {
  11.    
  12.     Socket client;
  13.     Application(Socket client) throws SocketException{
  14.         this.client = client;
  15.     }
  16.    
  17.     //Corps de l'appli
  18.    
  19.     public void run(){
  20.         try {
  21.             BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream(), "8859_1" ));
  22.             OutputStream out = client.getOutputStream();
  23.             PrintWriter pout = new PrintWriter(new OutputStreamWriter(out,"8859_1" ),true);
  24.            
  25.             //lire la requete HTTP dnas la socket
  26.            
  27.             String requete = in.readLine();
  28.             System.out.println("Requete:"+requete);
  29.            
  30.             //Filtrage de la requete grace a l'expression reguliere
  31.            
  32.             Matcher get = Pattern.compile("GET (/?\\S*).*" ).matcher(requete);
  33.            
  34.             //traitement de la requete aprés filtrage
  35.            
  36.             if(get.matches()){
  37.                 requete = get.group(1);
  38.                 if(requete.endsWith("/" ) || requete.equals("" ))
  39.                     requete = requete + "index.html";
  40.                
  41.                 //envoie du fichier par bloc
  42.                
  43.                 try{
  44.                     FileInputStream fis = new FileInputStream(requete);
  45.                     byte [] data = new byte [64*1024];
  46.                    
  47.                     for(int read = 0;(fis.read(data))> -1;){
  48.                         out.write(data,0,read);
  49.                         out.flush();
  50.                     }
  51.                        
  52.                 } catch(FileNotFoundException e){
  53.                     pout.println("Objet non trouve" );
  54.                 }
  55.             }else
  56.                 pout.println("requete erronee" );
  57.             client.close();
  58.            
  59.                
  60.                
  61.             } catch(IOException e){
  62.                
  63.                 System.out.print("Erreur E/S"+e);
  64.            
  65.         }
  66.     }
  67.    
  68.    
  69. }


 
 
Bon après si j'ai fais trop compliqué n'hésitez pas à me conseiller, j'ai commencé java socket depuis peu ^^ donc je suis ouvert à toute solution :)
 
Merci et bonne soirée :)

Reply

Marsh Posté le 04-03-2013 à 17:49:40   

Reply

Marsh Posté le 04-03-2013 à 19:05:46    

  • Tu tentes d'instancier un Thread en lui passant une Application. Ce constructeur n'existe pas. Par contre, un Runnable conviendrait
  • Thread, c'est vraiment bas niveau et old school
  • Je passe sur la gestion des exceptions et les différents buffers mal fermés, je suppose que tu débutes


---------------
http://devicenotready.com/ - Informatique et autres bizarreries
Reply

Marsh Posté le 04-03-2013 à 19:26:50    

Bonsoir devicenotready,
 
Tous d'abord merci de ta réponse. Ensuite oui je débute :) .
Concernant Application, dans Application.java, je précise qu'il aura en paramètre le socket client donc il est bien existant.
Après pour les exceptions et buffer mal fermés je vais regarder ça de plus près . :)
Ensuite Thread, je dois l'utiliser, ça m'est imposé ^^
En tout cas merci d'avoir pris le temps de répondre et bonne soirée :)

Reply

Marsh Posté le 25-03-2013 à 21:32:29    

Voilà après quelques modifications il me reste toujours une erreur(Au niveau de la classe Application) :
 

Code :
  1. byte[] data = new byte[64*1024]


 
Cette erreur disparaît lors de l'insertion d'un try/catch. Mais j'ai du mal le placé car il me dit d'utiliser finally au lieu du catch. voilà la partie du code :
 

Code :
  1. try{
  2.     FileInputStream fis = new FileInputStream(requete);
  3.     ByteArrayOutputStream bos = new ByteArrayOutputStream();
  4.     byte[] data = new byte[64*1024];
  5.    
  6.     for(int read; (read=fis.read(data)) > -1;)
  7.         out.write(data);
  8.         out.flush();
  9.    
  10.     }
  11.     catch{
  12.         (Exception e)
  13.         }
  14.         client.close();
  15.    
  16.    
  17.    
  18.        
  19. }
  20. }

Reply

Sujets relatifs:

Leave a Replay

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