asp.net基于windows服务实现定时发送邮件的方法

这篇文章主要介绍了asp.net基于windows服务实现定时发送邮件的方法,结合实例形式较为详细的分析了asp.net调用Windows系统服务的相关技巧,具有一定参考借鉴价值,需要的朋友可以参考下

 

本文实例讲述了asp.net基于windows服务实现定时发送邮件的方法。分享给大家供大家参考，具体如下：
 

1. //定义组件 
2. private System.Timers.Timer time; 
3. public int nowhour; 
4. public int minutes; 
5. public string sendTime; 
6. public Thread th; 
7. public string isOpen;//是否启用定时发送 
8. public string strToEUser; 
9. public static int index = -1; 
10. public static ArrayList mulitaddress; 
11. //服务开始 
12. protected override void OnStart(string[] args) 
13. { 
14.   time = new System.Timers.Timer(); 
15.   time.Enabled = true; 
16.   time.AutoReset = true; 
17.   //定时执行方法 
18.    time.Elapsed+=new System.Timers.ElapsedEventHandler(time_Elapsed); 
19.     UserEmail toUser =new UserEmail(); 
20.     mulitaddress = GetMailAdressName(); 
21.    // LogHelper.SaveNote("当前索引的值" + index.ToString()); 
22.     Thread.Sleep(2000); 
23.    time.Start(); 
24. } 
25. public class LogHelper 
26. { 
27.   public static void SaveNote(string note) 
28.   { 
29.     FileStream stream = new FileStream(GetLogDirectory("Common") + DateTime.Now.ToString("yyyy-MM-dd") + ".txt", FileMode.Append, FileAccess.Write, FileShare.Delete | FileShare.ReadWrite); 
30.     StreamWriter writer = new StreamWriter(stream, Encoding.UTF8); 
31.     writer.WriteLine("================================================================"); 
32.     writer.WriteLine(string.Format("Note:/t{0}", note)); 
33.     writer.WriteLine(string.Format("DateTime:/t{0}/r/n/r/n",DateTime.Now.ToString())); 
34.     stream.Flush(); 
35.     writer.Close(); 
36.     stream.Close(); 
37.     stream.Dispose(); 
38.     writer.Dispose(); 
39.   } 
40.   public static void SaveNote(string note, string txtname) 
41.   { 
42.     FileStream stream = new FileStream(GetLogDirectory(txtname) + DateTime.Now.ToString("yyyy-MM-dd") + ".txt", FileMode.Append, FileAccess.Write, FileShare.Delete | FileShare.ReadWrite); 
43.     StreamWriter writer = new StreamWriter(stream, Encoding.GetEncoding("gb2312")); 
44.     writer.WriteLine("================================================================"); 
45.     writer.WriteLine(string.Format("Note:/t{0}", note)); 
46.     writer.WriteLine(string.Format("DateTime:/t{0}/r/n/r/n", DateTime.Now.ToString("yyyyMMddHHmmss"))); 
47.     stream.Flush(); 
48.     writer.Close(); 
49.     stream.Close(); 
50.     stream.Dispose(); 
51.     writer.Dispose(); 
52.   } 
53.   public static void SaveException(Exception e) 
54.   { 
55.     SaveException(e, string.Empty); 
56.   } 
57.   public static void SaveException(Exception e, string memo) 
58.   { 
59.     FileStream stream = new FileStream(GetLogDirectory("Common") + DateTime.Now.ToString("yyyy-MM-dd") + ".txt", FileMode.Append, FileAccess.Write, FileShare.Delete | FileShare.ReadWrite); 
60.     StreamWriter writer = new StreamWriter(stream); 
61.     writer.WriteLine("================================================================"); 
62.     writer.WriteLine(string.Format("Memo:/t{0}", memo)); 
63.     writer.WriteLine(string.Format("DateTime:/t{0}", DateTime.Now.ToShortTimeString())); 
64.     writer.WriteLine(string.Format("Message:/t{0}", e.Message)); 
65.     writer.WriteLine(string.Format("StackTrace:/r/n----------/r/n{0}/r/n----------/r/n/r/n/r/n", e.StackTrace)); 
66.     stream.Flush(); 
67.     writer.Close(); 
68.     stream.Close(); 
69.     stream.Dispose(); 
70.     writer.Dispose(); 
71.   } 
72.   public static string GetLogDirectory(string category) 
73.   { 
74.     string baseDirectory = string.Empty; 
75.     if ((HttpContext.Current != null) && (HttpContext.Current.Server != null)) 
76.     { 
77.       baseDirectory = HttpContext.Current.Server.MapPath("~"); 
78.     } 
79.     else 
80.     { 
81.       baseDirectory = AppDomain.CurrentDomain.BaseDirectory; 
82.     } 
83.     if ((baseDirectory[baseDirectory.Length - 1] != '/') && (baseDirectory[baseDirectory.Length - 1] != '//')) 
84.     { 
85.       baseDirectory = baseDirectory + @"/"; 
86.     } 
87.     baseDirectory = string.Format(@"{0}Log/{1}/", baseDirectory, category); 
88.     if (!Directory.Exists(baseDirectory)) 
89.     { 
90.       Directory.CreateDirectory(baseDirectory); 
91.     } 
92.     return baseDirectory; 
93.   } 
94. } 
95. void time_Elapsed(object sender, System.Timers.ElapsedEventArgs e) 
96. { 
97.   try 
98.   { 
99.     if (mulitaddress != null) 
100.     { 
101.       LogHelper.SaveNote("进入time_Elapsed"); 
102.       //获取定时发送时间 
103.       sendTime = Convert.ToString(GetConfigValue("sendTime")); 
104.       LogHelper.SaveNote("sendTime" + sendTime); 
105.       //是否开启定时发送功能 
106.       isOpen = GetConfigValue("isOpen"); 
107.       int sleeptime = Convert.ToInt32(GetConfigValue("SleepTime")); 
108.       int stoptime = Convert.ToInt32(GetConfigValue("stoptime")); 
109.       //LogHelper.SaveNote("数组长度" + mulitaddress.Count); 
110.       // LogHelper.SaveNote("是否开启定时发送功能" + isOpen + "定时时间" + sendTime + "定时小时数:" + Convert.ToInt32(sendTime.Split(new char[] { ':' })[0]) + "定时分钟数:" + Convert.ToInt32(sendTime.Split(new char[] { ':' })[1])); 
111.       if (isOpen == "true") 
112.       { 
113.         //现在时间 小时 
114.         nowhour = Convert.ToInt32(DateTime.Now.Hour.ToString());//10 
115.         //现在分钟 
116.         minutes = Convert.ToInt32(DateTime.Now.Minute.ToString());//5 
117.         //获取发送小时 
118.         int sendhour = Convert.ToInt32(sendTime.Split(new char[] { ':' })[0]); 
119.         //获取发送的分钟 
120.         int sendMinute = Convert.ToInt32(sendTime.Split(new char[] { ':' })[1]); 
121.         LogHelper.SaveNote("进入定时发送邮件服务! 定时小时为:" + sendhour.ToString() + "定时分钟为:" + sendMinute.ToString() + "现在小时为:" + nowhour.ToString() + "现在定时的分钟为:" + minutes.ToString()); 
122.         LogHelper.SaveNote("当前索引的值" + index.ToString()); 
123.         if (nowhour == stoptime) 
124.         { 
125.           LogHelper.SaveNote("停止时间点到了 邮件停止发送 ！！！"); 
126.           index = -1; 
127.         } 
128.         else 
129.         { 
130.           //如果和当前的时间 小时相等 则定时发送邮件 
131.           if ((Convert.ToDateTime(DateTime.Now.ToShortTimeString()) >= Convert.ToDateTime(sendTime)) && index < mulitaddress.Count) 
132.           { 
133.             index++; 
134.             if (index < mulitaddress.Count) 
135.             { 
136.               SendEmail(((UserEmail)mulitaddress[index])); 
137.             } 
138.             else 
139.             { 
140.               LogHelper.SaveNote("发送完毕 当前的索引值为" + index.ToString()); 
141.             } 
142.           } 
143.         } 
144.       } 
145.       else 
146.       { 
147.         //LogHelper.SaveNote("当前索引的值" + index.ToString()); 
148.         index++; 
149.         if (index < mulitaddress.Count) 
150.         { 
151.           SendEmail(((UserEmail)mulitaddress[index])); 
152.         } 
153.         else 
154.         { 
155.           LogHelper.SaveNote("发送完毕 时间停止"); 
156.           time.Enabled = false; 
157.           time.Stop(); 
158.         } 
159.       } 
160.       Thread.Sleep(sleeptime); 
161.     } 
162.     else 
163.       LogHelper.SaveNote("mulitaddress=null"); 
164.   } 
165.   catch (Exception ex)  
166.   { 
167.     LogHelper.SaveNote(ex.ToString()); 
168.   } 
169. } 
170. public ArrayList GetMailAdressName() 
171. { 
172.   ArrayList list = new ArrayList(); 
173.   string strSQL = "select b.mailAddress, a.mailtemplate,a.title from tg_product as a inner join tg_mailOrder as b on a.ccode=b.ccode where a.createtime=(select max(createtime) from tg_product)"; 
174.   SqlDataReader dr = SqlHelper.ExecuteReader(CommandType.Text, strSQL, null); 
175.   if (dr.HasRows) 
176.   { 
177.     while (dr.Read()) 
178.     { 
179.       UserEmail email = new UserEmail(); 
180.       email.Mailaddres = dr["mailAddress"].ToString(); 
181.       email.Title = dr["title"].ToString(); 
182.       email.Contents = dr["mailtemplate"].ToString(); 
183.       list.Add(email); 
184.     } 
185.   } 
186.   return list; 
187. } 
188. /// <summary> 
189. /// 定义用户邮件 标题 内容 Email地址 
190. /// </summary> 
191. public class UserEmail { 
192.   private string title; 
193.   private string contents; 
194.   public string Contents 
195.   { 
196.     get { return contents; } 
197.     set { contents = value; } 
198.   } 
199.   private string mailaddres; 
200.   public string Mailaddres 
201.   { 
202.     get { return mailaddres; } 
203.     set { mailaddres = value; } 
204.   } 
205.   public string Title {  
206.   get{return title;} 
207.     set { title = value; } 
208.   } 
209. } 
210. #region 发送邮件 
211. /// <summary> 
212. /// 发送邮件 
213. /// </summary> 
214. public void SendEmail(UserEmail user) 
215. { 
216.   try 
217.   { 
218.     LogHelper.SaveNote("进入SendEmail!!!"); 
219.     //邮件服务器 
220.     string smtpserver = GetConfigValue("smtpserver"); 
221.     //发件人的邮箱名称 
222.     string emailuserName = GetConfigValue("emailuserName"); 
223.     //发件人的邮箱密码 
224.     string emailuserpwd = GetConfigValue("emailuserpwd"); 
225.     //邮箱地址 
226.     string emailfrom = GetConfigValue("emailfrom"); 
227.     int port = Convert.ToInt32(GetConfigValue("serverPort")); 
228.     bool f = true; 
229.     //是否经过SSL加密 
230.     string isSSL = GetConfigValue("SSL"); 
231.     if (isSSL == "true") 
232.     { 
233.       f = true; 
234.     } 
235.     else 
236.     { 
237.       f = false; 
238.     } 
239.     LogHelper.SaveNote("发件人的邮箱名称" + emailuserName + "邮件地址(emailFrom)" + emailfrom + "收件人" + user.Mailaddres); 
240.     SendEmailToUser(smtpserver, port, f, user.Mailaddres, null, emailuserName, emailuserpwd, emailfrom, user.Title,user.Contents); 
241.     LogHelper.SaveNote("Send Mail Success"); 
242.   } 
243.   //获取异常信息 
244.   catch (Exception error) 
245.   { 
246.     //写入异常信息 
247.     using (StreamWriter sw = new StreamWriter("F://MailErrorlog.txt", true, System.Text.Encoding.UTF8)) 
248.     { 
249.       sw.WriteLine(DateTime.Now.ToString() + "："); 
250.       sw.WriteLine("Exception 异常信息如下................."); 
251.       sw.WriteLine(error.ToString()); 
252.       sw.WriteLine("---------------------------------------------"); 
253.       sw.Close(); 
254.     } 
255.   } 
256. } 
257. #endregion 
258. #region 利用.Net自带类(SmtpClient) 发送邮件 
259. /// <summary> 
260. /// 利用.Net自带类(SmtpClient) 发送邮件 
261. /// </summary> 
262. /// <param name="stmpserver">邮件服务器</param> 
263. /// <param name="username">用户名(邮箱名称)</param> 
264. /// <param name="pwd">密码</param> 
265. /// <param name="f">是否经过SSL加密</param> 
266. /// <param name="port">邮件服务器端口(没有加密 一般都是25)</param> 
267. /// <param name="strfrom">发件人</param> 
268. /// <param name="strto">收件人</param> 
269. /// <param name="subject">主题</param> 
270. /// <param name="body">内容</param> 
271. /// <param name="Mulitaddress">发送多人 收件人的邮箱地址以逗号隔开</param> 
272. /// <param name="attachmentName">发送的附件名称 没有附件则为null or ""</param> 
273. public void SendEmailToUser(string stmpserver,int port,bool f, string Mulitaddress, string attachmentName, string username, string pwd, string strfrom, string subject, string body) 
274. { 
275.   string ErrorLog = GetConfigValue("ErrorLog"); 
276.   SmtpClient smtp = new SmtpClient(); 
277.   //发送邮件的方式 
278.   smtp.DeliveryMethod = SmtpDeliveryMethod.Network; 
279.   //指定邮件服务器 
280.   smtp.Host = stmpserver; 
281.   //Gmail QQ stmp ssl加密使用的端口  
282.   smtp.Port = port; 
283.   smtp.EnableSsl = f; ;//true 经过ssl加密  
284.   //验证发件人的身份 用户名(邮件地址和密码) 
285.   smtp.Credentials = new System.Net.NetworkCredential(username, pwd); 
286.   //初始化信息(来自 接收人) 
287.   MailMessage _mailmessage = new MailMessage(); 
288.   //_mailmessage.To = strto; 
289.   //发送多个人 接收人邮件地址以,隔开 
290.   _mailmessage.From = new MailAddress(strfrom); 
291.   _mailmessage.To.Add(Mulitaddress); 
292.   //如果发送失败，SMTP 服务器将发送 失败邮件通知 
293.   _mailmessage.DeliveryNotificationOptions = DeliveryNotificationOptions.OnFailure; 
294.   //优先级 
295.   _mailmessage.Priority = MailPriority.High; 
296.   //发送主题 
297.   _mailmessage.Subject = subject; 
298.   //有附件则添加附件 
299.   if (!string.IsNullOrEmpty(attachmentName)) 
300.   { 
301.     System.Net.Mail.Attachment attch = new System.Net.Mail.Attachment(attachmentName); 
302.     _mailmessage.Attachments.Add(attch); 
303.   } 
304.   //邮件主题编码 
305.   _mailmessage.SubjectEncoding = System.Text.Encoding.UTF8; 
306.   //指定发送的格式 (Html) 
307.   _mailmessage.IsBodyHtml = true; 
308.   //指定发送邮件的编码 
309.   _mailmessage.BodyEncoding = System.Text.Encoding.UTF8; 
310.   //指定邮件内容 
311.   _mailmessage.Body = body; 
312.   //发送邮件 
313.   try 
314.   { 
315.     smtp.Send(_mailmessage); 
316.   } 
317.   catch (Exception ex) 
318.   { 
319.     using (StreamWriter writer = new StreamWriter(ErrorLog+"://MailErrorlog.txt", true, System.Text.Encoding.UTF8)) 
320.     { 
321.       writer.WriteLine("---------------------------------------------"); 
322.       writer.WriteLine("SendEmail方法发送邮件错误日志................"); 
323.       writer.WriteLine(ex.ToString()); 
324.       writer.Flush(); 
325.       writer.Close(); 
326.     } 
327.   } 
328. } 
329. #endregion 
330. #region 获取邮件配置节点的值 
331. /// <summary> 
332. /// 加载相应配置文件 并按节点名称获取对应的值 
333. /// </summary> 
334. /// <param name="target">当前节点的名称</param> 
335. /// <returns>返回当前节点名称所对应的值</returns> 
336. public string GetConfigValue(string target) 
337. { 
338.   string configpath=System.Windows.Forms.Application.StartupPath.ToString() + "/Email.config"; 
339.   return GetConfigValue(configpath, target); 
340. } 
341. /// <summary> 
342. /// 根据节点名称获取配置文件对应的值(邮件配置信息) 
343. /// </summary> 
344. /// <param name="configpath">配置文件路径</param> 
345. /// <param name="target">要获取配置节点的名称</param> 
346. /// <returns>返回当前节点名称所对应的值</returns> 
347. public string GetConfigValue(string configpath, string target) 
348. { 
349.   XmlDocument doc = new XmlDocument(); 
350.   //加载文件路径s 
351.   doc.Load(configpath); 
352.   //获取当前节点的根节点 
353.   XmlElement root = doc.DocumentElement; 
354.   //获取当前节点下所有匹配子节点元素 
355.   XmlNodeList xmlnode = root.GetElementsByTagName(target); 
356.   //返回值 
357.   return xmlnode[0].InnerXml; 
358. } 
359. #endregion 
360. //服务结束 
361. protected override void OnStop() 
362. { 
363.   time.Enabled = false; 
364. }