資訊專欄INFORMATION COLUMN
摘要：現(xiàn)在，我們想要統(tǒng)計(jì)的是網(wǎng)站的在線人數(shù)。隔一段時(shí)間去做某事，這肯定是定時(shí)器的任務(wù)呀。定時(shí)器應(yīng)該在服務(wù)器一啟動(dòng)的時(shí)候，就應(yīng)該被創(chuàng)建了。定時(shí)器掃描容器的時(shí)候，可能是獲取不到所有的的。
從第一篇已經(jīng)講解過(guò)了監(jiān)聽器的基本概念，以及Servlet各種的監(jiān)聽器。這篇博文主要講解的是監(jiān)聽器的應(yīng)用。
統(tǒng)計(jì)網(wǎng)站在線人數(shù) 分析我們?cè)诰W(wǎng)站中一般使用Session來(lái)標(biāo)識(shí)某用戶是否登陸了，如果登陸了，就在Session域中保存相對(duì)應(yīng)的屬性。如果沒(méi)有登陸，那么Session的屬性就應(yīng)該為空。
現(xiàn)在，我們想要統(tǒng)計(jì)的是網(wǎng)站的在線人數(shù)。我們應(yīng)該這樣做：我們監(jiān)聽是否有新的Session創(chuàng)建了，如果新創(chuàng)建了Sesssion，那么在線人數(shù)就應(yīng)該+1。這個(gè)在線人數(shù)是整個(gè)站點(diǎn)的，所以應(yīng)該有Context對(duì)象保存。
大致思路：
監(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對(duì)象，使用Context域?qū)ο蟊４嬗脩粼诰€的個(gè)數(shù)
ServletContext context = se.getSession().getServletContext();
//直接判斷Context對(duì)象是否存在這個(gè)域，如果存在就人數(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);
}
}
}
顯示頁(yè)面代碼：
在線人數(shù)：${num}
測(cè)試
我們每使用一個(gè)瀏覽器訪問(wèn)服務(wù)器，都會(huì)新創(chuàng)建一個(gè)Session。那么網(wǎng)站的在線人數(shù)就會(huì)+1。
使用同一個(gè)頁(yè)面刷新，還是使用的是那個(gè)Sesssion，所以網(wǎng)站的在線人數(shù)是不會(huì)變的。
自定義Session掃描器我們都知道Session是保存在內(nèi)存中的，如果Session過(guò)多，服務(wù)器的壓力就會(huì)非常大。
但是呢，Session的默認(rèn)失效時(shí)間是30分鐘(30分鐘沒(méi)人用才會(huì)失效)，這造成Seesion可能會(huì)過(guò)多（沒(méi)人用也存在內(nèi)存中，這不是明顯浪費(fèi)嗎？）
當(dāng)然啦，我們可以在web.xml文件中配置Session的生命周期。但是呢，這是由服務(wù)器來(lái)做的，我嫌它的時(shí)間不夠準(zhǔn)確。（有時(shí)候我配置了3分鐘，它用4分鐘才幫我移除掉Session）
所以，我決定自己用程序手工移除那些長(zhǎng)時(shí)間沒(méi)人用的Session。
分析要想移除長(zhǎng)時(shí)間沒(méi)人用的Session，肯定要先拿到全部的Session啦。所以我們使用一個(gè)容器來(lái)裝載站點(diǎn)所有的Session。。
只要Sesssion一創(chuàng)建了，就把Session添加到容器里邊。毫無(wú)疑問(wèn)的，我們需要監(jiān)聽Session了。
接著，我們要做的就是隔一段時(shí)間就去掃描一下全部Session，如果有Session長(zhǎng)時(shí)間沒(méi)使用了，我們就把它從內(nèi)存中移除。隔一段時(shí)間去做某事，這肯定是定時(shí)器的任務(wù)呀。
定時(shí)器應(yīng)該在服務(wù)器一啟動(dòng)的時(shí)候，就應(yīng)該被創(chuàng)建了。因此還需要監(jiān)聽Context
最后，我們還要考慮到并發(fā)的問(wèn)題，如果有人同時(shí)訪問(wèn)站點(diǎn)，那么監(jiān)聽Session創(chuàng)建的方法就會(huì)被并發(fā)訪問(wèn)了。定時(shí)器掃描容器的時(shí)候，可能是獲取不到所有的Session的。
這需要我們做同步
于是乎，我們已經(jīng)有大致的思路了
監(jiān)聽Session和Context的創(chuàng)建
使用一個(gè)容器來(lái)裝載Session
定時(shí)去掃描Session，如果它長(zhǎng)時(shí)間沒(méi)有使用到了，就把該Session從內(nèi)存中移除。
并發(fā)訪問(wèn)的問(wèn)題
代碼監(jiān)聽器代碼：
public class Listener1 implements ServletContextListener,
HttpSessionListener {
//服務(wù)器一啟動(dòng)，就應(yīng)該創(chuàng)建容器。我們使用的是LinkList(涉及到增刪)。容器也應(yīng)該是線程安全的。
List list = Collections.synchronizedList(new LinkedList());
//定義一把鎖（Session添加到容器和掃描容器這兩個(gè)操作應(yīng)該同步起來(lái)）
private Object lock = 1;
public void contextInitialized(ServletContextEvent sce) {
Timer timer = new Timer();
//執(zhí)行我想要的任務(wù)，0秒延時(shí)，每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)來(lái)了。
*
* 要想得到在監(jiān)聽器上的鎖，也只能是傳遞進(jìn)來(lái)
*
* */
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秒沒(méi)人使用，我就移除它啦
if (System.currentTimeMillis() - session.getLastAccessedTime() > (1000 * 15)) {
session.invalidate();
sessions.remove(session);
}
}
}
}
}
測(cè)試：
15秒如果Session沒(méi)有活躍，那么就被刪除！
使用集合來(lái)裝載我們所有的Session
使用定時(shí)器來(lái)掃描session的聲明周期【由于定時(shí)器沒(méi)有session，我們傳進(jìn)去就好了】
關(guān)于并發(fā)訪問(wèn)的問(wèn)題，我們?cè)趻呙韬蜋z測(cè)session添加的時(shí)候，同步起來(lái)就好了【當(dāng)然，定時(shí)器的鎖也是要外面?zhèn)鬟f進(jìn)來(lái)的】
踢人小案列列出所有的在線用戶，后臺(tái)管理者擁有踢人的權(quán)利，點(diǎn)擊踢人的超鏈接，該用戶就被注銷了。
分析首先，怎么能列出所有的在線用戶呢？？一般我們?cè)诰€用戶都是用Session來(lái)標(biāo)記的，所有的在線用戶就應(yīng)該用一個(gè)容器來(lái)裝載所有的Session。。
我們監(jiān)聽Session的是否有屬性添加(監(jiān)聽Session的屬性有添加、修改、刪除三個(gè)方法。如果監(jiān)聽到Session添加了，那么這個(gè)肯定是個(gè)在線用戶！)。
裝載Session的容器應(yīng)該是在Context里邊的【屬于全站點(diǎn)】，并且容器應(yīng)該使用Map集合【待會(huì)還要通過(guò)用戶的名字來(lái)把用戶踢了】
思路：
寫監(jiān)聽器，監(jiān)聽是否有屬性添加在Session里邊了。
寫簡(jiǎn)單的登陸頁(yè)面。
列出所有的在線用戶
實(shí)現(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對(duì)象，看看context對(duì)象是否有容器裝載Session
ServletContext context = sbe.getSession().getServletContext();
//如果沒(méi)有，就創(chuàng)建一個(gè)唄
Map map = (Map) context.getAttribute("map");
if (map == null) {
map = new HashMap();
context.setAttribute("map", map);
}
//---------------------------------------------------------------------------------------
//得到Session屬性的值
Object o = sbe.getValue();
//判斷屬性的內(nèi)容是否是User對(duì)象
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.
*/
}
}
登陸頁(yè)面
處理登陸Servlet
//得到傳遞過(guò)來(lái)的數(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);
列出在線用戶
