+++ /dev/null
-package com.ozacc.mail.impl;\r
-\r
-import java.io.UnsupportedEncodingException;\r
-import java.util.Date;\r
-import java.util.Properties;\r
-\r
-import javax.mail.AuthenticationFailedException;\r
-import javax.mail.MessagingException;\r
-import javax.mail.Session;\r
-import javax.mail.Transport;\r
-import javax.mail.internet.InternetAddress;\r
-import javax.mail.internet.MimeMessage;\r
-\r
-import org.apache.commons.logging.Log;\r
-import org.apache.commons.logging.LogFactory;\r
-\r
-import com.ozacc.mail.Mail;\r
-import com.ozacc.mail.MailAuthenticationException;\r
-import com.ozacc.mail.MailBuildException;\r
-import com.ozacc.mail.MailException;\r
-import com.ozacc.mail.MailSendException;\r
-import com.ozacc.mail.SendMail;\r
-\r
-/**\r
- * SendMailインターフェースの実装クラス。\r
- * \r
- * @since 1.0\r
- * @author Tomohiro Otsuka\r
- * @version $Id: SendMailImpl.java,v 1.7.2.6 2007/03/30 13:03:44 otsuka Exp $\r
- */\r
-public class SendMailImpl implements SendMail {\r
-\r
- private static Log log = LogFactory.getLog(SendMailImpl.class);\r
-\r
- /** デフォルトのプロトコル。「smtp」 */\r
- public static final String DEFAULT_PROTOCOL = "smtp";\r
-\r
- /**\r
- * デフォルトのポート。「-1」<br>\r
- * -1はプロトコルに応じた適切なポートを設定する特別な値。\r
- * */\r
- public static final int DEFAULT_PORT = -1;\r
-\r
- /** デフォルトのSMTPサーバ。「localhost」 */\r
- public static final String DEFAULT_HOST = "localhost";\r
-\r
- /** ISO-2022-JP */\r
- public static final String JIS_CHARSET = "ISO-2022-JP";\r
-\r
- private static final String RETURN_PATH_KEY = "mail.smtp.from";\r
-\r
- /** 接続タイムアウト */\r
- private static final int DEFAULT_CONNECTION_TIMEOUT = 5000;\r
-\r
- /** 読込タイムアウト */\r
- private static final int DEFAULT_READ_TIMEOUT = 5000;\r
-\r
- private String protocol = DEFAULT_PROTOCOL;\r
-\r
- private String host = DEFAULT_HOST;\r
-\r
- private int port = DEFAULT_PORT;\r
-\r
- private String username;\r
-\r
- private String password;\r
-\r
- private String charset = JIS_CHARSET;\r
-\r
- private String returnPath;\r
-\r
- private String messageId;\r
-\r
- private int connectionTimeout = DEFAULT_CONNECTION_TIMEOUT;\r
-\r
- private int readTimeout = DEFAULT_READ_TIMEOUT;\r
-\r
- /**\r
- * コンストラクタ。\r
- */\r
- public SendMailImpl() {}\r
-\r
- /**\r
- * コンストラクタ。使用するSMTPサーバを指定します。\r
- * \r
- * @param host SMTPサーバのホスト名、またはIPアドレス\r
- */\r
- public SendMailImpl(String host) {\r
- this();\r
- setHost(host);\r
- }\r
-\r
- /**\r
- * @see com.ozacc.mail.SendMail#send(com.ozacc.mail.Mail)\r
- */\r
- public void send(Mail mail) throws MailException {\r
- send(new Mail[] { mail });\r
- }\r
-\r
- /**\r
- * @see com.ozacc.mail.SendMail#send(com.ozacc.mail.Mail[])\r
- */\r
- public void send(Mail[] mails) throws MailException {\r
- MimeMessageWrapper[] mmws = new MimeMessageWrapper[mails.length];\r
- Session session = Session.getInstance(new Properties());\r
- for (int i = 0; i < mails.length; i++) {\r
- Mail mail = mails[i];\r
-\r
- // MimeMessageを生成\r
- MimeMessage message = createMimeMessage(session);\r
- if (isMessageIdCustomized()) {\r
- mail.addHeader("Message-ID", ((OMLMimeMessage)message).getMessageId());\r
- }\r
- MimeMessageBuilder builder = new MimeMessageBuilder(message, charset);\r
- try {\r
- builder.buildMimeMessage(mail);\r
- } catch (UnsupportedEncodingException e) {\r
- throw new MailBuildException("サポートされていない文字コードが指定されました。", e);\r
- } catch (MessagingException e) {\r
- throw new MailBuildException("MimeMessageの生成に失敗しました。", e);\r
- }\r
-\r
- // Return-Pathを取得\r
- String returnPath;\r
- if (mail.getReturnPath() != null) {\r
- returnPath = mail.getReturnPath().getAddress();\r
- } else {\r
- returnPath = this.returnPath;\r
- }\r
-\r
- mmws[i] = new MimeMessageWrapper(message, returnPath, mail.getEnvelopeTo());\r
- }\r
- processSend(mmws);\r
- }\r
-\r
- /**\r
- * @see com.ozacc.mail.SendMail#send(javax.mail.internet.MimeMessage)\r
- */\r
- public void send(MimeMessage message) throws MailException {\r
- send(new MimeMessage[] { message });\r
- }\r
-\r
- /**\r
- * @see com.ozacc.mail.SendMail#send(javax.mail.internet.MimeMessage[])\r
- */\r
- public void send(MimeMessage[] messages) throws MailException {\r
- MimeMessageWrapper[] mmws = new MimeMessageWrapper[messages.length];\r
- for (int i = 0; i < messages.length; i++) {\r
- mmws[i] = new MimeMessageWrapper(messages[i], returnPath);\r
- }\r
- processSend(mmws);\r
- }\r
-\r
- private void processSend(MimeMessageWrapper[] mmws) throws MailException {\r
-\r
- Properties prop = new Properties();\r
- // タイムアウトの設定\r
- prop.put("mail.smtp.connectiontimeout", String.valueOf(connectionTimeout));\r
- prop.put("mail.smtp.timeout", String.valueOf(readTimeout));\r
- // mail.smtp.authプロパティの設定\r
- if (username != null && !"".equals(username) && password != null && !"".equals(password)) {\r
- prop.put("mail.smtp.auth", "true");\r
- }\r
- Session session = Session.getInstance(prop);\r
-\r
- Transport transport = null;\r
- try {\r
- // SMTPサーバに接続\r
- log.debug("SMTPサーバ[" + host + "]に接続します。");\r
- transport = session.getTransport(protocol);\r
- transport.connect(host, port, username, password);\r
- log.debug("SMTPサーバ[" + host + "]に接続しました。");\r
-\r
- for (int i = 0; i < mmws.length; i++) {\r
- MimeMessage mimeMessage = mmws[i].getMimeMessage();\r
- // Return-Pathをセット\r
- String returnPath = mmws[i].getReturnPath();\r
- if (returnPath != null) {\r
- session.getProperties().put(RETURN_PATH_KEY, returnPath);\r
- log.debug("Return-Path[" + returnPath + "]を設定しました。");\r
- }\r
- // 送信日時をセット\r
- mimeMessage.setSentDate(new Date());\r
- mimeMessage.saveChanges();\r
-\r
- // 送信\r
- log.debug("メールを送信します。");\r
- if (mmws[i].hasEnvelopeTo()) {\r
- log.debug("メールはenvelope-toアドレスに送信されます。");\r
- transport.sendMessage(mimeMessage, mmws[i].getEnvelopeTo());\r
- } else {\r
- transport.sendMessage(mimeMessage, mimeMessage.getAllRecipients());\r
- }\r
- log.debug("メールを送信しました。");\r
-\r
- // Return-Pathを解除\r
- if (returnPath != null) {\r
- session.getProperties().remove(RETURN_PATH_KEY);\r
- log.debug("Return-Path設定をクリアしました。");\r
- }\r
- }\r
- } catch (AuthenticationFailedException ex) {\r
- log.error("SMTPサーバ[" + host + "]への接続認証に失敗しました。", ex);\r
- throw new MailAuthenticationException(ex);\r
- } catch (MessagingException ex) {\r
- log.error("メールの送信に失敗しました。", ex);\r
- throw new MailSendException("メールの送信に失敗しました。", ex);\r
- } finally {\r
- if (transport != null && transport.isConnected()) {\r
- log.debug("SMTPサーバ[" + host + "]との接続を切断します。");\r
- try {\r
- // SMTPサーバとの接続を切断\r
- transport.close();\r
- } catch (MessagingException e) {\r
- log.error("SMTPサーバ[" + host + "]との接続切断に失敗しました。", e);\r
- throw new MailException("SMTPサーバ[" + host + "]との接続切断に失敗しました。");\r
- }\r
- log.debug("SMTPサーバ[" + host + "]との接続を切断しました。");\r
- }\r
- }\r
- }\r
-\r
- /**\r
- * 新しいMimeMessageオブジェクトを生成します。<br>\r
- * messageIdプロパティがセットされている場合、OMLMimeMessageのインスタンスを生成します。\r
- * \r
- * @return 新しいMimeMessageオブジェクト\r
- */\r
- private MimeMessage createMimeMessage(Session session) {\r
- if (isMessageIdCustomized()) {\r
- return new OMLMimeMessage(session, messageId);\r
- }\r
- return new MimeMessage(session);\r
- }\r
-\r
- /**\r
- * Message-Idヘッダのドメイン部分を独自にセットしているかどうか判定します。\r
- * \r
- * @return Message-Idヘッダのドメイン部分を独自にセットしている場合 true\r
- */\r
- private boolean isMessageIdCustomized() {\r
- return messageId != null;\r
- }\r
-\r
- /**\r
- * エンコーディングに使用する文字コードを返します。\r
- * \r
- * @return エンコーディングに使用する文字コード\r
- */\r
- public String getCharset() {\r
- return charset;\r
- }\r
-\r
- /**\r
- * メールの件名や本文のエンコーディングに使用する文字コードを指定します。\r
- * デフォルトは<code>ISO-2022-JP</code>です。\r
- * <p>\r
- * 日本語環境で利用する場合は通常変更する必要はありません。\r
- * \r
- * @param charset エンコーディングに使用する文字コード\r
- */\r
- public void setCharset(String charset) {\r
- this.charset = charset;\r
- }\r
-\r
- /**\r
- * セットされたSMTPサーバのホスト名、またはIPアドレスを返します。\r
- * \r
- * @return SMTPサーバのホスト名、またはIPアドレス\r
- */\r
- public String getHost() {\r
- return host;\r
- }\r
-\r
- /**\r
- * SMTPサーバのホスト名、またはIPアドレスをセットします。\r
- * デフォルトは localhost です。\r
- * \r
- * @param host SMTPサーバのホスト名、またはIPアドレス\r
- */\r
- public void setHost(String host) {\r
- this.host = host;\r
- }\r
-\r
- /**\r
- * @return SMTPサーバ認証パスワード\r
- */\r
- public String getPassword() {\r
- return password;\r
- }\r
-\r
- /**\r
- * SMTPサーバの接続認証が必要な場合にパスワードをセットします。\r
- * \r
- * @param password SMTPサーバ認証パスワード\r
- */\r
- public void setPassword(String password) {\r
- this.password = password;\r
- }\r
-\r
- /**\r
- * @return SMTPサーバのポート番号\r
- */\r
- public int getPort() {\r
- return port;\r
- }\r
-\r
- /**\r
- * SMTPサーバのポート番号をセットします。\r
- * \r
- * @param port SMTPサーバのポート番号\r
- */\r
- public void setPort(int port) {\r
- this.port = port;\r
- }\r
-\r
- /**\r
- * プロトコルを返します。\r
- * \r
- * @return プロトコル\r
- */\r
- public String getProtocol() {\r
- return protocol;\r
- }\r
-\r
- /**\r
- * プロトコルをセットします。デフォルトは「smtp」。\r
- * \r
- * @param protocol プロトコル\r
- */\r
- public void setProtocol(String protocol) {\r
- this.protocol = protocol;\r
- }\r
-\r
- /**\r
- * @return Return-Pathアドレス\r
- */\r
- public String getReturnPath() {\r
- return returnPath;\r
- }\r
-\r
- /**\r
- * Return-Pathアドレスをセットします。\r
- * <p>\r
- * 送信するMailインスタンスに指定されたFromアドレス以外のアドレスをReturn-Pathとしたい場合に使用します。\r
- * ここでセットされたReturn-Pathより、MailインスタンスにセットされたReturn-Pathが優先されます。\r
- * \r
- * @param returnPath Return-Pathアドレス\r
- */\r
- public void setReturnPath(String returnPath) {\r
- this.returnPath = returnPath;\r
- }\r
-\r
- /**\r
- * @return SMTPサーバ認証ユーザ名\r
- */\r
- public String getUsername() {\r
- return username;\r
- }\r
-\r
- /**\r
- * SMTPサーバの接続認証が必要な場合にユーザ名をセットします。\r
- * \r
- * @param username SMTPサーバ認証ユーザ名\r
- */\r
- public void setUsername(String username) {\r
- this.username = username;\r
- }\r
-\r
- /**\r
- * SMTPサーバとの接続タイムアウトをセットします。\r
- * 単位はミリ秒。デフォルトは5,000ミリ秒(5秒)です。\r
- * <p>\r
- * -1を指定すると無限大になりますが、お薦めしません。\r
- * \r
- * @since 1.1.4\r
- * @param connectionTimeout SMTPサーバとの接続タイムアウト\r
- */\r
- public void setConnectionTimeout(int connectionTimeout) {\r
- this.connectionTimeout = connectionTimeout;\r
- }\r
-\r
- /**\r
- * SMTPサーバへの送信時のタイムアウトをセットします。\r
- * 単位はミリ秒。デフォルトは5,000ミリ秒(5秒)です。<br>\r
- * 送信時にタイムアウトすると、<code>com.ozacc.mail.MailSendException</code>がスローされます。\r
- * <p>\r
- * -1を指定すると無限大になりますが、お薦めしません。\r
- * \r
- * @since 1.1.4\r
- * @param readTimeout SMTPサーバへの送受信時のタイムアウト\r
- */\r
- public void setReadTimeout(int readTimeout) {\r
- this.readTimeout = readTimeout;\r
- }\r
-\r
- /**\r
- * 生成されるMimeMessageに付けられるMessage-Idヘッダのドメイン部分を指定します。<br>\r
- * 指定されない場合(nullや空文字列の場合)は、JavaMailがMessage-Idヘッダを生成します。\r
- * JavaMailが生成する「JavaMail.実行ユーザ名@ホスト名」のMessage-Idを避けたい場合に、このメソッドを使用します。\r
- * <p>\r
- * messageIdプロパティがセットされている場合、Mailから生成されるMimeMessageのMessage-Idには\r
- * <code>タイムスタンプ + ランダムに生成される16桁の数値 + ここでセットされた値</code>\r
- * が使用されます。\r
- * <p>\r
- * 生成されるMessage-Idの例。 (実際の数値部分は送信メール毎に変わります)<ul>\r
- * <li>messageIdに'example.com'を指定した場合・・・1095714924963.5619528074501343@example.com</li>\r
- * <li>messageIdに'@example.com'を指定した場合・・・1095714924963.5619528074501343@example.com (上と同じ)</li>\r
- * <li>messageIdに'OML@example.com'を指定した場合・・・1095714924963.5619528074501343.OML@example.com</li>\r
- * <li>messageIdに'.OML@example.com'を指定した場合・・・1095714924963.5619528074501343.OML@example.com (上と同じ)</li>\r
- * </ul>\r
- * <p>\r
- * <strong>注:</strong> このMessage-Idは<code>send(Mail)</code>か<code>send(Mail[])</code>メソッドが呼びだれた時にのみ有効です。MimeMessageを直接送信する場合には適用されません。\r
- * \r
- * @param messageId メールに付けられるMessage-Idヘッダのドメイン部分\r
- * @throws IllegalArgumentException @を複数含んだ文字列を指定した場合\r
- */\r
- public void setMessageId(String messageId) {\r
- if (messageId == null || messageId.length() < 1) {\r
- return;\r
- }\r
-\r
- String[] parts = messageId.split("@");\r
- if (parts.length > 2) {\r
- throw new IllegalArgumentException("messageIdプロパティに'@'を複数含むことはできません。[" + messageId\r
- + "]");\r
- }\r
-\r
- this.messageId = messageId;\r
- }\r
-\r
- /**\r
- * MimeMessageインスタンスと、そのメールに対応するReturn-Path、envelope-toアドレスをラップするクラス。\r
- * \r
- * @author Tomohiro Otsuka\r
- * @version $Id: SendMailImpl.java,v 1.7.2.6 2007/03/30 13:03:44 otsuka Exp $\r
- */\r
- private static class MimeMessageWrapper {\r
-\r
- private MimeMessage mimeMessage;\r
-\r
- private String returnPath;\r
-\r
- private InternetAddress[] envelopeTo;\r
-\r
- public MimeMessageWrapper(MimeMessage mimeMessage, String returnPath) {\r
- this.mimeMessage = mimeMessage;\r
- this.returnPath = returnPath;\r
- }\r
-\r
- public MimeMessageWrapper(MimeMessage mimeMessage, String returnPath,\r
- InternetAddress[] envelopeTo) {\r
- this.mimeMessage = mimeMessage;\r
- this.returnPath = returnPath;\r
- this.envelopeTo = envelopeTo;\r
- }\r
-\r
- public MimeMessage getMimeMessage() {\r
- return mimeMessage;\r
- }\r
-\r
- public String getReturnPath() {\r
- return returnPath;\r
- }\r
-\r
- public boolean hasEnvelopeTo() {\r
- return envelopeTo.length > 0;\r
- }\r
-\r
- public InternetAddress[] getEnvelopeTo() {\r
- return envelopeTo;\r
- }\r
- }\r
-\r
-}
\ No newline at end of file
OSDN Git Service
