Использование Javamail для установки навесного оборудования

Question

Доброе утро,

Я работаю над этим проектом уже несколько дней и остановлюсь на земле. Загрузка вложений, похоже, длится вечно, и, похоже, это будет файл записи на диск. Я читал о многих вариантах (FileChannel, bulk getContent и некоторых других, но не могу сделать этот код с разумной скоростью). Я не уверен, что единственная бутылочная горловина - это загрузка файлов с O365, но я думал, что буду задайте вопрос, может ли кто-нибудь просмотреть этот код и, надеюсь, рассказать мне, что я сделал неправильно. Цель приложения - войти в Exchange Online (o365) и загрузить все вложения в определенном почтовом ящике. Обратите внимание, что этот код был изменен так много раз, чтобы увидеть, могу ли я увеличить производительность, используя потоки и так далее:

Как я уже сказал, я много переложил все, чтобы попытаться сделать эту работу лучше, поэтому, пожалуйста, «Взорвать меня, чтобы какой-то код не делал слишком много смысла. Я не пытаюсь заставить кого-то еще закончить этот проект, я ищу руководство с языком, с которым у меня нет большого опыта.

package o365connect; 

import java.io.IOException; 
import java.net.UnknownHostException; 
import java.util.Properties; 
import java.util.logging.Level; 
import java.util.logging.Logger; 
import javax.mail.Folder; 
import javax.mail.Message; 
import javax.mail.MessagingException; 
import javax.mail.Multipart; 
import javax.mail.NoSuchProviderException; 
import javax.mail.Part; 
import javax.mail.Session; 
import javax.mail.Store; 
import javax.mail.internet.MimeBodyPart; 

/** 
* 
* @author Charlie 
*/ 
public class AttDownload extends Thread { 
     public static int Lower = 0; 
     public static int Upper = 0; 
     public static int Counter = 0; 
     public static Session session; 
     public static Store store; 
     public static Properties props = new Properties(); 
     public static boolean fTest = false; 
    AttDownload(int i, int ii) { 
     Lower = i; 
     Upper = ii; 
    } 
    AttDownload() throws UnknownHostException { 
     super(); 
    } 
    @Override 
    public void run() { 
     String SSL_FACTORY = "javax.net.ssl.SSLSocketFactory"; 
     String pop3Host = "outlook.office365.com"; 
     String mailStoreType = "imap"; 
     String path = "Inbox/Scans to file"; 
     String userName = "XXX@XXX.com"; 
     String password = "XXXXXXX"; 
     Folder emailFolder; 
     try { 
      props.setProperty("mail.imaps.socketFactory.class", SSL_FACTORY); 
      props.setProperty("mail.imaps.socketFactory.fallback", "false"); 
      props.setProperty("mail.imaps.port", "993"); 
      props.setProperty("mail.imaps.socketFactory.port", "993"); 
      props.put("mail.imaps.host", "outlook.office365.com"); 
      session = Session.getInstance(props); 
      int Size = functions.MBSize(pop3Host, userName, password, path); 
      System.out.println(Size); 
      store = session.getStore("imaps"); 
      store.connect(pop3Host, userName, password); 
      emailFolder = store.getFolder(path); 
      emailFolder.open(Folder.READ_ONLY); 
      try { 
       Message[] messages; 
       messages = emailFolder.getMessages(Lower, Upper); 
       System.out.println("starting thread for - " + Lower + " - " + Upper); 
       int ASuc = receiveEmail(messages); 
      } catch (MessagingException | IOException ex) { 
       Logger.getLogger(AttDownload.class.getName()).log(Level.SEVERE, null, ex); 
      } 
     } catch (NoSuchProviderException ex) { 
      Logger.getLogger(AttDownload.class.getName()).log(Level.SEVERE, null, ex); 
     } catch (MessagingException ex) { 
      Logger.getLogger(AttDownload.class.getName()).log(Level.SEVERE, null, ex); 
     } 
    } 
    public static int receiveEmail(Message messagesarr[]) throws IOException, MessagingException { 
      for (Message messagesarr1 : messagesarr) { 
       try { 
        Message message = messagesarr1; 
        Object content = message.getContent(); 
        if (content instanceof String) { 
        } else if (content instanceof Multipart) { 
         Multipart multipart = (Multipart) message.getContent(); 
         for (int k = 0; k < multipart.getCount(); k++) { 
          MimeBodyPart bodyPart = (MimeBodyPart) multipart.getBodyPart(k); 
          if (Part.ATTACHMENT.equalsIgnoreCase(bodyPart.getDisposition())) { 
           long startTime = System.currentTimeMillis(); 
           int ran = (int) startTime; 
           String fileName; 
           String fName = bodyPart.getFileName(); 
           if (fName != null && !fName.isEmpty()) { 
            fileName = fName.replaceAll("\\s+", ""); 
           } else { 
            continue; 
           } 
           if ("ATT00001.txt".equals(fileName)) { 
            continue; 
           } else { 
            System.out.println("starting copy of - " + fileName); 
           } 
           String destFilePath = "D:/Scans/"; 
           bodyPart.saveFile(destFilePath + bodyPart.getFileName()); 
           long stopTime = System.currentTimeMillis(); 
           System.out.println("finished copying of - " + fileName + " - " + (stopTime - startTime) + " miliseconds."); 
           System.out.println(Counter); 
           Counter++; 
          } else { 
          } 
         } 

        } 
       }catch (MessagingException e) { 
        System.out.println(e); 
       } 
      } 
     return 1; 
    } 
} 

Functions.java

package o365connect; 

import javax.mail.Folder; 
import javax.mail.MessagingException; 
import javax.mail.NoSuchProviderException; 
import javax.mail.Session; 
import javax.mail.Store; 
import static o365connect.AttDownload.store; 

/** 
* 
* @author Oliver 
*/ 
public class functions { 

    public static int TestUser(String pop3host, String Username, String Password) throws NoSuchProviderException, MessagingException { 
     try { 
      Session session = Session.getInstance(AttDownload.props); 
      store = session.getStore("imaps"); 
      store.connect(pop3host, Username, Password); 
      return 0; 
     } catch (MessagingException e) { 
      System.out.println(e + "User Name Invalid"); 
      return 1; 
     } 
    } 

    public static Folder TestFolder(Store store, String Path) throws MessagingException { 
     Folder emailFolder; 
     emailFolder = store.getFolder(Path); 
     emailFolder.open(Folder.READ_ONLY); 
     AttDownload.fTest = true; 
     emailFolder.close(false); 
     return emailFolder; 
    } 

    public static int MBSize(String pop3Host, String userName, String password, String Path) { 
     int Size = 0; 
     Session session = Session.getInstance(AttDownload.props); 
     try { 
      Store store = session.getStore("imaps"); 
      store.connect(pop3Host, userName, password); 
      Folder emailFolder = store.getFolder(Path); 
      emailFolder.open(Folder.READ_ONLY); 
      Size = emailFolder.getMessageCount(); 
      emailFolder.close(false); 
      store.close(); 
      return Size; 
     } catch (MessagingException e) { 
      System.out.println(e + "MBSize"); 
     } 
     return Size; 
    } 
} 

O365Connect.java

package o365connect; 

import java.io.IOException; 
import javax.mail.MessagingException; 

public class O365Connect { 



    public static void main(String[] args) throws IOException, MessagingException, InterruptedException { 
     MainScreen ms = new MainScreen(); 
     ms.setVisible(true); 
     AttDownload dl = new AttDownload(1, 1000); 
     dl.start(); 

    } 
} 

Edit:

props.put("mail.imaps.fetchsize", "819200"); 
props.put("mail.imaps.partialfetch", "false"); 

ускорили вещи, 128 секунд до 12 секунд, чтобы загрузить 7MB файл.

Answer 1

fetchzize не используется, если partialfetch false; он загрузит все вложение по одному запросу. Пока у вас достаточно памяти для максимально возможного вложения, все в порядке. В противном случае оставьте параметр partialfetch равным true (по умолчанию) и установите значение fetchsize достаточно большим, чтобы обеспечить разумную производительность без чрезмерной памяти.

Свойства JavaMail описаны в javadocs на странице для каждого поставщика протокола. Например, свойства поставщика IMAP описаны в com.sun.mail.imap package javadoc page.