【C】C#通过POP3获取邮件的代码(正文和附件)-POP3-邮件

欢迎您访问我爱IT技术网，今天小编为你分享的编程技术是：【C#通过POP3获取邮件的代码(正文和附件)】，下面是详细的讲解！

C#通过POP3获取邮件的代码(正文和附件)

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();
}
}

}
}

关于C#通过POP3获取邮件的代码(正文和附件)的用户互动如下：

　　相关问题：

　　答： >>详细

　　相关问题：

　　答： >>详细

　　相关问题：

　　答： >>详细