using System;
using System.IO;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Collections;
using System.Collections.Specialized;
using KSN.Exceptions;
using KSN.Validate;
namespace KSN.Web.Mail
{
/// <summary>
/// 郵件內容
/// </summary>
public class MailMessage
{
private string sender=null;
private StringCollection receivers=new StringCollection();
private string subject="";
private string xMailer="";
private StringCollection attachments=new StringCollection();
private MailEncodings mailEncoding=MailEncodings.GB2312;
private MailTypes mailType=MailTypes.Html;
private byte[] mailBody=null;
/// <summary>
/// 獲取或設置發件人
/// </summary>
public string Sender
{
get{return this.sender;}
set{this.sender=value;}
}
/// <summary>
/// 獲取收件人地址集合
/// </summary>
public StringCollection Receivers
{
get{return this.receivers;}
}
/// <summary>
/// 獲取或設置郵件主題
/// </summary>
public string Subject
{
get{return this.subject;}
set{this.subject=value;}
}
/// <summary>
/// 獲取或設置郵件傳送者
/// </summary>
public string XMailer
{
get{return this.xMailer;}
set{this.xMailer=value;}
}
/// <summary>
/// 獲取附件列表
/// </summary>
public StringCollection Attachments
{
get{return this.attachments;}
}
/// <summary>
/// 獲取或設置郵件的編碼方式
/// </summary>
public MailEncodings MailEncoding
{
get{return this.mailEncoding;}
set{this.mailEncoding=value;}
}
/// <summary>
/// 獲取或設置郵件格式
/// </summary>
public MailTypes MailType
{
get{return this.mailType;}
set{this.mailType=value;}
}
/// <summary>
/// 獲取或設置郵件正文
/// </summary>
public byte[] MailBody
{
get{return this.mailBody;}
set{this.mailBody=value;}
}
}
/// <summary>
/// 郵件編碼
/// </summary>
public enum MailEncodings
{
GB2312,
ASCII,
Unicode,
UTF8
}
/// <summary>
/// 郵件格式
/// </summary>
public enum MailTypes
{
Html,
Text
}
/// <summary>
/// smtp服務器的驗證方式
/// </summary>
public enum SmtpValidateTypes
{
/// <summary>
/// 不需要驗證
/// </summary>
None,
/// <summary>
/// 通用的auth login驗證
/// </summary>
Login,
/// <summary>
/// 通用的auth plain驗證
/// </summary>
Plain,
/// <summary>
/// CRAM-MD5驗證
/// </summary>
CRAMMD5
}
/// <summary>
/// 郵件發送類
/// </summary>
public class KSN_Smtp
{
#region "member fields"
/// <summary>
/// 連接對象
/// </summary>
private TcpClient tc;
/// <summary>
/// 網絡流
/// </summary>
private NetworkStream ns;
/// <summary>
/// 錯誤的代碼字典
/// </summary>
private StringDictionary errorCodes=new StringDictionary();
/// <summary>
/// 操作執行成功後的響應代碼字典
/// </summary>
private StringDictionary rightCodes=new StringDictionary();
/// <summary>
/// 執行過程中錯誤的消息
/// </summary>
private string errorMessage="";
/// <summary>
/// 記錄操作日志
/// </summary>
private string logs="";
/// <summary>
/// 主機登陸的驗證方式
/// </summary>
private StringCollection validateTypes=new StringCollection();
/// <summary>
/// 換行常數
/// </summary>
private const string CRLF="\r\n";
private string serverName="smtp";
private string logPath=null;
private string userid=null;
private string password=null;
private string mailEncodingName="GB2312";
private bool sendIsComplete=false;
private SmtpValidateTypes smtpValidateType=SmtpValidateTypes.Login;
#endregion
#region "propertys"
/// <summary>
/// 獲取最後一此程序執行中的錯誤消息
/// </summary>
public string ErrorMessage
{
get{return this.errorMessage;}
}
/// <summary>
/// 獲取或設置日志輸出路徑
/// </summary>
public string LogPath
{
get
{
return this.logPath;
}
set{this.logPath=value;}
}
/// <summary>
/// 獲取或設置登陸smtp服務器的帳號
/// </summary>
public string UserID
{
get{return this.userid;}
set{this.userid=value;}
}
/// <summary>
/// 獲取或設置登陸smtp服務器的密碼
/// </summary>
public string Password
{
get{return this.password;}
set{this.password=value;}
}
/// <summary>
/// 獲取或設置要使用登陸Smtp服務器的驗證方式
/// </summary>
public SmtpValidateTypes SmtpValidateType
{
get{return this.smtpValidateType;}
set{this.smtpValidateType=value;}
}
#endregion
#region "construct functions"
/// <summary>
/// 構造函數
/// </summary>
/// <param name="server">主機名</param>
/// <param name="port">端口</param>
public KSN_Smtp(string server,int port)
{
tc=new TcpClient(server,port);
ns=tc.GetStream();
this.serverName=server;
this.initialFields();
}
/// <summary>
/// 構造函數
/// </summary>
/// <param name="ip">主機ip</param>
/// <param name="port">端口</param>
public KSN_Smtp(IPAddress ip,int port)
{
IPEndPoint endPoint=new IPEndPoint(ip,port);
tc=new TcpClient(endPoint);
ns=tc.GetStream();
this.serverName=ip.ToString();
this.initialFields();
}
#endregion
#region "methods"
private void initialFields() //初始化連接
{
logs="================"+DateTime.Now.ToLongDateString()+" "+DateTime.Now.ToLongTimeString()+"==============="+CRLF;
//*****************************************************************
//錯誤的狀態碼
//*****************************************************************
errorCodes.Add("421","服務未就緒,關閉傳輸通道");
errorCodes.Add("432","需要一個密碼轉換");
errorCodes.Add("450","要求的郵件操作未完成,郵箱不可用(如:郵箱忙)");
errorCodes.Add("451","放棄要求的操作,要求的操作未執行");
errorCodes.Add("452","系統存儲不足,要求的操作未完成");
errorCodes.Add("454","臨時的認證失敗");
errorCodes.Add("500","郵箱地址錯誤");
errorCodes.Add("501","參數格式錯誤");
errorCodes.Add("502","命令不可實現");
errorCodes.Add("503","命令的次序不正確");
errorCodes.Add("504","命令參數不可實現");
errorCodes.Add("530","需要認證");
errorCodes.Add("534","認證機制過於簡單");
errorCodes.Add("538","當前請求的認證機制需要加密");
errorCodes.Add("550","當前的郵件操作未完成,郵箱不可用(如：郵箱未找到或郵箱不能用)");
errorCodes.Add("551","用戶非本地,請嘗試<forward-path>");
errorCodes.Add("552","過量的存儲分配,制定的操作未完成");
errorCodes.Add("553","郵箱名不可用,如:郵箱地址的格式錯誤");
errorCodes.Add("554","傳送失敗");
errorCodes.Add("535","用戶身份驗證失敗");
//****************************************************************
//操作執行成功後的狀態碼
//****************************************************************
rightCodes.Add("220","服務就緒");
rightCodes.Add("221","服務關閉傳輸通道");
rightCodes.Add("235","驗證成功");
rightCodes.Add("250","要求的郵件操作完成");
rightCodes.Add("251","非本地用戶,將轉發向<forward-path>");
rightCodes.Add("334","服務器響應驗證Base64字符串");
rightCodes.Add("354","開始郵件輸入,以<CRLF>.<CRLF>結束");
//讀取系統回應
StreamReader reader=new StreamReader(ns);
logs+=reader.ReadLine()+CRLF;
}
/// <summary>
/// 向SMTP發送命令
/// </summary>
/// <param name="cmd"></param>
private string sendCommand(string cmd,bool isMailData)
{
if(cmd!=null && cmd.Trim()!=string.Empty)
{
byte[] cmd_b=null;
if(!isMailData)//不是郵件數據
cmd+=CRLF;
logs+=cmd;
//開始寫入郵件數據
if(!isMailData)
{
cmd_b=Encoding.ASCII.GetBytes(cmd);
ns.Write(cmd_b,0,cmd_b.Length);
}
else
{
cmd_b=Encoding.GetEncoding(this.mailEncodingName).GetBytes(cmd);
ns.BeginWrite(cmd_b,0,cmd_b.Length,new AsyncCallback(this.asyncCallBack),null);
}
//讀取服務器響應
StreamReader reader=new StreamReader(ns);
string response=reader.ReadLine();
logs+=response+CRLF;
//檢查狀態碼
string statusCode=response.Substring(0,3);
bool isExist=false;
bool isRightCode=true;
foreach(string err in this.errorCodes.Keys)
{
if(statusCode==err)
{
isExist=true;
isRightCode=false;
break;
}
}
foreach(string right in this.rightCodes.Keys)
{
if(statusCode==right)
{
isExist=true;
break;
}
}
//根據狀態碼來處理下一步的動作
if(!isExist) //不是合法的SMTP主機
{
this.setError("不是合法的SMTP主機,或服務器拒絕服務");
}
else if(!isRightCode)//命令沒能成功執行
{
this.setError(statusCode+":"+this.errorCodes[statusCode]);
}
else //命令成功執行
{
this.errorMessage="";
}
return response;
}
else
{
return null;
}
}
/// <summary>
/// 通過auth login方式登陸smtp服務器
/// </summary>
private void landingByLogin()
{
string base64UserId=this.convertBase64String(this.UserID,"ASCII");
string base64Pass=this.convertBase64String(this.Password,"ASCII");
//握手
this.sendCommand("helo "+this.serverName,false);
//開始登陸
this.sendCommand("auth login",false);
this.sendCommand(base64UserId,false);
this.sendCommand(base64Pass,false);
}
/// <summary>
/// 通過auth plain方式登陸服務器
/// </summary>
private void landingByPlain()
{
string NULL=((char)0).ToString();
string loginStr=NULL+this.UserID+NULL+this.Password;
string base64LoginStr=this.convertBase64String(loginStr,"ASCII");
//握手
this.sendCommand("helo "+this.serverName,false);
//登陸
this.sendCommand(base64LoginStr,false);
}
/// <summary>
/// 通過auth CRAM-MD5方式登陸
/// </summary>
private void landingByCRAMMD5()
{
//握手
this.sendCommand("helo "+this.serverName,false);
//登陸
string response=this.sendCommand("auth CRAM-MD5",false);
//得到服務器返回的標識
string identifier=response.Remove(0,4);
//用MD5加密標識
KSN_MACTripleDES mac=new KSN_MACTripleDES();
mac.Key=this.Password;
mac.Data=Encoding.ASCII.GetBytes(identifier);
string hash=mac.GetHashValue();
//發送用戶帳號信息
this.sendCommand(this.UserID+" "+hash,false);
}
/// <summary>
/// 發送郵件
/// </summary>
/// <returns></returns>
public bool SendMail(MailMessage mail)
{
bool isSended=true;
try
{
//檢測發送郵件的必要條件
if(mail.Sender==null)
{
this.setError("沒有設置發信人");
}
if(mail.Receivers.Count==0)
{
this.setError("至少要有一個收件人");
}
if(this.SmtpValidateType!=SmtpValidateTypes.None)
{
if(this.userid==null || this.password==null)
{
this.setError("當前設置需要smtp驗證,但是沒有給出登陸帳號");
}
}
//開始登陸
switch(this.SmtpValidateType)
{
case SmtpValidateTypes.None:
this.sendCommand("helo "+this.serverName,false);
break;
case SmtpValidateTypes.Login:
this.landingByLogin();
break;
case SmtpValidateTypes.Plain:
this.landingByPlain();
break;
case SmtpValidateTypes.CRAMMD5:
this.landingByCRAMMD5();
break;
default:
break;
}
//初始化郵件會話(對應SMTP命令mail)
this.sendCommand("mail from:<"+mail.Sender+">",false);
//標識收件人(對應SMTP命令Rcpt)
foreach(string receive in mail.Receivers)
{
this.sendCommand("rcpt to:<"+receive+">",false);
}
//標識開始輸入郵件內容(Data)
this.sendCommand("data",false);
//開始編寫郵件內容
string message="Subject:"+mail.Subject+CRLF;
message+="X-mailer:"+mail.XMailer+CRLF;
message+="MIME-Version:1.0"+CRLF;
if(mail.Attachments.Count==0)//沒有附件
{
if(mail.MailType==MailTypes.Text) //文本格式
{
message+="Content-Type:text/plain;"+CRLF+" ".PadRight(8,' ')+"charset=\""+
mail.MailEncoding.ToString()+"\""+CRLF;
message+="Content-Transfer-Encoding:base64"+CRLF+CRLF;
if(mail.MailBody!=null)
message+=Convert.ToBase64String(mail.MailBody,0,mail.MailBody.Length)+CRLF+CRLF+CRLF+"."+CRLF;
}
else//Html格式
{
message+="Content-Type:multipart/alertnative;"+CRLF+" ".PadRight(8,' ')+"boundary"
+"=\"=====003_Dragon310083331177_=====\""+CRLF+CRLF+CRLF;
message+="This is a multi-part message in MIME format"+CRLF+CRLF;
message+="--=====003_Dragon310083331177_====="+CRLF;
message+="Content-Type:text/html;"+CRLF+" ".PadRight(8,' ')+"charset=\""+
mail.MailEncoding.ToString().ToLower()+"\""+CRLF;
message+="Content-Transfer-Encoding:base64"+CRLF+CRLF;
if(mail.MailBody!=null)
message+=Convert.ToBase64String(mail.MailBody,0,mail.MailBody.Length)+CRLF+CRLF;
message+="--=====003_Dragon310083331177_=====--"+CRLF+CRLF+CRLF+"."+CRLF;
}
}
else//有附件
{
//處理要在郵件中顯示的每個附件的數據
StringCollection attatchmentDatas=new StringCollection();
foreach(string path in mail.Attachments)
{
if(!File.Exists(path))
{
this.setError("指定的附件沒有找到"+path);
}
else
{
//得到附件的字節流
FileInfo file=new FileInfo(path);
FileStream fs=new FileStream(path,FileMode.Open,FileAccess.Read);
if(fs.Length>(long)int.MaxValue)
{
this.setError("附件的大小超出了最大限制");
}
byte[] file_b=new byte[(int)fs.Length];
fs.Read(file_b,0,file_b.Length);
fs.Close();
string attatchmentMailStr="Content-Type:application/octet-stream;"+CRLF+" ".PadRight(8,' ')+"name="+
"\""+file.Name+"\""+CRLF;
attatchmentMailStr+="Content-Transfer-Encoding:base64"+CRLF;
attatchmentMailStr+="Content-Disposition:attachment;"+CRLF+" ".PadRight(8,' ')+"filename="+
"\""+file.Name+"\""+CRLF+CRLF;
attatchmentMailStr+=Convert.ToBase64String(file_b,0,file_b.Length)+CRLF+CRLF;
attatchmentDatas.Add(attatchmentMailStr);
}
}
//設置郵件信息
if(mail.MailType==MailTypes.Text) //文本格式
{
message+="Content-Type:multipart/mixed;"+CRLF+" ".PadRight(8,' ')+"boundary=\"=====001_Dragon320037612222_=====\""
+CRLF+CRLF;
message+="This is a multi-part message in MIME format."+CRLF+CRLF;
message+="--=====001_Dragon320037612222_====="+CRLF;
message+="Content-Type:text/plain;"+CRLF+" ".PadRight(8,' ')+"charset=\""+mail.MailEncoding.ToString().ToLower()+"\""+CRLF;
message+="Content-Transfer-Encoding:base64"+CRLF+CRLF;
if(mail.MailBody!=null)
message+=Convert.ToBase64String(mail.MailBody,0,mail.MailBody.Length)+CRLF;
foreach(string s in attatchmentDatas)
{
message+="--=====001_Dragon320037612222_====="+CRLF+s+CRLF+CRLF;
}
message+="--=====001_Dragon320037612222_=====--"+CRLF+CRLF+CRLF+"."+CRLF;
}
else
{
message+="Content-Type:multipart/mixed;"+CRLF+" ".PadRight(8,' ')+"boundary=\"=====001_Dragon255511664284_=====\""
+CRLF+CRLF;
message+="This is a multi-part message in MIME format."+CRLF+CRLF;
message+="--=====001_Dragon255511664284_====="+CRLF;
message+="Content-Type:text/html;"+CRLF+" ".PadRight(8,' ')+"charset=\""+mail.MailEncoding.ToString().ToLower()+"\""+CRLF;
message+="Content-Transfer-Encoding:base64"+CRLF+CRLF;
if(mail.MailBody!=null)
message+=Convert.ToBase64String(mail.MailBody,0,mail.MailBody.Length)+CRLF+CRLF;
for(int i=0;i<attatchmentDatas.Count;i++)
{
message+="--=====001_Dragon255511664284_====="+CRLF+attatchmentDatas[i]+CRLF+CRLF;
}
message+="--=====001_Dragon255511664284_=====--"+CRLF+CRLF+CRLF+"."+CRLF;
}
}
//發送郵件數據
this.mailEncodingName=mail.MailEncoding.ToString();
this.sendCommand(message,true);
if(this.sendIsComplete)
this.sendCommand("QUIT",false);
}
catch
{
isSended=false;
}
finally
{
this.disconnect();
//輸出日志文件
if(this.LogPath!=null)
{
FileStream fs=null;
if(File.Exists(this.LogPath))
{
fs=new FileStream(this.LogPath,FileMode.Append,FileAccess.Write);
this.logs=CRLF+CRLF+this.logs;
}
else
fs=new FileStream(this.LogPath,FileMode.Create,FileAccess.Write);
byte[] logPath_b=Encoding.GetEncoding("gb2312").GetBytes(this.logs);
fs.Write(logPath_b,0,logPath_b.Length);
fs.Close();
}
}
return isSended;
}
/// <summary>
/// 異步寫入數據
/// </summary>
/// <param name="result"></param>
private void asyncCallBack(IAsyncResult result)
{
if(result.IsCompleted)
this.sendIsComplete=true;
}
/// <summary>
/// 關閉連接
/// </summary>
private void disconnect()
{
try
{
ns.Close();
tc.Close();
}
catch
{
;
}
}
/// <summary>
/// 設置出現錯誤時的動作
/// </summary>
/// <param name="errorStr"></param>
private void setError(string errorStr)
{
this.errorMessage=errorStr;
logs+=this.errorMessage+CRLF+"【郵件處理動作中止】"+CRLF;
this.disconnect();
throw new ApplicationException("");
}
/// <summary>
///將字符串轉換為base64
/// </summary>
/// <param name="str"></param>
/// <param name="encodingName"></param>
/// <returns></returns>
private string convertBase64String(string str,string encodingName)
{
byte[] str_b=Encoding.GetEncoding(encodingName).GetBytes(str);
return Convert.ToBase64String(str_b,0,str_b.Length);
}
#endregion
}
}
