学步园

使用方法:

 获取第1封邮件
            Zgke.Net.POP3 _Popt = new Zgke.Net.POP3("192.168.0.1", 110);

            DataTable _Mail = _Popt.GetMail("zk", "zk", 1);

返回DataTable  数据内容为

Type为类型    Text为文字 如果是附件 为byte[]   Name 如果是附件里存放的为文件名 

下面是全部的类

using System;<br /> using System.Net.Sockets;<br /> using System.Net;<br /> using System.Security.Cryptography;<br /> using System.IO;<br /> using System.Data;</p> <p>namespace Zgke.Net<br /> {</p> <p> /// <summary><br /> /// 获取邮件的类<br /> /// zgke@sina.com<br /> /// qq:116149<br /> /// </summary><br /> public class POP3<br /> {<br /> private string m_Address = "127.0.0.1";</p> <p> private int m_Port = 110;</p> <p> public POP3(string p_Address, int p_Port)<br /> {<br /> m_Address = p_Address;<br /> m_Port = p_Port;<br /> }</p> <p> /// <summary><br /> /// 获取Mail列表<br /> /// </summary><br /> /// <param name="p_Name">用户名</param><br /> /// <param name="p_PassWord">密码</param><br /> /// <returns>Mail信息</returns><br /> public DataTable GetMailTable(string p_Name,string p_PassWord)<br /> {<br /> POP3Client _Client = new POP3Client();<br /> _Client.UserName = p_Name;<br /> _Client.PassWord = p_PassWord;<br /> _Client.Client = new TcpClient();<br /> _Client.Client.BeginConnect(m_Address, m_Port, new AsyncCallback(OnConnectRequest), _Client);<br /> while (!_Client.ReturnEnd)<br /> {<br /> System.Windows.Forms.Application.DoEvents();<br /> }<br /> if (_Client.Error.Length != 0) throw new Exception("错误信息!" + _Client.Error);<br /> return _Client.MailDataTable;<br /> }</p> <p> /// <summary><br /> /// 获取邮件内容<br /> /// </summary><br /> /// <param name="p_Name">名称</param><br /> /// <param name="p_PassWord">密码</param><br /> /// <param name="p_MailIndex">邮件编号</param><br /> /// <returns>数据集</returns><br /> public DataTable GetMail(string p_Name, string p_PassWord, int p_MailIndex)<br /> {<br /> POP3Client _Client = new POP3Client();<br /> _Client.UserName = p_Name;<br /> _Client.PassWord = p_PassWord;<br /> _Client.Client = new TcpClient();<br /> _Client.ReadIndex = p_MailIndex;<br /> _Client.Client.BeginConnect(m_Address, m_Port, new AsyncCallback(OnConnectRequest), _Client);<br /> while (!_Client.ReturnEnd)<br /> {<br /> System.Windows.Forms.Application.DoEvents();<br /> }<br /> if (_Client.Error.Length != 0) throw new Exception("错误信息!" + _Client.Error);<br /> return _Client.MailTable;<br /> }</p> <p> private class POP3Client<br /> {<br /> public TcpClient Client;</p> <p> public string UserName = "";</p> <p> public string PassWord = "";</p> <p> public bool ReturnEnd = false;</p> <p> public DataTable MailDataTable = new DataTable();</p> <p> public DataTable MailTable = new DataTable(); </p> <p> public string Error = "";</p> <p> public bool ReadEnd = false;</p> <p> public int ReadIndex = -1;</p> <p> public POP3Client()<br /> {<br /> MailDataTable.Columns.Add("NUM");<br /> MailDataTable.Columns.Add("Size");<br /> MailDataTable.Columns.Add("Form");<br /> MailDataTable.Columns.Add("To");<br /> MailDataTable.Columns.Add("Subject");<br /> MailDataTable.Columns.Add("Date");</p> <p> MailTable.Columns.Add("Type",typeof(string));<br /> MailTable.Columns.Add("Text",typeof(object));<br /> MailTable.Columns.Add("Name", typeof(string));<br /> }</p> <p> private int m_SendMessage = 0;<br /> private int m_TOPIndex = 1;</p> <p> /// <summary><br /> /// 获取下一个登陆到获取列表需要的命令<br /> /// </summary><br /> /// <param name="p_Value"></param><br /> /// <returns></returns><br /> public byte[] GetSendBytes(byte[] p_Value)<br /> {<br /> ReadEnd = false;<br /> string _Value = System.Text.Encoding.Default.GetString(p_Value).Replace("/0", "");<br /> if (_Value.IndexOf("+OK") == 0)<br /> {<br /> m_SendMessage++;<br /> switch (m_SendMessage)<br /> {<br /> case 1:<br /> return System.Text.Encoding.ASCII.GetBytes("USER " + UserName + "/r/n");<br /> case 2:<br /> return System.Text.Encoding.ASCII.GetBytes("PASS " + PassWord + "/r/n");<br /> case 3:<br /> ReadEnd = true;<br /> if (ReadIndex != -1)<br /> {<br /> m_SendMessage = 5;<br /> return System.Text.Encoding.ASCII.GetBytes("RETR " + ReadIndex.ToString() + "/r/n");<br /> }<br /> else<br /> {<br /> return System.Text.Encoding.ASCII.GetBytes("LIST/r/n");<br /> }<br /> case 4:<br /> string[] _List = _Value.Split(new char[] { '/r', '/n', '.' }, StringSplitOptions.RemoveEmptyEntries);<br /> for (int i = 1; i != _List.Length; i++)<br /> {<br /> string[] _MaliSize = _List[i].Split(' ');<br /> MailDataTable.Rows.Add(new object[] { _MaliSize[0], _MaliSize[1] });<br /> }<br /> if (MailDataTable.Rows.Count == 0)<br /> {<br /> ReturnEnd = true;<br /> return new byte[0];<br /> }<br /> else<br /> {<br /> ReadEnd = true;<br /> m_TOPIndex = 1;<br /> return System.Text.Encoding.ASCII.GetBytes("TOP 1/r/n");<br /> }<br /> case 5:<br /> System.Text.RegularExpressions.Regex _Regex = new System.Text.RegularExpressions.Regex(@"(?<=Date: ).*?(/r/n)+");<br /> System.Text.RegularExpressions.MatchCollection _Collection = _Regex.Matches(_Value);<br /> if (_Collection.Count != 0) MailDataTable.Rows[m_TOPIndex - 1]["Date"] = GetReadText(_Collection[0].Value);</p> <p> System.Text.RegularExpressions.Regex _RegexFrom = new System.Text.RegularExpressions.Regex(@"(?<=From: ).*?(/r/n)+");<br /> System.Text.RegularExpressions.MatchCollection _CollectionForm = _RegexFrom.Matches(_Value);<br /> if (_CollectionForm.Count != 0) MailDataTable.Rows[m_TOPIndex - 1]["Form"] = GetReadText(_CollectionForm[0].Value);</p> <p> System.Text.RegularExpressions.Regex _RegexTo = new System.Text.RegularExpressions.Regex(@"(?<=To: ).*?(/r/n)+");<br /> System.Text.RegularExpressions.MatchCollection _CollectionTo = _RegexTo.Matches(_Value);<br /> if (_CollectionTo.Count != 0) MailDataTable.Rows[m_TOPIndex - 1]["To"] = GetReadText(_CollectionTo[0].Value);</p> <p> System.Text.RegularExpressions.Regex _RegexSubject = new System.Text.RegularExpressions.Regex(@"(?<=Subject: ).*?(/r/n)+");<br /> System.Text.RegularExpressions.MatchCollection _CollectionSubject = _RegexSubject.Matches(_Value);<br /> if (_CollectionSubject.Count != 0) MailDataTable.Rows[m_TOPIndex - 1]["Subject"] = GetReadText(_CollectionSubject[0].Value);</p> <p> m_TOPIndex++;<br /> m_SendMessage--;<br /> ReadEnd = true;<br /> if (m_TOPIndex > MailDataTable.Rows.Count)<br /> {<br /> ReturnEnd = true;<br /> return System.Text.Encoding.ASCII.GetBytes("QUIT");<br /> }<br /> else<br /> {<br /> return System.Text.Encoding.ASCII.GetBytes("TOP " + m_TOPIndex.ToString() + "/r/n");<br /> }<br /> case 6:<br /> GetMailText(_Value);<br /> ReturnEnd = true;<br /> return System.Text.Encoding.ASCII.GetBytes("QUIT"); </p> <p> }<br /> }<br /> Error = _Value;<br /> ReturnEnd = true;<br /> return new byte[0];<br /> }</p> <p> /// <summary><br /> /// 转换文字里的字符集<br /> /// </summary><br /> /// <param name="p_Text"></param><br /> /// <returns></returns><br /> public string GetReadText(string p_Text)<br /> {<br /> System.Text.RegularExpressions.Regex _Regex = new System.Text.RegularExpressions.Regex(@"(?<=/=/?).*?(/?/=)+");<br /> System.Text.RegularExpressions.MatchCollection _Collection = _Regex.Matches(p_Text);<br /> string _Text = p_Text;<br /> foreach (System.Text.RegularExpressions.Match _Match in _Collection)<br /> {<br /> string _Value = "=?" + _Match.Value;<br /> if (_Value[0] == '=')<br /> {<br /> string[] _BaseData = _Value.Split('?');<br /> if (_BaseData.Length == 5)<br /> {<br /> System.Text.Encoding _Coding = System.Text.Encoding.GetEncoding(_BaseData[1]);<br /> _Text = _Text.Replace(_Value, _Coding.GetString(Convert.FromBase64String(_BaseData[3])));<br /> }<br /> }<br /> else<br /> {<br /> }<br /> }<br /> return _Text;<br /> }</p> <p> #region 获取邮件正文 和 附件<br /> /// <summary><br /> /// 获取文字主体<br /> /// </summary><br /> /// <param name="p_Mail"></param><br /> /// <returns></returns><br /> public void GetMailText(string p_Mail)<br /> {<br /> string _ConvertType = GetTextType(p_Mail, "/r/nContent-Type: ", ";");<br /> if (_ConvertType.Length == 0)<br /> {<br /> _ConvertType = GetTextType(p_Mail, "/r/nContent-Type: ", "/r");<br /> }<br /> int _StarIndex = -1;<br /> int _EndIndex = -1;<br /> string _ReturnText = "";<br /> string _Transfer = "";<br /> string _Boundary = "";<br /> string _EncodingName = GetTextType(p_Mail, "charset=/"", "/"").Replace("/"", "");<br /> System.Text.Encoding _Encoding = System.Text.Encoding.Default;<br /> if(_EncodingName!="")_Encoding = System.Text.Encoding.GetEncoding(_EncodingName);<br /> switch (_ConvertType)<br /> {<br /> case "text/html;":<br /> _Transfer = GetTextType(p_Mail, "/r/nContent-Transfer-Encoding: ", "/r/n").Trim();<br /> _StarIndex = p_Mail.IndexOf("/r/n/r/n");<br /> if (_StarIndex != -1) _ReturnText = p_Mail.Substring(_StarIndex, p_Mail.Length - _StarIndex);<br /> switch (_Transfer)<br /> {<br /> case "8bit":</p> <p> break;<br /> case "quoted-printable":<br /> _ReturnText = DecodeQuotedPrintable(_ReturnText, _Encoding);<br /> break;<br /> case "base64":<br /> _ReturnText = DecodeBase64(_ReturnText, _Encoding);<br /> break;<br /> }<br /> MailTable.Rows.Add(new object[] { "text/html", _ReturnText });<br /> break;<br /> case "text/plain;":<br /> _Transfer = GetTextType(p_Mail, "/r/nContent-Transfer-Encoding: ", "/r/n").Trim();<br /> _StarIndex = p_Mail.IndexOf("/r/n/r/n");<br /> if (_StarIndex != -1) _ReturnText = p_Mail.Substring(_StarIndex, p_Mail.Length - _StarIndex);<br /> switch (_Transfer)<br /> {<br /> case "8bit":</p> <p> break;<br /> case "quoted-printable":<br /> _ReturnText = DecodeQuotedPrintable(_ReturnText, _Encoding);<br /> break;<br /> case "base64":<br /> _ReturnText = DecodeBase64(_ReturnText, _Encoding);<br /> break;<br /> }<br /> MailTable.Rows.Add(new object[] { "text/plain", _ReturnText });<br /> break;<br /> case "multipart/alternative;":<br /> _Boundary = GetTextType(p_Mail, "boundary=/"", "/"").Replace("/"", "");<br /> _StarIndex = p_Mail.IndexOf("--" + _Boundary + "/r/n");<br /> if (_StarIndex == -1) return;<br /> while (true)<br /> {<br /> _EndIndex = p_Mail.IndexOf("--" + _Boundary, _StarIndex + _Boundary.Length);<br /> if (_EndIndex == -1) break;<br /> GetMailText(p_Mail.Substring(_StarIndex, _EndIndex - _StarIndex));<br /> _StarIndex = _EndIndex;<br /> }<br /> break;<br /> case "multipart/mixed;":<br /> _Boundary = GetTextType(p_Mail, "boundary=/"", "/"").Replace("/"", "");<br /> _StarIndex = p_Mail.IndexOf("--" + _Boundary + "/r/n");<br /> if (_StarIndex == -1) return;<br /> while (true)<br /> {<br /> _EndIndex = p_Mail.IndexOf("--" + _Boundary, _StarIndex + _Boundary.Length);<br /> if (_EndIndex == -1) break;<br /> GetMailText(p_Mail.Substring(_StarIndex, _EndIndex - _StarIndex));<br /> _StarIndex = _EndIndex;<br /> }<br /> break;<br /> default:<br /> if (_ConvertType.IndexOf("application/") == 0)<br /> {<br /> _StarIndex = p_Mail.IndexOf("/r/n/r/n");<br /> if (_StarIndex != -1) _ReturnText = p_Mail.Substring(_StarIndex, p_Mail.Length - _StarIndex);<br /> _Transfer = GetTextType(p_Mail, "/r/nContent-Transfer-Encoding: ", "/r/n").Trim();<br /> string _Name = GetTextType(p_Mail, "filename=/"", "/"").Replace("/"", "");<br /> _Name = GetReadText(_Name);<br /> byte[] _FileBytes = new byte[0];<br /> switch (_Transfer)<br /> {<br /> case "base64":<br /> _FileBytes = Convert.FromBase64String(_ReturnText);<br /> break;<br /> }<br /> MailTable.Rows.Add(new object[] { "application/octet-stream", _FileBytes, _Name });</p> <p> }<br /> break;<br /> }<br /> }</p> <p> /// <summary><br /> /// 获取类型（正则）<br /> /// </summary><br /> /// <param name="p_Mail">原始文字</param><br /> /// <param name="p_TypeText">前文字</param><br /> /// <param name="p_End">结束文字</param><br /> /// <returns>符合的记录</returns><br /> public string GetTextType(string p_Mail, string p_TypeText, string p_End)<br /> {<br /> System.Text.RegularExpressions.Regex _Regex = new System.Text.RegularExpressions.Regex(@"(?<=" + p_TypeText + ").*?(" + p_End + ")+");<br /> System.Text.RegularExpressions.MatchCollection _Collection = _Regex.Matches(p_Mail);<br /> if (_Collection.Count == 0) return "";<br /> return _Collection[0].Value;<br /> }</p> <p> /// <summary><br /> /// QuotedPrintable编码接码<br /> /// </summary><br /> /// <param name="p_Text">原始文字</param><br /> /// <param name="p_Encoding">编码方式</param><br /> /// <returns>接码后信息</returns><br /> public string DecodeQuotedPrintable(string p_Text, System.Text.Encoding p_Encoding)<br /> {<br /> System.IO.MemoryStream _Stream = new System.IO.MemoryStream();<br /> char[] _CharValue = p_Text.ToCharArray();<br /> for (int i = 0; i != _CharValue.Length; i++)<br /> {<br /> switch (_CharValue[i])<br /> {<br /> case '=':<br /> if (_CharValue[i + 1] == '/r' || _CharValue[i + 1] == '/n')<br /> {<br /> i += 2;<br /> }<br /> else<br /> {<br /> try<br /> {<br /> _Stream.WriteByte(Convert.ToByte(_CharValue[i + 1].ToString() + _CharValue[i + 2].ToString(), 16));<br /> i += 2;<br /> }<br /> catch<br /> {<br /> _Stream.WriteByte(Convert.ToByte(_CharValue[i]));<br /> }<br /> }<br /> break;<br /> default:<br /> _Stream.WriteByte(Convert.ToByte(_CharValue[i]));<br /> break;<br /> }<br /> }<br /> return p_Encoding.GetString(_Stream.ToArray());<br /> }</p> <p> /// <summary><br /> /// 解码BASE64<br /> /// </summary><br /> /// <param name="p_Text"></param><br /> /// <param name="p_Encoding"></param><br /> /// <returns></returns><br /> public string DecodeBase64(string p_Text, System.Text.Encoding p_Encoding)<br /> {<br /> if (p_Text.Trim().Length == 0) return "";<br /> byte[] _ValueBytes = Convert.FromBase64String(p_Text);<br /> return p_Encoding.GetString(_ValueBytes);<br /> }<br /> #endregion</p> <p> }</p> <p> /// <summary><br /> /// 连接事件<br /> /// </summary><br /> /// <param name="ar"></param><br /> private void OnConnectRequest(IAsyncResult ar)<br /> {<br /> POP3Client _Client = (POP3Client)ar.AsyncState;<br /> byte[] _ReadBytes =new byte[0];<br /> _Client.Client.Client.BeginReceive(_ReadBytes, 0, 0, SocketFlags.None, new AsyncCallback(OnWrite), _Client);<br /> }</p> <p> /// <summary><br /> /// 连接事件<br /> /// </summary><br /> /// <param name="ar"></param><br /> private void OnSend(IAsyncResult ar)<br /> {<br /> POP3Client _Client = (POP3Client)ar.AsyncState;<br /> byte[] _ReadBytes = new byte[0];<br /> _Client.Client.Client.BeginReceive(_ReadBytes, 0, 0, SocketFlags.None, new AsyncCallback(OnWrite), _Client);<br /> }</p> <p> /// <summary><br /> /// 连接事件<br /> /// </summary><br /> /// <param name="ar"></param><br /> private void OnWrite(IAsyncResult ar)<br /> {<br /> POP3Client _Client = (POP3Client)ar.AsyncState;<br /> byte[] _WriteBytes = new byte[_Client.Client.Client.ReceiveBufferSize];<br /> _Client.Client.Client.Receive(_WriteBytes);<br /> if (_Client.ReadEnd) _WriteBytes = ReadEnd(_WriteBytes, _Client);<br /> byte[] _SendBytes = _Client.GetSendBytes(_WriteBytes);<br /> if (_SendBytes.Length == 0) return;<br /> _Client.Client.Client.BeginSend(_SendBytes, 0, _SendBytes.Length, SocketFlags.None, new AsyncCallback(OnSend), _Client);<br /> }</p> <p> /// <summary><br /> /// 获取知道获取到. 否则一直获取数据<br /> /// </summary><br /> /// <param name="p_Value"></param><br /> /// <returns></returns><br /> private byte[] ReadEnd(byte[] p_Value,POP3Client p_Client)<br /> {<br /> if (System.Text.Encoding.ASCII.GetString(p_Value).IndexOf("/r/n./r/n") != -1) return p_Value;<br /> MemoryStream _Stream = new MemoryStream();<br /> _Stream.Write(p_Value, 0, p_Value.Length);<br /> while (true)<br /> {<br /> byte[] _WriteBytes = new byte[p_Client.Client.ReceiveBufferSize];<br /> p_Client.Client.Client.Receive(_WriteBytes);<br /> _Stream.Write(_WriteBytes, 0, _WriteBytes.Length);<br /> System.Threading.Thread.Sleep(100);<br /> if (System.Text.Encoding.ASCII.GetString(_WriteBytes).IndexOf("/r/n./r/n") != -1) return _Stream.ToArray();<br /> }<br /> }</p> <p> }<br /> }