Below is a tool for receiving emails, which is a bit long! ! !
public class ReciveMail { private MimeMessage msg = null; private String saveAttchPath = ""; private StringBuffer bodytext = new StringBuffer(); private String dateformate = "yy-MM-dd HH:mm"; public ReciveMail(MimeMessage msg){ this. msg = msg; } public void setMsg(MimeMessage msg) { this.msg = msg; } /** * Get the message sent by the email* @return * @throws MessagingException */ public String getFrom() throws MessagingException{ InternetAddress[] address = (InternetAddress[]) msg.getFrom(); String from = address[0].getAddress(); if(from == null){ from = ""; } String personal = address[0].getPersonal(); if(personal == null){ personal = ""; } String fromaddr = personal +"<"+from+">"; return fromaddr; } /** * Get the address of the email recipient, cc, and password and information. Depending on the parameters passed, "to"->Recipient, "cc"-->Cc address, "bcc"-->Client address* @param type * @return * @throws MessagingException * @throws UnsupportedEncodingException */ public String getMailAddress(String type) throws MessagingException, UnsupportedEncodingException{ String mailaddr = ""; String addrType = type.toUpperCase(); InternetAddress[] address = null; if(addrType.equals("TO")||addrType .equals("CC")||addrType.equals("BCC")){ if(addrType.equals("TO")){ address = (InternetAddress[]) msg.getRecipients(Message.RecipientType.TO); } if(addrType.equals("CC")){ address = (InternetAddress[]) msg.getRecipients(Message.RecipientType.CC); } if(addrType.equals("BCC")){ address = (InternetAddress[]) msg.getRecipients(Message.RecipientType.BCC); } if(address != null){ for(int i=0;i<address.length;i++){ String mail = address[i].getAddress(); if( mail == null){ mail = ""; }else{ mail = MimeUtility.decodeText(mail); } String personal = address[i].getPersonal(); if(personal == null){ personal = ""; } else{ personal = MimeUtility.decodeText(personal); } String compositeto = personal +"<"+mail+">"; mailaddr += ","+compositeto; } mailaddr = mailaddr.substring(1); } }else{ throw new RuntimeException("Error email Type!"); } return mailaddr; } /** * Get the email subject* @return * @throws UnsupportedEncodingException * @throws MessagingException */ public String getSubject() throws UnsupportedEncodingException, MessagingException{ String subject = " "; subject = MimeUtility.decodeText(msg.getSubject()); if(subject == null){ subject = ""; } return subject; } /** * Get the email send date* @return * @throws MessagingException */ public String getSendDate() throws MessagingException{ Date sendDate = msg.getSentDate(); SimpleDateFormat smd = new SimpleDateFormat(dateformate); return smd.format(sendDate); } /** * Get the content of the email text* @return */ public String getBodyText(){ return bodytext.toString(); } /** * Parses the email and save the obtained email content to a stringBuffer object. * Parsing emails mainly perform different operations according to different MimeType, parsing them step by step* @ param part * @throws MessagingException * @throws IOException */ public void getMailContent(Part part) throws MessagingException, IOException{ String contentType = part.getContentType(); int nameindex = contentType.indexOf("name"); boolean conname = false; if(nameindex != -1){ conname = true; } System.out.println("CONTENTTYPE:"+contentType); if(part.isMimeType("text/plain")&&!conname){ bodytext.append(( String)part.getContent()); }else if(part.isMimeType("text/html")&&!conname){ bodytext.append((String)part.getContent()); }else if(part.isMimeType( "multipart/*")){ Multipart multipart = (Multipart) part.getContent(); int count = multipart.getCount(); for(int i=0;i<count;i++){ getMailContent(multipart.getBodyPart(i )); } }else if(part.isMimeType("message/rfc822")){ getMailContent((Part) part.getContent()); } } /** * Determine whether the email needs a receipt. If the receipt is required, return true. Otherwise, return false * @return * @throws MessagingException */ public boolean getReplySign() throws MessagingException{ boolean replySign = false; String needreply[] = msg.getHeader("Disposition-Notification-TO"); if(needreply != null) { replySign = true; } return replySign; } /** * Get the message-id of this message * @return * @throws MessagingException */ public String getMessageId() throws MessagingException{ return msg.getMessageID(); } /** * Determine whether this message has been read. If it is not read, it returns false. If it is read, it returns true * @return * @throws MessagingException */ public boolean isNew() throws MessagingException{ boolean isnew = false; Flags flags = ((Message)msg). getFlags(); Flags.Flag[] flag = flags.getSystemFlags(); System.out.println("flags's length:"+flag.length); for(int i=0;i<flag.length;i++){ if(flag[i]==Flags.Flag.SEEN){ isnew = true; System.out.println("seen message ......"); break; } } return isnew; } /** * Determine whether the attachment is included * @param part * @return * @throws MessagingException * @throws IOException */ public boolean isContainAttch(Part part) throws MessagingException, IOException{ boolean flag = false; //String contentType = part.getContentType(); if(part.isMimeType("multipart/*")){ Multipart multipart = (Multipart) part.getContent(); int count = multipart.getCount(); for(int i=0;i<count;i++){ BodyPart bodypart = multipart.getBodyPart(i); String dispostion = bodypart.getDisposition(); if((dispostion != null)&&(dispostion.equals(Part.ATTACHMENT)||dispostion.equals(Part.INLINE))){ flag = true; }else if(bodypart.isMimeType("multipart/*")){ flag = isContainAttch(bodypart); }else{ String conType = bodypart.getContentType(); if(conType.toLowerCase().indexOf("appliaction ")!=-1){ flag = true; } if(conType.toLowerCase().indexOf("name")!=-1){ flag = true; } } } } } else if(part.isMimeType("message /rfc822")){ flag = isContainAttch((Part) part.getContent()); } return flag; } /** * Save attachment* @param part * @throws MessagingException * @throws IOException */ public void saveAttchMent(Part part) throws MessagingException, IOException{ String filename = ""; if(part.isMimeType("multipart/*")){ Multipart mp = (Multipart) part.getContent(); for(int i=0;i<mp. getCount();i++){ BodyPart part = mp.getBodyPart(i); String dispostion = parart.getDisposition(); if((dispostion != null)&&(dispostion.equals(Part.ATTACHMENT)||dispostion.equals( Part.INLINE))){ filename = parart.getFileName(); if(filename.toLowerCase().indexOf("gb2312")!=-1){ filename = MimeUtility.decodeText(filename); } saveFile(filename,mpart .getInputStream()); }else if(part.isMimeType("multipart/*")){ saveAttchMent(part); }else{ filename = parart.getFileName(); if(filename != null&&(filename.toLowerCase() .indexOf("gb2312")!=-1)){ filename = MimeUtility.decodeText(filename); } saveFile(filename,part.getInputStream()); } } } } else if(part.isMimeType("message/rfc822" )){ saveAttchMent((Part) part.getContent()); } } /** * Get the address to save the attachment* @return */ public String getSaveAttchPath() { return saveAttchPath; } /** * Set the address to save the attachment* @param saveAttchPath */ public void setSaveAttchPath(String saveAttchPath) { this.saveAttchPath = saveAttchPath; } /** * Set date format* @param dateformate */ public void setDateformate(String dateformate) { this.dateformate = dateformate; } /* * * Save file content* @param filename * @param inputStream * @throws IOException */ private void saveFile(String filename, InputStream inputStream) throws IOException { String osname = System.getProperty("os.name"); String storedir = getSaveAttchPath (); String sepatror = ""; if(osname == null){ osname = ""; } if(osname.toLowerCase().indexOf("win")!=-1){ sepatror = "//"; if(storedir==null||"".equals(storedir)){ storedir = "d://temp"; } }else{ sepatror = "/"; storedir = "/temp"; } File storefile = new File (storedir+sepatror+filename); System.out.println("storefile's path:"+storefile.toString()); BufferedOutputStream bos = null; BufferedInputStream bis = null; try { bos = new BufferedOutputStream(new FileOutputStream(storefile)) ; bis = new BufferedInputStream(inputStream); int c; while((c= bis.read())!=-1){ bos.write(c); bos.flush(); } } catch (FileNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally{ bos.close(); bis.close(); } } public void recive(Part part,int i) throws MessagingException, IOException{ System.out.println("------------------START------- ------------------"); System.out.println("Message"+i+" subject:" + getSubject()); System.out.println("Message"+ i+" from:" + getFrom()); System.out.println("Message"+i+" isNew:" + isNew()); boolean flag = isContainAttch(part); System.out.println("Message"+ i+" isContainAttch:" +flag); System.out.println("Message"+i+" replySign:" + getReplySign()); getMailContent(part); System.out.println("Message"+i+" content:" + getBodyText()); setSaveAttchPath("c://temp//"+i); if(flag){ saveAttchMent(part); } System.out.println("---------- -------END-------------------------------------"); }}There are several ways to write email reception and tool usage! :
I have read a lot of other codes on the Internet. The value of pop3Server is pop.mail.163.com, but I failed to try it successfully. The value of user can be either with [email protected] or username.
If the incoming email is 163 mailbox, you must first log in to 163 mailbox to set it up and enable pop3 service. I don't know other email addresses yet.
public static void main(String[] args) throws Exception { // The host name, protocol, user name, and password of the pop3 server connected to the pop3 server String pop3Server = "pop.163.com"; String protocol = "pop3"; String user = " username"; String pwd = "password"; // Create a Properties object with specific connection information Properties props = new Properties(); props.setProperty("mail.store.protocol", protocol); props.setProperty("mail .pop3.host", pop3Server); // Use Properties object to obtain the Session object Session session = Session.getInstance(props); session.setDebug(true); // Use the Session object to obtain the Store object and connect to the pop3 server Store store = session.getStore(); store.connect(pop3Server, user, pwd); // Get the folder Folder object in the mailbox and open Folder folder in "read-only" = store.getFolder("inbox"); folder.open( Folder.READ_ONLY); // Get all the messages Message objects in the folder Folder Message [] messages = folder.getMessages(); ReciveMail rm = null; for(int i=0;i< messages.size() ;i++) { rm = new ReciveMail((MimeMessage) messages[i]); rm.recive(messages[i],i);; } folder.close(false); store.close(); }