使用javamail批量讀取電子郵件

Question

我有以下代碼，我想通過批量檢索（例如：獲取前50封郵件，處理它，然後獲取下一個50）。目前它提取所有消息並將其存儲在一個數組中。Javamail是否支持該消息？如果不是如何批量檢索？

感謝您的回答。

Properties props = System.getProperties(); 
props.setProperty("mail.store.protocol", "imaps"); 

Session session = Session.getDefaultInstance(props, null); 
Store store = session.getStore("imaps"); 
store.connect(host, userName, password); 

Folder inbox = null; 
inbox = store.getFolder("Inbox"); 
inbox.open(Folder.READ_WRITE); 
Message[] messages = inbox.search(new FlagTerm(
     new Flags(Flag.SEEN), false)); 
FetchProfile fp = new FetchProfile(); 
fp.add(FetchProfile.Item.ENVELOPE); 
fp.add(FetchProfile.Item.CONTENT_INFO); 
inbox.fetch(messages, fp); 
for (int i = 0; i < messages.length; i++) 
{ 
    //Process a message 
} 

UPDATE：

我試圖實現配料如下，但預期它不工作。

的問題是：

• 假設有24的電子郵件收件箱中，然後totalUnread正顯示出正確的，但Message[] messages = inbox.search(new FlagTerm(new Flags(Flag.SEEN), false), inbox.getMessages(batchStart, batchEnd));正在返回的只有5個而不是10個記錄爲BATCH_SIZE爲10

• 另一個問題被處理的電子郵件沒有標記爲已讀，即使調用getContent()。

  private static final int BATCH_SIZE = 10; 
  Properties props = System.getProperties(); 
  props.setProperty("mail.store.protocol", "imaps"); 
  AuthenticationService authenticationService = null; 
  Session session = Session.getDefaultInstance(props, null); 
  Store store = session.getStore("imaps"); 
  store.connect(host, userName, password); 
  Folder inbox = null; 
  inbox = store.getFolder("Inbox"); 
  int totalUnread = inbox.getUnreadMessageCount(); 
  if (totalUnread != 0) 
  { 
      inbox.open(Folder.READ_WRITE); 
      int batchStart = 1; 
      int batchEnd = (totalUnread > BATCH_SIZE ? BATCH_SIZE 
        : totalUnread); 
      int batchCount = 0; 
      while (true) 
      { 
       processABatch(inbox, batchStart, batchEnd, batchCount); 
       batchStart = batchEnd + 1; 
       if (batchStart > totalUnread) 
       { 
        break; 
       } 
       batchEnd = ((batchEnd + BATCH_SIZE) < totalUnread ? (batchEnd + BATCH_SIZE) 
         : totalUnread); 
       batchCount++; 
      } 
  
  } 
  inbox.close(true); 
  store.close(); 
  } 
  
  private void processABatch(Folder inbox, int batchStart, int batchEnd, int batchCount) 
       throws MessagingException 
  { 
      Message[] messages = inbox.search(new FlagTerm(new Flags(Flag.SEEN), 
        false), inbox.getMessages(batchStart, batchEnd)); 
      FetchProfile fp = new FetchProfile(); 
      fp.add(FetchProfile.Item.ENVELOPE); 
      fp.add(FetchProfile.Item.CONTENT_INFO); 
      inbox.fetch(messages, fp); 
      for (int i = 0; i < messages.length; i++) 
      { 
       processMessage(messages[i], inbox); 
      } 
  } 
  

Answer 1

而不是做inbox.search(new FlagTerm(...))，你可能想要做inbox.search(new FlagTerm(...), getMessages(start, end))。它使用getMessages(int, int)方法，它允許您檢索當前Folder中所有消息的子集。

事實上getMessages(start, end)適用於完整的Folder。根據該方法的Javadoc，Message對象預計會提供輕量級，因爲它們只是對實際消息的引用。

因此，也許你可以寫一個返回第一50未讀郵件，通過不斷獲取消息，並把它們放在一個List或類似的東西的方法，直到您有它的50條短信或你已經達到結束Folder。該消息的結果將是「批次」。

之後，您可以對消息進行常規處理。