Lind.DDD.Messaging框架通讯组件介绍

    /// <summary>
    /// Message Interface
    /// Author:Garrett /// </summary> public interface IMessageManager { /// <summary> /// Sends a message to a channel using a content item as the recipient /// </summary> /// <param name="recipient">接收者</param> /// <param name="subject">主题</param> /// <param name="body">消息主体</param> /// <param name="serverVirtualPath">本参数可以没有，服务端模块级路径，只在xmpp中有意义</param> void Send(string recipient, string subject, string body, string serverVirtualPath = null); /// <summary> /// Sends a message to a channel using a set of content items as the recipients /// </summary> /// <param name="recipients">A set of content items to send the message to. Only one message may be sent if the channel manages it.</param> /// <param name="type">A custom string specifying what type of message is sent. Used in even handlers to define the message.</param> /// <param name="service">The name of the channel to use, e.g. "email"</param> /// <param name="properties">A set of specific properties for the channel.</param> void Send(IEnumerable<string> recipients, string subject, string body, string serverVirtualPath = null); /// <summary> /// Async Sends a message to a channel using a set of content items as the recipients /// </summary> /// <param name="recipients">A set of content items to send the message to. Only one message may be sent if the channel manages it.</param> /// <param name="type">A custom string specifying what type of message is sent. Used in even handlers to define the message.</param> /// <param name="service">The name of the channel to use, e.g. "email"</param> /// <param name="properties">A set of specific properties for the channel.</param> /// <param name="isAsync">is Async</param> void Send(IEnumerable<string> recipients, string subject, string body, bool isAsync, string serverVirtualPath = null); }

 /// <summary>
    /// 消息实体
    /// </summary> public class MessageContext { /// <summary> /// 消息类型 /// </summary> public MessageType Type { get; set; } /// <summary> /// 消息头 /// </summary> public string Subject { get; set; } /// <summary> /// 消息正文 /// </summary> public string Body { get; set; } /// <summary> /// 接受方地址列表 /// </summary> public IEnumerable<string> Addresses { get; set; } /// <summary> /// 是否处于准备发送状态 /// </summary> public bool MessagePrepared { get; set; } public MessageContext() { Addresses = Enumerable.Empty<string>();//这时Addresses!=null,使用Addresses.ToList().ForEach(i => Console.WriteLine(i));不会引发异常  } }

/// <summary>
    /// 消息生产者
    /// 具体消息生产者是单例，如Email,SMS,Rtx等 /// </summary> public sealed class MessageFactory { /// <summary> /// 消息工厂 /// </summary> public static IMessageManager GetService(MessageType messageType) { switch (messageType) { case MessageType.Email: return EmailMessageManager.Instance; case MessageType.SMS: return SMSMessageManager.Instance; case MessageType.RTX: return RTXMessageManager.Instance; case MessageType.XMPP: return XMPPMessageManager.Instance; default: throw new NotImplementedException("消息生产者未被识别..."); } } }

    /// <summary>
    ///Email消息服务
    /// </summary> internal class EmailMessageManager : IMessageManager { #region Singleton private static object lockObj = new object(); public static EmailMessageManager Instance; static string email_Address = ConfigurationManager.AppSettings["Email_Address"]; static string email_DisplayName = ConfigurationManager.AppSettings["Email_DisplayName"]; static string email_Host = ConfigurationManager.AppSettings["Email_Host"]; static string email_Password = ConfigurationManager.AppSettings["Email_Password"]; static int email_Port = Convert.ToInt32(ConfigurationManager.AppSettings["Email_Port"] ?? "21"); static string email_UserName = ConfigurationManager.AppSettings["Email_UserName"]; static EmailMessageManager() { lock (lockObj) { if (Instance == null) Instance = new EmailMessageManager(); } } private EmailMessageManager() { } #endregion #region IMessageManager 成员 public void Send(string recipient, string subject, string body, string serverVirtualPath = null) { Send(new List<string> { recipient }, subject, body); } public void Send(IEnumerable<string> recipients, string subject, string body, string serverVirtualPath = null) { Send(recipients, subject, body, false); } public void Send(IEnumerable<string> recipients, string subject, string body, bool isAsync, string serverVirtualPath = null) { try { if (recipients != null && recipients.Any()) { using (SmtpClient client = new SmtpClient() { Host = email_Host, Port = email_Port, Credentials = new NetworkCredential(email_UserName, email_Password), EnableSsl = false,//设置为true会出现"服务器不支持安全连接的错误" DeliveryMethod = SmtpDeliveryMethod.Network, }) { #region Send Message var mail = new MailMessage { From = new MailAddress(email_Address, email_DisplayName), Subject = subject, Body = body, IsBodyHtml = true, }; MailAddressCollection mailAddressCollection = new MailAddressCollection(); recipients.ToList().ForEach(i => { //email有效性验证 if (new Regex(@"^([\w-\.]+)@((\[[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}\.)|(([\w-]+\.)+))([a-zA-Z]{2,4}|[0-9]{1,3})(\]?)$").IsMatch(i)) mail.To.Add(i); }); if (isAsync) { client.SendCompleted += new SendCompletedEventHandler(client_SendCompleted); client.SendAsync(mail, recipients); } else { client.Send(mail); } #endregion } } } catch (Exception ex) { LoggerFactory.Instance.Logger_Info(ex.Message); } } void client_SendCompleted(object sender, System.ComponentModel.AsyncCompletedEventArgs e) { string arr = null; (e.UserState as List<string>).ToList().ForEach(i => { arr += i; }); //发送完成后要做的事件，可能是写日志  } #endregion }