smtpmailsender.java

短信发送

										+ (fileName = getBase64String(fileName))
										+ "\"", out);
						sendNewline(out);
						sendString("Content-Transfer-Encoding: base64", out);
						sendNewline(out);
						sendString(
								"Content-Disposition: attachment; filename=\""
										+ fileName + "\"", out);
						sendNewline(out);

						log("发送: ");
						sendNewline(out);

						do {
							k = attachment.read(data, 0, 54);

							if (k == -1) {
								break;
							}

							sendString(Base64.encode(data, 0, k), out);
							sendNewline(out);
						} while (k == 54);
					}
				} catch (FileNotFoundException e) {
					log("错误: 附件\"" + attachments[fileIndex].getAbsolutePath()
							+ "\"不存在");
					return FAILED;
				} catch (IOException e) {
					log("错误: 无法读取附件\""
							+ attachments[fileIndex].getAbsolutePath() + "\"");
					return FAILED;
				} finally {
					if (attachment != null) {
						try {
							attachment.close();
						} catch (IOException e) {
						}
					}
				}

				sendString("--" + BOUNDARY + "--", out);
				sendNewline(out);
			}

			sendString(".", out);
			sendNewline(out);

			if (response(in) != 250) {
				return FAILED;
			}

			sendString("QUIT", out);
			sendNewline(out);

			if (response(in) != 221) {
				return FAILED;
			}

			return SUCCESSFUL;
		} catch (SocketTimeoutException e) {
			log("错误: 连接超时");
			return FAILED;
		} catch (IOException e) {
			log("错误: 连接出错");
			return FAILED;
		} catch (Exception e) {
			log("错误: " + e.toString());
			return FAILED;
		} finally {
			if (in != null) {
				try {
					in.close();
				} catch (IOException e) {
				}
			}

			if (out != null) {
				try {
					out.close();
				} catch (IOException e) {
				}
			}

			if (socket != null) {
				try {
					socket.close();
				} catch (IOException e) {
				}
			}
		}
	}

	/**
	 * 给多个发件人发送邮件。
	 * @param to 收件人
	 * @param subject 主题
	 * @param content 正文
	 * @param attachments 附件
	 * @param isHtml 使用网页形式发送
	 * @param isUrgent 紧急邮件
	 * @return 任务状况
	 * @throws IllegalArgumentException 如果参数to为null或格式不正确
	 */
	public boolean[] sendMail(String[] to, String subject, String content,
			File[] attachments, boolean isHtml, boolean isUrgent)
			throws IllegalArgumentException {
		boolean[] task = new boolean[to.length];

		for (int k = 0; k < task.length; k++) {
			task[k] = sendMail(to[k], subject, content, attachments, isHtml,
					isUrgent);
		}

		return task;
	}

	/**
	 * 发送纯文本邮件。
	 * @param to 收件人
	 * @param subject 主题
	 * @param content 正文
	 * @return 是否发送成功
	 * @throws IllegalArgumentException 如果参数to为null或格式不正确
	 */
	public boolean sendTextMail(String to, String subject, String content)
			throws IllegalArgumentException {
		return sendMail(to, subject, content, null, false, false);
	}

	/**
	 * 发送HTML邮件。
	 * @param to 收件人
	 * @param subject 主题
	 * @param content 正文
	 * @return 是否发送成功
	 * @throws IllegalArgumentException 如果参数to为null或格式不正确
	 */
	public boolean sendHtmlMail(String to, String subject, String content)
			throws IllegalArgumentException {
		return sendMail(to, subject, content, null, true, false);
	}

	/**
	 * 给多个发件人发送纯文本邮件。
	 * @param to 收件人
	 * @param subject 主题
	 * @param content 正文
	 * @return 任务状况
	 * @throws IllegalArgumentException 如果参数to为null或格式不正确
	 */
	public boolean[] sendTextMail(String[] to, String subject, String content)
			throws IllegalArgumentException {
		return sendMail(to, subject, content, null, false, false);
	}

	/**
	 * 给多个发件人发送HTML邮件。
	 * @param to 收件人
	 * @param subject 主题
	 * @param content 正文
	 * @return 任务状况
	 * @throws IllegalArgumentException 如果参数to为null或格式不正确
	 */
	public boolean[] sendHtmlMail(String[] to, String subject, String content)
			throws IllegalArgumentException {
		return sendMail(to, subject, content, null, true, false);
	}

	/**
	 * 发送带附件的纯文本邮件。
	 * @param to 收件人
	 * @param subject 主题
	 * @param content 正文
	 * @param attachments 附件
	 * @return 是否发送成功
	 * @throws IllegalArgumentException 如果参数to为null或格式不正确
	 */
	public boolean sendTextMail(String to, String subject, String content,
			File[] attachments) throws IllegalArgumentException {
		return sendMail(to, subject, content, attachments, false, false);
	}

	/**
	 * 发送带附件的HTML邮件。
	 * @param to 收件人
	 * @param subject 主题
	 * @param content 正文
	 * @param attachments 附件
	 * @return 是否发送成功
	 * @throws IllegalArgumentException 如果参数to为null或格式不正确
	 */
	public boolean sendHtmlMail(String to, String subject, String content,
			File[] attachments) throws IllegalArgumentException {
		return sendMail(to, subject, content, attachments, true, false);
	}

	/**
	 * 给多个发件人发送带附件的纯文本邮件。
	 * @param to 收件人
	 * @param subject 主题
	 * @param content 正文
	 * @param attachments 附件
	 * @return 任务状况
	 * @throws IllegalArgumentException 如果参数to为null或格式不正确
	 */
	public boolean[] sendTextMail(String[] to, String subject, String content,
			File[] attachments) throws IllegalArgumentException {
		return sendMail(to, subject, content, attachments, false, false);
	}

	/**
	 * 给多个发件人发送带附件的HTML邮件。
	 * @param to 收件人
	 * @param subject 主题
	 * @param content 正文
	 * @param attachments 附件
	 * @return 任务状况
	 * @throws IllegalArgumentException 如果参数to为null或格式不正确
	 */
	public boolean[] sendHtmlMail(String[] to, String subject, String content,
			File[] attachments) throws IllegalArgumentException {
		return sendMail(to, subject, content, attachments, true, false);
	}

	/**
	 * 添加一个日志管理器。
	 * @param manager 日志管理器
	 */
	public void addLogManager(LogManager manager) {
		logManager.add(manager);
	}

	/**
	 * 移除日志管理器。
	 * @param manager 要移除的日志管理器
	 */
	public void removeLogManager(LogManager manager) {
		logManager.remove(manager);
	}

	/**
	 * 通过分析收件人邮箱域名的DNS记录获取邮件接收服务器地址。
	 * @param url 收件人邮箱域名
	 * @return 主机地址列表
	 */
	private String[] parseDomain(String url) {
		try {
			NamingEnumeration records = dirContext.getAttributes(url,
					new String[] { "mx" }).getAll();

			String[] address;
			String[] tmpMx;
			MX[] tmpMxArray;
			MX tmp;

			if (records.hasMore()) {
				url = records.next().toString();
				url = url.substring(url.indexOf(": ") + 2);
				address = url.split(",");
				tmpMxArray = new MX[address.length];

				for (int k = 0; k < address.length; k++) {
					tmpMx = address[k].trim().split(" ");
					tmpMxArray[k] = new MX(Integer.parseInt(tmpMx[0]), tmpMx[1]);
				}

				for (int n = 1; n < tmpMxArray.length; n++) {
					for (int m = n; m > 0; m--) {
						if (tmpMxArray[m - 1].pri > tmpMxArray[m].pri) {
							tmp = tmpMxArray[m - 1];
							tmpMxArray[m - 1] = tmpMxArray[m];
							tmpMxArray[m] = tmp;
						}
					}
				}

				for (int k = 0; k < tmpMxArray.length; k++) {
					address[k] = tmpMxArray[k].address;
				}

				return address;
			}//分析mx记录

			records = dirContext.getAttributes(url, new String[] { "a" })
					.getAll();

			if (records.hasMore()) {
				url = records.next().toString();
				url = url.substring(url.indexOf(": ") + 2).replace(" ", "");
				address = url.split(",");

				return address;
			}//分析a记录

			return new String[] { url };
		} catch (NamingException e) {
			log("错误: 域名\"" + url + "\"无法解析");
			return null;
		}
	}

	/**
	 * 获得响应码。
	 * @param in 输入流
	 * @return 响应码
	 * @throws IOException 如果发生 I/O 错误。
	 */
	private int response(InputStream in) throws IOException {
		byte[] buffer = new byte[1024];
		int k = in.read(buffer);

		if (k == -1) {
			return -1;
		}

		String response = new String(buffer, 0, k).trim();
		log("响应: " + response);
		return Integer.parseInt(response.substring(0, 3));
	}

	/**
	 * 输出字符串。
	 * @param str 字符串
	 * @param out 输出流
	 * @throws IOException 如果发生 I/O 错误。
	 */
	private void sendString(String str, OutputStream out) throws IOException {
		log("发送: " + str);

		if (str == null) {
			str = "";
		}

		out.write(str.getBytes());
		out.flush();
	}

	/**
	 * 写日志。
	 * @param info 信息
	 */
	private void log(String info) {
		for (int n = 0, m = logManager.size(); n < m; n++) {
			logManager.get(n).output(info);
		}
	}

	/**
	 * 输出一个换行符。
	 * @param out 输出流
	 * @throws IOException 如果发生 I/O 错误。
	 */
	private static void sendNewline(OutputStream out) throws IOException {
		out.write('\r');
		out.write('\n');
		out.flush();
	}

	/**
	 * 获得字符串的Base64加密形式。
	 * @param str 字符串
	 * @return 加密后的字符串
	 */
	private static String getBase64String(String str) {
		if (str == null || str.length() == 0) {
			return "";
		}

		StringBuffer tmpStr = new StringBuffer();
		byte[] bytes = str.getBytes();

		for (int k = 0; k < bytes.length;) {
			if (k != 0) {
				tmpStr.append(' ');
			}

			tmpStr.append("=?");
			tmpStr.append(CHARSET);
			tmpStr.append("?B?");
			tmpStr.append(Base64.encode(bytes, k, Math
					.min(bytes.length - k, 30)));
			tmpStr.append("?=");

			k += 30;

			if (k < bytes.length) {
				tmpStr.append('\r');
				tmpStr.append('\n');
			}
		}

		return tmpStr.toString();
	}

	/**
	 * 分析邮箱域名。
	 * @param address E-Mail地址
	 * @return 邮箱域名
	 */
	private static String parseUrl(String address) {
		return address.substring(address.lastIndexOf('@') + 1);
	}

	/**
	 * MX记录。
	 */
	private class MX {
		final int pri;
		final String address;

		MX(int pri, String host) {
			this.pri = pri;
			this.address = host;
		}
	}
}