用socket连接服务器直接发送接收邮件

SMTP 命令
SMTP 命令包括：
HELO 向服务器标识用户身份。发送者能欺骗，说谎，但一般情况下服务器都能检测到。
EHLO 向服务器标识用户身份。发送者能欺骗，说谎，但一般情况下服务器都能检测到。
MAIL FROM 命令中指定的地址是发件人地址
RCPT TO 标识单个的邮件接收人；可有多个 RCPT TO；常在 MAIL 命令后面。
DATA 在单个或多个 RCPT 命令后，表示所有的邮件接收人已标识，并初始化数据传输，以 CRLF.CRLF 结束
VRFY 用于验证指定的用户/邮箱是否存在；由于安全方面的原因，服务器常禁止此命令
EXPN 验证给定的邮箱列表是否存在，扩充邮箱列表，也常被禁用
HELP 查询服务器支持什么命令
NOOP 无操作，服务器应响应 OK
RSET 重置会话，当前传输被取消
QUIT 结束会话

POP3 命令包括：
USER username 认证用户名
PASS password 认证密码认证，认证通过则状态转换
APOP name,digest 认可一种安全传输口令的办法，执行成功导致状态转换，请参见 RFC 1321 。
STAT 处理请求 server 回送邮箱统计资料，如邮件数、 邮件总字节数
UIDL n 处理 server 返回用于该指定邮件的唯一标识， 如果没有指定，返回所有的。
LIST n 处理 server 返回指定邮件的大小等
RETR n 处理 server 返回邮件的全部文本
DELE n 处理 server 标记删除，QUIT 命令执行时才真正删除
RSET 处理撤消所有的 DELE 命令
TOP n,m 处理 返回 n 号邮件的前 m 行内容，m 必须是自然数
NOOP 处理 server 返回一个肯定的响应
QUIT 希望结束会话。如果 server 处于"处理" 状态，则现在进入"更新"状态，删除那些标记成删除的邮件。如果 server 处于"认可"状态，则结束会话时 server 不进入"更新"状态 。



import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;

import sun.misc.BASE64Encoder;

public class SmtpClinent {
public static void main(String[] args) throws Exception {
socketReceiveMail();
// socketSendMail();
}

// socket接收邮件
public static void socketReceiveMail() {
String POP3Server = "";
String USERNAME = "";// 实际应用中改成真实的用户名
String PASSWORD = "";// 实际应用中改成真实的密码

int POP3Port = 110;
Socket client = null;

String filePath = "D:\\mailtest\\";//将正文保存的路径
try {
// 向POP3服务程序建立一个套接字连接。
client = new Socket(POP3Server, POP3Port);
// 创建一个BufferedReader对象，以便从套接字读取输出。
InputStream is = client.getInputStream();
BufferedReader sockin = new BufferedReader(new InputStreamReader(is));
// 创建一个PrintWriter对象，以便向套接字写入内容。
OutputStream os = client.getOutputStream();
PrintWriter sockout = new PrintWriter(os, true);
// 显示同SMTP服务程序的握手过程。
System.out.println("S:" + sockin.readLine());
sockout.println("USER " + USERNAME);
System.out.println("S:" + sockin.readLine());
sockout.println("PASS " + PASSWORD);
System.out.println("S:" + sockin.readLine());
sockout.println("UIDL " + "1");
System.out.println("S:" + sockin.readLine());

sockout.println("STAT");
String statStr = sockin.readLine();
System.out.println("statStr:" + statStr);

String temp[] = statStr.split(" ");
int count = Integer.parseInt(temp[1]);// 得到信箱中共有多少封邮件
for (int i = 1; i < count + 1; i++) {// 依次打印出邮件的内容
sockout.println("RETR " + i);
System.out.println("以下为第" + i + "封邮件的内容");

File file = new File(filePath + i + ".eml");
streamToFile(sockin, file);
}
} catch (IOException e) {
System.out.println(e.toString());
} finally {
try {
if (client != null) {
client.close();
}
} catch (IOException e) {
}
}
}

private static void streamToFile(BufferedReader sockin, File file) throws IOException {
BufferedWriter buff = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(file)));

while (true) {
String reply = sockin.readLine();
buff.write(reply);
buff.write("\r\n");
buff.flush();
// System.out.println(reply);
if (reply.toLowerCase().equals(".")) {
break;
}
}
buff.close();
}

static String From = "[e-mail]";

static String To = "[e-mail]";

// socket发送邮件
public static void socketSendMail() throws IOException {
String SMTPServer = "";
String USERNAME = "";// 实际应用中改成真实的用户名
String PASSWORD = "";// 实际应用中改成真实的密码

InetAddress mailServer = InetAddress.getByName(SMTPServer);
Socket mailTo = new Socket(mailServer, 25);
BufferedReader in = new BufferedReader(new InputStreamReader(mailTo.getInputStream()));
PrintWriter out = new PrintWriter(new OutputStreamWriter(mailTo.getOutputStream()));
// 首先和服务器25端口建立连接，服务器返回220表示连接成功
String initialID = in.readLine();
System.out.println(initialID);
// 向服务器发送HELO name，用来表示发件人，服务器返回250
out.println("HELO mali");
out.flush();
out.println("AUTH LOGIN");
out.flush();
BASE64Encoder encoder = new BASE64Encoder();
out.println(encoder.encode(USERNAME.getBytes()));
out.flush();
out.println(encoder.encode(PASSWORD.getBytes()));
out.flush();
System.out.println(in.readLine());
// 用MAIL FROM [e-mail]告诉服务器你要发邮件
out.println("Mail FROM: " + From);
out.flush();
System.out.println(in.readLine());
// 用RCPT TO：[e-mail]
out.println("RCPT TO: " + To);
out.flush();
System.out.println(in.readLine());
// 用DATA发送邮件正文
out.println("Data");
out.flush();
System.out.println(in.readLine());

// test3(out);
// test1(out);
test2(out);

out.flush();
System.out.println(in.readLine());
// 发送QUIT断开连接
out.println("QUIT");
out.flush();
System.out.println(in.readLine());

out.close();
in.close();
}

public static void test3(PrintWriter out) {
out.println("Date: Thu, 13 Aug 2009 16:30:34 +0800 (CST)");
out.println("From: " + From);
out.println("To: " + To);
out.println("Message-ID: <14452073.1.1250152234828.JavaMail.new@mali>");
out.println("Subject: my mail");
out.println("MIME-Version: 1.0");
out.println("Content-Type: multipart/mixed; ");
out.println(" boundary=\"----=_Part_0_23065739.1250152234750\"");
out.println("Disposition-Notification-To: [e-mail]");
out.println("------=_Part_0_23065739.1250152234750");
out.println("Content-Type: text/plain;charset=\"utf-8\"");
out.println("Content-Transfer-Encoding: 7bit \r\n");
out.println("content0");
out.println("------=_Part_0_23065739.1250152234750--");
out.println(".");
}

public static void test1(PrintWriter out) {
out.println("Date: Thu, 6 Aug 2009 16:37:13 +0800");
out.println("From: " + From);
out.println("To: " + To);
out.println("Subject: 777777777777777777777");
out.println("X-mailer: Foxmail 5.0 [cn]");
out.println("Mime-Version: 1.0");
out.println("Content-Type: text/plain;charset=\"gb2312\"");
out.println("Content-Transfer-Encoding: 7bit");
out.println("66666666666666666");
out.println(".");
}

public static void test2(PrintWriter out) {
BufferedReader reader = null;
try {
reader = new BufferedReader(new InputStreamReader(new FileInputStream("D:\\mailtest\\sendmail2.eml"), "utf-8"), 1024);
String temp = reader.readLine();
while (temp != null) {
out.println(temp);
temp = reader.readLine();

}
out.println(".");
} catch (Exception e) {
e.printStackTrace();
} finally {
if (reader != null) {
try {
reader.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
}