1. 包列表
  2. 类列表
  3. javax.mail.internet.MimeUtility

Java 类javax.mail.internet.MimeUtility 实例源码

项目：jsf-core    文件：ReciveMail.java    
/**   
 * 【保存附件】   
 */   
public void saveAttachMent(Part part) throws Exception {   
    String fileName = "";   
    if (part.isMimeType("multipart/*")) {   
        Multipart mp = (Multipart) part.getContent();   
        for (int i = 0; i < mp.getCount(); i++) {   
            BodyPart mpart = mp.getBodyPart(i);   
            String disposition = mpart.getDisposition();   
            if ((disposition != null)   
                    && ((disposition.equals(Part.ATTACHMENT)) || (disposition   
                            .equals(Part.INLINE)))) {   
                fileName = mpart.getFileName();   
                if (fileName.toLowerCase().indexOf("gb2312") != -1) {   
                    fileName = MimeUtility.decodeText(fileName);   
                }   
                saveFile(fileName, mpart.getInputStream());   
            } else if (mpart.isMimeType("multipart/*")) {   
                saveAttachMent(mpart);   
            } else {   
                fileName = mpart.getFileName();   
                if ((fileName != null)   
                        && (fileName.toLowerCase().indexOf("GB2312") != -1)) {   
                    fileName = MimeUtility.decodeText(fileName);   
                    saveFile(fileName, mpart.getInputStream());   
                }   
            }   
        }   
    } else if (part.isMimeType("message/rfc822")) {   
        saveAttachMent((Part) part.getContent());   
    }   
}
项目：lemon    文件：JavamailService.java    
public static String getFrom(MimeMessage msg) throws MessagingException,
        UnsupportedEncodingException {
    String from = "";
    Address[] froms = msg.getFrom();

    if (froms.length < 1) {
        throw new MessagingException("没有发件人!");
    }

    InternetAddress address = (InternetAddress) froms[0];
    String person = address.getPersonal();

    if (person != null) {
        person = MimeUtility.decodeText(person) + " ";
    } else {
        person = "";
    }

    from = person + "<" + address.getAddress() + ">";

    return from;
}
项目：ephesoft    文件：MailReceiverServiceImpl.java    
private void downloadAttachment(Part part, String folderPath) throws MessagingException, IOException {
    String disPosition = part.getDisposition();
    String fileName = part.getFileName();
    String decodedAttachmentName = null;

    if (fileName != null) {
        LOGGER.info("Attached File Name :: " + fileName);
        decodedAttachmentName = MimeUtility.decodeText(fileName);
        LOGGER.info("Decoded string :: " + decodedAttachmentName);
        decodedAttachmentName = Normalizer.normalize(decodedAttachmentName, Normalizer.Form.NFC);
        LOGGER.info("Normalized string :: " + decodedAttachmentName);
        int extensionIndex = decodedAttachmentName.indexOf(EXTENSION_VALUE_46);
        extensionIndex = extensionIndex == -1 ? decodedAttachmentName.length() : extensionIndex;
        File parentFile = new File(folderPath);
        LOGGER.info("Updating file name if any file with the same name exists. File : " + decodedAttachmentName);
        decodedAttachmentName = FileUtils.getUpdatedFileNameForDuplicateFile(decodedAttachmentName.substring(0, extensionIndex), parentFile, -1)
                + decodedAttachmentName.substring(extensionIndex);

        LOGGER.info("Updated file name : " + decodedAttachmentName);
    }
    if (disPosition != null && disPosition.equalsIgnoreCase(Part.ATTACHMENT)) {
        File file = new File(folderPath + File.separator + decodedAttachmentName);
        file.getParentFile().mkdirs();
        saveEmailAttachment(file, part);
    }
}
项目：txazo    文件：MimeEmail.java    
private void parsePart(Part part) throws Exception {
    if (part.isMimeType("text/*")) {
        content.append((String) part.getContent());
    } else if (part.isMimeType("multipart/*")) {
        Part p = null;
        Multipart multipart = (Multipart) part.getContent();
        for (int i = 0; i < multipart.getCount(); i++) {
            p = multipart.getBodyPart(i);
            String disposition = p.getDisposition();
            if (disposition != null && (disposition.equals(Part.ATTACHMENT) || disposition.equals(Part.INLINE))) {
                attachments.add(MimeUtility.decodeText(p.getFileName()));
            }
            parsePart(p);
        }
    } else if (part.isMimeType("message/rfc822")) {
        parsePart((Part) part.getContent());
    }
}
项目：play    文件：MailHelper.java    
/**
 * �����Ĵ������ϴ�
 */
private void saveFile(Message message, BodyPart bp) throws Exception {
    String fileName = bp.getFileName();
    if ((fileName != null)) {
        new File(dir).mkdirs(); // �½�Ŀ¼
        fileName = MimeUtility.decodeText(fileName);
        String suffix = fileName.substring(fileName.lastIndexOf("."));
        String filePath = dir + "/" + UUID.randomUUID() + suffix;
        message.attachMap.put(fileName, filePath);

        File file = new File(filePath);
        BufferedInputStream bis = new BufferedInputStream(bp.getInputStream());
        BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(file));
        int i;
        while ((i = bis.read()) != -1) {
            bos.write(i);
        }
        bos.close();
        bis.close();
    }
}
项目：openbd-core    文件：cfMailMessageData.java    
public static String getFilename( Part Mess ) throws MessagingException{
// Part.getFileName() doesn't take into account any encoding that may have been 
// applied to the filename so in order to obtain the correct filename we
// need to retrieve it from the Content-Disposition

String [] contentType = Mess.getHeader( "Content-Disposition" );
    if ( contentType != null && contentType.length > 0 ){
        int nameStartIndx = contentType[0].indexOf( "filename=\"" );
        if ( nameStartIndx != -1 ){
            String filename = contentType[0].substring( nameStartIndx+10, contentType[0].indexOf( '\"', nameStartIndx+10 ) );
            try {
            filename = MimeUtility.decodeText( filename );
            return filename;
        } catch (UnsupportedEncodingException e) {}
        }       
    }

    // couldn't determine it using the above, so fall back to more reliable but 
// less correct option
    return Mess.getFileName();
}
项目：James    文件：DigestUtil.java    
/**
 * Calculate digest of given String using given algorithm. Encode digest in
 * MIME-like base64.
 * 
 * @param pass
 *            the String to be hashed
 * @param algorithm
 *            the algorithm to be used
 * @return String Base-64 encoding of digest
 * 
 * @throws NoSuchAlgorithmException
 *             if the algorithm passed in cannot be found
 */
public static String digestString(String pass, String algorithm) throws NoSuchAlgorithmException {

    MessageDigest md;
    ByteArrayOutputStream bos;

    try {
        md = MessageDigest.getInstance(algorithm);
        byte[] digest = md.digest(pass.getBytes("iso-8859-1"));
        bos = new ByteArrayOutputStream();
        OutputStream encodedStream = MimeUtility.encode(bos, "base64");
        encodedStream.write(digest);
        return bos.toString("iso-8859-1");
    } catch (IOException ioe) {
        throw new RuntimeException("Fatal error: " + ioe);
    } catch (MessagingException me) {
        throw new RuntimeException("Fatal error: " + me);
    }
}
项目：iBase4J-Common    文件：EmailSender.java    
/**
 * 设置发信人
 * 
 * @param from
 * @return
 */
public boolean setFrom(String from) {
    if (from == null || from.trim().equals("")) {
        from = PropertiesUtil.getString("email.send.from");
    }
    try {
        String[] f = from.split(",");
        if (f.length > 1) {
            from = MimeUtility.encodeText(f[0]) + "<" + f[1] + ">";
        }
        mimeMsg.setFrom(new InternetAddress(from)); // 设置发信人
        return true;
    } catch (Exception e) {
        logger.error(e.getLocalizedMessage());
        return false;
    }
}
项目：alfresco-repository    文件：SubethaEmailMessage.java    
/**
 * Method extracts file name from a message part for saving its as aa attachment. If the file name can't be extracted, it will be generated based on defaultPrefix parameter.
 * 
 * @param defaultPrefix This prefix fill be used for generating file name.
 * @param messagePart A part of message
 * @return File name.
 * @throws MessagingException
 */
private String getPartFileName(String defaultPrefix, Part messagePart) throws MessagingException
{
    String fileName = messagePart.getFileName();
    if (fileName != null)
    {
        try
        {
            fileName = MimeUtility.decodeText(fileName);
        }
        catch (UnsupportedEncodingException ex)
        {
            // Nothing to do :)
        }
    }
    else
    {
        fileName = defaultPrefix;
        if (messagePart.isMimeType(MIME_PLAIN_TEXT))
            fileName += ".txt";
        else if (messagePart.isMimeType(MIME_HTML_TEXT))
            fileName += ".html";
        else if (messagePart.isMimeType(MIME_XML_TEXT))
            fileName += ".xml";
        else if (messagePart.isMimeType(MIME_IMAGE))
            fileName += ".gif";
    }
    return fileName;
}
项目：alfresco-repository    文件：ContentModelMessage.java    
/**
 * This method builds {@link MimeMessage} based on {@link ContentModel}
 * 
 * @throws MessagingException
 */
private void buildContentModelMessage() throws MessagingException
{
    Map<QName, Serializable> properties = messageFileInfo.getProperties();
    String prop = null;
    setSentDate(messageFileInfo.getModifiedDate());
    // Add FROM address
    Address[] addressList = buildSenderFromAddress();
    addFrom(addressList);
    // Add TO address
    addressList = buildRecipientToAddress();
    addRecipients(RecipientType.TO, addressList);
    prop = (String) properties.get(ContentModel.PROP_TITLE);
    try
    {
        prop = (prop == null || prop.equals("")) ? messageFileInfo.getName() : prop;
        prop = MimeUtility.encodeText(prop, AlfrescoImapConst.UTF_8, null);
    }
    catch (UnsupportedEncodingException e)
    {
        // ignore
    }
    setSubject(prop);
    setContent(buildContentModelMultipart());
}
项目：automat    文件：EmailSender.java    
/**
 * 设置发信人
 * 
 * @param name String
 * @param pass String
 */
public boolean setFrom(String from) {
    if (from == null || from.trim().equals("")) {
        from = PropertiesUtil.getString("email.send.from");
    }
    try {
        String[] f = from.split(",");
        if (f.length > 1) {
            from = MimeUtility.encodeText(f[0]) + "<" + f[1] + ">";
        }
        mimeMsg.setFrom(new InternetAddress(from)); // 设置发信人
        return true;
    } catch (Exception e) {
        logger.error(e.getLocalizedMessage());
        return false;
    }
}
项目：iBase4J    文件：EmailSender.java    
/**
 * 设置发信人
 * 
 * @param name String
 * @param pass String
 */
public boolean setFrom(String from) {
    if (from == null || from.trim().equals("")) {
        from = PropertiesUtil.getString("email.send.from");
    }
    try {
        String[] f = from.split(",");
        if (f.length > 1) {
            from = MimeUtility.encodeText(f[0]) + "<" + f[1] + ">";
        }
        mimeMsg.setFrom(new InternetAddress(from)); // 设置发信人
        return true;
    } catch (Exception e) {
        logger.error(e.getLocalizedMessage());
        return false;
    }
}
项目：JAVA-    文件：EmailSender.java    
/**
 * 设置发信人
 * 
 * @param name String
 * @param pass String
 */
public boolean setFrom(String from) {
    if (from == null || from.trim().equals("")) {
        from = PropertiesUtil.getString("email.send.from");
    }
    try {
        String[] f = from.split(",");
        if (f.length > 1) {
            from = MimeUtility.encodeText(f[0]) + "<" + f[1] + ">";
        }
        mimeMsg.setFrom(new InternetAddress(from)); // 设置发信人
        return true;
    } catch (Exception e) {
        logger.error(e.getLocalizedMessage());
        return false;
    }
}
项目：hermes    文件：DispositionNotification.java    
private void saveReportValues() throws AS2MessageException {
    try {
        Enumeration reportEn = reportValues.getAllHeaderLines();
        StringBuffer reportData = new StringBuffer();

        while (reportEn.hasMoreElements()) {
            reportData.append((String) reportEn.nextElement()).append("\r\n");
        }

        reportData.append("\r\n");

        String reportText = MimeUtility.encodeText(reportData.toString(),
                "us-ascii", "7bit");
        reportPart.setContent(reportText,
                AS2Header.CONTENT_TYPE_MESSAGE_DISPOSITION_NOTIFICATION);
        reportPart.setHeader("Content-Type",
                AS2Header.CONTENT_TYPE_MESSAGE_DISPOSITION_NOTIFICATION);
        reportPart.setHeader("Content-Transfer-Encoding", "7bit");
    }
    catch (Exception e) {
        throw new AS2MessageException("Error in saving report values", e);
    }
}
项目：hermes    文件：DispositionNotification.java    
private void saveReportValues() throws AS2MessageException {
    try {
        Enumeration reportEn = reportValues.getAllHeaderLines();
        StringBuffer reportData = new StringBuffer();

        while (reportEn.hasMoreElements()) {
            reportData.append((String) reportEn.nextElement()).append("\r\n");
        }

        reportData.append("\r\n");

        String reportText = MimeUtility.encodeText(reportData.toString(),
                "us-ascii", "7bit");
        reportPart.setContent(reportText,
                AS2Header.CONTENT_TYPE_MESSAGE_DISPOSITION_NOTIFICATION);
        reportPart.setHeader("Content-Type",
                AS2Header.CONTENT_TYPE_MESSAGE_DISPOSITION_NOTIFICATION);
        reportPart.setHeader("Content-Transfer-Encoding", "7bit");
    }
    catch (Exception e) {
        throw new AS2MessageException("Error in saving report values", e);
    }
}
项目：scada    文件：MailUtils.java    
/**
 * ����ʼ�������
 * @param msg �ʼ�����
 * @return ���� <Email��ַ>
 */ 
public static String getFrom(MimeMessage msg) throws MessagingException, UnsupportedEncodingException { 
    String from = ""; 
    Address[] froms = msg.getFrom(); 
    if (froms.length < 1){
        //return "ϵͳ�ָ�";
        throw new MessagingException("û�з�����!");
    }         
    InternetAddress address = (InternetAddress) froms[0]; 
    String person = address.getPersonal(); 
    if (person != null) { 
        person = MimeUtility.decodeText(person) + " "; 
    } else { 
        person = ""; 
    } 
    from = person + "<" + address.getAddress() + ">"; 

    return from; 
}
项目：nbone    文件：MailServiceImpl.java    
/**
 * 
 * 发送邮件时添加附件列表
 * @param mp
 * @param attachFiles
 * @return
 * @throws MailException
 * @throws IOException
 * @throws MessagingException
 */
private Multipart  addAttachFile(Multipart mp, Set<String> attachFiles) throws MailException, IOException, MessagingException{

    if(mp == null){
        throw new MailException("bean Multipart is null .");
    }

    //没有附件时直接返回
    if(attachFiles == null || (attachFiles.size())== 0){
        return mp;
    }
    Iterator<String> iterator = attachFiles.iterator();
    while (iterator.hasNext()) {
        String fileName  = iterator.next();
        MimeBodyPart mbp_file = new MimeBodyPart();
        mbp_file.attachFile(fileName);
        mp.addBodyPart(mbp_file);
        //防止乱码
        String encode = MimeUtility.encodeText(mbp_file.getFileName());
           mbp_file.setFileName(encode); 

    }

    return mp;
}
项目：alimama    文件：POP3ReceiveMailTest.java    
/**
 * 获得邮件发件人
 * @param msg 邮件内容
 * @return 姓名 <Email地址>
 * @throws MessagingException
 * @throws UnsupportedEncodingException 
 */
public static String getFrom(MimeMessage msg) throws MessagingException, UnsupportedEncodingException {
    String from = "";
    Address[] froms = msg.getFrom();
    if (froms.length < 1)
        throw new MessagingException("没有发件人!");

    InternetAddress address = (InternetAddress) froms[0];
    String person = address.getPersonal();
    if (person != null) {
        person = MimeUtility.decodeText(person) + " ";
    } else {
        person = "";
    }
    from = person + "<" + address.getAddress() + ">";

    return from;
}
项目：communote-server    文件：MailMessageHelper.java    
/**
 * Extracts the attachments from the mail.
 *
 * @param message
 *            The message.
 * @return Collection of attachments as {@link AttachmentTO}.
 * @throws IOException
 *             Exception.
 * @throws MessagingException
 *             Exception.
 */
public static Collection<AttachmentTO> getAttachments(Message message)
        throws MessagingException, IOException {
    Collection<AttachmentTO> attachments = new ArrayList<AttachmentTO>();
    Collection<Part> parts = getAllParts(message);
    for (Part part : parts) {
        String disposition = part.getDisposition();
        String contentType = part.getContentType();
        if (StringUtils.containsIgnoreCase(disposition, "inline")
                || StringUtils.containsIgnoreCase(disposition, "attachment")
                || StringUtils.containsIgnoreCase(contentType, "name=")) {
            String fileName = part.getFileName();
            Matcher matcher = FILENAME_PATTERN.matcher(part.getContentType());
            if (matcher.matches()) {
                fileName = matcher.group(1);
                fileName = StringUtils.substringBeforeLast(fileName, ";");
            }
            if (StringUtils.isNotBlank(fileName)) {
                fileName = fileName.replace("\"", "").replace("\\\"", "");
                fileName = MimeUtility.decodeText(fileName);
                if (fileName.endsWith("?=")) {
                    fileName = fileName.substring(0, fileName.length() - 2);
                }
                fileName = fileName.replace("?", "_");
                AttachmentTO attachmentTO = new AttachmentStreamTO(part.getInputStream());
                attachmentTO.setContentLength(part.getSize());
                attachmentTO.setMetadata(new ContentMetadata());
                attachmentTO.getMetadata().setFilename(fileName);
                if (StringUtils.isNotBlank(contentType)) {
                    contentType = contentType.split(";")[0].toLowerCase();
                }
                attachmentTO.setStatus(AttachmentStatus.UPLOADED);
                attachments.add(attachmentTO);
            }
        }
    }
    return attachments;
}
项目：Camel    文件：MimeMultipartDataFormat.java    
private String getAttachmentKey(BodyPart bp) throws MessagingException, UnsupportedEncodingException {
    // use the filename as key for the map
    String key = bp.getFileName();
    // if there is no file name we use the Content-ID header
    if (key == null && bp instanceof MimeBodyPart) {
        key = ((MimeBodyPart)bp).getContentID();
        if (key != null && key.startsWith("<") && key.length() > 2) {
            // strip <>
            key = key.substring(1, key.length() - 1);
        }
    }
    // or a generated content id
    if (key == null) {
        key = UUID.randomUUID().toString() + "@camel.apache.org";
    }
    return MimeUtility.decodeText(key);
}
项目：metasfresh    文件：Util.java    
/***
 * encode base64
 *
 * @param b
 * @return
 * @throws Exception
 */
// metas: 03749
public static byte[] encodeBase64(final byte[] b)
{
    try
    {
        final ByteArrayOutputStream baos = new ByteArrayOutputStream();
        final OutputStream b64os = MimeUtility.encode(baos, "base64");
        b64os.write(b);
        b64os.close();
        return baos.toByteArray();
    }
    catch (Exception e)
    {
        throw new AdempiereException(e);
    }
}
项目：metasfresh    文件：Util.java    
/***
 * decode base64
 *
 * @param b
 * @return
 * @throws Exception
 */
// metas: 03749
public static byte[] decodeBase64(byte[] b)
{
    try
    {
        ByteArrayInputStream bais = new ByteArrayInputStream(b);
        InputStream b64is = MimeUtility.decode(bais, "base64");
        byte[] tmp = new byte[b.length];
        int n = b64is.read(tmp);
        byte[] res = new byte[n];
        System.arraycopy(tmp, 0, res, 0, n);
        return res;
    }
    catch (Exception e)
    {
        throw new AdempiereException(e);
    }
}
项目：Raven-Messenger    文件：MailControlAndroid.java    
public static void receiveEmailPOPAndroid(MailProfile mailprofile, String folder, int offset, int limit) throws Exception{
    Properties props = new Properties();
       props.setProperty("mail.store.protocol", "pop3");
       props.put("mail.pop3.port", mailprofile.getPop3Port());   
        props.setProperty("mail.pop3.socketFactory.class",
                "javax.net.ssl.SSLSocketFactory");
        props.setProperty("mail.pop3.socketFactory.fallback",
                "false");
        props.setProperty("mail.pop3.port", "" + mailprofile.getPop3Port());
        props.setProperty("mail.pop3.socketFactory.port", ""
                + mailprofile.getPop3Port());

           Session session = Session.getInstance(props, null);
           Store store = session.getStore();
           store.connect(mailprofile.getPop3Host(), mailprofile.getEmail(), mailprofile.getPassword());
           Folder inbox = store.getFolder(folder);
           inbox.open(Folder.READ_ONLY); 
           if(limit > inbox.getMessageCount()) limit = inbox.getMessageCount()-1;
           javax.mail.Message[] msg = inbox.getMessages(inbox.getMessageCount()-offset-limit, inbox.getMessageCount()-offset);
           String content = null;
           javax.mail.Message m;
           try{
            for(int i=msg.length-1; i >= 0; i--){
                m = msg[i];
                 Object msgContent = m.getContent();                   
                     if (msgContent instanceof Multipart) {
                         Multipart multipart = (Multipart) msgContent;
                         for (int j = 0; j < multipart.getCount(); j++) {
                         BodyPart bodyPart = multipart.getBodyPart(j);
                         String disposition = bodyPart.getDisposition();
                         if (disposition != null && (disposition.equalsIgnoreCase("ATTACHMENT"))) { 
                              DataHandler handler = bodyPart.getDataHandler();                 
                          }
                          else { 
                              if(bodyPart instanceof IMAPBodyPart){
                                     content = ((IMAPBodyPart)bodyPart).getContent().toString();  // the changed code 
                                     if(((IMAPBodyPart)bodyPart).getContent() instanceof MimeMultipart){
                                         Multipart multi2 = (Multipart) ((IMAPBodyPart)bodyPart).getContent();
                                         for (int k = 0; k < multi2.getCount(); k++) 
                                             content =multi2.getBodyPart(k).getContent().toString();
                                    }
                                }    
                            }
                        }
                     }
                     else                
                         content= m.getContent().toString();

                    if(m.getContentType().startsWith("com.sun.mail.util.BASE64DecoderStream"))
                        content = ((BASE64DecoderStream) m.getContent()).toString();
                    mailprofile.addReceivedMessage(
                            new Email(
                                    MimeUtility.decodeText(m.getFrom()[0].toString()), 
                                    MimeUtility.decodeText(m.getAllRecipients()[0].toString()), 
                                    MimeUtility.decodeText(m.getSubject()), m.getReceivedDate(), 
                                    content, 
                                    new ArrayList<File>()
                            )
                    );
            }
           } catch(Exception e){}
           finally{
            if(inbox != null)
                inbox.close(true);
            if(store != null)
                store.close();
           }

}
项目：Raven-Messenger    文件：MailControlAndroid.java    
public static void receiveEmailIMAPAndroid(MailProfile mailprofile, String folder, int offset, int limit) throws Exception{
    Properties props = new Properties();
       props.setProperty("mail.store.protocol", "imaps");
       props.put("mail.imap.port", mailprofile.getImapPort());   
        props.setProperty("mail.imap.socketFactory.class",
                    "javax.net.ssl.SSLSocketFactory");
            props.setProperty("mail.imap.socketFactory.fallback",
                    "false");
            props.setProperty("mail.imap.port", "" + mailprofile.getImapPort());
            props.setProperty("mail.imap.socketFactory.port", ""
                    + mailprofile.getImapPort());

           Session session = Session.getInstance(props, null);
           Store store = session.getStore();
           store.connect(mailprofile.getImapHost(), mailprofile.getEmail(), mailprofile.getPassword());
           Folder inbox = store.getFolder(folder);
           inbox.open(Folder.READ_ONLY); 
           if(limit > inbox.getMessageCount()) limit = inbox.getMessageCount()-1;
           javax.mail.Message[] msg = inbox.getMessages(inbox.getMessageCount()-offset-limit, inbox.getMessageCount()-offset);
           String content;
           javax.mail.Message m;
           try{
            for(int i=msg.length-1; i >= 0; i--){
                m = msg[i];
                    content = m.getContent().toString();                
                     Object msgContent = m.getContent();

                     if (msgContent instanceof Multipart) {
                         Multipart multipart = (Multipart) msgContent;
                         for (int j = 0; j < multipart.getCount(); j++) {
                         BodyPart bodyPart = multipart.getBodyPart(j);
                         String disposition = bodyPart.getDisposition();
                         if (disposition != null && (disposition.equalsIgnoreCase("ATTACHMENT"))) { 
                             DataHandler handler = bodyPart.getDataHandler();                    
                          }
                          else { 
                            if(bodyPart instanceof IMAPBodyPart){
                                 content = ((IMAPBodyPart)bodyPart).getContent().toString();  // the changed code 
                                 if(((IMAPBodyPart)bodyPart).getContent() instanceof MimeMultipart){
                                     Multipart multi2 = (Multipart) ((IMAPBodyPart)bodyPart).getContent();
                                     for (int k = 0; k < multi2.getCount(); k++) 
                                         content =multi2.getBodyPart(k).getContent().toString();
                                }
                            }

                            }
                        }
                     }

                     else                
                         content= m.getContent().toString();
                    if(content.startsWith("com.sun.mail.util.BASE64DecoderStream")){

                    }
                    mailprofile.addReceivedMessage(
                            new Email(
                                    MimeUtility.decodeText(m.getFrom()[0].toString()), 
                                    MimeUtility.decodeText(m.getAllRecipients()[0].toString()), 
                                    MimeUtility.decodeText(m.getSubject()), m.getReceivedDate(), 
                                    content, 
                                    new ArrayList<File>()
                            )
                    );

            } 
           } catch(Exception e){e.printStackTrace();} 
           finally{
            if(inbox != null)
                inbox.close(true);
            if(store != null)
                store.close();


           }

}
项目：daq-eclipse    文件：SMTPAppender.java    
/**
   Activate the specified options, such as the smtp host, the
   recipient, from, etc. */
public
void activateOptions() {
  Session session = createSession();
  msg = new MimeMessage(session);

   try {
      addressMessage(msg);
      if(subject != null) {
         try {
              msg.setSubject(MimeUtility.encodeText(subject, "UTF-8", null));
         } catch(UnsupportedEncodingException ex) {
              LogLog.error("Unable to encode SMTP subject", ex);
         }
      }
   } catch(MessagingException e) {
     LogLog.error("Could not activate SMTPAppender options.", e );
   }

   if (evaluator instanceof OptionHandler) {
       ((OptionHandler) evaluator).activateOptions();
   }
}
项目：sakai    文件：BaseMailArchiveService.java    
/**
 * Access the from: address of the message.
 * 
 * @return The from: address of the message.
 */
public String getFromAddress()
{
    String fromAddress = ((m_fromAddress == null) ? "" : m_fromAddress);

    try
    {
        fromAddress = MimeUtility.decodeText(fromAddress);
    }
    catch (UnsupportedEncodingException e)
    {
        // if unable to decode RFC address, just return address as is
        log.debug(this+".getFromAddress "+e.toString());
    }

    return fromAddress;

}
项目：LNTUOnline-API    文件：Mail.java    
public static boolean sendAndCc(String smtp, String from, String to, String copyto,
                                String subject, String content, String username, String password) throws UnsupportedEncodingException {
    Mail theMail = new Mail(smtp);
    theMail.setNeedAuth(true); // 验证
    if (!theMail.setSubject(MimeUtility.encodeText(subject,MimeUtility.mimeCharset("gb2312"),null)))
        return false;
    if (!theMail.setBody(content))
        return false;
    if (!theMail.setTo(to))
        return false;
    if (!theMail.setCopyTo(copyto))
        return false;
    if (!theMail.setFrom(from))
        return false;
    theMail.setNamePass(username, password);
    if (!theMail.sendOut())
        return false;
    return true;
}
项目：Genji    文件：MailReader.java    
private static void handleAttachment(Part part, List<EmailAttachment> attachments) throws MessagingException {
    String fileName = part.getFileName();
    try {
        if (fileName != null) {
            fileName = MimeUtility.decodeText(fileName);
        } else {
            fileName = "binaryPart.dat";
        }
        attachments.add(createEmailAttachment(part, fileName));
    } catch (Exception e) {
        // just ignore
    }
}
项目：smtp-sender    文件：Rfc2074MenuItem.java    
private ActionListener createDecodeAction() {
    return new ActionListener() {

        @Override
        public void actionPerformed(ActionEvent event) {
            try {
                String encodeText = StringUtils.defaultIfEmpty(Rfc2074Dialog.this.encodeTextArea.getText(), "");
                String decodeText = encodeText;
                if (encodeText.startsWith("=?")) {
                    decodeText = MimeUtility.decodeWord(encodeText);
                }
                Rfc2074Dialog.this.decodeTextArea.setText(decodeText);
            } catch (Throwable e) {
                JOptionPane.showMessageDialog(Rfc2074Dialog.this, e.getClass().getSimpleName() + " - " + e.getMessage(), "Decoding fail !", JOptionPane.ERROR_MESSAGE);
            }
        }
    };
}
项目：translationstudio8    文件：MessageParser.java    
/**
 * 获取消息附件中的文件.
 * @return List&lt;ResourceFileBean&gt;
 *              文件的集合(每个 ResourceFileBean 对象中存放文件名和 InputStream 对象)
 * @throws MessagingException
 *             the messaging exception
 * @throws IOException
 *             Signals that an I/O exception has occurred.
 */
public List<ResourceFileBean> getFiles() throws MessagingException, IOException {
    List<ResourceFileBean> resourceList = new ArrayList<ResourceFileBean>();
    Object content = message.getContent();
    Multipart mp = null;
    if (content instanceof Multipart) {
        mp = (Multipart) content;
    } else {
        return resourceList;
    }
    for (int i = 0, n = mp.getCount(); i < n; i++) {
        Part part = mp.getBodyPart(i);
        //此方法返回 Part 对象的部署类型。
        String disposition = part.getDisposition();
        //Part.ATTACHMENT 指示 Part 对象表示附件。
        //Part.INLINE 指示 Part 对象以内联方式显示。
        if ((disposition != null) && ((disposition.equals(Part.ATTACHMENT) || (disposition.equals(Part.INLINE))))) {
            //part.getFileName():返回 Part 对象的文件名。
            String fileName = MimeUtility.decodeText(part.getFileName());
            //此方法为 Part 对象返回一个 InputStream 对象
            InputStream is = part.getInputStream();
            resourceList.add(new ResourceFileBean(fileName, is));
        } else if (disposition == null) {
            //附件也可以没有部署类型的方式存在
            getRelatedPart(part, resourceList);
        }
    }
    return resourceList;
}
项目：community-edition-old    文件：SubethaEmailMessage.java    
/**
 * Method extracts file name from a message part for saving its as aa attachment. If the file name can't be extracted, it will be generated based on defaultPrefix parameter.
 * 
 * @param defaultPrefix This prefix fill be used for generating file name.
 * @param messagePart A part of message
 * @return File name.
 * @throws MessagingException
 */
private String getPartFileName(String defaultPrefix, Part messagePart) throws MessagingException
{
    String fileName = messagePart.getFileName();
    if (fileName != null)
    {
        try
        {
            fileName = MimeUtility.decodeText(fileName);
        }
        catch (UnsupportedEncodingException ex)
        {
            // Nothing to do :)
        }
    }
    else
    {
        fileName = defaultPrefix;
        if (messagePart.isMimeType(MIME_PLAIN_TEXT))
            fileName += ".txt";
        else if (messagePart.isMimeType(MIME_HTML_TEXT))
            fileName += ".html";
        else if (messagePart.isMimeType(MIME_XML_TEXT))
            fileName += ".xml";
        else if (messagePart.isMimeType(MIME_IMAGE))
            fileName += ".gif";
    }
    return fileName;
}
项目：community-edition-old    文件：ContentModelMessage.java    
/**
 * This method builds {@link MimeMessage} based on {@link ContentModel}
 * 
 * @throws MessagingException
 */
private void buildContentModelMessage() throws MessagingException
{
    Map<QName, Serializable> properties = messageFileInfo.getProperties();
    String prop = null;
    setSentDate(messageFileInfo.getModifiedDate());
    // Add FROM address
    Address[] addressList = buildSenderFromAddress();
    addFrom(addressList);
    // Add TO address
    addressList = buildRecipientToAddress();
    addRecipients(RecipientType.TO, addressList);
    prop = (String) properties.get(ContentModel.PROP_TITLE);
    try
    {
        prop = (prop == null || prop.equals("")) ? messageFileInfo.getName() : prop;
        prop = MimeUtility.encodeText(prop, AlfrescoImapConst.UTF_8, null);
    }
    catch (UnsupportedEncodingException e)
    {
        // ignore
    }
    setSubject(prop);
    setContent(buildContentModelMultipart());
}
项目：SelfSoftShop    文件：MailServiceImpl.java    
public void sendMail(String subject, String templatePath, Map<String, Object> data, String toMail) {
    try {
        Setting setting = SettingUtil.getSetting();
        JavaMailSenderImpl javaMailSenderImpl = (JavaMailSenderImpl)javaMailSender;
        javaMailSenderImpl.setHost(setting.getSmtpHost());
        javaMailSenderImpl.setPort(setting.getSmtpPort());
        javaMailSenderImpl.setUsername(setting.getSmtpUsername());
        javaMailSenderImpl.setPassword(setting.getSmtpPassword());
        MimeMessage mimeMessage = javaMailSenderImpl.createMimeMessage();
        Configuration configuration = freemarkerManager.getConfiguration(servletContext);
        Template template = configuration.getTemplate(templatePath);
        String text = FreeMarkerTemplateUtils.processTemplateIntoString(template, data);
        MimeMessageHelper mimeMessageHelper = new MimeMessageHelper(mimeMessage, false, "utf-8");
        mimeMessageHelper.setFrom(MimeUtility.encodeWord(setting.getShopName()) + " <" + setting.getSmtpFromMail() + ">");
        mimeMessageHelper.setTo(toMail);
        mimeMessageHelper.setSubject(subject);
        mimeMessageHelper.setText(text, true);
        addSendMailTask(mimeMessage);
    } catch (Exception e) {
        e.printStackTrace();
    }
}
项目：geokettle-2.0    文件：JobEntryGetPOP.java    
public static void handlePart(String foldername, Part part) throws MessagingException, IOException
{
  String disposition = part.getDisposition();
  // String contentType = part.getContentType();

  if ((disposition != null)
      && (disposition.equalsIgnoreCase(Part.ATTACHMENT) || disposition.equalsIgnoreCase(Part.INLINE)))
  {
    saveFile(foldername, MimeUtility.decodeText(part.getFileName()), part.getInputStream());
  }
}
项目：sakai    文件：BaseMailArchiveService.java    
/**
 * Access the from: address of the message.
 * 
 * @return The from: address of the message.
 */
public String getFromAddress()
{
    String fromAddress = ((m_fromAddress == null) ? "" : m_fromAddress);

    try
    {
        fromAddress = MimeUtility.decodeText(fromAddress);
    }
    catch (UnsupportedEncodingException e)
    {
        // if unable to decode RFC address, just return address as is
        log.debug(this+".getFromAddress "+e.toString());
    }

    return fromAddress;

}
项目：jcabi-email    文件：StSubject.java    
@Override
public void attach(final Message message) throws MessagingException {
    if (this.subject == null) {
        throw new IllegalArgumentException(
            "Email subject can't be NULL"
        );
    }
    if (this.charset == null) {
        throw new IllegalArgumentException(
            "Subject charset can't be NULL"
        );
    }
    try {
        message.setSubject(
            MimeUtility.encodeText(this.subject, this.charset, "Q")
        );
    } catch (final UnsupportedEncodingException ex) {
        throw new IllegalStateException(ex);
    }
}
项目：jcabi-email    文件：EnHtml.java    
@Override
public MimeBodyPart part() throws MessagingException {
    if (this.text == null) {
        throw new IllegalArgumentException(
            "Attachment text can't be NULL"
        );
    }
    if (this.charset == null) {
        throw new IllegalArgumentException(
            "Attachment charset can't be NULL"
        );
    }
    final MimeBodyPart mime = new MimeBodyPart();
    final String characterset = MimeUtility.quote(
        this.charset,
        "()<>@,;:\\\"\t []/?="
    );
    final String ctype = String.format(
        "text/html;charset=\"%s\"",
        characterset
    );
    mime.setContent(this.text, ctype);
    mime.addHeader("Content-Type", ctype);
    return mime;
}
项目：cs-actions    文件：GetMailMessage.java    
protected Map<String, String> getMessageByContentTypes(Message message, String characterSet) throws Exception {

        Map<String, String> messageMap = new HashMap<>();

        if (message.isMimeType(TEXT_PLAIN)) {
            messageMap.put(TEXT_PLAIN, MimeUtility.decodeText(message.getContent().toString()));
        } else if (message.isMimeType(TEXT_HTML)) {
            messageMap.put(TEXT_HTML, MimeUtility.decodeText(convertMessage(message.getContent().toString())));
        } else if (message.isMimeType(MULTIPART_MIXED) || message.isMimeType(MULTIPART_RELATED)) {
            messageMap.put(MULTIPART_MIXED, extractMultipartMixedMessage(message, characterSet));
        } else {
            Object obj = message.getContent();
            Multipart mpart = (Multipart) obj;

            for (int i = 0, n = mpart.getCount(); i < n; i++) {

                Part part = mpart.getBodyPart(i);

                if (decryptMessage && part.getContentType() != null &&
                        part.getContentType().equals(ENCRYPTED_CONTENT_TYPE)) {
                    part = decryptPart((MimeBodyPart)part);
                }

                String disposition = part.getDisposition();
                String partContentType = part.getContentType().substring(0, part.getContentType().indexOf(";"));
                if (disposition == null) {
                    if (part.getContent() instanceof MimeMultipart) {
                        // multipart with attachment
                        MimeMultipart mm = (MimeMultipart) part.getContent();
                        for (int j = 0; j < mm.getCount(); j++) {
                            if (mm.getBodyPart(j).getContent() instanceof String) {
                                BodyPart bodyPart = mm.getBodyPart(j);
                                if ((characterSet != null) && (characterSet.trim().length() > 0)) {
                                    String contentType = bodyPart.getHeader(CONTENT_TYPE)[0];
                                    contentType = contentType
                                            .replace(contentType.substring(contentType.indexOf("=") + 1), characterSet);
                                    bodyPart.setHeader(CONTENT_TYPE, contentType);
                                }
                                String partContentType1 = bodyPart
                                        .getContentType().substring(0, bodyPart.getContentType().indexOf(";"));
                                messageMap.put(partContentType1,
                                        MimeUtility.decodeText(bodyPart.getContent().toString()));
                            }
                        }
                    } else {
                        //multipart - w/o attachment
                        //if the user has specified a certain characterSet we decode his way
                        if ((characterSet != null) && (characterSet.trim().length() > 0)) {
                            InputStream istream = part.getInputStream();
                            ByteArrayInputStream bis = new ByteArrayInputStream(ASCIIUtility.getBytes(istream));
                            int count = bis.available();
                            byte[] bytes = new byte[count];
                            count = bis.read(bytes, 0, count);
                            messageMap.put(partContentType,
                                    MimeUtility.decodeText(new String(bytes, 0, count, characterSet)));
                        } else {
                            messageMap.put(partContentType, MimeUtility.decodeText(part.getContent().toString()));
                        }
                    }
                }
            } //for
        } //else

        return messageMap;
    }
项目：cs-actions    文件：GetMailMessageTest.java    
/**
 * Test execute method throws UnsupportedEncodingException.
 *
 * @throws Exception
 */
@Test
public void testExecuteUnsupportedEncodingException() throws Exception {
    doReturn(messageMock).when(getMailMessageSpy).getMessage();
    doNothing().when(messageMock).setFlag(Flags.Flag.DELETED, true);
    doReturn(new String[]{"1"}).when(messageMock).getHeader(anyString());
    doReturn(SUBJECT_TEST).when(getMailMessageSpy).changeHeaderCharset("1", CHARACTERSET);
    PowerMockito.mockStatic(MimeUtility.class);
    PowerMockito.doThrow(new UnsupportedEncodingException("")).when(MimeUtility.class, "decodeText", anyString());

    addRequiredInputs();
    inputs.setSubjectOnly("");
    inputs.setCharacterSet(BAD_CHARACTERSET);

    exception.expect(Exception.class);
    exception.expectMessage("The given encoding (" + BAD_CHARACTERSET + ") is invalid or not supported.");
    getMailMessageSpy.execute(inputs);
}
项目：yako    文件：SimpleEmailMessageProvider.java    
/**
 * Returns an attachment list for a given Mime Multipart object.
 * 
 * @param mp the input Mime part of the email's content
 * @param level debug variable
 * @return list of files where the attachments are saved
 * @throws MessagingException
 * @throws IOException 
 */
private List<Attachment> getAttachmentsOfMultipartMessage(Multipart mp, boolean onlyInfo, int level) throws MessagingException, IOException {
  List<Attachment> files = new LinkedList<Attachment>();

  for (int j = 0; j < mp.getCount(); j++) {

    Part bp = mp.getBodyPart(j);
    String contentType = bp.getContentType().toLowerCase();

    if (!Part.ATTACHMENT.equalsIgnoreCase(bp.getDisposition())) {
      if (contentType.indexOf("multipart/") != -1) {
        files.addAll(getAttachmentsOfMultipartMessage((Multipart)(bp.getContent()), onlyInfo, level + 1));
      }
      continue;
    }
    String fName = bp.getFileName() == null ? "noname" : bp.getFileName();
    files.add(new Attachment(MimeUtility.decodeText(fName), bp.getSize()));
    if (!onlyInfo) {
      InputStream is = bp.getInputStream();
      File f = new File(this.attachmentFolder + bp.getFileName());
      FileOutputStream fos = new FileOutputStream(f);
      byte[] buf = new byte[4096];
      int bytesRead;
      while((bytesRead = is.read(buf))!=-1) {
          fos.write(buf, 0, bytesRead);
      }
      fos.close();
    }

  }

  return files;
}