Pb Protocole TCP[Résolu]

Pb Protocole TCP[Résolu] - Java - Programmation

Marsh Posté le 24-12-2012 à 15:44:12    

Bonjour,  
 
 Je cherche à programmer une application de vidéo à la demande, mais je rencontre des erreurs à l'exécution...
Peut etre pouvez vous m'aider ?
 
Mon application se compose d'une class Serveur (canal de commande) et d'une classe ServeurDonnee (canal de communication)
spécialisé en deux sous-classe : TCP_PUSH et TCP_PULL.
Pour me connecter au serveur, j'utilise soit du tellnet soit des applications clients trouvé sur le net.
Je me connecte alors au serveur, qui m'envoie un catalogue des flux dont il dispose.  
Je me connecte alors au serveur qui possède le flux qui m'intéresse.
Je créer alors un autre terminal et je demande à ce nouveau serveur de m'envoyer les données sur un nouveau port par l'intermédiaire des commandes "GET id" et "START".
 
Voici le détail de mes classes :  
 
 
class Serveur :
 
 

Code :
  1. public class Serveur implements Runnable{
  5. public static void main(String[] args) throws Exception {
  7.  ServerSocket srv = new ServerSocket(port());
  8.  while(true){
  9.  Socket client=srv.accept();
  10.        Thread t = new Thread(new Serveur(client));
  11.        t.start();
  12.       System.out.println("client connecté" );
  13.  }
  14.    }
  16.    BufferedReader clientInput_1;
  17.    OutputStream clientOutput_1;
  18.    OutputStream clientOutput_2;
  19.    PrintWriter out;
  20.    File f;
  21.    Socket clientInput;
  22.    ArrayList<String> IMAGE_ID;
  23.    float ips=0;
  24.    String clientIP;
  25.   Thread serveurDonnee;
  26.   String protocole;
  27.  
  29.   public Serveur(Socket client) throws Exception {
  30.      clientInput_1 = new BufferedReader(
  31.        new InputStreamReader(client.getInputStream()));
  32.      clientOutput_1 = client.getOutputStream();
  33.       out=new PrintWriter(clientOutput_1, true);
  34.       clientIP=client.getInetAddress().getHostAddress();
  35.       IMAGE_ID=new ArrayList<String>();
  36.      
  37.       protocole="TCP_PUSH";
  40.      
  41.    }
  42.  
  43.   public int copyStream(InputStream in, OutputStream out, boolean close)
  44.   throws IOException
  45.   {
  46.     int nbytes = 0, total = 0;
  47.     byte[] buf = new byte[1024];
  48.     while ((nbytes = in.read(buf)) > 0)
  49.     {
  50.     out.write(buf, 0, nbytes);
  51.     total += nbytes;
  52.    }
  53.    if(close) in.close();
  54.    return total;
  55.  }
  56.  
  57.   public String entete(int number)
  58.   {
  59.    String s="";
  60.    s+="HTTP/1.1 200 OK\n\r";
  61.    s+="Server: TP_4IF_MediaServer\n\r";
  62.    s+="Connection: Keep-Alive\n\r";
  63.    s+="Content-Type: text/txt\n\r";
  64.    s+="Content-Length: "+number+"\n\r";
  65.    return s;
  66.   }
  67.  
  68.   public static int port() throws IOException
  69.   {
  70.    int res=0;
  71.    File startup =new File("startup.txt" );
  72.    InputStream ips=new FileInputStream(startup);
  73.    InputStreamReader ipsr=new InputStreamReader(ips);
  74.    BufferedReader br=new BufferedReader(ipsr);
  75.    br.readLine();
  76.    res=Integer.parseInt(br.readLine().split(": " )[1]);
  77.    br.close();
  78.    return res;
  79.   
  80.   }
  81.  
  82.   public File creerFichier() throws Exception
  83.   {
  85.    File f=new File("Catalogue.txt" );
  86.    File startup =new File("startup.txt" );
  87.    InputStream ips=new FileInputStream(startup);
  88.    InputStreamReader ipsr=new InputStreamReader(ips);
  89.    BufferedReader br=new BufferedReader(ipsr);
  90.    OutputStream ops=new FileOutputStream(f);
  91.    OutputStreamWriter opsr=new OutputStreamWriter(ops);
  92.    BufferedWriter bw=new BufferedWriter(opsr);
  93.    String ligne;
  94.    ligne=br.readLine();
  95.    bw.write(ligne);
  96.    bw.newLine();
  97.    ligne=br.readLine();
  98.    bw.write(ligne);
  99.    bw.newLine();
  100.    while ((ligne=br.readLine())!=null)
  101.    {
  102.     File g=new File(ligne);
  103.     InputStream ips2=new FileInputStream(g);
  104.     InputStreamReader ipsr2=new InputStreamReader(ips2);
  105.     BufferedReader br2=new BufferedReader(ipsr2);
  106.     String contenu = "Object ";
  107.     String ligne2;
  108.     int c=0;
  109.     while (c++<7)
  110.     {
  111.      ligne2=br2.readLine();
  112.      contenu+=ligne2.split(": " )[0].toLowerCase()+"="+ligne2.split(": " )[1]+" ";
  113.     }
  114.     bw.write(contenu);
  115.     bw.newLine();
  116.     br2.close();
  117.    }
  118.    bw.newLine();
  119.    br.close();
  120.    bw.close();
  121.    return f;
  122.   }
  124.  
  125.   public void run() {
  126.   
  127.    boolean pause=false;
  128.    boolean first_Get_Occ_TCP_PULL=true;
  129.    TCP_PULL tcp_pull=null;
  130.    TCP_PUSH tcp_push=null;
  131.    int ID=0;
  132.    int port_client=0;
  133.   
  134.    while(true){
  135.       try {
  137.         String line = clientInput_1.readLine();
  138.       
  139.         if(line.equals("GET /catalog.txt HTTP/1.0" ))
  140.         {
  141.          File f = creerFichier();
  142.         if(f.exists()) {
  143.          out.println(entete((int)f.length()));
  144.              copyStream(new FileInputStream(f), clientOutput_1, true);
  145.              System.out.println(" transfer done." );
  146.            }
  147.            else {
  148.              System.out.println(" file is not here..." );
  149.            }
  150.         }
  151.       
  152.         if(line!=null)
  153.         {
  154.          System.out.println("line="+line);
  155.         }
  156.       
  157.         if(line.substring(0, 3).equals("END" ))
  158.         {
  159.          System.out.println("Commande End envoyée" );
  160.         if(protocole.equals("TCP_PULL" ))
  161.          {
  162.           tcp_pull.end();
  163.          }
  164.         if(protocole.equals("TCP_PUSH" ))
  165.         {
  166.          tcp_push.end();
  167.         }
  168.         }
  169.       
  170.         if(line.equals("test" )){
  171.          out.println("bien reçu" );
  172.         }
  173.       
  174.         if(line.substring(0, 3).equals("GET" ))
  175.         { 
  177.          if(first_Get_Occ_TCP_PULL)
  178.          {
  179.           first_Get_Occ_TCP_PULL=false;
  180.           ID=Integer.parseInt(line.split(" " )[1]);
  181.           port_client=Integer.parseInt(clientInput_1.readLine().split(" " )[1]);
  182.           System.out.println("client écoute sur port "+port_client+" et demande "+ID);
  183.         
  184.           if(protocole.equals("TCP_PULL" ))
  185.           {
  186.            tcp_pull=new TCP_PULL(clientIP,port_client,ID);
  187.           }
  188.           if(protocole.equals("TCP_PUSH" ))
  189.           {
  190.            tcp_push=new TCP_PUSH(clientIP,port_client,ID);
  191.           }
  192.         
  193.          }else
  194.          {
  195.           if(protocole.equals("TCP_PULL" ))
  196.           {
  197.            int im_id=Integer.parseInt(line.split(" " )[1]);
  198.            tcp_pull.setId(im_id);
  199.           }
  200.          }
  202.         }
  203.       
  204.         if(line.substring(0, 5).equals("START" ))
  205.         {
  206.          if(pause)
  207.          {
  208.           tcp_push.reprend();
  209.           pause=false;
  210.          }else
  211.          {
  212.           tcp_push.start();
  213.          }
  214.         }
  215.       
  216.         if(line.substring(0, 5).equals("PAUSE" ))
  217.         {
  218.          tcp_push.pause();
  219.          pause=true;
  220.        
  221.         }
  222.       
  223.         System.out.println("juste avant end" );
  224.       
  227.      } catch(Exception e) { }
  228.     }
  229.   }
  230.  
  231.  
  233. }


 

class ServeurDonnee :
 

Code :
  1. public class ServeurDonnee extends Socket implements Runnable{
  3. OutputStream clientOutput;
  4. PrintWriter out;
  5. ArrayList<String> IMAGE_ID;
  6. float ips;
  8. public ServeurDonnee(String adresse_client, int port_client,int id) throws Exception
  9. {
  10.  super(adresse_client,port_client);
  11.  System.out.println(adresse_client+" "+port_client);
  12.     IMAGE_ID=new ArrayList<String>();
  13.     parcourir(id);
  14.     clientOutput =this.getOutputStream();
  16.     out=new PrintWriter(clientOutput, true);
  18. }
  20.   public void parcourir(int id) throws Exception {
  21.    File flux=new File("flux"+id+".txt" );
  22.    InputStream ifs=new FileInputStream(flux);
  23.    InputStreamReader ifsr=new InputStreamReader(ifs);
  24.    BufferedReader brf=new BufferedReader(ifsr);
  25.    String line;
  26.    line=brf.readLine();
  27.    line=brf.readLine();
  28.    line=brf.readLine();
  29.    line=brf.readLine();
  30.    line=brf.readLine();
  31.    line=brf.readLine();
  32.    line=brf.readLine();
  33.    ips=Float.parseFloat(line.split(": " )[1]);
  34.    while(line!=null){
  35.     line=brf.readLine();
  36.    if(line!=null) IMAGE_ID.add(line);
  37.    }
  38.    brf.close();
  39.   }
  40.  
  41.   public void send(int id) throws IOException, InterruptedException
  42.   {
  43.    Thread.sleep((long)(1000/ips));
  44.    System.out.println("Procédure commencée" );
  45.        File g=new File(IMAGE_ID.get(id));
  46.        out.flush();
  47.     out.write((id+1)+"\r\n"+g.length()+"\r\n" ); 
  48.      copyStream(new FileInputStream(g),clientOutput,true);
  49.      System.out.println("Transfert done" );
  50.   }
  51.  
  52.   public int copyStream(InputStream in, OutputStream out, boolean close)
  53.   throws IOException
  54.   {
  55.     int nbytes = 0, total = 0;
  56.     byte[] buf = new byte[1024];
  57.     while ((nbytes = in.read(buf)) > 0)
  58.     {
  59.     out.write(buf, 0, nbytes);
  60.     total += nbytes;
  61.    }
  62.    if(close) in.close();
  63.    return total;
  64.  }
  65.  
  66. public void run()
  67. {
  68. }
  70. }[/spoiler]
  72. class TCP_PUSH :
  75. [spoiler]public class TCP_PUSH extends ServeurDonnee{
  77. Thread t;
  79. public TCP_PUSH(String adresse_client, int port_client,int id) throws Exception
  80. {
  81.  super(adresse_client,port_client,id);
  82.  t=new Thread(this);
  83. }
  85. public void start()
  86. {
  87.  t.start();
  88. }
  89. public void reprend()
  90. {
  91.  t.notify();
  92. }
  94. public void pause() throws InterruptedException
  95. {
  96.  t.wait();
  97. }
  99. public void end()
  100. {
  101.  System.exit(0);
  102. }
  104. public void run()
  105. {
  106.  try{
  107.       for(int i=0;i<IMAGE_ID.size()-1;i++)
  108.       {
  109.      send(i);
  110.       }
  111.     
  112.  } catch(Exception e) {e.printStackTrace();}
  113. }
  115. }


 
 
 
 
class TCP_PULL :
 
 

Code :
  1. public class TCP_PULL extends ServeurDonnee {
  3. int cursor_on_IMAGE_ID=-1;
  4. boolean isActualised=false;
  5. boolean fellow=false;
  6. Thread t;
  8. public TCP_PULL(String adresse_client, int port_client,int id) throws Exception
  9. {
  10.  super(adresse_client,port_client,id);
  11.  t=(new Thread(this));
  12.  t.start();
  14. }
  16. public void end()
  17. {
  18.  System.exit(0);
  19. }
  21. public void pause()
  22. {
  23.  try {
  24.   t.wait();
  25.  } catch (InterruptedException e) {
  26.   e.printStackTrace();
  27.  }
  28. }
  29.  
  30.   public void setId(int i) throws IOException, InterruptedException
  31.   {
  32.   
  34.    if(i<IMAGE_ID.size()-1)
  35.    {
  36.     if(i==-1 && cursor_on_IMAGE_ID< IMAGE_ID.size()-1)
  37.     {
  38.      cursor_on_IMAGE_ID++;
  39.      isActualised=true;
  40.      System.out.println("isActualised" );
  41.      t.notify();
  42.     }else
  43.     {
  44.      if(i!=-1)
  45.      {
  46.       cursor_on_IMAGE_ID++;
  47.       isActualised=true;
  48.       t.notify();
  49.      }
  50.     }
  51.    }
  52.   }
  53.  
  54. public void run()
  55. {
  56.  try{
  57.   for(;;)
  58.   {
  59.    pause();
  60.    if(isActualised)
  61.    {
  62.     send(cursor_on_IMAGE_ID);
  63.     isActualised=false;
  64.    }
  66.   }
  67.   } catch(Exception e) {e.printStackTrace();}
  68. }
  70. }


 
Et voici la trace de ma dernière exécution :
 

Citation :

client connecté
line=GET 1
client écoute sur port 60204 et demande 1
127.0.0.1 60204
juste avant end
line=
line=START
juste avant end
line=
Procédure commencée
line=END
Commande End envoyée


 
 
Merci d'avance pour toute aide, car je suis vraiment à cours d'idée.


Message édité par NotUsedPseudo le 03-01-2013 à 20:13:38
Reply

Marsh Posté le 24-12-2012 à 15:44:12   

Reply

Marsh Posté le 03-01-2013 à 20:13:58    

Pb résolu.
Pour ceux qui rencontrerait des difficultés similaires, les lignes à l'origine du problème sont celle ci :  
 

Code :
  1. out.write((id+1)+"\r\n"+g.length()+"\r\n" ); //entête
  2. copyStream(new FileInputStream(g),clientOutput,true); //image


 
La bonne façon de faire était de créer une entête à part, puis de l'envoyer aussi sous forme de byte.


Message édité par NotUsedPseudo le 04-01-2013 à 18:54:55
Reply

Sujets relatifs:

Leave a Replay

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