转载

我心中的核心组件（可插拔的AOP）~消息组件~完善篇

回到目录

为什么要有本篇文章

本篇文章主要实现了RTX消息生产者，并且完成了整体的设计方式，之前在设计时消息生产者全局使用单一的生产方式，即一个项目里使用了Email就不能使用SMS，这种设计方法和实际不相符，虽然在性能上是最佳的（采用了单例模型，维护一个生产者，使用策略模式进行生产者的实现，使用工厂模式生产具体生产者），实际项目中，应该是可以自动选择消息生产者的，当然为了程序的性能，我们还必须使用单例模式来生产具体生产者，这种单例，在本程序中，采用了具体类型，具体单例的方法，即Email自己维护单例，SMS自己维护单例，这样，程序即能满足实际的需要，又可以提高自己的性能！

第五回消息组件

第六回消息组件~续

强大的设计

强大的生产者

  /// <summary> /// 消息生产者 /// 具体消息生产者是单例，如Email,SMS,Rtx等 /// </summary> public 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;    default:     throw new NotImplementedException("消息生产者未被识别...");   }  } }

RTX生产者的实现

/// <summary> /// RTX消息服务 /// </summary> internal class RTXMessageManager : IMessageManager {  #region Singleton  private static object lockObj = new object();  public static RTXMessageManager Instance;  static RTXMessageManager()  {   lock (lockObj)   {    if (Instance == null)     Instance = new RTXMessageManager();   }  }  private RTXMessageManager()  { }  #endregion  private string EncodingString(string str)  {   return HttpUtility.UrlEncode(str, Encoding.GetEncoding("GB2312"));  }  private string rtxUrl = System.Configuration.ConfigurationManager.AppSettings["RtxApi"] ??   "http://192.168.1.8:8012/sendnotifynew.cgi?";  #region IMessageManager 成员  public void Send(string recipient, string subject, string body)  {   Send(new List<string> { recipient }, subject, body);  }  public void Send(IEnumerable<string> recipients, string subject, string body)  {   try   {    var dic = new Dictionary<string, string>()        { {"title",EncodingString(subject)},      {"msg",EncodingString(body)},      {"receiver", EncodingString(string.Join(",",recipients))},      {"delaytime","0"}     };    StringBuilder str = new StringBuilder();    foreach (var item in dic)    {     str.Append(item.Key + "=" + item.Value + "&");    }    new HttpClient().GetAsync(rtxUrl + str.ToString()).Wait();   }   catch (Exception ex)   {    Logger.Core.LoggerFactory.Instance.Logger_Info(ex.Message);   }  }  public void Send(IEnumerable<string> recipients, string subject, string body, bool isAsync)  {   if (isAsync)    Task.Run(() =>    {     Send(recipients, subject, body);    });   else    Send(recipients, subject, body);  }  #endregion }