sendmailjob.java

定时器开源项目, 相对于 jcrontab, Quartz 算是更完整的一个项目, 随著开发的版本上来, 他已经脱离只是写在程序里面的计时器, 在指定的时间或区间, 处理所指定的事件. 也加入了 se

/*
 * Copyright James House (c) 2001-2004
 * 
 * All rights reserved.
 * 
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met: 1.
 * Redistributions of source code must retain the above copyright notice, this
 * list of conditions and the following disclaimer. 2. Redistributions in
 * binary form must reproduce the above copyright notice, this list of
 * conditions and the following disclaimer in the documentation and/or other
 * materials provided with the distribution.
 * 
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND ANY
 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
 * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE FOR ANY
 * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
 * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *  
 */
package org.quartz.jobs.ee.mail;

import java.util.Date;
import java.util.Properties;

import javax.mail.Address;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.Session;
import javax.mail.Transport;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

/**
 * <p>
 * A Job which sends an e-mail with the configured content to the configured
 * recipient.
 * </p>
 * 
 * @author James House
 */
public class SendMailJob implements Job {

    /*
     * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
     * 
     * Constants.
     * 
     * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
     */

    /**
     * The host name of the smtp server. REQUIRED.
     */
    public static final String PROP_SMTP_HOST = "smtp_host";

    /**
     * The e-mail address to send the mail to. REQUIRED.
     */
    public static final String PROP_RECIPIENT = "recipient";

    /**
     * The e-mail address to cc the mail to. Optional.
     */
    public static final String PROP_CC_RECIPIENT = "cc_recipient";

    /**
     * The e-mail address to claim the mail is from. REQUIRED.
     */
    public static final String PROP_SENDER = "sender";

    /**
     * The e-mail address the message should say to reply to. Optional.
     */
    public static final String PROP_REPLY_TO = "reply_to";

    /**
     * The subject to place on the e-mail. REQUIRED.
     */
    public static final String PROP_SUBJECT = "subject";

    /**
     * The e-mail message body. REQUIRED.
     */
    public static final String PROP_MESSAGE = "message";

    /*
     * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
     * 
     * Interface.
     * 
     * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
     */

    /**
     * @see org.quartz.Job#execute(org.quartz.JobExecutionContext)
     */
    public void execute(JobExecutionContext context)
            throws JobExecutionException {

        JobDataMap data = context.getJobDetail().getJobDataMap();

        String smtpHost = data.getString(PROP_SMTP_HOST);
        String to = data.getString(PROP_RECIPIENT);
        String cc = data.getString(PROP_CC_RECIPIENT);
        String from = data.getString(PROP_SENDER);
        String replyTo = data.getString(PROP_REPLY_TO);
        String subject = data.getString(PROP_SUBJECT);
        String message = data.getString(PROP_MESSAGE);

        if (smtpHost == null || smtpHost.trim().length() == 0)
                throw new IllegalArgumentException(
                        "PROP_SMTP_HOST not specified.");
        if (to == null || to.trim().length() == 0)
                throw new IllegalArgumentException(
                        "PROP_RECIPIENT not specified.");
        if (from == null || from.trim().length() == 0)
                throw new IllegalArgumentException("PROP_SENDER not specified.");
        if (subject == null || subject.trim().length() == 0)
                throw new IllegalArgumentException(
                        "PROP_SUBJECT not specified.");
        if (message == null || message.trim().length() == 0)
                throw new IllegalArgumentException(
                        "PROP_MESSAGE not specified.");

        if (cc != null && cc.trim().length() == 0) cc = null;

        if (replyTo != null && replyTo.trim().length() == 0) replyTo = null;

        String mailDesc = "'" + subject + "' to: " + to;

        getLog().info("Sending message " + mailDesc);

        try {
            sendMail(smtpHost, to, cc, from, replyTo, subject, message);
        } catch (MessagingException e) {
            throw new JobExecutionException("Unable to send mail: " + mailDesc,
                    e, false);
        }

    }

    private static Log getLog() {
        return LogFactory.getLog(SendMailJob.class);
    }

    private void sendMail(String smtpHost, String to, String cc, String from,
            String replyTo, String subject, String message)
            throws MessagingException {
        MimeMessage mimeMessage = prepareMimeMessage(smtpHost, to, cc, from,
                replyTo, subject);
        mimeMessage.setText(message);
        Transport.send(mimeMessage);
    }

    private MimeMessage prepareMimeMessage(String smtpHost, String to,
            String cc, String from, String replyTo, String subject)
            throws MessagingException {

        Properties properties = new Properties();
        properties.put("mail.smtp.host", smtpHost);
        Session session = Session.getDefaultInstance(properties, null);

        MimeMessage mimeMessage = new MimeMessage(session);

        Address[] toAddresses = InternetAddress.parse(to);
        mimeMessage.setRecipients(Message.RecipientType.TO, toAddresses);

        if (cc != null) {
            Address[] ccAddresses = InternetAddress.parse(cc);
            mimeMessage.setRecipients(Message.RecipientType.CC, ccAddresses);
        }

        mimeMessage.setFrom(new InternetAddress(from));
        if (replyTo != null)
                mimeMessage
                        .setReplyTo(new InternetAddress[]{new InternetAddress(
                                replyTo)});
        mimeMessage.setSubject(subject);
        mimeMessage.setSentDate(new Date());

        return mimeMessage;
    }

}