首页 / 软件开发 / WCF / WCF后续之旅（9） 通过WCF双向通信实现Session管理[Part II]

WCF后续之旅（9） 通过WCF双向通信实现Session管理[Part II]2011-01-03 cnblogs artech5、Session Management Service的实现

现在我们来看看Session Management真正的实现，和我以前的例子不同，我不是把所有的实现都写在WCF service上，而是定义了另一个class来实现所有的业务逻辑：SessionManager。我们分析一下具体的实现逻辑。

namespace Artech.SessionManagement.Service

{
public static class SessionManager
{
private static object _syncHelper = new object（）;

internal static TimeSpan Timeout
{ get; set; }

public static IDictionary<Guid, SessionInfo> CurrentSessionList
{ get; set; }

public static IDictionary<Guid, ISessionCallback> CurrentCallbackList
{ get; set; }

static SessionManager（）
{
string sessionTimeout = ConfigurationManager.AppSettings["SessionTimeout"];
if （string.IsNullOrEmpty（sessionTimeout））
{
throw new ConfigurationErrorsException（"The session timeout application setting is missing"）;
}

double timeoutMinute;
if （！double.TryParse（sessionTimeout, out timeoutMinute））
{
throw new ConfigurationErrorsException（"The session timeout application setting should be of doubdle type."）;
}

Timeout = new TimeSpan（0, 0, （int）（timeoutMinute * 60））;
CurrentSessionList = new Dictionary<Guid, SessionInfo>（）;
CurrentCallbackList = new Dictionary<Guid, ISessionCallback>（）;
}

… … … … … … … … … … … … … … … …… … … … … … … … … … … … … … … …
}
}

首先来看Field、Property和static constructor的定义。_syncHelper 用于实现多线程同步之用；Timeout是session timeout的时间，可配置；CurrentSessionList和CurrentCallbackList两个dictionary在上面我们已经作过介绍，分别代表当前活动的session列表和callback列表，key均为SessionID。在静态构造函数中，初始化session timeout的时间，和实例化CurrentSessionList和CurrentCallbackList。

接着我们来看看StartSession和EndSession两个方法，这两个方法分别代表Session的开始和结束。

public static Guid StartSession（SessionClientInfo clientInfo）
{
Guid sessionID = Guid.NewGuid（）;
ISessionCallback callback = OperationContext.Current.GetCallbackChannel<ISessionCallback>（）;
SessionInfo sesionInfo = new SessionInfo（） { SessionID = sessionID, StartTime = DateTime.Now, LastActivityTime = DateTime.Now, ClientInfo = clientInfo };
lock （_syncHelper）
{
CurrentSessionList.Add（sessionID, sesionInfo）;
CurrentCallbackList.Add（sessionID, callback）;
}
return sessionID;
}

public static void EndSession（Guid sessionID）
{
if （！CurrentSessionList.ContainsKey（sessionID））
{
return;
}

lock （_syncHelper）
{
CurrentCallbackList.Remove（sessionID）;
CurrentSessionList.Remove（sessionID）;
}
}