Asp.net源码交流论坛 Asp.net交流讨论区Asp.net技术文章ASP.NET在线用户列表精确版—解决用户意外退出在线列表无法及时更新问题

Asp.net网站配置基础视频出炉了源码使用常见问题源码发布请点这里 
1  /  1  页    1  跳转页
发表新主题 回复该主题

标题: ASP.NET在线用户列表精确版—解决用户意外退出在线列表无法及时更新问题

本主题由 董事长 51aspx 于 2008-2-27 13:47:44 执行 移动主题 操作

身份：董事长

 
  • UID:2
  • 来自:北京
  • 精华:27
  • 积分:1696
  • 帖子:1507
  • 注册: 2007-05-17
  • 状态: 离线
  • 威望:54.00
  • 金钱:268.95 元
 
源码发布专家

ASP.NET在线用户列表精确版—解决用户意外退出在线列表无法及时更新问题

最近所做的一个项目需要用到的在线用户列表，上网搜索了一下发现现有的解决方案对用户意外退出的处理均不是太理想。一般来说，用户离开系统的方式有三种：主动注销、会话超时、直接关闭浏览器，对于前两种，我们很容易便可将该用户从在线列表中清除，关键是第三种（很多用户都是直接关闭窗口的~~郁闷ing），程序无法捕获窗口关闭的精确时间，只能等到会话超时后在能将该用户清除出在线列表，假设我们设置会话超时时间为60分钟，而用户登陆系统随便浏览一个页面就以关闭浏览器的方式退出的话，我们要在将近1小时后才能从在线列表中将该用户清除出去（想象一下，系统显示n多人在线，可能除了你之外其他的n-1人都关机走人了，汗一个先```），而本文将尝试寻找一个解决方案把这种尴尬降至最低。
    我的大概思路是，给每在线用户增加一个RefreshTime属性，建立一个负责将当前用户的RefreshTime属性设置为当前时间的单独页面（Refresh.aspx），然后在系统的主要页面（也可以是所有页面）中通过xmlhttp不断地请求Refresh.aspx页面，一旦用户关闭了与本系统相关的所有窗口，即以直接关闭浏览器的方式退出系统，那么该用户的RefreshTime属性便不会自动更新了，我们再设置一个自动刷新的超时时间（这个要比会话超时短很多_refreshTimeout），当发现某用户超过_refreshTimeout的时间没有自动刷新，就能判定该用户已经以直接关闭浏览器的方式退出了。
    假设我们设置会话超时时间为60分钟，自动刷新超时时间为1分钟，在客户端通过xmlhttp每隔25秒（之所以不设1分钟，是防止网速慢的时候访问Refresh.aspx超时，个人感觉，不一定正确）访问一次Refresh.aspx页面，在用户登陆、用户注销、检测用户是否在线的时候都执行清理超时用户（包括会话超时和自动刷新超时）操作，这样一来，在线用户列表的统计误差就由60分钟降至1分钟了。
==========================================

具体实现如下：

1、 新建一个名为ActiveUser的类，存储单个活动用户数据。

[运行代码] [复制到剪贴板] [ ± ]
CODE:

/// <summary>
/// 单个在线用户数据，无法继承此类。
/// </summary>
public sealed class ActiveUser
{ 
  private readonly string _ticket;    //票据名称
  private readonly string _username;  //登陆用户名
  private readonly string _truename;  //登陆用户名
  private readonly string _roleid;    //角色
  private readonly DateTime _refreshtime;  //最新刷新时间
  private readonly DateTime _activetime;  //最新活动时间
  private readonly string _clientip;  //登陆IP
 
  public ActiveUser(string Ticket,string UserName,string TrueName,string RoleID,string ClientIP) {
  this._ticket=Ticket;
  this._username=UserName;
  this._truename=TrueName;
  this._roleid=RoleID;
  this._refreshtime=DateTime.Now;
  this._activetime=DateTime.Now;
  this._clientip=ClientIP;
  }
  public ActiveUser(string Ticket,string UserName,string TrueName,string RoleID,DateTime RefreshTime,DateTime ActiveTime,string ClientIP)  {
  this._ticket=Ticket;
  this._username=UserName;
  this._truename=TrueName;
  this._roleid=RoleID;
  this._refreshtime=RefreshTime;
  this._activetime=ActiveTime;
  this._clientip=ClientIP;
  }
 
  public string Ticket  { get{return _ticket;}  }
  public string UserName  { get{return _username;}  }
  public string TrueName  { get{return _truename;}  }
  public string RoleID  { get{return _roleid;}  }
  public DateTime RefreshTime { get{return _refreshtime;} }
  public DateTime ActiveTime { get{return _activetime;} }
  public string ClientIP  { get{return _clientip;}  }//51aspx.com
}


2、 新建一个名为PassPort的类，存储在线用户列表。

[运行代码] [复制到剪贴板] [ ± ]
CODE:

/// <summary>
/// PassPort 存储在线用户列表。
/// </summary>
public class PassPort
{
  private  static  DataTable  _activeusers;
  private  int  _activeTimeout;
  private  int  _refreshTimeout;
  /// <summary>
  /// 初始化在线用户表。
  /// </summary>
  private void userstableFormat()
  {
  if(_activeusers==null) {
    _activeusers  =  new  DataTable("ActiveUsers");
    DataColumn  myDataColumn;
    System.Type mystringtype;
    mystringtype = System.Type.GetType("System.String");
    System.Type mytimetype;
    mytimetype = System.Type.GetType("System.DateTime");
    myDataColumn  =  new  DataColumn("Ticket",mystringtype);
    _activeusers.Columns.Add(myDataColumn);
    myDataColumn  =  new  DataColumn("UserName",mystringtype);
    _activeusers.Columns.Add(myDataColumn);
    myDataColumn  =  new  DataColumn("TrueName",mystringtype);
    _activeusers.Columns.Add(myDataColumn);
    myDataColumn  =  new  DataColumn("RoleID",mystringtype);
    _activeusers.Columns.Add(myDataColumn);   
    myDataColumn  =  new  DataColumn("RefreshTime",mytimetype);
    _activeusers.Columns.Add(myDataColumn);
    myDataColumn  =  new  DataColumn("ActiveTime",mytimetype);
    _activeusers.Columns.Add(myDataColumn);
    myDataColumn  =  new  DataColumn("ClientIP",mystringtype);
    _activeusers.Columns.Add(myDataColumn); 
  }
  }
  public PassPort()
  {
  userstableFormat(); //初始化在线用户表
  //活动超时时间初始化 单位：分钟
  try { _activeTimeout=int.Parse(ConfigurationSettings.AppSettings["ActiveTimeout"]); }
  catch{ _activeTimeout=60; } 
  //自动刷新超时时间初始化 单位：分钟
  try { _refreshTimeout=int.Parse(ConfigurationSettings.AppSettings["RefreshTimeout"]); }
  catch{ _refreshTimeout=1; } 
  }
  //全部用户列表
  public  DataTable  ActiveUsers
  {
  get{return  _activeusers.Copy();}
  }
 
  /// <summary>
  /// 新用户登陆。
  /// </summary>
  public void Login(ActiveUser user,bool SingleLogin)
  {
  DelTimeOut();  //清除超时用户
  if(SingleLogin){
    //若是单人登陆则注销原来登陆的用户
    this.Logout(user.UserName,false);
  }
  DataRow myRow;
  try
  {
    myRow  =  _activeusers.NewRow();   
    myRow["Ticket"]  =  user.Ticket.Trim();
    myRow["UserName"]  =  user.UserName.Trim();
    myRow["TrueName"]  =  ""+user.TrueName.Trim();
    myRow["RoleID"]  =  ""+user.RoleID.Trim();
    myRow["ActiveTime"]  =  DateTime.Now;
    myRow["RefreshTime"]  =  DateTime.Now;
    myRow["ClientIP"]  =  user.ClientIP.Trim();
    _activeusers.Rows.Add(myRow);
  }
  catch(Exception  e)
  {
    throw(new  Exception(e.Message));
  } 
  _activeusers.AcceptChanges();
 
  }
  /// <summary>
  ///用户注销，根据Ticket或UserName。
  /// </summary>
  private void Logout(string strUserKey,bool byTicket)
  {
  DelTimeOut();  //清除超时用户
  strUserKey=strUserKey.Trim();
  string  strExpr; 
  strExpr =byTicket ? "Ticket=''" + strUserKey +"''" : "UserName=''" + strUserKey + "''";
  DataRow[]  curUser;
  curUser  =  _activeusers.Select(strExpr);
  if  (curUser.Length  >0  )
  {
    for(int  i  =  0;  i  <  curUser.Length;  i  ++)
    {
    curUser[i].Delete();
    }
  }
  _activeusers.AcceptChanges(); 
  }
  /// <summary>
  ///用户注销，根据Ticket。
  /// </summary>
  /// <param name="strTicket">要注销的用户Ticket</param>
  public void Logout(string strTicket){
  this.Logout(strTicket,true);
  }
  /// <summary>
  ///清除超时用户。
  /// </summary>
  private  bool DelTimeOut()
  { 
  string  strExpr; 
  strExpr = "ActiveTime < ''" + DateTime.Now.AddMinutes( 0 - _activeTimeout) + "''or RefreshTime < ''"+DateTime.Now.AddMinutes( 0 - _refreshTimeout)+"''"; 
  DataRow[]  curUser;
  curUser  =  _activeusers.Select(strExpr);
  if  (curUser.Length  >0  )
  {
    for(int  i  =  0;  i  <  curUser.Length;  i  ++)
    {
    curUser[i].Delete();   
    }
  }
  _activeusers.AcceptChanges();
  return  true;
  }
  /// <summary>
  ///更新用户活动时间。
  /// </summary>
  public  void  ActiveTime(string  strTicket)
  {
  DelTimeOut();
  string  strExpr;
  strExpr  =  "Ticket=''"  +  strTicket  +  "''"; 
  DataRow[]  curUser;
  curUser  =  _activeusers.Select(strExpr);
  if  (curUser.Length  >0  )
  {
    for(int  i  =  0;  i  <  curUser.Length;  i  ++)
    {
    curUser[i]["ActiveTime"]=DateTime.Now;
    curUser[i]["RefreshTime"]=DateTime.Now;
    }
  }
  _activeusers.AcceptChanges();
  }
  /// <summary>
  ///更新系统自动刷新时间。
  /// </summary>
  public  void  RefreshTime(string  strTicket)
  {
  DelTimeOut();
  string  strExpr;
  strExpr  =  "Ticket=''"  +  strTicket  +  "''"; 
  DataRow[]  curUser;
  curUser  =  _activeusers.Select(strExpr);
  if  (curUser.Length  >0  )
  {
    for(int  i  =  0;  i  <  curUser.Length;  i  ++)
    {
    curUser[i]["RefreshTime"]=DateTime.Now;
    }
  }
  _activeusers.AcceptChanges();
  }
  private ActiveUser SingleUser(string strUserKey,bool byTicket)
  {
  strUserKey=strUserKey.Trim();
  string  strExpr;
  ActiveUser myuser;
  strExpr =byTicket ? "Ticket=''" + strUserKey +"''" : "UserName=''" + strUserKey + "''";
  DataRow[]  curUser;
  curUser  =  _activeusers.Select(strExpr);
  if  (curUser.Length  >0  )
{
    string myTicket=(string)curUser[0]["Ticket"];
    string myUser=(string)curUser[0]["UserName"];
    string myName=(string)curUser[0]["TrueName"];
    string myRoleID=(string)curUser[0]["RoleID"];   
    DateTime myActiveTime=(DateTime)curUser[0]["ActiveTime"];
    DateTime myRefreshtime=(DateTime)curUser[0]["RefreshTime"];
    string myClientIP =(string)curUser[0]["ClientIP"];
    myuser=new ActiveUser(myTicket,myUser,myName,myRoleID,myActiveTime,myRefreshtime,myClientIP); 
  }
  else
  {
    myuser=new ActiveUser("","","","","");   
  }
  return  myuser;
  }
  /// <summary>
  ///按Ticket获取活动用户。
  /// </summary>
  public ActiveUser SingleUser_byTicket(string strTicket)
  {
  return this.SingleUser(strTicket,true);
  }
  /// <summary>
  ///按UserName获取活动用户。
  /// </summary>
  public ActiveUser SingleUser_byUserName(string strUserName)
  {
  return this.SingleUser(strUserName,false);
  }
  /// <summary>
  ///按Ticket判断用户是否在线。
  /// </summary>
  public bool IsOnline_byTicket(string strTicket)
  {
  return (bool)(this.SingleUser(strTicket,true).UserName!="");
  }
  /// <summary>
  ///按UserName判断用户是否在线。
  /// </summary>
  public bool IsOnline_byUserName(string strUserName)
  {
  return (bool)(this.SingleUser(strUserName,false).UserName!="");
  }
}


3、 新建一个继承自PlaceHolder名为Refresh的类，执行更新自动刷新时间操作。

[运行代码] [复制到剪贴板] [ ± ]
CODE:

/// <summary>
/// Refresh 执行更新自动刷新时间操作。
/// </summary>
public class Refresh: PlaceHolder
{
  /// <summary>
  /// 设置存储Ticket的Session名称，默认为Ticket。
  /// </summary>
  public virtual string SessionName
  {
  get{
    object obj1 = this.ViewState["SessionName"];
    if (obj1 != null){ return ((string) obj1).Trim(); }
    return "Ticket";
  }
  set{
    this.ViewState["SessionName"] = value;
  }
  }
  protected override void Render(HtmlTextWriter writer)
  {
  string myTicket=(string)this.Page.Session[this.SessionName];
  if(myTicket!=null)
  { 
    PassPort myPass = new PassPort();
    myPass.RefreshTime(myTicket);
    writer.Write("OK："+DateTime.Now.ToString());
  }
  else{
    writer.Write("Sorry："+DateTime.Now.ToString());
  }
  base.Render(writer);
}
}


4、 新建一个继承自PlaceHolder名为Script的类，生成执行xmlhttp的js脚本。。

[运行代码] [复制到剪贴板] [ ± ]
CODE:

/// <summary>
/// Script 生成执行xmlhttp的js脚本。
/// </summary>
public class Script: PlaceHolder
{
  /// <summary>
  /// 设置js自动刷新的间隔时间，默认为25秒。
  /// </summary>
  public virtual int RefreshTime
  {
  get
  {
    object obj1 = this.ViewState["RefreshTime"];
    if (obj1 != null){return int.Parse(((string) obj1).Trim());}
    return 25;
  }
  set
  {   
    this.ViewState["RefreshTime"] = value;
  }
  }
  protected override void Render(HtmlTextWriter writer)
  {
  //从web.config中读取xmlhttp的访问地址
  string refreshUrl=(string)ConfigurationSettings.AppSettings["refreshUrl"];
  string scriptString = @" <script language=""JavaScript"">"+writer.NewLine;
  scriptString += @"  window.attachEvent(""onload"", "+this.ClientID+@"_postRefresh);"+writer.NewLine;
  scriptString += @"  var "+this.ClientID+@"_xmlhttp=null;"+writer.NewLine;
  scriptString += @"  function "+this.ClientID+@"_postRefresh(){"+writer.NewLine;
  scriptString += @"  var "+this.ClientID+@"_xmlhttp = new ActiveXObject(""Msxml2.XMLHTTP"");"+writer.NewLine;
  scriptString += @"  "+this.ClientID+@"_xmlhttp.Open(""POST"", """+refreshUrl+@""", false);"+writer.NewLine;
  scriptString += @"  "+this.ClientID+@"_xmlhttp.Send();"+writer.NewLine;
  scriptString += @"  var refreshStr= "+this.ClientID+@"_xmlhttp.responseText;"+writer.NewLine;
   
  scriptString += @"  try {"+writer.NewLine;
  scriptString += @"    var refreshStr2=refreshStr;"+writer.NewLine;
  //scriptString += @"    alert(refreshStr2);"+writer.NewLine;
  scriptString += @"  }"+writer.NewLine;
  scriptString += @"  catch(e) {}"+writer.NewLine;
  scriptString += @"  setTimeout("""+this.ClientID+@"_postRefresh()"","+this.RefreshTime.ToString()+@"000);"+writer.NewLine;
  scriptString += @"  }"+writer.NewLine;
  scriptString += @"<";
  scriptString += @"/";
  scriptString += @"script>"+writer.NewLine;
  writer.Write(writer.NewLine);
  writer.Write(scriptString);
  writer.Write(writer.NewLine);
  base.Render(writer);
  }
}


注意以上四个类同属于一个名为OnlineUser的工程，他们的命名空间为OnlineUser，编译生成一个dll。

===============================================

下面我简单介绍一下调用方法：
1、 新建一个名为OnlineUserDemo的asp.net web应用程序
2、 在vs的工具箱选项卡上右击，选择[添加/移除项]，浏览定位到OnlineUser.dll，确定即可把Refresh 和Script添加到工具箱。
3、 把自动生成的WebForm1.aspx删除，并设置web.config

[运行代码] [复制到剪贴板] [ ± ]
CODE:
<appSettings>
  <add key="ActiveTimeout" value="30" />
  <add key="RefreshTimeout" value="1" />
  <add key="refreshUrl" value="refresh.aspx" />
</appSettings>


4、 添加一个名为Online.aspx的web窗体，给该窗体添加一个Script控件，一个DataGrid控件（id为DataGrid1），两个HyperLink控件（分别链接到login.aspx和logout.aspx，text属性分别设置为“登陆”和“注销”），调整好四个控件的位置，转到codebehind，在Page_Load中加入如下代码：

[运行代码] [复制到剪贴板] [ ± ]
CODE:
string myTicket=(string)this.Page.Session["Ticket"];
  if(myTicket!=null)
  {
    OnlineUser.PassPort myPassPort= new OnlineUser.PassPort();
    if(myPassPort.IsOnline_byTicket(this.Session["Ticket"].ToString()))
    {
    myPassPort.ActiveTime(this.Session["Ticket"].ToString());
    DataGrid1.DataSource=myPassPort.ActiveUsers;
    DataGrid1.DataBind();
    }
    else{
    //若在线用户列表中找不到当前用户,则定向到注销页面
    Response.Redirect("Logout.aspx");
    }
  }
  else{
    Response.Redirect("Login.aspx");
  }


5、 添加一个名为login.aspx的web窗体，给该窗体添加一个label控件（id为Label1），设置text属性为“输入一个用户名”，再添加一个textbox控件（id为TextBox1）和一个button控件（id为Button1），调整好他们的位置，双击Button1控件转到codebehind，为Button1的Click事件加入如下代码：

[运行代码] [复制到剪贴板] [ ± ]
CODE:
if(TextBox1.Text.Trim()=="")
  {
    //不能为空
    String scriptString = @"<script language=JavaScript>";
    scriptString += @"alert(""输入一个用户名\n"");";
    scriptString += @"history.go(-1);";
    scriptString += @"<";
    scriptString += @"/";
    scriptString += @"script>";
    if(!this.Page.IsStartupScriptRegistered("Startup"))
    this.Page.RegisterStartupScript("Startup", scriptString);
  }
  else{
    OnlineUser.PassPort myPassPort= new OnlineUser.PassPort();
    string myTicket=DateTime.Now.ToString("yyyyMMddHHmmss");
    string myUser=TextBox1.Text.Trim();
    string myClintIP=this.Request.UserHostAddress;
    this.Session["Ticket"]=myTicket;
    OnlineUser.ActiveUser myActiveUser=new OnlineUser.ActiveUser(myTicket,myUser,myUser,"test",myClintIP);
    myPassPort.Login(myActiveUser,true);
    Response.Redirect("Online.aspx");
  }


6、 添加一个名为logout.aspx的web窗体，给该窗体添加一个HyperLink控件，指向login.aspx，text属性设置为“重登陆”转到codebehind，在Page_Load中加入如下代码：

[运行代码] [复制到剪贴板] [ ± ]
CODE:
OnlineUser.PassPort myPassPort= new OnlineUser.PassPort();
  myPassPort.Logout(this.Session["Ticket"].ToString());
this.Session["Ticket"]="";


7、 添加一个名为Refresh.txt的文本文件，设置其内容为：

[运行代码] [复制到剪贴板] [ ± ]
CODE:
<%@ Register TagPrefix="cc2" Namespace="OnlineUser" Assembly="OnlineUser" %>
<%@ Page %>
<cc2:Refresh id="myRefresh" runat="server"></cc2:Refresh>
把Refresh.txt改名为Refresh.aspx


8、 编译生成工程。
===============================================

下面进行功能测试：
1、 打开浏览器，在地址栏输入
http://你机器的IP地址/onlineuserdemo/Login.aspx
2、 输入一个用户名（假设是test1）登陆，自动转到online.aspx页面
3、 找同网段的另外一台机器（设你的机器为a，这台机器为b），重复执行第一步。
4、 输入一个用户名（假设是test2）登陆，自动转到online.aspx页面51aspx
5、 在b机器不断刷新online.aspx，若发现test1用户RefreshTime每过25秒自动更新一次而ActiveTime不变（这个时候a机器不要刷新页面啊），则证明a机器的自动刷新生效。
6、 在a机器不断刷新online.aspx，若发现test2用户RefreshTime每过25秒自动更新一次而ActiveTime不变（这个时候b机器不要刷新页面啊），则证明b机器的自动刷新生效。
7、 直接关闭一台机器（假设是a）上的online.aspx浏览窗口，在另一台机器（就是b啦）上刷新online.aspx，若发现1分钟后test1掉线在线用户只剩下test2，证明通过_refreshTimeout清除在线用户成功。
8、 若5、6、7三步正常，则大功告成，否则就再调试调试~~
 
技术问题请直接发布到论坛，合作及咨询请加技术支持QQ：793095132
问题搜索请点击！
引用 回复
 

身份：工程师

 
  • UID:2224
  • 来自:天津
  • 精华:0
  • 积分:148
  • 帖子:143
  • 注册: 2007-12-10
  • 状态: 离线
  • 威望:5.00
  • 金钱:15.05 元

回复：ASP.NET在线用户列表精确版—解决用户意外退出在线列表无法及时更新问题

这个东西原理上我基本理解了,可是这个过程,已经调试了2个小时,貌似我还没完全成功,看来基础还是比较差肯定是哪遗漏了什么东西.

这是个非常好的缓解服务器资源,提高在线人数统计的准确的一种东西,很值得推广呢.
soulsword 最后编辑于 2008-02-27 15:08:37
引用 回复
 

身份：学员

 
  • UID:1059
  • 来自:
  • 精华:0
  • 积分:23
  • 帖子:23
  • 注册: 2007-09-06
  • 状态: 离线
  • 威望:0.00
  • 金钱:2.45 元

回复：ASP.NET在线用户列表精确版—解决用户意外退出在线列表无法及时更新问题

在javascript 中有个方法 可以 判断 浏览器 是否关闭  在 用户 关闭 浏览器的 同时 想 服务器 发送一个 信息 告诉 服务器 该浏览器 已经 关闭
引用 回复
 

身份：学员

 
  • UID:6874
  • 来自:
  • 精华:0
  • 积分:24
  • 帖子:25
  • 注册: 2008-02-15
  • 状态: 离线
  • 威望:0.00
  • 金钱:3.55 元

回复：ASP.NET在线用户列表精确版—解决用户意外退出在线列表无法及时更新问题

我用的是asp.net2005
为什么 script 和 refresh 放入 页面 提示 无法创建控件 因为 visual studio 无法在控件程序集中找到该控件的类型
引用 回复
 

身份：学员

 
  • UID:29526
  • 来自:
  • 精华:0
  • 积分:3
  • 帖子:3
  • 注册: 2008-08-30
  • 状态: 离线
  • 威望:0.00
  • 金钱:0.60 元

回复：ASP.NET在线用户列表精确版—解决用户意外退出在线列表无法及时更新问题

语法错误:“2008”运算符后缺少操作数。
说明: 执行当前 Web 请求期间，出现未处理的异常。请检查堆栈跟踪信息，以了解有关该错误以及代码中导致错误的出处的详细信息。

异常详细信息: System.Data.SyntaxErrorException: 语法错误:“2008”运算符后缺少操作数。

源错误:


行 150:            strExpr = "ActiveTime < ''" + DateTime.Now.AddMinutes(0 - _activeTimeout) + "''or RefreshTime < ''" + DateTime.Now.AddMinutes(0 - _refreshTimeout) + "''";
行 151:            DataRow[] curUser;
行 152:            curUser = _activeusers.Select(strExpr);
行 153:            if (curUser.Length > 0)
行 154:            {


源文件: C:\Documents and Settings\Administrator\My Documents\Visual Studio 2008\Projects\userOnline\online\PassPort.cs    行: 152


第152行出现这样的错误
引用 回复
 
1  /  1  页    1  跳转页
发表新主题 回复该主题

现在时间是:2009-01-08 07:10:33 京ICP备06046876号