二十四種設計模式:提供者模式(Provider Pattern)

提供者模式(Provider Pattern)


介紹
爲一個API進行定義和實現的分離。

示例
有一個Message實體類,對它的操做有Insert()和Get()方法,持久化數據在SqlServer數據庫中或Xml文件裏。根據配置文件中的配置來決定數據持久化方案是使用SqlServer數據庫仍是Xml文件。數據庫

  MessageModelide

using System;

namespace Pattern.Provider
{
    /// <summary>
    /// Message實體類
    /// </summary>
    public class MessageModel
    {
        /// <summary>
        /// 構造函數
        /// </summary>
        /// <param name="msg">Message內容</param>
        /// <param name="pt">Message發佈時間</param>
        public MessageModel(string msg, DateTime pt)
        {
            this._message = msg;
            this._publishTime = pt;
        }

        private string _message;
        /// <summary>
        /// Message內容
        /// </summary>
        public string Message
        {
            get { return _message; }
            set { _message = value; }
        }

        private DateTime _publishTime;
        /// <summary>
        /// Message發佈時間
        /// </summary>
        public DateTime PublishTime
        {
            get { return _publishTime; }
            set { _publishTime = value; }
        }
    }
}

  MessageProvider函數

using System.Configuration.Provider;
using System.Collections.Generic;

namespace Pattern.Provider
{
    /// <summary>
    /// 操做Message抽象類
    /// </summary>
    public abstract class MessageProvider : ProviderBase
    {
        /// <summary>
        /// 插入Message
        /// </summary>
        /// <param name="mm">Message實體對象</param>
        /// <returns></returns>
        public abstract bool Insert(MessageModel mm);

        /// <summary>
        /// 得到Message
        /// </summary>
        /// <returns></returns>
        public abstract List<MessageModel> Get();
    }
}

  SqlMessageProviderui

using System;
using System.Collections.Specialized;
using System.Collections.Generic;

using System.Configuration.Provider;
using System.Configuration;

namespace Pattern.Provider
{
    /// <summary>
    /// Sql方式操做Message
    /// </summary>
    public class SqlMessageProvider : MessageProvider
    {
        private string _connectionString;

        /// <summary>
        /// 插入Message
        /// </summary>
        /// <param name="mm">Message實體對象</param>
        /// <returns></returns>
        public override bool Insert(MessageModel mm)
        {
            // 代碼略
            return true;
        }

        /// <summary>
        /// 獲取Message
        /// </summary>
        /// <returns></returns>
        public override List<MessageModel> Get()
        {
            List<MessageModel> l = new List<MessageModel>();
            l.Add(new MessageModel("SQL方式,鏈接字符串是" + this._connectionString, DateTime.Now));

            return l;
        }

        /// <summary>
        /// 初始化提供程序。
        /// </summary>
        /// <param name="name">該提供程序的友好名稱。</param>
        /// <param name="config">名稱/值對的集合,表示在配置中爲該提供程序指定的、提供程序特定的屬性。</param>
        public override void Initialize(string name, NameValueCollection config)
        {
            if (string.IsNullOrEmpty(name))
                name = "MessageProvider";

            if (null == config)
                throw new ArgumentException("config參數不能爲null");

            if (string.IsNullOrEmpty(config["description"]))
            {
                config.Remove("description");
                config.Add("description", "SqlServer操做Message");
            }

            base.Initialize(name, config);

            string temp = config["connectionStringName"];
            if (temp == null || temp.Length < 1)
                throw new ProviderException("connectionStringName屬性缺乏或爲空");

            _connectionString = ConfigurationManager.ConnectionStrings[temp].ConnectionString;
            if (_connectionString == null || _connectionString.Length < 1)
            {
                throw new ProviderException("沒找到'" + temp + "'所指的鏈接字符串,或所指鏈接字符串爲空");
            }

            config.Remove("connectionStringName");
        }
    }
}

  XmlMessageProviderthis

using System;
using System.Collections.Specialized;
using System.Collections.Generic;

using System.Configuration.Provider;
using System.Configuration;

namespace Pattern.Provider
{
    /// <summary>
    /// Xmll方式操做Message
    /// </summary>
    public class XmlMessageProvider : MessageProvider
    {
        private string _connectionString;

        /// <summary>
        /// 插入Message
        /// </summary>
        /// <param name="mm">Message實體對象</param>
        /// <returns></returns>
        public override bool Insert(MessageModel mm)
        {
            // 代碼略
            return true;
        }

        /// <summary>
        /// 獲取Message
        /// </summary>
        /// <returns></returns>
        public override List<MessageModel> Get()
        {
            List<MessageModel> l = new List<MessageModel>();
            l.Add(new MessageModel("XML方式,鏈接字符串是" + this._connectionString, DateTime.Now));

            return l;
        }

        /// <summary>
        /// 初始化提供程序。
        /// </summary>
        /// <param name="name">該提供程序的友好名稱。</param>
        /// <param name="config">名稱/值對的集合,表示在配置中爲該提供程序指定的、提供程序特定的屬性。</param>
        public override void Initialize(string name, NameValueCollection config)
        {
            if (string.IsNullOrEmpty(name))
                name = "MessageProvider";

            if (null == config)
                throw new ArgumentException("config參數不能爲null");

            if (string.IsNullOrEmpty(config["description"]))
            {
                config.Remove("description");
                config.Add("description", "XML操做Message");
            }

            base.Initialize(name, config);

            string temp = config["connectionStringName"];
            if (temp == null || temp.Length < 1)
                throw new ProviderException("connectionStringName屬性缺乏或爲空");

            _connectionString = ConfigurationManager.ConnectionStrings[temp].ConnectionString;
            if (_connectionString == null || _connectionString.Length < 1)
            {
                throw new ProviderException("沒找到'" + temp + "'所指的鏈接字符串,或所指鏈接字符串爲空");
            }

            config.Remove("connectionStringName");
        }
    }
}

  MessageProviderCollectionspa

using System.Configuration.Provider;
using System;

namespace Pattern.Provider
{
    /// <summary>
    /// Message的Provider集合類
    /// </summary>
    public class MessageProviderCollection : ProviderCollection
    {
        /// <summary>
        /// 向集合中添加提供程序。
        /// </summary>
        /// <param name="provider">要添加的提供程序。</param>
        public override void Add(ProviderBase provider)
        {
            if (provider == null)
                throw new ArgumentNullException("provider參數不能爲null");

            if (!(provider is MessageProvider))
                throw new ArgumentException("provider參數類型必須是MessageProvider.");

            base.Add(provider);
        }
    }
}

  MessageProviderConfigurationSectionserver

using System.Configuration;

namespace Pattern.Provider
{
    /// <summary>
    /// Message的Provider的配置
    /// </summary>
    public class MessageProviderConfigurationSection : ConfigurationSection
    {
        private readonly ConfigurationProperty _defaultProvider;
        private readonly ConfigurationProperty _providers;
        private ConfigurationPropertyCollection _properties;
        
        /// <summary>
        /// 構造函數
        /// </summary>
        public MessageProviderConfigurationSection()
        {
            _defaultProvider = new ConfigurationProperty("defaultProvider", typeof(string), null);
            _providers = new ConfigurationProperty("providers", typeof(ProviderSettingsCollection), null);
            _properties = new ConfigurationPropertyCollection();

            _properties.Add(_providers);
            _properties.Add(_defaultProvider);
        }

        /// <summary>
        /// Message的默認的Provider
        /// </summary>
        [ConfigurationProperty("defaultProvider")]
        public string DefaultProvider
        {
            get { return (string)base[_defaultProvider]; }
            set { base[_defaultProvider] = value; }
        }

        /// <summary>
        /// Message的全部的Provider集合
        /// </summary>
        [ConfigurationProperty("providers", DefaultValue = "SqlMessageProvider")]
        [StringValidator(MinLength = 1)]
        public ProviderSettingsCollection Providers
        {
            get { return (ProviderSettingsCollection)base[_providers]; }
        }

        /// <summary>
        /// Message的Provider的屬性集合
        /// </summary>
        protected override ConfigurationPropertyCollection Properties
        {
            get { return _properties; }
        }
    }
}

  Messagexml

using System;
using System.Collections.Generic;
using System.Configuration;
using System.Web.Configuration;

namespace Pattern.Provider
{
    /// <summary>
    /// 暴露給客戶端用的Message的類(Context)
    /// </summary>
    public class Message
    {
        private static bool m_isInitialized = false;
        private static MessageProviderCollection _providers = null;
        private static MessageProvider _provider = null;

        /// <summary>
        /// 靜態構造函數,初始化
        /// </summary>
        static Message()
        {
            Initialize();
        }

        /// <summary>
        /// 插入信息
        /// </summary>
        /// <param name="mm">Message實體對象</param>
        /// <returns></returns>
        public static bool Insert(MessageModel mm)
        {
            return _provider.Insert(mm);
        }

        /// <summary>
        /// 獲取信息
        /// </summary>
        /// <returns></returns>
        public static List<MessageModel> Get()
        {
            return _provider.Get();
        }

        private static void Initialize()
        {
            try
            {
                MessageProviderConfigurationSection messageConfig = null;

                if (!m_isInitialized)
                {

                    // 找到配置文件中「MessageProvider」節點
                    messageConfig = (MessageProviderConfigurationSection)ConfigurationManager.GetSection("MessageProvider");

                    if (messageConfig == null)
                        throw new ConfigurationErrorsException("在配置文件中沒找到「MessageProvider」節點");

                    _providers = new MessageProviderCollection();

                    // 使用System.Web.Configuration.ProvidersHelper類調用每一個Provider的Initialize()方法
                    ProvidersHelper.InstantiateProviders(messageConfig.Providers, _providers, typeof(MessageProvider));

                    // 所用的Provider爲配置中默認的Provider
                    _provider = _providers[messageConfig.DefaultProvider] as MessageProvider;

                    m_isInitialized = true;

                }
            }
            catch (Exception ex)
            {
                string msg = ex.Message;
                throw new Exception(msg);
            }
        }

        private static MessageProvider Provider
        {
            get
            {
                return _provider;
            }
        }

        private static MessageProviderCollection Providers
        {
            get
            {
                return _providers;
            }
        }
    }
}

  Web.config對象

<?xml version="1.0" encoding="utf-8"?>
<configuration>
  <configSections>
    <section name="MessageProvider" type="Pattern.Provider.MessageProviderConfigurationSection, Pattern.Provider" />
  </configSections>
  <MessageProvider defaultProvider="SqlMessageProvider">
    <providers>
      <add name="XmlMessageProvider" type="Pattern.Provider.XmlMessageProvider, Pattern.Provider" connectionStringName="XmlConnection" />
      <add name="SqlMessageProvider" type="Pattern.Provider.SqlMessageProvider, Pattern.Provider" connectionStringName="SqlConnection" />
    </providers>
  </MessageProvider>
  <connectionStrings>
    <add name="SqlConnection" connectionString="server=.;database=db;uid=sa;pwd=sa" />
    <add name="XmlConnection" connectionString="XmlPath" />
  </connectionStrings>
</configuration>

  Testblog

using System;
using System.Data;
using System.Configuration;
using System.Collections;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Web.UI.HtmlControls;

using Pattern.Provider;

public partial class Provider : System.Web.UI.Page
{
    protected void Page_Load(object sender, EventArgs e)
    {
        Response.Write(Message.Insert(new MessageModel("插入", DateTime.Now)));
        Response.Write("<br />");
        Response.Write(Message.Get()[0].Message + " " + Message.Get()[0].PublishTime.ToString());
    }
}

  運行結果  True  SQL方式,鏈接字符串是server=.;database=db;uid=sa;pwd=sa 2007-1-22 8:21:44

相關文章
相關標籤/搜索