JAVA Ftp Quartz

JAVA Ftp Quartz - Java - Programmation

Marsh Posté le 08-09-2017 à 12:20:43    

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 !

Reply

Marsh Posté le 08-09-2017 à 12:20:43   

Reply

Marsh Posté le 12-09-2017 à 13:37:07    

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  

Reply

Sujets relatifs:

Leave a Replay

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