portletsessionmanager.java

GridSphere 门户 提供一个基于 portlet 的高级开放源代码门户。GridSphere 是在欧盟提供基金的 GridLab 项目下开发的

package org.gridsphere.portletcontainer.impl;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.gridsphere.portletcontainer.PortletSessionListener;

import javax.servlet.http.HttpSession;
import javax.servlet.http.HttpSessionEvent;
import javax.servlet.http.HttpSessionListener;
import java.util.*;

/**
 * @author <a href="mailto:[e-mail]">Jason Novotny</a>
 * @version $Id: PortletSessionManager.java 4985 2006-08-04 09:54:28Z novotny $
 */
public class PortletSessionManager implements HttpSessionListener {

    private static PortletSessionManager instance = new PortletSessionManager();
    private Log log = LogFactory.getLog(PortletSessionManager.class);

    private Hashtable sessions = new Hashtable();
    private Hashtable sessionListeners = new Hashtable();

    private PortletSessionManager() {

    }

    public static PortletSessionManager getInstance() {
        return instance;
    }

    public int getNumSessions() {
        return sessions.size();        
    }

    public Set getSessions() {
        return sessions.keySet();
    }

    /**
     * Record the fact that a session has been created.
     *
     * @param event The session event
     */
    public void sessionCreated(HttpSessionEvent event) {
        log.debug("sessionCreated('" + event.getSession().getId() + "')");
        String id = event.getSession().getId();
        sessions.put(id, event.getSession());
        dumpSessions();
    }


    /**
     * Record the fact that a session has been destroyed.
     *
     * @param event The session event
     */
    public void sessionDestroyed(HttpSessionEvent event) {
        log.debug("sessionDestroyed('" + event.getSession().getId() + "')");
        HttpSession httpSession = event.getSession();
        if (httpSession != null) {
            String id = event.getSession().getId();

            List listeners = (List) sessionListeners.get(id);
            if (listeners != null) {
                Iterator it = listeners.iterator();
                while (it.hasNext()) {
                    PortletSessionListener sessionListener = (PortletSessionListener) it.next();

                        log.info("logging a session listener out: " + sessionListener.getClass());
                        sessionListener.logout(httpSession);
                    
                }
                log.info("Removing session: " + httpSession.getId());
                sessions.remove(id);
                sessionListeners.remove(id);
            }
        } else {
            log.info("Not sure why sessionDestroyed listener provides null session id!");
        }
        dumpSessions();
    }

    public void addSessionListener(String sessionId, PortletSessionListener sessionListener) {
        log.debug("adding session listener for : " + sessionId + " " + sessionListener.getClass());
        HttpSession session = (HttpSession)sessions.get(sessionId);
        if (session != null) {
            List listeners = (List) sessionListeners.get(sessionId);
            if (listeners == null) listeners = new ArrayList();
            listeners.add(sessionListener);
            System.err.println("adding session listener for : " + sessionId + " " + sessionListener.getClass());
            sessionListeners.put(sessionId, listeners);
        }
        dumpSessions();
    }

    public void dumpSessions() {
        log.debug("PortletSessionManager Session information:");
        log.debug("# current sessions: " + sessions.size());
        Set keySet = sessions.keySet();
        Iterator it = keySet.iterator();
        while (it.hasNext()) {
            log.debug("session #id: " + (String)it.next());
        }
    }

}