ichengchao

//启动邮件服务器
public void startMailServer() {
        try {
            MySimpleMessageListener myListener = new MySimpleMessageListener();
            SMTPServer smtpServer = new SMTPServer(new SimpleMessageListenerAdapter(myListener));
            smtpServer.setPort(25);
            smtpServer.start();
        } catch (Exception e) {
            logger.error(e.getMessage(), e);
        }
    }
//MySimpleMessageListener.java
public class MySimpleMessageListener implements SimpleMessageListener {
    private Log          logger = LogFactory.getLog(MySimpleMessageListener.class);
    @Override
    public boolean accept(String from, String recipient) {
        // System.out.println(from);
        // System.out.println(recipient);
        // true表示需要投递
        return true;
    }
    @Override
    public void deliver(String from, String recipient, InputStream data) throws Exception {
        // System.out.println(from);
        // System.out.println(recipient);
        // System.out.println("===================================");
        // String body = this.convertStreamToString(data);
        Session session = Session.getInstance(new Properties(), null);
        try {
            MimeMessage mm = new MimeMessage(session, data);
            // System.out.println(mm.getContentType());
            // System.out.println(mm.getContent());
            String msg = mm.getContent().toString();
        } catch (Exception e) {
            logger.error(e.getMessage(), e);
        }
    }
}