2. 程式人生 > >依賴於session的線上人數統計

依賴於session的線上人數統計

阿新 • • 發佈：2019-01-07

最近工作中遇到一個問題,

在做線上人數統計時.我們實現了HttpSessionListner,HttpSessionAttributeListener裡面的attributedAdded()方法和attributeRemoved()的方法以及sessionDestroyed(),來操作一個map,將登陸的使用者資訊放入到map裡面,使用者退出時,再從map裡面移除.

生產環境是在websphere上,出現了一個現象.很多天之前登入的使用者還在線上人數裡面,並且通過日誌發現,此使用者登入之後並沒有做過任何業務操作.

第一步,重現問題.

開發環境是tomcat部署的,使用了一下四種方式產生的結果:

1.登入之後,點選登出,線上人數得到了更新

2.登入之後不做任何操作,等待session失效,線上人數得到了更新

3.登入之後關閉瀏覽器,等待session失效,線上人數得到了更新

4.登入之後,開啟另一個瀏覽器,當前使用者的線上人數資訊得到了更新

在開發環境無法重現此問題,我們轉戰到生產環境:

1.登入一個使用者,不做任何操作,等待到了session失效時間,線上人數沒有更新---經測試,進入sessionDestroyed()方法.沒有進入attributeRemoveded()方法

2.登入一個使用者,關閉瀏覽器,在人數沒有得到更新,等待session到失效時間--經過測試,沒有進入sessionDestroyed()方法.沒有進入attributeRemoveded

()方法

3.登入一個使用者,點選登出,線上人數得到更新

4.登入一個使用者,開啟另一個瀏覽器再次登入,線上人數使用者資訊沒有得到更新.

5.登入一個使用者,不做任何操作,等待session失效後,此時線上人數沒有得到更新.再次登入此使用者,線上人數沒有更新.點選登出,線上人數得到更新.

第二步,分析問題.

也就是說在websphere上面,只有主動呼叫invalidate(),進入監聽方法,執行操作.

問題來了,當到了到了session失效時間之後,有三種可能性:

1.session並沒有失效;

2.session失效了,但是沒有進入監聽執行sessionDestroyed()方法

3.session失效了,也進入了sessionDestroyed()方法,但是此時已經獲取不到session了,所以無法執行移除操作.

測試發現

1.登入一個使用者,不做任何操作---經測試,進入sessionDestroyed()方法.沒有進入attributeRemoveded()方法.在web.xml設定失效時間為2,但是時間是30min才執行的.

2.登入一個使用者,關閉瀏覽器,等待session到失效時間 ---經過測試,沒有進入sessionDestroyed()方法.沒有進入attributeRemoveded()方法 liuqian15:50關閉瀏覽器在web.xml設定失效時間為2,但是時間是90min才執行的.

When timeout, server executerequest.getRemoteUser() and re-login this user automatically, and sent aNew JESSIONID to user browser by including below header.

Set-Cookie JSESSIONID=0000O0OB4W_4sxtn6elSmolMxI9:-1; Path=/; HttpOnly

3.不知道是那個使用者進入sessionDestroyed()方法和attributeRemoveded()方法.但是sessionuser為空.並沒有執行移除操作.

4.更多的情況是不進入這幾個方法.

綜上所述:session注意的點有如下:

1.覆蓋機制

2.session失效後,呼叫監聽方法的時間不確定性.

3.在was上,session失效時間的不確定性.

最終的解決辦法是再實現一個過濾器,每次客戶端傳送請求是,先將所有session檢查一遍,使用系統當前時間與最後一次操作時間相比,如果差大於session的有效時間.則主動呼叫session的失效方法.這樣就會正常觸發監聽方法.達到人數統計的目的.

貼上程式碼:

package com.sunshine.monitor.comm.filter;

import java.io.IOException;
import java.util.Map;
import java.util.Map.Entry;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.locks.ReentrantLock;

import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import javax.servlet.http.HttpSessionAttributeListener;
import javax.servlet.http.HttpSessionBindingEvent;
import javax.servlet.http.HttpSessionEvent;
import javax.servlet.http.HttpSessionListener;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.sunshine.core.util.DateUtil;
import com.sunshine.monitor.comm.bean.UserSession;
import com.sunshine.monitor.comm.startup.AppSystemListener;
import com.sunshine.monitor.system.manager.bean.SysUser;

public class OnlineUserListener
		implements
			HttpSessionListener, HttpSessionAttributeListener, Filter {
	
	private Logger log = LoggerFactory.getLogger(OnlineUserListener.class);
	
	/**
	 * 使用者Session物件
	 */
	public static final String USER_SESSION_NAME = "userSession";

	/**
	 * 線上人數
	 */
	public static AtomicInteger lineCount = new AtomicInteger(0);
	
	private final ReentrantLock lock = new ReentrantLock();
	
	public final static String LISTENER_NAME = "_login";
	
	private static volatile Map<String, SysUser> users = new ConcurrentHashMap<String, SysUser>();
	private static volatile Map<String, HttpSession> sessions = new ConcurrentHashMap<String, HttpSession>();
	
	/**
	 * 需要人工新增屬性_login,觸發此方法
	 */
	@Override
	public void attributeAdded(HttpSessionBindingEvent hbe) {
		if(LISTENER_NAME.equals(hbe.getName())){
			// 使用者登入成功後,將HttpSession儲存到一個map.
			HttpSession session = hbe.getSession();
			//System.out.println(hbe.getName() + "-HttpSessionAttributeListener(attributeAdded)...........");
			SysUser user = (SysUser) hbe.getValue();
			String yhdh = user.getYhdh();
			final ReentrantLock _lock = this.lock;
			_lock.lock();
			try {
				boolean flag = users.containsKey(yhdh);
				users.put(yhdh, user);
				sessions.put(yhdh, session);
				if(!flag){
					lineCount.addAndGet(1); // 累加器
				}
				System.out.println(yhdh + "-HttpSessionAttributeListener(attributeAdded)..........." + lineCount.intValue());
			} finally {
				_lock.unlock();
			}
		}
		
	}
	
	/**
	 * 需要人工刪除屬性_login,觸發此方法
	 */
	@Override
	public void attributeRemoved(HttpSessionBindingEvent hbe) {
		if(LISTENER_NAME.equals(hbe.getName())){
			System.out.println(hbe.getName() + "-HttpSessionAttributeListener(attributeRemoved)...........");
			SysUser user = (SysUser) hbe.getValue();
			if(user == null)
				return;
			String yhdh = user.getYhdh();
			final ReentrantLock _lock = this.lock;
			_lock.lock();
			try{
				if(users.containsKey(yhdh)){
					users.remove(user.getYhdh());
					sessions.remove(user.getYhdh());
					lineCount.decrementAndGet();
					System.out.println(yhdh + "-HttpSessionAttributeListener(attributeRemoved)..........." + lineCount.intValue());
				}
			} finally {
				_lock.unlock();
			}
		}
	}

	@Override
	public void attributeReplaced(HttpSessionBindingEvent hbe) {
		
	}
	
	/**
	 * 會話建立時執行
	 */
	@Override
	public void sessionCreated(HttpSessionEvent he) {
		/*HttpSession session = he.getSession();
		UserSession userSession = (UserSession)session.getAttribute(USER_SESSION_NAME);
		if(userSession != null){
			final ReentrantLock _lock = this.lock;
			_lock.lock();
			//System.out.println(he.getSource()+ "-HttpSessionListener(sessionCreated)...........");
			SysUser user = userSession.getSysuser();
			if(user == null) return;
			String yhdh =user.getYhdh();
			try{
				boolean flag = users.containsKey(yhdh);
				if(!flag){
					users.put(yhdh, user);
					lineCount.addAndGet(1); // 累加器
//					System.out.println(yhdh+ "-HttpSessionListener(sessionCreated)..........." + lineCount.intValue());
				}
			} finally {
				_lock.unlock();
			}
		}*/
	}
	/**
	 * 會話消毀執行
	 */
	@Override
	public void sessionDestroyed(HttpSessionEvent he) {
		HttpSession session = he.getSession();
		UserSession userSession = (UserSession)session.getAttribute(USER_SESSION_NAME);
		if(userSession != null){
			log.info(he.getSource()+ "-HttpSessionListener(sessionDestroyed)...........");
			SysUser user = userSession.getSysuser();
			String yhdh = user.getYhdh();
			final ReentrantLock _lock = this.lock;
			_lock.lock();
			try{
				if(users.containsKey(yhdh)){
					users.remove(user.getYhdh());
					sessions.remove(user.getYhdh());
					lineCount.decrementAndGet();
					log.info(yhdh+ "-HttpSessionListener(sessionDestroyed)..........." + lineCount.intValue());
				}
			} finally {
				_lock.unlock();
			}
		}
	}

	public static Map<String, SysUser> getUsers() {
		return users;
	}
	
	public static void setUsers(Map<String, SysUser> vaildUsers) {
		users = vaildUsers;
	}
	
	public static Map<String, HttpSession> getSessions() {
		return sessions;
	}
	
	public static void setSessions(Map<String, HttpSession> vaildSessions) {
		sessions = vaildSessions;
	}

	@Override
	public void destroy() {
		
		
	}

	@Override
	public void doFilter(ServletRequest arg0, ServletResponse arg1,
			FilterChain arg2) throws IOException, ServletException {
		//HttpServletRequest request = (HttpServletRequest)arg0;
		//HttpSession session = request.getSession(false);
		for(Entry<String, HttpSession> entry : sessions.entrySet()){
			HttpSession ss = entry.getValue();
			if(ss!=null){
				log.info(ss.getId());
				log.info("系統當前時間:"+DateUtil.longToTime(System.currentTimeMillis()));
				log.info("最後一次操作時間:"+DateUtil.longToTime(ss.getLastAccessedTime()));
				// 系統當前時間-最後操作時間>則強制使session失效.
				if((System.currentTimeMillis() - ss.getLastAccessedTime())>ss.getMaxInactiveInterval()*1000){// session timeout
					log.info("強制使session:"+ss.getId()+"失效...");
					ss.invalidate();
				}
			}else{
				System.out.println("This session is null....");
			}
		}
		arg2.doFilter(arg0, arg1);
	}

	@Override
	public void init(FilterConfig arg0) throws ServletException {
		// TODO Auto-generated method stub
		
	}
}


相關推薦

依賴於session的線上人數統計

最近工作中遇到一個問題, 在做線上人數統計時.我們實現了HttpSessionListner,HttpSessionAttributeListener裡面的attributedAdded()方法和attributeRemoved()的方法以及sessionDestroyed

線上人數統計,解決了關閉瀏覽器視窗，釋放session的問題

在頁面裡頁設定一個退出按鈕．呼叫quit.jsp=它的內容是：h>我們用一個quit.jsp來處理使用者退出系統的操作，quit.jsp負責登出session，及時釋放資源。>D6T©達內科技論壇 -- 達內科技論壇　　uj&B　　·登出session。Z5K&©達內科技論壇 --

Java監聽器實現網站線上人數統計

1.監聽器定義 監聽器也叫Listener，是Servlet的監聽器，它可以監聽客戶端的請求、服務端的操作等。通過監聽器，可以自動激發一些操作，比如監聽線上的使用者的數量。 2.常見的監聽器 1)ServletContextAttribut

HttpSessionListener實現網站線上人數統計

        過去的一般做法是結合登入和退出功能，即當用戶輸入使用者名稱密碼進行登入的時候計數器加1，然後當用戶點選退出按鈕退出系統的時候計數器減1。這種處理方式存在一些缺點，例如：使用者正常登入後，可能會忘記點選退出按鈕，而直接關閉瀏覽器，導致計數器減1的操作沒有及時執行；網站上還經常有一些內容是不需要登

javaweb中實現線上人數統計

session並不是瀏覽器關閉時銷燬的，而是在session失效的時候銷燬下列程式碼就是監測session建立、銷燬 package com.my.count; import javax.serv

線上人數統計和總訪問量統計

1.新建網站，新增幾個窗體。webForm1.aspx ,ViewStateForm.aspx 2.在網站的根目錄下新增全域性應用程式類“Global.aspx” 。（重要） 3.在“Global.aspx” 有固有的格式和會話資訊結構。 4.在“Global.aspx”中

spring boot + webSocket 實現簡單會話與線上人數統計的demo

webSocket推送是常用於生產專案的模組，在我們部門做的一個彙報演示的demo中遇到了webSocket的一些問題。 自己下來看看了看webSocket的東西，結合spring boot 做了一個簡單的demo; 介紹的部分大家可以參考眾多的帖子，度娘 http://w

利用redis和springsession實現線上人數統計

1.springSession相比以前的session機制，好處在於可以實現session共享。 2.通過攔截器（filter要寫在其他攔截器的前面）和裝飾者模式替換原有session機制，不需要改程式碼 3.配置： web.xml applicationcontext.

asp.net 實現線上人數統計

在解決方案資源管理器中新增新項,Global.asax,其中程式碼如下: <%@ Application Language="C#" %> <script runat="server"> void Application_Start(o

web開發之線上人數統計

需求： 統計當前線上人數（當前訪問網站的使用者） 思路： 第一步，把訪客的資訊存入到資料庫，每次訪問或者重新整理頁面的時候，都更新該訪客在資料庫中的記錄，也就是更新該訪客的最後活動時間。 第二步，刪

SpringMVC的線上人數統計監聽器

package com.shenofusc.utils; import java.util.ArrayList; import java.util.HashSet; import javax.servlet.ServletContext; import javax.servlet.annotation.Web

PHP+memcache實現的網站線上人數統計程式碼

今天閒來無事，想在部落格統計中顯示線上人數。在網上找了好多例子，不是資料庫儲存資料就是檔案儲存，程式碼也看起來過於複雜。晚上回來後，構思了下，看到我伺服器中安裝有 Memcache 服務，何不用 Memcache 實現呢。下面就來講下實現過程：效果圖：實現程式碼：?12345

REDIS實踐之線上人數統計幾種方案分析

線上人數統計業務是我們開發web肯定要設計的業務邏輯，本文就會給出幾種設計方案，來分析下各個方案的優缺點： 使用有序集合這種方案能夠同時儲存線上的使用者 和 使用者上線時間，能夠執行非常多的聚合計算，但是所消耗的記憶體也是非常可觀的。 使用集合這種方案能儲存線上的使用者，

ASP.NET中利用Application和Session統計線上人數、歷史訪問量

          先來簡單說一下ASP.NET中的Application和Session           下圖是我們非常熟悉的Web應用程式的結構：                    在這張圖中，Web伺服器中執行的Web應用程式就是我們所說的Applicati

session監聽器(可用於統計線上人數，當前客戶)

在系統執行中，有時候我們想了解下當前使用系統的使用者，有多少人在使用系統？具體是哪些人在使用系統？ 這時候，就可以通過session監聽器(javax.servlet.http.HttpSessionAttributeListener 介面)的功能來實現。當

web專案設定session監聽器，統計同時線上人數

session中有一個功能是監聽器，在session被建立或者銷燬的時候可以觸發後臺的程式碼，也可以用和這個來統計同時線上的使用者人數 首先需要時web專案 監聽類，實現介面HttpSessio

巧用session機制實現使用者不重複登入、記錄使用者登入日誌、統計線上人數

HttpSessionBindingListener 這個具體的使用文件自查，本篇中是新建了一個類實現本介面 public class UsersOnlineCountListener implements HttpSessionBindingListe

Session監聽統計網站的線上人數HashSet

import java.util.ArrayList; import java.util.HashSet; import java.util.List; import javax.servlet.S

使用HttpSessionListener介面監聽Session的建立和失效（可以用於統計線上人數）

轉自：http://uule.iteye.com/blog/824115 HttpSessionListener :    Session建立事件發生在每次一個新的session建立的時候，類似地Session失效事件發生在每次一個Session失效的時

關於Java統計網頁線上人數

利用HttpSessionBindingListener介面Java語言，編寫一個線上人數統計的程式。當一個使用者登入後，顯示歡迎資訊，同時顯示出當前線上的總人數和使用者名稱單。當一個使用者退出登入或者Session超時值發生時，從線上使用者名稱單中刪除這個使用