Java/Servlets/Email
Содержание
Email Bean
import java.io.IOException;
import java.io.PrintWriter;
import java.util.Properties;
import javax.mail.Folder;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.Session;
import javax.mail.Store;
import javax.mail.Transport;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;
public class EmailBean {
//defaults
private final static String DEFAULT_CONTENT = "Unknown content";
private final static String DEFAULT_SUBJECT = "Unknown subject";
private static String DEFAULT_SERVER = null;
private static String DEFAULT_TO = null;
private static String DEFAULT_FROM = null;
static {
java.util.ResourceBundle bundle = java.util.ResourceBundle
.getBundle("com.jexp.mailDefaults");
DEFAULT_SERVER = bundle.getString("DEFAULT_SERVER");
DEFAULT_TO = bundle.getString("DEFAULT_TO");
DEFAULT_FROM = bundle.getString("DEFAULT_FROM");
System.out.println("DEFAULT_SERVER: " + DEFAULT_SERVER);
}
//JavaBean properties
private String smtpHost;
private String to;
private String from;
private String content;
private String subject;
public void sendMessage() throws Exception {
Properties properties = System.getProperties();
//populate the "Properties" object with the mail
//server address, so that the default "Session"
//instance can use it.
properties.put("mail.smtp.host", smtpHost);
Session session = Session.getDefaultInstance(properties);
Message mailMsg = new MimeMessage(session);//a new email message
InternetAddress[] addresses = null;
try {
if (to != null) {
//throws "AddressException" if the "to" email address
//violates RFC822 syntax
addresses = InternetAddress.parse(to, false);
mailMsg.setRecipients(Message.RecipientType.TO, addresses);
} else {
throw new MessagingException(
"The mail message requires a "To" address.");
}
if (from != null) {
mailMsg.setFrom(new InternetAddress(from));
} else {
throw new MessagingException(
"The mail message requires a valid "From" address.");
}
if (subject != null)
mailMsg.setSubject(subject);
if (content != null)
mailMsg.setText(content);
//Finally, send the mail message; throws a "SendFailedException"
//if any of the message"s recipients have an invalid address
Transport.send(mailMsg);
} catch (Exception exc) {
throw exc;
}
}//sendMessage
private void handleMessages(HttpServletRequest request, PrintWriter out)
throws IOException, ServletException {
HttpSession httpSession = request.getSession();
String user = (String) httpSession.getAttribute("user");
String password = (String) httpSession.getAttribute("pass");
String popAddr = (String) httpSession.getAttribute("pop");
Store popStore = null;
Folder folder = null;
if (!check(popAddr))
popAddr = EmailBean.DEFAULT_SERVER;
try {
if ((!check(user)) || (!check(password)))
throw new ServletException(
"A valid username and password is required to check email.");
Properties properties = System.getProperties();
Session session = Session.getDefaultInstance(properties);
popStore = session.getStore("pop3");
popStore.connect(popAddr, user, password);
folder = popStore.getFolder("INBOX");
if (!folder.exists())
throw new ServletException(
"An "INBOX" folder does not exist for the user.");
folder.open(Folder.READ_ONLY);
Message[] messages = folder.getMessages();
int msgLen = messages.length;
if (msgLen == 0)
out
.println("<h2>The INBOX folder does not yet contain any email messages.</h2>");
for (int i = 0; i < msgLen; i++) {
displayMessage(messages[i], out);
out.println("<br /><br />");
}
} catch (Exception exc) {
out
.println("<h2>Sorry, an error occurred while accessing the email messages.</h2>");
out.println(exc.toString());
} finally {
try {
if (folder != null)
folder.close(false);
if (popStore != null)
popStore.close();
} catch (Exception e) {
}
}
}//handleMessages
private void displayMessage(Message msg, PrintWriter out)
throws MessagingException, IOException {
if (msg != null && msg.getContent() instanceof String) {
if (msg.getFrom()[0] instanceof InternetAddress) {
out.println("Message received from: "
+ ((InternetAddress) msg.getFrom()[0]).getAddress()
+ "<br />");
}
out.println("Message received on: " + msg.getReceivedDate()
+ "<br />");
out.println("Message content type: " + msg.getContentType()
+ "<br />");
out.println("Message content type: " + (String) msg.getContent());
} else {
out
.println("<h2>The received email message was not of a text content type.</h2>");
}
}//displayMessage
public void setSmtpHost(String host) {
if (check(host)) {
this.smtpHost = host;
} else {
this.smtpHost = EmailBean.DEFAULT_SERVER;
}
}//setTo
public void setTo(String to) {
if (check(to)) {
this.to = to;
} else {
this.to = EmailBean.DEFAULT_TO;
}
}//setTo
public void setFrom(String from) {
if (check(from)) {
this.from = from;
} else {
this.from = EmailBean.DEFAULT_FROM;
}
}//setFrom
public void setContent(String content) {
if (check(content)) {
this.content = content;
} else {
this.content = EmailBean.DEFAULT_CONTENT;
}
}//setContent
public void setSubject(String subject) {
if (check(subject)) {
this.subject = subject;
} else {
this.subject = EmailBean.DEFAULT_SUBJECT;
}
}//setSubject
private boolean check(String value) {
if (value == null || value.equals(""))
return false;
return true;
}
}
Java servlet application
Mail Accessor
import java.io.IOException;
import java.io.PrintWriter;
import java.util.Properties;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import com.sun.corba.se.impl.protocol.giopmsgheaders.Message;
public class MailAccessor extends HttpServlet {
private final static String DEFAULT_SERVER = "mail.attbi.ru";
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, java.io.IOException {
response.setContentType("text/html");
java.io.PrintWriter out = response.getWriter();
out.println("<html><head><title>Email Reader</title></head><body>");
handleMessages(request, out);
out.println("</body></html>");
out.close();
} //doGet
private void handleMessages(HttpServletRequest request, PrintWriter out)
throws IOException, ServletException {
HttpSession httpSession = request.getSession();
String user = (String) httpSession.getAttribute("user");
String password = (String) httpSession.getAttribute("pass");
String popAddr = (String) httpSession.getAttribute("pop");
Store popStore = null;
Folder folder = null;
if (!check(popAddr))
popAddr = MailAccessor.DEFAULT_SERVER;
try {
if ((!check(user)) || (!check(password)))
throw new ServletException(
"A valid username and password is required to check email.");
Properties properties = System.getProperties();
Session session = Session.getDefaultInstance(properties);
popStore = session.getStore("pop3");
popStore.connect(popAddr, user, password);
folder = popStore.getFolder("INBOX");
if (!folder.exists())
throw new ServletException(
"An "INBOX" folder does not exist for the user.");
folder.open(Folder.READ_ONLY);
Message[] messages = folder.getMessages();
int msgLen = messages.length;
if (msgLen == 0)
out
.println("<h2>The INBOX folder does not yet contain any email messages.</h2>");
for (int i = 0; i < msgLen; i++) {
displayMessage(messages[i], out);
out.println("<br /><br />");
}
} catch (Exception exc) {
out
.println("<h2>Sorry, an error occurred while accessing the email messages.</h2>");
out.println(exc.toString());
} finally {
try {
if (folder != null)
folder.close(false);
if (popStore != null)
popStore.close();
} catch (Exception e) {
}
}
}//printMessages
private void displayMessage(Message msg, PrintWriter out)
throws MessagingException, IOException {
if (msg != null && msg.getContent() instanceof String) {
if (msg.getFrom()[0] instanceof InternetAddress) {
out.println("Message received from: "
+ ((InternetAddress) msg.getFrom()[0]).getAddress()
+ "<br />");
}
out.println("Message content type: " + msg.getContentType()
+ "<br />");
out.println("Message body content: " + (String) msg.getContent());
} else {
out
.println("<h2>The received email message was not of a text content type.</h2>");
}
}//displayMessage
private boolean check(String value) {
if (value == null || value.equals(""))
return false;
return true;
}
}
Sending e-mail by using the JavaMail API and JDBC
import java.util.Properties;
import javax.mail.*;
import javax.mail.internet.*;
import java.sql.*;
import javax.sql.*;
import javax.servlet.*;
import javax.servlet.http.*;
public class SendMailBean {
private Connection con = null;
protected String username;
public String getPasswordAndEmailAddress() {
//load email from database
String password = "Password";
String email = "Email";
emailPassword(email, username, password);
}
public void emailPassword(String email, String memberName, String password) {
String host = "mail";
String from = "w@j.ru";
Properties props = System.getProperties();
props.put("mail.smtp.host", host);
Session session = Session.getDefaultInstance(props, null);
MimeMessage message = new MimeMessage(session);
try {
message.setFrom(new InternetAddress(from));
message.addRecipient(Message.RecipientType.TO, new InternetAddress(email));
message.setSubject("Password Reminder");
message.setText("Hi " + memberName + ",\nYour password is: " + password + "\nregards - "
+ from);
Transport.send(message);
} catch (AddressException ae) {
} catch (MessagingException me) {
}
}
}
Sending E-Mail from Servlets
Servlet and email
import java.util.Properties;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import sun.rmi.transport.Transport;
import com.sun.corba.se.impl.protocol.giopmsgheaders.Message;
public class EmailServlet extends HttpServlet {
//default value for mail server address, in case the user
//doesn"t provide one
private final static String DEFAULT_SERVER = "mail.attbi.ru";
public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, java.io.IOException {
String smtpServ = DEFAULT_SERVER;
String from = "jexp@yourserver.ru";
String to = "yourname@yourserver.ru";
String subject = "subject line";
String emailContent = "emailContent";
response.setContentType("text/html");
java.io.PrintWriter out = response.getWriter();
out
.println("<html><head><title>Email message sender</title></head><body>");
try {
sendMessage(smtpServ, to, from, subject, emailContent);
} catch (Exception e) {
throw new ServletException(e.getMessage());
}
out.println("<h2>The message was sent successfully</h2>");
out.println("</body></html>");
} //doPost
private void sendMessage(String smtpServer, String to, String from,
String subject, String emailContent) throws Exception {
Properties properties = System.getProperties();
//populate the "Properties" object with the mail
//server address, so that the default "Session"
//instance can use it.
properties.put("mail.smtp.host", smtpServer);
Session session = Session.getDefaultInstance(properties);
Message mailMsg = new MimeMessage(session);//a new email message
InternetAddress[] addresses = null;
try {
if (to != null) {
//throws "AddressException" if the "to" email address
//violates RFC822 syntax
addresses = InternetAddress.parse(to, false);
mailMsg.setRecipients(Message.RecipientType.TO, addresses);
} else {
throw new MessagingException(
"The mail message requires a "To" address.");
}
if (from != null) {
mailMsg.setFrom(new InternetAddress(from));
} else {
throw new MessagingException(
"The mail message requires a valid "From" address.");
}
if (subject != null)
mailMsg.setSubject(subject);
if (emailContent != null)
mailMsg.setText(emailContent);
//Finally, send the meail message; throws a "SendFailedException"
//if any of the message"s recipients have an invalid adress
Transport.send(mailMsg);
} catch (Exception exc) {
throw exc;
}
}//sendMessage
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, java.io.IOException {
doPost(request, response);
}
}//EmailServlet
