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

  1. 云栖社区>
  2. 博客>
  3. 正文

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

mcy247 2017-12-07 23:48:00 浏览1111
展开阅读全文

为什么要有本篇文章

本篇文章主要实现了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
    }

 本文转自博客园张占岭(仓储大叔)的博客,原文链接:我心中的核心组件(可插拔的AOP)~消息组件~完善篇,如需转载请自行联系原博主。

网友评论

登录后评论
0/500
评论
mcy247
+ 关注