javaweb學習總結(四十七)——監聽器(Listener)在開發中的應用

　　監聽器在JavaWeb開發中用得比較多，下面說一下監聽器(Listener)在開發中的常見應用

一、統計當前在線人數

　　在JavaWeb應用開發中，有時候我們需要統計當前在線的用戶數，此時就可以使用監聽器技術來實現這個功能了。

package me.gacl.web.listener;

import javax.servlet.ServletContext;
import javax.servlet.http.HttpSessionEvent;
import javax.servlet.http.HttpSessionListener;

/**
* @ClassName: OnLineCountListener
* @Description: 統計當前在線用戶個數
* @author: 孤傲蒼狼
* @date: 2014-9-10 下午10:01:26
*
*/ 
public class OnLineCountListener implements HttpSessionListener {

    @Override
    public void sessionCreated(HttpSessionEvent se) {
        ServletContext context = se.getSession().getServletContext();
        Integer onLineCount = (Integer) context.getAttribute("onLineCount");
        if(onLineCount==null){
            context.setAttribute("onLineCount", 1);
        }else{
            onLineCount++;
            context.setAttribute("onLineCount", onLineCount);
        }
    }

    @Override
    public void sessionDestroyed(HttpSessionEvent se) {
        ServletContext context = se.getSession().getServletContext();
        Integer onLineCount = (Integer) context.getAttribute("onLineCount");
        if(onLineCount==null){
            context.setAttribute("onLineCount", 1);
        }else{
            onLineCount--;
            context.setAttribute("onLineCount", onLineCount);
        }
    }
}

二、自定義Session掃描器

　　當一個Web應用創建的Session很多時，為了避免Session占用太多的內存，我們可以選擇手動將這些內存中的session銷毀，那么此時也可以借助監聽器技術來實現。

package me.gacl.web.listener;

import java.util.Collections;
import java.util.LinkedList;
import java.util.List;
import java.util.ListIterator;
import java.util.Timer;
import java.util.TimerTask;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.servlet.http.HttpSession;
import javax.servlet.http.HttpSessionEvent;
import javax.servlet.http.HttpSessionListener;

/**
* @ClassName: SessionScanerListener
* @Description: 自定義session掃描器
* @author: 孤傲蒼狼
* @date: 2014-9-10 下午10:16:42
* 
*/ 
public class SessionScanerListener implements HttpSessionListener,ServletContextListener {

    /**
    * @Field: list
    *          定義一個集合存儲服務器創建的HttpSession
    *        LinkedList不是一個線程安全的集合
    */ 
    /**
     * private List<HttpSession> list = new LinkedList<HttpSession>();
     * 這樣寫涉及到線程安全問題,SessionScanerListener對象在內存中只有一個
     * sessionCreated可能會被多個人同時調用，
     * 當有多個人並發訪問站點時，服務器同時為這些並發訪問的人創建session
     * 那么sessionCreated方法在某一時刻內會被幾個線程同時調用，幾個線程並發調用sessionCreated方法
     * sessionCreated方法的內部處理是往一個集合中添加創建好的session，那么在加session的時候就會
     * 涉及到幾個Session同時搶奪集合中一個位置的情況，所以往集合中添加session時，一定要保證集合是線程安全的才行
     * 如何把一個集合做成線程安全的集合呢？
     * 可以使用使用 Collections.synchronizedList(List<T> list)方法將不是線程安全的list集合包裝線程安全的list集合
     */
    //使用 Collections.synchronizedList(List<T> list)方法將LinkedList包裝成一個線程安全的集合
    private List<HttpSession> list = Collections.synchronizedList(new LinkedList<HttpSession>());
    //定義一個對象，讓這個對象充當一把鎖，用這把鎖來保證往list集合添加的新的session和遍歷list集合中的session這兩個操作達到同步
    private Object lock = new Object();
            
    @Override
    public void sessionCreated(HttpSessionEvent se) {
        System.out.println("session被創建了!!");
        HttpSession session = se.getSession();
        
        synchronized (lock){
            /**
             *將該操作加鎖進行鎖定，當有一個thread-1(線程1)在調用這段代碼時，會先拿到lock這把鎖，然后往集合中添加session，
             *在添加session的這個過程中假設有另外一個thread-2(線程2)來訪問了，thread-2可能是執行定時器任務的，
             *當thread-2要調用run方法遍歷list集合中的session時，結果發現遍歷list集合中的session的那段代碼被鎖住了，
             *而這把鎖正在被往集合中添加session的那個thread-1占用着，因此thread-2只能等待thread-1操作完成之后才能夠進行操作
             *當thread-1添加完session之后，就把lock放開了，此時thread-2拿到lock，就可以執行遍歷list集合中的session的那段代碼了
             *通過這把鎖就保證了往集合中添加session和變量集合中的session這兩步操作不能同時進行，必須按照先來后到的順序來進行。
             */
            list.add(session);
        }
    }

    @Override
    public void sessionDestroyed(HttpSessionEvent se) {
        System.out.println("session被銷毀了了!!");
    }

    /* Web應用啟動時觸發這個事件
     * @see javax.servlet.ServletContextListener#contextInitialized(javax.servlet.ServletContextEvent)
     */
    @Override
    public void contextInitialized(ServletContextEvent sce) {
        System.out.println("web應用初始化");
        //創建定時器
        Timer timer = new Timer();
        //每隔30秒就定時執行任務
        timer.schedule(new MyTask(list,lock), 0, 1000*30);
    }

    @Override
    public void contextDestroyed(ServletContextEvent sce) {
        System.out.println("web應用關閉");
    }
}

/**
* @ClassName: MyTask
* @Description:定時器要定時執行的任務
* @author: 孤傲蒼狼
* @date: 2014-9-11 上午12:02:36
*
*/ 
class MyTask extends TimerTask {
        
    //存儲HttpSession的list集合
    private List<HttpSession> list;
    //存儲傳遞過來的鎖
    private Object lock;
    public MyTask(List<HttpSession> list,Object lock){
        this.list = list;
        this.lock = lock;
    }
    /* run方法指明了任務要做的事情
     * @see java.util.TimerTask#run()
     */
    @Override
    public void run() {
            //將該操作加鎖進行鎖定
        synchronized (lock) {
            System.out.println("定時器執行！！");
            ListIterator<HttpSession> it = list.listIterator();
            /**
             * 迭代list集合中的session，在迭代list集合中的session的過程中可能有別的用戶來訪問，
             * 用戶一訪問，服務器就會為該用戶創建一個session,此時就會調用sessionCreated往list集合中添加新的session，
             * 然而定時器在定時執行掃描遍歷list集合中的session時是無法知道正在遍歷的list集合又添加的新的session進來了，
             * 這樣就導致了往list集合添加的新的session和遍歷list集合中的session這兩個操作無法達到同步
             * 那么解決的辦法就是把"list.add(session)和while(it.hasNext()){//迭代list集合}"這兩段代碼做成同步，
             * 保證當有一個線程在訪問"list.add(session)"這段代碼時，另一個線程就不能訪問"while(it.hasNext()){//迭代list集合}"這段代碼
             * 為了能夠將這兩段不相干的代碼做成同步，只能定義一把鎖(Object lock)，然后給這兩步操作加上同一把鎖，
             * 用這把鎖來保證往list集合添加的新的session和遍歷list集合中的session這兩個操作達到同步
             * 當在執行往list集合添加的新的session操作時，就必須等添加完成之后才能夠對list集合進行迭代操作，
             * 當在執行對list集合進行迭代操作時，那么必須等到迭代操作結束之后才能夠往往list集合添加的新的session
             */
            while(it.hasNext()){
                HttpSession session = (HttpSession) it.next();
                /**
                 * 如果當前時間-session的最后訪問時間>1000*15(15秒)
                 * session.getLastAccessedTime()獲取session的最后訪問時間
                 */
                if(System.currentTimeMillis()-session.getLastAccessedTime()>1000*30){
                    //手動銷毀session
                    session.invalidate();
                    //移除集合中已經被銷毀的session
                    it.remove();
                }
            }
        }
    }
}

 以上就是監聽器的兩個簡單應用場景。