資訊專欄INFORMATION COLUMN
摘要：現(xiàn)在，我們想要統(tǒng)計的是網(wǎng)站的在線人數(shù)。隔一段時間去做某事，這肯定是定時器的任務(wù)呀。定時器應(yīng)該在服務(wù)器一啟動的時候，就應(yīng)該被創(chuàng)建了。定時器掃描容器的時候，可能是獲取不到所有的的。
從第一篇已經(jīng)講解過了監(jiān)聽器的基本概念，以及Servlet各種的監(jiān)聽器。這篇博文主要講解的是監(jiān)聽器的應(yīng)用。
統(tǒng)計網(wǎng)站在線人數(shù) 分析我們在網(wǎng)站中一般使用Session來標(biāo)識某用戶是否登陸了，如果登陸了，就在Session域中保存相對應(yīng)的屬性。如果沒有登陸，那么Session的屬性就應(yīng)該為空。
現(xiàn)在，我們想要統(tǒng)計的是網(wǎng)站的在線人數(shù)。我們應(yīng)該這樣做：我們監(jiān)聽是否有新的Session創(chuàng)建了，如果新創(chuàng)建了Sesssion，那么在線人數(shù)就應(yīng)該+1。這個在線人數(shù)是整個站點(diǎn)的，所以應(yīng)該有Context對象保存。
大致思路：
監(jiān)聽Session是否被創(chuàng)建了
如果Session被創(chuàng)建了，那么在Context的域?qū)ο蟮闹稻蛻?yīng)該+1
如果Session從內(nèi)存中移除了，那么在Context的域?qū)ο蟮闹稻蛻?yīng)該-1.
代碼監(jiān)聽器代碼：
public class CountOnline implements HttpSessionListener {
public void sessionCreated(HttpSessionEvent se) {
//獲取得到Context對象，使用Context域?qū)ο蟊４嬗脩粼诰€的個數(shù)
ServletContext context = se.getSession().getServletContext();
//直接判斷Context對象是否存在這個域，如果存在就人數(shù)+1,如果不存在，那么就將屬性設(shè)置到Context域中
Integer num = (Integer) context.getAttribute("num");
if (num == null) {
context.setAttribute("num", 1);
} else {
num++;
context.setAttribute("num", num);
}
}
public void sessionDestroyed(HttpSessionEvent se) {
ServletContext context = se.getSession().getServletContext();
Integer num = (Integer) se.getSession().getAttribute("num");
if (num == null) {
context.setAttribute("num", 1);
} else {
num--;
context.setAttribute("num", num);
}
}
}
顯示頁面代碼：
在線人數(shù)：${num}
測試
我們每使用一個瀏覽器訪問服務(wù)器，都會新創(chuàng)建一個Session。那么網(wǎng)站的在線人數(shù)就會+1。
使用同一個頁面刷新，還是使用的是那個Sesssion，所以網(wǎng)站的在線人數(shù)是不會變的。
自定義Session掃描器我們都知道Session是保存在內(nèi)存中的，如果Session過多，服務(wù)器的壓力就會非常大。
但是呢，Session的默認(rèn)失效時間是30分鐘(30分鐘沒人用才會失效)，這造成Seesion可能會過多（沒人用也存在內(nèi)存中，這不是明顯浪費(fèi)嗎？）
當(dāng)然啦，我們可以在web.xml文件中配置Session的生命周期。但是呢，這是由服務(wù)器來做的，我嫌它的時間不夠準(zhǔn)確。（有時候我配置了3分鐘，它用4分鐘才幫我移除掉Session）
所以，我決定自己用程序手工移除那些長時間沒人用的Session。
分析要想移除長時間沒人用的Session，肯定要先拿到全部的Session啦。所以我們使用一個容器來裝載站點(diǎn)所有的Session。。
只要Sesssion一創(chuàng)建了，就把Session添加到容器里邊。毫無疑問的，我們需要監(jiān)聽Session了。
接著，我們要做的就是隔一段時間就去掃描一下全部Session，如果有Session長時間沒使用了，我們就把它從內(nèi)存中移除。隔一段時間去做某事，這肯定是定時器的任務(wù)呀。
定時器應(yīng)該在服務(wù)器一啟動的時候，就應(yīng)該被創(chuàng)建了。因此還需要監(jiān)聽Context
最后，我們還要考慮到并發(fā)的問題，如果有人同時訪問站點(diǎn)，那么監(jiān)聽Session創(chuàng)建的方法就會被并發(fā)訪問了。定時器掃描容器的時候，可能是獲取不到所有的Session的。
這需要我們做同步
于是乎，我們已經(jīng)有大致的思路了
監(jiān)聽Session和Context的創(chuàng)建
使用一個容器來裝載Session
定時去掃描Session，如果它長時間沒有使用到了，就把該Session從內(nèi)存中移除。
并發(fā)訪問的問題
代碼監(jiān)聽器代碼：
public class Listener1 implements ServletContextListener,
HttpSessionListener {
//服務(wù)器一啟動，就應(yīng)該創(chuàng)建容器。我們使用的是LinkList(涉及到增刪)。容器也應(yīng)該是線程安全的。
List list = Collections.synchronizedList(new LinkedList());
//定義一把鎖（Session添加到容器和掃描容器這兩個操作應(yīng)該同步起來）
private Object lock = 1;
public void contextInitialized(ServletContextEvent sce) {
Timer timer = new Timer();
//執(zhí)行我想要的任務(wù)，0秒延時，每10秒執(zhí)行一次
timer.schedule(new MyTask(list, lock), 0, 10 * 1000);
}
public void sessionCreated(HttpSessionEvent se) {
//只要Session一創(chuàng)建了，就應(yīng)該添加到容器中
synchronized (lock) {
list.add(se.getSession());
}
System.out.println("Session被創(chuàng)建啦");
}
public void sessionDestroyed(HttpSessionEvent se) {
System.out.println("Session被銷毀啦。");
}
public void contextDestroyed(ServletContextEvent sce) {
}
}
任務(wù)代碼：
/*
* 在任務(wù)中應(yīng)該掃描容器，容器在監(jiān)聽器上，只能傳遞進(jìn)來了。
*
* 要想得到在監(jiān)聽器上的鎖，也只能是傳遞進(jìn)來
*
* */
class MyTask extends TimerTask {
private List sessions;
private Object lock;
public MyTask(List sessions, Object lock) {
this.sessions = sessions;
this.lock = lock;
}
@Override
public void run() {
synchronized (lock) {
//遍歷容器
for (HttpSession session : sessions) {
//只要15秒沒人使用，我就移除它啦
if (System.currentTimeMillis() - session.getLastAccessedTime() > (1000 * 15)) {
session.invalidate();
sessions.remove(session);
}
}
}
}
}
測試：
15秒如果Session沒有活躍，那么就被刪除！
使用集合來裝載我們所有的Session
使用定時器來掃描session的聲明周期【由于定時器沒有session，我們傳進(jìn)去就好了】
關(guān)于并發(fā)訪問的問題，我們在掃描和檢測session添加的時候，同步起來就好了【當(dāng)然，定時器的鎖也是要外面?zhèn)鬟f進(jìn)來的】
踢人小案列列出所有的在線用戶，后臺管理者擁有踢人的權(quán)利，點(diǎn)擊踢人的超鏈接，該用戶就被注銷了。
分析首先，怎么能列出所有的在線用戶呢？？一般我們在線用戶都是用Session來標(biāo)記的，所有的在線用戶就應(yīng)該用一個容器來裝載所有的Session。。
我們監(jiān)聽Session的是否有屬性添加(監(jiān)聽Session的屬性有添加、修改、刪除三個方法。如果監(jiān)聽到Session添加了，那么這個肯定是個在線用戶！)。
裝載Session的容器應(yīng)該是在Context里邊的【屬于全站點(diǎn)】，并且容器應(yīng)該使用Map集合【待會還要通過用戶的名字來把用戶踢了】
思路：
寫監(jiān)聽器，監(jiān)聽是否有屬性添加在Session里邊了。
寫簡單的登陸頁面。
列出所有的在線用戶
實現(xiàn)踢人功能(也就是摧毀Session)
代碼監(jiān)聽器
public class KickPerson implements HttpSessionAttributeListener {
// Public constructor is required by servlet spec
public KickPerson() {
}
public void attributeAdded(HttpSessionBindingEvent sbe) {
//得到context對象，看看context對象是否有容器裝載Session
ServletContext context = sbe.getSession().getServletContext();
//如果沒有，就創(chuàng)建一個唄
Map map = (Map) context.getAttribute("map");
if (map == null) {
map = new HashMap();
context.setAttribute("map", map);
}
//---------------------------------------------------------------------------------------
//得到Session屬性的值
Object o = sbe.getValue();
//判斷屬性的內(nèi)容是否是User對象
if (o instanceof User) {
User user = (User) o;
map.put(user.getUsername(), sbe.getSession());
}
}
public void attributeRemoved(HttpSessionBindingEvent sbe) {
/* This method is called when an attribute
is removed from a session.
*/
}
public void attributeReplaced(HttpSessionBindingEvent sbe) {
/* This method is invoked when an attibute
is replaced in a session.
*/
}
}
登陸頁面
處理登陸Servlet
//得到傳遞過來的數(shù)據(jù)
String username = request.getParameter("username");
User user = new User();
user.setUsername(username);
//標(biāo)記該用戶登陸了！
request.getSession().setAttribute("user", user);
//提供界面，告訴用戶登陸是否成功
request.setAttribute("message", "恭喜你，登陸成功了！");
request.getRequestDispatcher("/message.jsp").forward(request, response);
列出在線用戶
