回到顶部

回到顶部

/// <summary>/// 使用Cookie实现SessionStateStoreProviderBase/// 注意：它只适合保存简单的基元类型数据。/// </summary>public class RedisSessionStateStore : SessionStateStoreProviderBase{public override SessionStateStoreData CreateNewStoreData(HttpContext context, int timeout){return CreateLegitStoreData(context, null, null, timeout);}internal static SessionStateStoreData CreateLegitStoreData(HttpContext context, ISessionStateItemCollection sessionItems, HttpStaticObjectsCollection staticObjects, int timeout){if (sessionItems == null)sessionItems = new SessionStateItemCollection();if (staticObjects == null && context != null)staticObjects = SessionStateUtility.GetSessionStaticObjects(context);return new SessionStateStoreData(sessionItems, staticObjects, timeout);}public override void CreateUninitializedItem(HttpContext context, string id, int timeout){RedisSessionState state = new RedisSessionState(null, null, timeout);RedisBase.Item_Set<string>(id, state.ToJson(), timeout);}private SessionStateStoreData DoGet(HttpContext context, string id, bool exclusive, out bool locked, out TimeSpan lockAge, out object lockId, out SessionStateActions actionFlags){locked = false;lockId = null;lockAge = TimeSpan.Zero;actionFlags = SessionStateActions.None;RedisSessionState state = RedisSessionState.FromJson(RedisBase.Item_Get<string>(id));if (state == null){return null;}RedisBase.Item_SetExpire(id, state._timeout);return CreateLegitStoreData(context, state._sessionItems, state._staticObjects, state._timeout);}public override SessionStateStoreData GetItem(HttpContext context, string id, out bool locked, out TimeSpan lockAge, out object lockId, out SessionStateActions actionFlags){return this.DoGet(context, id, false, out locked, out lockAge, out lockId, out actionFlags);}public override SessionStateStoreData GetItemExclusive(HttpContext context, string id, out bool locked, out TimeSpan lockAge, out object lockId, out SessionStateActions actionFlags){return this.DoGet(context, id, true, out locked, out lockAge, out lockId, out actionFlags);}public override void SetAndReleaseItemExclusive(HttpContext context, string id, SessionStateStoreData item, object lockId, bool newItem){ISessionStateItemCollection sessionItems = null;HttpStaticObjectsCollection staticObjects = null;if (item.Items.Count > 0)sessionItems = item.Items;if (!item.StaticObjects.NeverAccessed)staticObjects = item.StaticObjects;RedisSessionState state2 = new RedisSessionState(sessionItems, staticObjects, item.Timeout);RedisBase.Item_Set<string>(id, state2.ToJson(), item.Timeout);}#region "未实现方法"public override void Dispose(){}public override void EndRequest(HttpContext context){}public override void InitializeRequest(HttpContext context){}public override void ReleaseItemExclusive(HttpContext context, string id, object lockId){}public override void RemoveItem(HttpContext context, string id, object lockId, SessionStateStoreData item){RedisBase.Item_Remove(id);}public override void ResetItemTimeout(HttpContext context, string id){}public override bool SetItemExpireCallback(SessionStateItemExpireCallback expireCallback){return true;}#endregion}internal sealed class SessionStateItem{public Dictionary<string, SaveValue> Dict;public int Timeout;}internal sealed class SaveValue{public object Value { get; set; }public Type Type { get; set; }}internal sealed class RedisSessionState{internal ISessionStateItemCollection _sessionItems;internal HttpStaticObjectsCollection _staticObjects;internal int _timeout;internal RedisSessionState(ISessionStateItemCollection sessionItems, HttpStaticObjectsCollection staticObjects, int timeout){this.Copy(sessionItems, staticObjects, timeout);}internal void Copy(ISessionStateItemCollection sessionItems, HttpStaticObjectsCollection staticObjects, int timeout){this._sessionItems = sessionItems;this._staticObjects = staticObjects;this._timeout = timeout;}public string ToJson(){// 这里忽略_staticObjects这个成员。if (_sessionItems == null || _sessionItems.Count == 0){return null;}Dictionary<string, SaveValue> dict = new Dictionary<string, SaveValue>(_sessionItems.Count);NameObjectCollectionBase.KeysCollection keys = _sessionItems.Keys;string key;object objectValue = string.Empty;Type type = null;　　　　　　//2016-09-04解决存入值没有类型导致读取值是jobject问题　　for (int i = 0; i < keys.Count; i++){key = keys[i];objectValue = _sessionItems[key];if (objectValue != null){type = objectValue.GetType();}else{type = typeof(object);}dict.Add(key, new SaveValue { Value = objectValue, Type = type });}SessionStateItem item = new SessionStateItem { Dict = dict, Timeout = this._timeout };return JsonConvert.SerializeObject(item);}public static RedisSessionState FromJson(string json){if (string.IsNullOrEmpty(json)){return null;}try{SessionStateItem item = JsonConvert.DeserializeObject<SessionStateItem>(json);SessionStateItemCollection collections = new SessionStateItemCollection();SaveValue objectValue = null;　　　　　//2016-09-04解决读取出来的值 没有类型的问题JsonSerializer serializer = new JsonSerializer();StringReader sr = null;JsonTextReader tReader = null;foreach (KeyValuePair<string, SaveValue> kvp in item.Dict){objectValue = kvp.Value as SaveValue;if (objectValue.Value == null){collections[kvp.Key] = null;}else{if (!IsValueType(objectValue.Type)){sr = new StringReader(objectValue.Value.ToString());tReader = new JsonTextReader(sr);collections[kvp.Key] = serializer.Deserialize(tReader, objectValue.Type);}else{collections[kvp.Key] = objectValue.Value;}}}return new RedisSessionState(collections, null, item.Timeout);}catch{return null;}}/// <summary>/// 判断是否为值类型/// </summary>/// <param name="type">Type</param>/// <returns></returns>public static bool IsValueType(Type type){if (type.IsValueType){return true;}//基础数据类型if (type == typeof(string) || type == typeof(char)|| type == typeof(ushort) || type == typeof(short) || type == typeof(uint) || type == typeof(int)|| type == typeof(ulong) || type == typeof(long) || type == typeof(double) || type == typeof(decimal)|| type == typeof(bool)|| type == typeof(byte)){return true;}//可为null的基础数据类型if (type.IsGenericType && !type.IsGenericTypeDefinition){Type genericType = type.GetGenericTypeDefinition();if (Object.ReferenceEquals(genericType, typeof(Nullable<>))){var actualType = type.GetGenericArguments()[0];return IsValueType(actualType);}}return false;}}

使用也很简单，修改web.config,如下图

然后可以保持原先代码不变,像Session["UserCode"]="admin"方式进行使用，但是现在的Session已经具备了分布式的特征,支持跨域。这里得说一下该方式的缺点,在GetItem和SetAndReleaseItemExclusive时需要对键值对进行反序列化和序列化操作,对于保存数据量大的情况反而性能相对于系统提供的方式大打折扣,所以使用的时候需要考虑自己的实际场景。

回到顶部

如果，您认为阅读这篇博客让您有些收获，不妨点击一下右下角的【推荐】按钮。
如果，您希望更容易地发现我的新博客，不妨点击一下绿色通道的【关注我】。

因为，我的写作热情也离不开您的肯定支持。

感谢您的阅读，如果您对我的博客所讲述的内容有兴趣，请继续关注我的后续博客，我是焰尾迭 。