使用Mongodb 做对象缓存

mongodb高效的访问速度,用来快速存取数据再合适不过了,缓存神马的,可以用这个的

另外,有的时候,如果仅仅存储几条数据,单独去建立一张表代价太大,这个时候,不妨试试这个

先发一个mongodb数据访问帮助类

public class MongdbHelper : IDisposable
    {
        public MongoServer Server { get; private set; }

        public MongoDB.Driver.MongoDatabase Database { get; private set; }

        public MongoCollection DataSet { get; set; }

        public MongdbHelper( string dbName, string tableName)
        {
            Server = MongoServer.Create("mongodb://localhost/?socketTimeoutMS=2400000");
            Database = Server.GetDatabase(dbName);
            DataSet = Database.GetCollection(tableName);
        }

        public MongdbHelper(string connectionString, string dbName, string tableName)
        {
            Server = MongoServer.Create(connectionString);
            Database = Server.GetDatabase(dbName);
            DataSet = Database.GetCollection(tableName);
        }

        public void Dispose()
        {
            Server.Disconnect();
        }

        public static List GetOnColumn(string dbName, string tableName, string column, Func convert)
        {
            try
            {
                using (MongdbHelper db = new MongdbHelper(dbName, tableName))
                {
                    List results = new List();
                    var r = db.DataSet.FindAll();
                    r.SetFields(column);
                    foreach (var c in r)
                    {
                        results.Add(convert(c[column]));
                    }

                    return results;
                }
            }
            catch
            {
                return null;
            }
        }

        public static bool IsExist(string dbName, string tableName, string column, object value)
        {
            try
            {
                using (MongdbHelper db = new MongdbHelper(dbName, tableName))
                {
                    IMongoQuery query = new QueryDocument() { { column, value.ToString() } };
                    var results = db.DataSet.FindOne(query);
                    return results != null;
                }
            }
            catch
            {
                return false;
            }
        }
    }

再来看具体的实现:

原理:将对象通过序列化操作后以二进制的方式存储到mongodb中

存实现:

/// 
        /// 存储数据
        /// 
        /// 
        /// 
        /// 
        public static void Set(string key, T value)
        {
            try
            {
                using (MongdbHelper db = new MongdbHelper(DefaultDbName, DefaultTableName))
                {
                    IMongoQuery query = new QueryDocument()
                {
                    {"Key",key}
                };
                    var document = db.DataSet.FindOne(query);
                    if (document != null)
                    {
                        document["Value"] = SerializeHelper.BinarySerialize(value);
                        document["Type"] = value.GetType().Name;
                        document["Date"] = DateTime.Now.ToString();
                    }
                    else
                    {
                        IDictionary newDict = new Dictionary();
                        newDict.Add("Value", SerializeHelper.BinarySerialize(value));
                        newDict.Add("Key", key);
                        newDict.Add("Type", value.GetType().Name);
                        newDict.Add("Date", DateTime.Now.ToString());
                        document = new BsonDocument(newDict);
                    }
                    db.DataSet.Save(document);
                }
            }
            catch (Exception ex)
            {
                throw new Exception("保存数据出错", ex);
            }
        }

取实现:

/// 
        /// 获取对象
        /// 
        /// 
        /// 
        /// 
        public static T Get(string key)
        {
            using (MongdbHelper db = new MongdbHelper(DefaultDbName, DefaultTableName))
            {

                IDictionary dict = new Dictionary();
                dict.Add("Key", key);

                IMongoQuery query = new QueryDocument()
                {
                    {"Key",key}
                };

                // 查询
                var document = db.DataSet.FindOne(query);

                if (document != null)
                {
                    try
                    {
                        byte[] bytes = ((MongoDB.Bson.BsonBinaryData)document["Value"]).Bytes;

                        #region 反序列化字节数组

                        if (string.Equals(document["Type"].ToString(), typeof(T).Name, StringComparison.InvariantCultureIgnoreCase))
                        {
                            return SerializeHelper.BinaryDeSerialize(bytes);
                        }
                        else
                        {
                            return default(T);
                        }

                        #endregion
                    }
                    catch
                    {
                        return default(T);
                    }
                }
                return default(T);

            }
        }

另外,为了方便存储单个对象的数据,例如配置信息,增加下面两个方法:

/// 
        /// 存储对象 
        /// 适用于只有单个对象或单条记录的数据,例如系统配置
        /// 
        /// 
        /// 
        public static void Set(T value)
        {
            Set(typeof(T).Name, value);
        }

        /// 
        /// 获取对象
        /// 适用于只有单个对象或单条记录的数据,例如系统配置
        /// 
        /// 
        /// 
        public static T Ge()
        {
            return Get(typeof(T).Name);
        }

完整代码:

public class SerializeHelper
    {
        /// 
        /// 反序列化
        /// 
        /// 
        /// 
        /// 
        public static T BinaryDeSerialize(byte[] serializedObject)
        {
            MemoryStream serializationStream = new MemoryStream();
            serializationStream.Write(serializedObject, 0, serializedObject.Length);
            serializationStream.Seek(0L, SeekOrigin.Begin);
            object obj2 = new BinaryFormatter().Deserialize(serializationStream);
            serializationStream.Close();
            serializationStream.Dispose();
            return (T)obj2;
        }

        /// 
        /// 序列化
        /// 
        /// 
        /// 
        public static byte[] BinarySerialize(object obj)
        {
            MemoryStream serializationStream = new MemoryStream();
            new BinaryFormatter().Serialize(serializationStream, obj);
            serializationStream.Seek(0L, SeekOrigin.Begin);
            byte[] buffer = serializationStream.ToArray();
            serializationStream.Close();
            serializationStream.Dispose();
            return buffer;
        }
    }

    /// 
    /// 简易的mongodb数据存储服务
    /// 
    public class DataService
    {
        /// 
        /// 数据接名
        /// 
        static string DefaultDbName = "MongodbService";

        static string DefaultTableName = "DataSet";

 
        /// 
        /// 获取对象
        /// 
        /// 
        /// 
        /// 
        public static T Get(string key)
        {
            using (MongdbHelper db = new MongdbHelper(DefaultDbName, DefaultTableName))
            {

                IDictionary dict = new Dictionary();
                dict.Add("Key", key);

                IMongoQuery query = new QueryDocument()
                {
                    {"Key",key}
                };

                // 查询
                var document = db.DataSet.FindOne(query);

                if (document != null)
                {
                    try
                    {
                        byte[] bytes = ((MongoDB.Bson.BsonBinaryData)document["Value"]).Bytes;

                        #region 反序列化字节数组

                        if (string.Equals(document["Type"].ToString(), typeof(T).Name, StringComparison.InvariantCultureIgnoreCase))
                        {
                            return SerializeHelper.BinaryDeSerialize(bytes);
                        }
                        else
                        {
                            return default(T);
                        }

                        #endregion
                    }
                    catch
                    {
                        return default(T);
                    }
                }
                return default(T);

            }
        }

        /// 
        /// 存储数据
        /// 
        /// 
        /// 
        /// 
        public static void Set(string key, T value)
        {
            try
            {
                using (MongdbHelper db = new MongdbHelper(DefaultDbName, DefaultTableName))
                {
                    IMongoQuery query = new QueryDocument()
                {
                    {"Key",key}
                };
                    var document = db.DataSet.FindOne(query);
                    if (document != null)
                    {
                        document["Value"] = SerializeHelper.BinarySerialize(value);
                        document["Type"] = value.GetType().Name;
                        document["Date"] = DateTime.Now.ToString();
                    }
                    else
                    {
                        IDictionary newDict = new Dictionary();
                        newDict.Add("Value", SerializeHelper.BinarySerialize(value));
                        newDict.Add("Key", key);
                        newDict.Add("Type", value.GetType().Name);
                        newDict.Add("Date", DateTime.Now.ToString());
                        document = new BsonDocument(newDict);
                    }
                    db.DataSet.Save(document);
                }
            }
            catch (Exception ex)
            {
                throw new Exception("保存数据出错", ex);
            }
        }


        /// 
        /// 存储对象 
        /// 适用于只有单个对象或单条记录的数据,例如系统配置
        /// 
        /// 
        /// 
        public static void Set(T value)
        {
            Set(typeof(T).Name, value);
        }

        /// 
        /// 获取对象
        /// 适用于只有单个对象或单条记录的数据,例如系统配置
        /// 
        /// 
        /// 
        public static T Ge()
        {
            return Get(typeof(T).Name);
        }

    }

使用举例:

有这个一个用户类:

/// 
    /// 简易的用户模型
    /// 
    [Serializable]
    public class UserModel
    {
        public int UserId
        {
            get;
            set;
        }

        public string UserName
        {
            get;
            set;
        }

        public string Name
        {
            get;
            set;
        }
    }

可以用这样的方式来进行存取:

public UserModel CurrentUser
        {
            get
            {
                if (currentUser == null)
                {
                    if (!string.IsNullOrEmpty(CurrentUserName))
                    {
                        currentUser = DataService.Get(this.CurrentUserName);

                        if (currentUser == null)
                        {
                            var user = IoC.Resolve().FindByAccountName(CurrentUserName);
                            if (user != null)
                            {
                                currentUser = new UserModel
                                {
                                    UserName = CurrentUserName,
                                    Name = user.Name,
                                    UserId = user.ID
                                };

                                // 保存到mongodb 长久存储
                                DataService.Set(this.CurrentUserName, currentUser);
                            }
                        }
                    }
                }
                return currentUser;
            }
        }

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏大内老A

WCF版的PetShop之三:实现分布式的Membership和上下文传递

通过上一篇了解了模块内基本的层次划分之后,接下来我们来聊聊PetShop中一些基本基础功能的实现,以及一些设计、架构上的应用如何同WCF进行集成。本篇讨论两个问...

2305
来自专栏大内老A

[ASP.NET MVC] 利用自定义的AuthenticationFilter实现Basic认证

很多情况下目标Action方法都要求在一个安全上下文中被执行,这里所谓的安全上下文主要指的是当前请求者是一个经过授权的用户。授权的本质就是让用户在他许可的权限范...

21110
来自专栏菩提树下的杨过

利用Spring MVC搭建REST Service

之前写过一篇 利用JAX-RS快速开发RESTful 服务 今天来看下spring-mvc框架如何实现类似的功能:  一、pom.xml 1 <?xml v...

18310
来自专栏大内老A

如何实现对上下文(Context)数据的统一管理 [提供源代码下载]

在应用开发中,我们经常需要设置一些上下文(Context)信息,这些上下文信息一般基于当前的会话(Session),比如当前登录用户的个人信息;或者基于当前方法...

3326
来自专栏程序员的SOD蜜

SQLSERVER 占了500多M内存,原来的程序无法一次查询出50多W数据了,记录下这个问题的解决过程。

    今天需要使用“数据同步程序”将外网数据库的FundYield 数据重新同步到内网,上次成功的一次将50W数据查询了出来,但这次不行了。记得上次外网服务器...

2019
来自专栏跟着阿笨一起玩NET

ASP.NET多线程下使用HttpContext.Current为null解决方案

前面我还提到在APM模式下的异步完成回调时,访问HttpContext.Current也会返回null,那么此时该怎么办呢?

842
来自专栏开发 & 算法杂谈

Django-Database 之 Many-To-Many关系

这里对Many-To-Many即多对多的映射关系以详细事例来分析Django中Database操作多对多映射关系的一些基本用法和注意事项

762
来自专栏博客园

持久化方式

HttpContext抽象提供了一个简单的IDictionary<Object,Object>类型的字典集合,叫做Items。在每个请求中,这个集合从HttpR...

792
来自专栏码匠的流水账

聊聊Spring Data Auditable接口的变化

spring-data-commons-1.12.8.RELEASE-sources.jar!/org/springframework/data/domain/...

492
来自专栏大内老A

通过一个模拟程序让你明白ASP.NET MVC是如何运行的

ASP.NET MVC的路由系统通过对HTTP请求的解析得到表示Controller、Action和其他相关的数据,并以此为依据激活Controller对象,调...

2616

扫码关注云+社区