POP3邮件接收

///

/// 收到的邮件实体///

public class MailInfo{///

/// 发件地址///

public string From{get;set;}///

/// 收件地址///

public string To{get;set;}///

/// 发件日期///

public DateTime Date{get;set;}///

/// 内容///

public string Content{get;set;}}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO;
using System.Net;
using System.Net.Sockets;namespace Email.Pop3
{///

/// 读取邮件客户端///

public class Pop3Client{private TcpClient Server;private NetworkStream NetStrm;private StreamReader RdStrm;private string Data;private byte[] szData;private string CRLF &＃61; "\r\n";///

/// 收件箱中邮件数量///

private int mailCount;private bool conn &＃61; false;///

/// 是否已连接///

public bool Connected{get { return conn; }}////

/// 连接邮件服务器///

/// 邮件服务器/// 账号/// 密码/// 是否连接成功public bool Connect(string server, string account, string passWord){//用110端口新建POP3服务器连接Server &＃61; new TcpClient(server, 110);try{//初始化NetStrm &＃61; Server.GetStream();RdStrm &＃61; new StreamReader(Server.GetStream());string init &＃61; RdStrm.ReadLine();//登录服务器过程Data &＃61; "USER " &＃43; account &＃43; CRLF;szData &＃61; System.Text.Encoding.ASCII.GetBytes(Data.ToCharArray());NetStrm.Write(szData, 0, szData.Length);string user &＃61; RdStrm.ReadLine();Data &＃61; "PASS " &＃43; passWord &＃43; CRLF;szData &＃61; System.Text.Encoding.ASCII.GetBytes(Data.ToCharArray());NetStrm.Write(szData, 0, szData.Length);string pass &＃61; RdStrm.ReadLine();if (pass[0] &＃61;&＃61; &＃39;&＃43;&＃39;){//向服务器发送STAT命令&＃xff0c;从而取得邮箱的相关信息&＃xff1a;邮件数量和大小Data &＃61; "STAT" &＃43; CRLF;szData &＃61; System.Text.Encoding.ASCII.GetBytes(Data.ToCharArray());NetStrm.Write(szData, 0, szData.Length);//依据返回信息&＃xff0c;初始化队列大小string[] inboxParams &＃61; RdStrm.ReadLine().Split(new string[] { " " }, StringSplitOptions.RemoveEmptyEntries);int.TryParse(inboxParams[1], out mailCount);conn &＃61; true;}}catch (InvalidOperationException ex) { conn &＃61; false; throw ex; }return conn;}///

/// 断开连接///

public void DisConnect(){//向服务器发送QUIT命令从而结束和POP3服务器的会话Data &＃61; "QUIT" &＃43; CRLF;szData &＃61; System.Text.Encoding.ASCII.GetBytes(Data.ToCharArray());NetStrm.Write(szData, 0, szData.Length);string msg &＃61; RdStrm.ReadLine();//断开连接
NetStrm.Close();RdStrm.Close();}///

/// 收信///

/// public Queue Receive(){Queue mailQueue &＃61; new Queue();string szTemp;for (int i &＃61; 1; i <&＃61; mailCount; i&＃43;&＃43;){//根据邮件编号从服务器获得相应邮件Data &＃61; "RETR " &＃43; i &＃43; CRLF;szData &＃61; System.Text.Encoding.ASCII.GetBytes(Data.ToCharArray());NetStrm.Write(szData, 0, szData.Length);szTemp &＃61; RdStrm.ReadLine();StringBuilder mailTxt &＃61; new StringBuilder();if (szTemp.Length > 0 && szTemp[0] !&＃61; &＃39;-&＃39;){//不断地读取邮件内容&＃xff0c;直到结束标志&＃xff1a;英文句号while (szTemp !&＃61; "."){mailTxt.Append(szTemp &＃43; "\n");szTemp &＃61; RdStrm.ReadLine();}MailInfo m &＃61; new MailInfo(){From &＃61; MessageParse.GetFrom(mailTxt.ToString()),To &＃61; MessageParse.GetTo(mailTxt.ToString()),Date &＃61; MessageParse.GetDate(mailTxt.ToString()),Content &＃61; MessageParse.GetContent(mailTxt.ToString())};mailQueue.Enqueue(m);}}return mailQueue;}///

/// 删除读取后的邮件///

public void Delete(){for (int i &＃61; 1; i <&＃61; mailCount; i&＃43;&＃43;){Data &＃61; "DELE " &＃43; i &＃43; CRLF;szData &＃61; System.Text.Encoding.ASCII.GetBytes(Data.ToCharArray());NetStrm.Write(szData, 0, szData.Length);}}}
}

///

/// 读取邮件内容///

public class MessageParse{///

/// 获取发件人///

/// /// public static string GetFrom(string message){if (!message.Contains("\nFrom:")){return string.Empty;}string cutMsg &＃61; message.Substring(message.IndexOf("\nFrom:") &＃43; 7);cutMsg &＃61; cutMsg.Remove(cutMsg.IndexOf("\n"));if (cutMsg.Contains(&＃39;<&＃39;) && cutMsg.Contains(&＃39;>&＃39;)){int indexS &＃61; cutMsg.IndexOf(&＃39;<&＃39;);int indexE &＃61; cutMsg.IndexOf(&＃39;>&＃39;);if (indexE - 1 > indexS){cutMsg &＃61; cutMsg.Substring(indexS &＃43; 1, indexE - indexS - 1);}}cutMsg&＃61;cutMsg.Trim(&＃39;>&＃39;);cutMsg&＃61;cutMsg.Trim(&＃39;<&＃39;);return cutMsg;}///

/// 获取收件人///

/// /// public static string GetTo(string message){if (!message.Contains("\nTo:")){return string.Empty;}string cutMsg &＃61; message.Substring(message.IndexOf("\nTo:") &＃43; 5);cutMsg &＃61; cutMsg.Remove(cutMsg.IndexOf("\n"));if (cutMsg.Contains(&＃39;<&＃39;) && cutMsg.Contains(&＃39;>&＃39;)){int indexS &＃61; cutMsg.IndexOf(&＃39;<&＃39;);int indexE &＃61; cutMsg.IndexOf(&＃39;>&＃39;);if (indexE - 1 > indexS){cutMsg &＃61; cutMsg.Substring(indexS &＃43; 1, indexE - indexS - 1);}}cutMsg&＃61;cutMsg.Trim(&＃39;>&＃39;);cutMsg&＃61;cutMsg.Trim(&＃39;<&＃39;);return cutMsg;}///

/// 获取收件日期///

/// /// public static DateTime GetDate(string message){if (!message.Contains("\nTo:")){return DateTime.MinValue;}string cutMsg &＃61; message.Substring(message.IndexOf("\nDate:") &＃43; 7);cutMsg &＃61; cutMsg.Remove(cutMsg.IndexOf("\n"));DateTime time &＃61; DateTime.Now;try{time &＃61; Convert.ToDateTime(cutMsg);}catch { }return time; }///

/// 获取内容///

/// /// public static string GetContent(string message){if (!message.Contains("\nContent")){return string.Empty;}string cutMsg &＃61; message.Substring(message.LastIndexOf("\nContent"));cutMsg &＃61; cutMsg.Substring(cutMsg.IndexOf("\n\n") &＃43; 2);if (cutMsg.IndexOf("\n\n") > 0){cutMsg &＃61; cutMsg.Remove(cutMsg.IndexOf("\n\n"));}if (message.Contains("\nContent-Transfer-Encoding: base64")){if (message.Contains("charset&＃61;")){string charSet &＃61; message.Substring(message.LastIndexOf("charset&＃61;") &＃43; 8);charSet &＃61; charSet.Remove(charSet.IndexOf(&＃39;\n&＃39;)).Trim(&＃39;"&＃39;);try{Encoding encoding &＃61; Encoding.GetEncoding(charSet);cutMsg &＃61; Encoding.GetEncoding(charSet).GetString(Convert.FromBase64String(cutMsg));}catch{try{cutMsg &＃61; Encoding.Default.GetString(Convert.FromBase64String(cutMsg));}catch { }}}}return cutMsg;}}