使用Mongodb 做对象缓存
使用Mongodb 做对象缓存
JadePeng
发布于 2018-03-12 14:49:02
发布于 2018-03-12 14:49:02
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;
}
}本文参与 腾讯云自媒体分享计划，分享自作者个人站点/博客。
原始发表：2012-03-15 ，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
相关产品与服务
云数据库 MongoDB
腾讯云数据库 MongoDB（TencentDB for MongoDB）是腾讯云基于全球广受欢迎的 MongoDB 打造的高性能 NoSQL 数据库，100%完全兼容 MongoDB 协议，支持跨文档事务，提供稳定丰富的监控管理，弹性可扩展、自动容灾，适用于文档型数据库场景，您无需自建灾备体系及控制管理系统。