Forum |  HardWare.fr | News | Articles | PC | S'identifier | S'inscrire | Shop Recherche
1674 connectés 

  FORUM HardWare.fr
  Programmation
  Java

  JAVA Ftp Quartz

 
 


 Mot :   Pseudo :  
 
Bas de page
Auteur Sujet :

JAVA Ftp Quartz

n°2305483
killkala
Posté le 08-09-2017 à 12:20:43  profilanswer
 

Bonjour,  
 
Je me permet de poster car j'ai un soucis et peut-être que vous pourrez m'aider !  
Pour un projet, on m'a demander d'établir une connection FTP en Java afin de download des fichiers (Pour cela il n'y a pas de problème). On m'a demandé que le programme récupère toutes les heures fichiers (car ils subiront une modification régulière). J'ai donc pour cela décié d'utiliser Quartz et plus particulièrement Cron Schedule.  
Le problème est donc le tout ensemble. Je vous montre mon code pour que vous puissiez voir (je pense que j'utilise mal mon Job mais comme je ne connais pas du tout cette API j'ai du mal à comprendre)  
 
Quartz.java  
 

Code :
  1. package com.auscult.ftp;
  3. import java.io.IOException;
  4. import java.util.TimeZone;
  6. import org.quartz.CronScheduleBuilder;
  7. import org.quartz.JobBuilder;
  8. import org.quartz.JobDetail;
  9. import org.quartz.Scheduler;
  10. import org.quartz.SchedulerException;
  11. import org.quartz.SchedulerFactory;
  12. import org.quartz.Trigger;
  13. import org.quartz.TriggerBuilder;
  14. import org.quartz.impl.StdSchedulerFactory;
  16. public class Quartz {
  18.  public static void main(final String[] args) {
  19.      final SchedulerFactory factory = new StdSchedulerFactory();
  20.      Scheduler scheduler = null;
  21.      try {
  22.        scheduler = factory.getScheduler();
  24.        final JobDetail jobDetail = JobBuilder
  25.            .newJob(FTPFunctions.class)
  26.            .withIdentity("monJob", "groupe_1" )
  27.            .usingJobData("monParametre", "12345" )
  28.            .build();
  30.        final Trigger cronTrigger = TriggerBuilder
  31.            .newTrigger()
  32.            .withIdentity("monTrigger", "groupe_1" )
  33.            .withSchedule(
  34.                CronScheduleBuilder.cronSchedule("0 0/1 * * * ?" ) //Interval de 1mn afin de faire des test)
  35.                  .inTimeZone(TimeZone.getTimeZone("Europe/Paris" )))
  36.            .build();
  38.        scheduler.start();
  39.        scheduler.scheduleJob(jobDetail, cronTrigger);
  41.        System.in.read();
  42.        if (scheduler != null) {
  43.          scheduler.shutdown();
  44.        }
  45.      } catch (final SchedulerException e) {
  46.        e.printStackTrace();
  47.      } catch (final IOException e) {
  48.        e.printStackTrace();
  49.      }
  50.    }
  51. }


 
FTPFunctions.java
 

Code :
  1. package com.auscult.ftp;
  3. import java.io.BufferedOutputStream;
  4. import java.io.File;
  5. import java.io.FileOutputStream;
  6. import java.io.IOException;
  7. import java.io.OutputStream;
  8. import java.io.PrintWriter;
  10. import org.apache.commons.net.PrintCommandListener;
  11. import org.apache.commons.net.ftp.FTP;
  12. import org.apache.commons.net.ftp.FTPClient;
  13. import org.apache.commons.net.ftp.FTPFile;
  14. import org.apache.commons.net.ftp.FTPReply;
  16. import org.quartz.Job;
  17. import org.quartz.JobExecutionContext;
  18. import org.quartz.JobExecutionException;
  20. public class FTPFunctions implements Job {
  22. private String host;
  23. private String username;
  24. private String password;
  25. private int port;
  27. private static String remoteFilePath;
  28. private static String savePath;
  30. private static String parentDir;
  31. private static String currentDir;
  32. private static String saveDir;
  34. private static FTPClient ftpClient = new FTPClient();
  36.  public FTPFunctions(String server, int pPort, String pUsername, String pPassword) throws Exception {
  38.   host = server;
  39.   port = pPort;
  40.   username = pUsername;
  41.   password = pPassword;
  44.   ftpClient.addProtocolCommandListener (new PrintCommandListener(new PrintWriter(System.out)));
  45.         int reply;
  46.         ftpClient.connect( host , port);
  47.         System.out.println("FTP URL is:"+ftpClient.getDefaultPort());
  48.         reply = ftpClient.getReplyCode();
  49.         if (!FTPReply.isPositiveCompletion(reply)) {
  50.             ftpClient.disconnect();
  51.             throw new Exception("Exception in connecting to FTP Server" );
  52.         }
  53.         ftpClient.login(username, password);
  54.         ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
  55.         ftpClient.enterLocalPassiveMode();     
  56.        
  57.  }
  59.  public static boolean downloadFTPFile(FTPClient ftpClient, String RemoteFilePath, String SavePath) throws IOException {
  61.   remoteFilePath  = RemoteFilePath;
  62.   savePath    = SavePath;
  65.   File downloadFile = new File(savePath);
  66.     
  67.      File parentDir = downloadFile.getParentFile();
  68.      if (!parentDir.exists()) {
  69.          parentDir.mkdir();
  70.      }
  71.         
  72.      OutputStream outputStream = new BufferedOutputStream(new FileOutputStream(downloadFile));
  73.     
  74.      try {
  75.     
  76.          ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
  77.          return ftpClient.retrieveFile(remoteFilePath, outputStream);
  78.      } catch (IOException ex) {
  79.          throw ex;
  80.      } finally {
  81.          if (outputStream != null) {
  82.              outputStream.close();
  83.          }
  84.      }
  85.     }
  87.  public static void downloadDirectory(FTPClient ftpClient, String ParentDir, String CurrentDir, String SaveDir) throws IOException {
  89.   parentDir  = ParentDir;
  90.   currentDir = CurrentDir;
  91.   saveDir    = SaveDir;
  93.      String dirToList = parentDir;
  94.      if (!currentDir.equals("" )) {
  95.          dirToList += "/" + currentDir;
  96.      }
  98.      FTPFile[] subFiles = ftpClient.listFiles(dirToList);
  100.      if (subFiles != null && subFiles.length > 0) {
  101.          for (FTPFile aFile : subFiles) {
  102.              String currentFileName = aFile.getName();
  103.              if (currentFileName.equals("." ) || currentFileName.equals(".." )) {
  104.                  continue;
  105.              }
  106.              String filePath = parentDir + "/" + currentDir + "/"
  107.                      + currentFileName;
  108.              if (currentDir.equals("" )) {
  109.                  filePath = parentDir + "/" + currentFileName;
  110.              }
  112.              String newDirPath = saveDir + parentDir + File.separator + currentDir + File.separator + currentFileName;
  113.              if (currentDir.equals("" )) {
  114.                  newDirPath = saveDir + parentDir + File.separator
  115.                            + currentFileName;
  116.              }
  118.              if (aFile.isDirectory()) {
  119.                  File newDir = new File(newDirPath);
  120.                  boolean created = newDir.mkdirs();
  121.                  if (created) {
  122.                      System.out.println("CREATED the directory: " + newDirPath);
  123.                  } else {
  124.                      System.out.println("COULD NOT create the directory: " + newDirPath);
  125.                  }
  127.                  downloadDirectory(ftpClient, dirToList, currentFileName, saveDir);
  128.              } else {
  129.                  boolean success = downloadFTPFile(ftpClient, filePath, newDirPath);
  130.                  if (success) {
  131.                      System.out.println("DOWNLOADED the file: " + filePath);
  132.                  } else {
  133.                      System.out.println("COULD NOT download the file: " + filePath);
  134.                  }
  135.              }
  136.          }
  137.      }
  138.  }
  141.  public void disconnect(){
  142.         if (FTPFunctions.ftpClient.isConnected()) {
  143.              try {
  144.                  FTPFunctions.ftpClient.logout();
  145.                  FTPFunctions.ftpClient.disconnect();
  146.              } catch (IOException f) {
  147.              }
  148.          }
  149.     }
  152. public void execute(JobExecutionContext arg0) throws JobExecutionException {
  153.                 System.out.println("FTP execut" );
  154.   try {
  156.    FTPFunctions ftp = new FTPFunctions("Test", 21, "killkala", "test" );
  158.    String remoteDirPath = "/Station1";
  159.             String saveDirPath = "//192.168.7.191/web/FTP";
  160.  
  161.             FTPFunctions.downloadDirectory(ftpClient, remoteDirPath, "", saveDirPath);
  163.    System.out.println("FTP File downloaded successfully" );
  164.    ftp.disconnect();
  165.     } catch (Exception e) {
  166.      e.printStackTrace();
  167.     }       
  168. }
  170. }


 
Je pense que mon Job n'aime pas trop toutes mes fonctions privées & public plus haut. En faite le problème c'est que je n'ai aucune erreur, juste rien ne se passe dans ma console. J'ai fais des test dépendant pour essayer de comprendre et c'est pour cela que j'en suis arrivé à la conclusion que l'association de mon Job à ma classe FTPFunctions n'a pas été concluante !  
Je pense que ca dois être une erreur trop bete, mais j'ai pas encore assez de connaissances pour savoir !
Donc si jamais vous avez un peu de temps pour m'aider, ca serai avec grand plaisir !!!  
 
Merci d'avance pour vos réponses !

mood
Publicité
Posté le 08-09-2017 à 12:20:43  profilanswer
 

n°2305585
killkala
Posté le 12-09-2017 à 13:37:07  profilanswer
 

J'ai finalement résolu mes soucis.
Pour ceux que ça intéresse j'ai :  
- fais un handler de Job à part.  
- enlevé tous mes "statics" et supprimé ftpClient des paramètres de méthode
- rendu ma classe FTPFonctions AutoCloseable
- rendu paramétrable mon Job.  
 
Si certains on un soucis similaire qu'il n'hésite pas à consulter ce topic :  
 
https://www.developpez.net/forums/d [...] ost9606343
Mon code modifier y est posté dessus  


Aller à :
Ajouter une réponse
  FORUM HardWare.fr
  Programmation
  Java

  JAVA Ftp Quartz

 

Sujets relatifs
Problème Main en java avec XML eclipsegestion des collisions dans jeu en 2D java
Mon premier dev java sous AndroidCopie et suppression dossier FTP tout les jours
interface en java[Java] Erreur java.net.SocketException : socket closed (EOS)
Problème de paramètres Java en SQLJ (JDBC)JAVA, je bloque totalement...
Ouvrir un fichier sur java's Cool 4[Java] Erreur Compilation
Plus de sujets relatifs à : JAVA Ftp Quartz

Forum MesDiscussions.Net, Version 2010.2
(c) 2000-2011 Doctissimo
Page générée en 0.085 secondes

Copyright © 1997-2022 Hardware.fr SARL (Signaler un contenu illicite / Données personnelles) / Groupe LDLC / Shop HFR