通?过?P?O?P?3?获?取?邮?件?(?正?文?和?附?件?)代码,CSharp代码库,德仔网

代码语言
代码分类
【CSharp】通?过?P?O?P?3?获?取?邮?件?(?正?文?和?附?件?)
作者:dezai / 发布于2014/7/29/ 923

	using System;
	using System.Net.Sockets;
	using System.Net;
	using System.Security.Cryptography;
	using System.IO;
	using System.Data;

	namespace Zgke.Net
	{
	
	 /// <summary>
	 /// 获取邮件的类
	 /// zgke@sina.com
	 /// qq:116149
	 /// </summary>
	 public class POP3
	 {
	 private string m_Address = "127.0.0.1";

	 private int m_Port = 110;

	 public POP3(string p_Address, int p_Port)
	 {
	 m_Address = p_Address;
	 m_Port = p_Port;
	 }

	 /// <summary>
	 /// 获取Mail列表
	 /// </summary>
	 /// <param name="p_Name">用户名</param>
	 /// <param name="p_PassWord">密码</param>
	 /// <returns>Mail信息</returns>
	 public DataTable GetMailTable(string p_Name,string p_PassWord)
	 {
	 POP3Client _Client = new POP3Client();
	 _Client.UserName = p_Name;
	 _Client.PassWord = p_PassWord;
	 _Client.Client = new TcpClient();
	 _Client.Client.BeginConnect(m_Address, m_Port, new AsyncCallback(OnConnectRequest), _Client);
	 while (!_Client.ReturnEnd)
	 {
	 System.Windows.Forms.Application.DoEvents();
	 }
	 if (_Client.Error.Length != 0) throw new Exception("错误信息!" + _Client.Error);
	 return _Client.MailDataTable;
	 }

	
	 /// <summary>
	 /// 获取邮件内容
	 /// </summary>
	 /// <param name="p_Name">名称</param>
	 /// <param name="p_PassWord">密码</param>
	 /// <param name="p_MailIndex">邮件编号</param>
	 /// <returns>数据集</returns>
	 public DataTable GetMail(string p_Name, string p_PassWord, int p_MailIndex)
	 {
	 POP3Client _Client = new POP3Client();
	 _Client.UserName = p_Name;
	 _Client.PassWord = p_PassWord;
	 _Client.Client = new TcpClient();
	 _Client.ReadIndex = p_MailIndex;
	 _Client.Client.BeginConnect(m_Address, m_Port, new AsyncCallback(OnConnectRequest), _Client);
	 while (!_Client.ReturnEnd)
	 {
	 System.Windows.Forms.Application.DoEvents();
	 }
	 if (_Client.Error.Length != 0) throw new Exception("错误信息!" + _Client.Error);
	 return _Client.MailTable;
	 }

	 private class POP3Client
	 {
	 public TcpClient Client;

	 public string UserName = "";

	 public string PassWord = "";

	 public bool ReturnEnd = false;

	 public DataTable MailDataTable = new DataTable();

	 public DataTable MailTable = new DataTable();
	
	 public string Error = "";

	 public bool ReadEnd = false;

	 public int ReadIndex = -1;

	
	 public POP3Client()
	 {
	 MailDataTable.Columns.Add("NUM");
	 MailDataTable.Columns.Add("Size");
	 MailDataTable.Columns.Add("Form");
	 MailDataTable.Columns.Add("To");
	 MailDataTable.Columns.Add("Subject");
	 MailDataTable.Columns.Add("Date");

	 MailTable.Columns.Add("Type",typeof(string));
	 MailTable.Columns.Add("Text",typeof(object));
	 MailTable.Columns.Add("Name", typeof(string));
	 }

	 private int m_SendMessage = 0;
	 private int m_TOPIndex = 1;

	 /// <summary>
	 /// 获取下一个登陆到获取列表需要的命令
	 /// </summary>
	 /// <param name="p_Value"></param>
	 /// <returns></returns>
	 public byte[] GetSendBytes(byte[] p_Value)
	 {
	 ReadEnd = false;
	 string _Value = System.Text.Encoding.Default.GetString(p_Value).Replace("/0", "");
	 if (_Value.IndexOf("+OK") == 0)
	 {
	 m_SendMessage++;
	 switch (m_SendMessage)
	 {
	 case 1:
	 return System.Text.Encoding.ASCII.GetBytes("USER " + UserName + "/r/n");
	 case 2:
	 return System.Text.Encoding.ASCII.GetBytes("PASS " + PassWord + "/r/n");
	 case 3:
	 ReadEnd = true;
	 if (ReadIndex != -1)
	 {
	 m_SendMessage = 5;
	 return System.Text.Encoding.ASCII.GetBytes("RETR " + ReadIndex.ToString() + "/r/n");
	 }
	 else
	 {
	 return System.Text.Encoding.ASCII.GetBytes("LIST/r/n");
	 }
	 case 4:
	 string[] _List = _Value.Split(new char[] { '/r', '/n', '.' }, StringSplitOptions.RemoveEmptyEntries);
	 for (int i = 1; i != _List.Length; i++)
	 {
	 string[] _MaliSize = _List[i].Split(' ');
	 MailDataTable.Rows.Add(new object[] { _MaliSize[0], _MaliSize[1] });
	 }
	 if (MailDataTable.Rows.Count == 0)
	 {
	 ReturnEnd = true;
	 return new byte[0];
	 }
	 else
	 {
	 ReadEnd = true;
	 m_TOPIndex = 1;
	 return System.Text.Encoding.ASCII.GetBytes("TOP 1/r/n");
	 }
	 case 5:
	 System.Text.RegularExpressions.Regex _Regex = new System.Text.RegularExpressions.Regex(@"(?<=Date: ).*?(/r/n)+");
	 System.Text.RegularExpressions.MatchCollection _Collection = _Regex.Matches(_Value);
	 if (_Collection.Count != 0) MailDataTable.Rows[m_TOPIndex - 1]["Date"] = GetReadText(_Collection[0].Value);

	 System.Text.RegularExpressions.Regex _RegexFrom = new System.Text.RegularExpressions.Regex(@"(?<=From: ).*?(/r/n)+");
	 System.Text.RegularExpressions.MatchCollection _CollectionForm = _RegexFrom.Matches(_Value);
	 if (_CollectionForm.Count != 0) MailDataTable.Rows[m_TOPIndex - 1]["Form"] = GetReadText(_CollectionForm[0].Value);

	
	 System.Text.RegularExpressions.Regex _RegexTo = new System.Text.RegularExpressions.Regex(@"(?<=To: ).*?(/r/n)+");
	 System.Text.RegularExpressions.MatchCollection _CollectionTo = _RegexTo.Matches(_Value);
	 if (_CollectionTo.Count != 0) MailDataTable.Rows[m_TOPIndex - 1]["To"] = GetReadText(_CollectionTo[0].Value);

	 System.Text.RegularExpressions.Regex _RegexSubject = new System.Text.RegularExpressions.Regex(@"(?<=Subject: ).*?(/r/n)+");
	 System.Text.RegularExpressions.MatchCollection _CollectionSubject = _RegexSubject.Matches(_Value);
	 if (_CollectionSubject.Count != 0) MailDataTable.Rows[m_TOPIndex - 1]["Subject"] = GetReadText(_CollectionSubject[0].Value);

	 m_TOPIndex++;
	 m_SendMessage--;
	 ReadEnd = true;
	 if (m_TOPIndex > MailDataTable.Rows.Count)
	 {
	 ReturnEnd = true;
	 return System.Text.Encoding.ASCII.GetBytes("QUIT");
	 }
	 else
	 {
	 return System.Text.Encoding.ASCII.GetBytes("TOP " + m_TOPIndex.ToString() + "/r/n");
	 }
	 case 6:
	 GetMailText(_Value);
	 ReturnEnd = true;
	 return System.Text.Encoding.ASCII.GetBytes("QUIT");

	 }
	 }
	 Error = _Value;
	 ReturnEnd = true;
	 return new byte[0];
	 }

	 /// <summary>
	 /// 转换文字里的字符集
	 /// </summary>
	 /// <param name="p_Text"></param>
	 /// <returns></returns>
	 public string GetReadText(string p_Text)
	 {
	 System.Text.RegularExpressions.Regex _Regex = new System.Text.RegularExpressions.Regex(@"(?<=/=/?).*?(/?/=)+");
	 System.Text.RegularExpressions.MatchCollection _Collection = _Regex.Matches(p_Text);
	 string _Text = p_Text;
	 foreach (System.Text.RegularExpressions.Match _Match in _Collection)
	 {
	 string _Value = "=?" + _Match.Value;
	 if (_Value[0] == '=')
	 {
	 string[] _BaseData = _Value.Split('?');
	 if (_BaseData.Length == 5)
	 {
	 System.Text.Encoding _Coding = System.Text.Encoding.GetEncoding(_BaseData[1]);
	 _Text = _Text.Replace(_Value, _Coding.GetString(Convert.FromBase64String(_BaseData[3])));
	 }
	 }
	 else
	 {
	 }
	 }
	 return _Text;
	 }

	
	 #region 获取邮件正文 和 附件
	 /// <summary>
	 /// 获取文字主体
	 /// </summary>
	 /// <param name="p_Mail"></param>
	 /// <returns></returns>
	 public void GetMailText(string p_Mail)
	 {
	 string _ConvertType = GetTextType(p_Mail, "/r/nContent-Type: ", ";");
	 if (_ConvertType.Length == 0)
	 {
	 _ConvertType = GetTextType(p_Mail, "/r/nContent-Type: ", "/r");
	 }
	 int _StarIndex = -1;
	 int _EndIndex = -1;
	 string _ReturnText = "";
	 string _Transfer = "";
	 string _Boundary = "";
	 string _EncodingName = GetTextType(p_Mail, "charset=/"", "/"").Replace("/"", "");
	 System.Text.Encoding _Encoding = System.Text.Encoding.Default;
	 if(_EncodingName!="")_Encoding = System.Text.Encoding.GetEncoding(_EncodingName);
	 switch (_ConvertType)
	 {
	 case "text/html;":
	 _Transfer = GetTextType(p_Mail, "/r/nContent-Transfer-Encoding: ", "/r/n").Trim();
	 _StarIndex = p_Mail.IndexOf("/r/n/r/n");
	 if (_StarIndex != -1) _ReturnText = p_Mail.Substring(_StarIndex, p_Mail.Length - _StarIndex);
	 switch (_Transfer)
	 {
	 case "8bit":
	
	 break;
	 case "quoted-printable":
	 _ReturnText = DecodeQuotedPrintable(_ReturnText, _Encoding);
	 break;
	 case "base64":
	 _ReturnText = DecodeBase64(_ReturnText, _Encoding);
	 break;
	 }
	 MailTable.Rows.Add(new object[] { "text/html", _ReturnText });
	 break;
	 case "text/plain;":
	 _Transfer = GetTextType(p_Mail, "/r/nContent-Transfer-Encoding: ", "/r/n").Trim();
	 _StarIndex = p_Mail.IndexOf("/r/n/r/n");
	 if (_StarIndex != -1) _ReturnText = p_Mail.Substring(_StarIndex, p_Mail.Length - _StarIndex);
	 switch (_Transfer)
	 {
	 case "8bit":

	 break;
	 case "quoted-printable":
	 _ReturnText = DecodeQuotedPrintable(_ReturnText, _Encoding);
	 break;
	 case "base64":
	 _ReturnText = DecodeBase64(_ReturnText, _Encoding);
	 break;
	 }
	 MailTable.Rows.Add(new object[] { "text/plain", _ReturnText });
	 break;
	 case "multipart/alternative;":
	 _Boundary = GetTextType(p_Mail, "boundary=/"", "/"").Replace("/"", "");
	 _StarIndex = p_Mail.IndexOf("--" + _Boundary + "/r/n");
	 if (_StarIndex == -1) return;
	 while (true)
	 {
	 _EndIndex = p_Mail.IndexOf("--" + _Boundary, _StarIndex + _Boundary.Length);
	 if (_EndIndex == -1) break;
	 GetMailText(p_Mail.Substring(_StarIndex, _EndIndex - _StarIndex));
	 _StarIndex = _EndIndex;
	 }
	 break;
	 case "multipart/mixed;":
	 _Boundary = GetTextType(p_Mail, "boundary=/"", "/"").Replace("/"", "");
	 _StarIndex = p_Mail.IndexOf("--" + _Boundary + "/r/n");
	 if (_StarIndex == -1) return;
	 while (true)
	 {
	 _EndIndex = p_Mail.IndexOf("--" + _Boundary, _StarIndex + _Boundary.Length);
	 if (_EndIndex == -1) break;
	 GetMailText(p_Mail.Substring(_StarIndex, _EndIndex - _StarIndex));
	 _StarIndex = _EndIndex;
	 }
	 break;
	 default:
	 if (_ConvertType.IndexOf("application/") == 0)
	 {
	 _StarIndex = p_Mail.IndexOf("/r/n/r/n");
	 if (_StarIndex != -1) _ReturnText = p_Mail.Substring(_StarIndex, p_Mail.Length - _StarIndex);
	 _Transfer = GetTextType(p_Mail, "/r/nContent-Transfer-Encoding: ", "/r/n").Trim();
	 string _Name = GetTextType(p_Mail, "filename=/"", "/"").Replace("/"", "");
	 _Name = GetReadText(_Name);
	 byte[] _FileBytes = new byte[0];
	 switch (_Transfer)
	 {
	 case "base64":
	 _FileBytes = Convert.FromBase64String(_ReturnText);
	 break;
	 }
	 MailTable.Rows.Add(new object[] { "application/octet-stream", _FileBytes, _Name });

	 }
	 break;
	 }
	 }

	 /// <summary>
	 /// 获取类型（正则）
	 /// </summary>
	 /// <param name="p_Mail">原始文字</param>
	 /// <param name="p_TypeText">前文字</param>
	 /// <param name="p_End">结束文字</param>
	 /// <returns>符合的记录</returns>
	 public string GetTextType(string p_Mail, string p_TypeText, string p_End)
	 {
	 System.Text.RegularExpressions.Regex _Regex = new System.Text.RegularExpressions.Regex(@"(?<=" + p_TypeText + ").*?(" + p_End + ")+");
	 System.Text.RegularExpressions.MatchCollection _Collection = _Regex.Matches(p_Mail);
	 if (_Collection.Count == 0) return "";
	 return _Collection[0].Value;
	 }

	 /// <summary>
	 /// QuotedPrintable编码接码
	 /// </summary>
	 /// <param name="p_Text">原始文字</param>
	 /// <param name="p_Encoding">编码方式</param>
	 /// <returns>接码后信息</returns>
	 public string DecodeQuotedPrintable(string p_Text, System.Text.Encoding p_Encoding)
	 {
	 System.IO.MemoryStream _Stream = new System.IO.MemoryStream();
	 char[] _CharValue = p_Text.ToCharArray();
	 for (int i = 0; i != _CharValue.Length; i++)
	 {
	 switch (_CharValue[i])
	 {
	 case '=':
	 if (_CharValue[i + 1] == '/r' || _CharValue[i + 1] == '/n')
	 {
	 i += 2;
	 }
	 else
	 {
	 try
	 {
	 _Stream.WriteByte(Convert.ToByte(_CharValue[i + 1].ToString() + _CharValue[i + 2].ToString(), 16));
	 i += 2;
	 }
	 catch
	 {
	 _Stream.WriteByte(Convert.ToByte(_CharValue[i]));
	 }
	 }
	 break;
	 default:
	 _Stream.WriteByte(Convert.ToByte(_CharValue[i]));
	 break;
	 }
	 }
	 return p_Encoding.GetString(_Stream.ToArray());
	 }

	 /// <summary>
	 /// 解码BASE64
	 /// </summary>
	 /// <param name="p_Text"></param>
	 /// <param name="p_Encoding"></param>
	 /// <returns></returns>
	 public string DecodeBase64(string p_Text, System.Text.Encoding p_Encoding)
	 {
	 if (p_Text.Trim().Length == 0) return "";
	 byte[] _ValueBytes = Convert.FromBase64String(p_Text);
	 return p_Encoding.GetString(_ValueBytes);
	 }
	 #endregion

	
	 }
	
	 /// <summary>
	 /// 连接事件
	 /// </summary>
	 /// <param name="ar"></param>
	 private void OnConnectRequest(IAsyncResult ar)
	 {
	 POP3Client _Client = (POP3Client)ar.AsyncState;
	 byte[] _ReadBytes =new byte[0];
	 _Client.Client.Client.BeginReceive(_ReadBytes, 0, 0, SocketFlags.None, new AsyncCallback(OnWrite), _Client);
	 }

	 /// <summary>
	 /// 连接事件
	 /// </summary>
	 /// <param name="ar"></param>
	 private void OnSend(IAsyncResult ar)
	 {
	 POP3Client _Client = (POP3Client)ar.AsyncState;
	 byte[] _ReadBytes = new byte[0];
	 _Client.Client.Client.BeginReceive(_ReadBytes, 0, 0, SocketFlags.None, new AsyncCallback(OnWrite), _Client);
	 }

	 /// <summary>
	 /// 连接事件
	 /// </summary>
	 /// <param name="ar"></param>
	 private void OnWrite(IAsyncResult ar)
	 {
	 POP3Client _Client = (POP3Client)ar.AsyncState;
	 byte[] _WriteBytes = new byte[_Client.Client.Client.ReceiveBufferSize];
	 _Client.Client.Client.Receive(_WriteBytes);
	 if (_Client.ReadEnd) _WriteBytes = ReadEnd(_WriteBytes, _Client);
	 byte[] _SendBytes = _Client.GetSendBytes(_WriteBytes);
	 if (_SendBytes.Length == 0) return;
	 _Client.Client.Client.BeginSend(_SendBytes, 0, _SendBytes.Length, SocketFlags.None, new AsyncCallback(OnSend), _Client);
	 }

	 /// <summary>
	 /// 获取知道获取到. 否则一直获取数据
	 /// </summary>
	 /// <param name="p_Value"></param>
	 /// <returns></returns>
	 private byte[] ReadEnd(byte[] p_Value,POP3Client p_Client)
	 {
	 if (System.Text.Encoding.ASCII.GetString(p_Value).IndexOf("/r/n./r/n") != -1) return p_Value;
	 MemoryStream _Stream = new MemoryStream();
	 _Stream.Write(p_Value, 0, p_Value.Length);
	 while (true)
	 {
	 byte[] _WriteBytes = new byte[p_Client.Client.ReceiveBufferSize];
	 p_Client.Client.Client.Receive(_WriteBytes);
	 _Stream.Write(_WriteBytes, 0, _WriteBytes.Length);
	 System.Threading.Thread.Sleep(100);
	 if (System.Text.Encoding.ASCII.GetString(_WriteBytes).IndexOf("/r/n./r/n") != -1) return _Stream.ToArray();
	 }
	 }
	
	 }
	}
试试其它关键字
同语言下
可能有用的
dezai贡献的其它代码(1065)