MemCache.cs

using System;
using System.Collections.Generic;
using System.Text;
using CYQ.Data.Cache;
using System.Web.Caching;
using CYQ.Data.Table;
using CYQ.Data.Tool;

namespace CYQ.Data.Cache
{
    /// <summary>
    /// ·Ö²¼Ê½»º´æÀà
    /// </summary>
    internal class MemCache : CacheManage
    {
        MemcachedClient client;
        internal MemCache()
        {
            MemcachedClient.Setup("MyCache", AppConfig.Cache.MemCacheServers.Split(','));
            client = MemcachedClient.GetInstance("MyCache");

        }

        public override void Add(string key, object value, double cacheMinutes)
        {
            client.Add(key, value, DateTime.Now.AddMinutes(cacheMinutes));
        }
        public override void Add(string key, object value, string fileName, double cacheMinutes)
        {
            client.Add(key, value, DateTime.Now.AddMinutes(cacheMinutes));
        }

        public override void Add(string key, object value, string fileName)
        {
            client.Add(key, value, DateTime.Now.AddMinutes(AppConfig.Cache.DefaultCacheTime));
        }

        public override void Add(string key, object value)
        {
            client.Add(key, value, DateTime.Now.AddMinutes(AppConfig.Cache.DefaultCacheTime));
        }

        public override void Add(string key, object value, string fileName, double cacheMinutes, CacheItemPriority level)
        {
            client.Add(key, value, DateTime.Now.AddMinutes(cacheMinutes));
        }

        public override Dictionary<string, CacheDependencyInfo> CacheInfo
        {
            get { return null; }
        }
        DateTime allowCacheTableTime = DateTime.Now;
        private MDataTable cacheTable = null;
        public override MDataTable CacheTable
        {
            get
            {
                if (cacheTable == null || DateTime.Now > allowCacheTableTime)
                {
                    cacheTable = null;
                    cacheTable = new MDataTable();
                    Dictionary<string, Dictionary<string, string>> status = client.Stats();
                    if (status != null)
                    {

                        foreach (KeyValuePair<string, Dictionary<string, string>> item in status)
                        {
                            if (item.Value.Count > 0)
                            {
                                MDataTable dt = MDataTable.CreateFrom(item.Value);
                                if (cacheTable.Columns.Count == 0)//µÚÒ»´Î
                                {
                                    cacheTable = dt;
                                }
                                else
                                {
                                    cacheTable.JoinOnName = "Key";
                                    cacheTable = cacheTable.Join(dt, "Value");
                                }
                                cacheTable.Columns["Value"].ColumnName = item.Key;
                            }
                        }
                    }
                    cacheTable.TableName = "MemCache";
                    allowCacheTableTime = DateTime.Now.AddMinutes(1);
                }
                return cacheTable;
            }
        }

        public override void Clear()
        {
            client.FlushAll();
        }

        public override bool Contains(string key)
        {
            return Get(key) != null;
        }

        //int count = -1;
        //DateTime allowGetCountTime = DateTime.Now;
        public override int Count
        {
            get
            {
                int count = 0;
                MDataRow row = CacheTable.FindRow("Key='curr_items'");
                if (row != null)
                {
                    for (int i = 1; i < row.Columns.Count; i++)
                    {
                        count += int.Parse(row[i].strValue);
                    }
                }
                return count;
            }
        }

        public override object Get(string key)
        {
            return client.Get(key);
        }


        public override bool GetFileDependencyHasChanged(string key)
        {
            return false;
        }

        public override bool GetHasChanged(string key)
        {
            return false;
        }

        public override long RemainMemoryBytes
        {
            get { return 0; }
        }

        public override long RemainMemoryPercentage
        {
            get { return 0; }
        }

        public override void Remove(string key)
        {
            client.Delete(key);
        }

        public override void Set(string key, object value)
        {
            client.Set(key, value, DateTime.Now.AddMilliseconds(AppConfig.Cache.DefaultCacheTime));
        }

        public override void Set(string key, object value, double cacheMinutes)
        {
            client.Set(key, value, DateTime.Now.AddMinutes(cacheMinutes));
        }

        public override void SetChange(string key, bool isChange)
        {

        }

        public override void Update(string key, object value)
        {
            client.Replace(key, value);
        }

        DateTime allowGetWorkInfoTime = DateTime.Now;
        string workInfo = string.Empty;
        public override string WorkInfo
        {
            get
            {
                if (workInfo == string.Empty || DateTime.Now > allowGetWorkInfoTime)
                {
                    workInfo = null;
                    Dictionary<string, Dictionary<string, string>> status = client.Status();
                    if (status != null)
                    {
                        JsonHelper js = new JsonHelper(false, false);
                        js.Add("OKServerCount", client.okServer.ToString());
                        js.Add("DeadServerCount", client.errorServer.ToString());
                        foreach (KeyValuePair<string, Dictionary<string, string>> item in status)
                        {
                            js.Add(item.Key, JsonHelper.ToJson(item.Value));
                        }
                        js.AddBr();
                        workInfo = js.ToString();
                    }
                    allowGetWorkInfoTime = DateTime.Now.AddMinutes(5);
                }
                return workInfo;
            }
        }
    }
}