ssm如何在监听器中使用spring注解注入的service层?

       在我的个人博客项目中,有这样的需求:利用seesion监听器统计在线人数和网站访问量情况。这个需求在我看来,应该有两种思路:

    1. 直接在监听器定义四个变量存储数据

    2. 在项目数据库中设计一张数据表来专门存储数据

 下面我从这两个思路分别来说明一下:

直接在监听器定义四个变量存储数据

首先在session监听器中定义4个变量:

         当前在线用户数(count)、总访问量(all)、今日访问量(today)、今日日期(day)

         然后session监听器SessionCounter实现了HttpSessionListener接口,所以类中包含了sessionCreated以及sessionDestroyed方法,      sessionCreated方法是在session创建的时候执行,而sessionDestroyed方法则是在session销毁时执行。在session创建时对当前在线用户数 (count)、总访问量(all)的值进行++操作,然后通过对比今日日期(day) 的值以及直接获取到的日期,对今日访问量(today)进行不同的操作即可。所 以具体的实现代码如下:

实现代码:

package com.pwt.utils;

import org.springframework.stereotype.Component;

import javax.servlet.ServletContext;

import javax.servlet.http.HttpSessionEvent;

import javax.servlet.http.HttpSessionListener;

import java.util.Date;

/**

 * count 当前在线用户数

 * all 总访问量

 * today 今日访问量

 * day 今日日期

*/

@Component

public class SessionCounter implements HttpSessionListener {

    private static Integer count = 0;

    private static long today = 0;

    private static long all = 0;

    private static int day = 0;

    //session创建

    @Override

    public void sessionCreated(HttpSessionEvent arg0) {

        ServletContext context = arg0.getSession().getServletContext();

        count = (Integer) context.getAttribute("onlineCount");

        if (count == null) {

            count = new Integer(1);

        } else {

            int co = count.intValue();

            count = new Integer(co + 1);

        }

        // 保存人数

        context.setAttribute("onlineCount", count);

        all++;

        Date date=new Date();

        int tday=date.getDate();

        //如果日期发生变化则将today置为1,否则将today加1

        if(tday!=day){

            day=tday;

            today=1;

        }else{

            today++;

        }

    }

    @Override

    public void sessionDestroyed(HttpSessionEvent arg0) {

        ServletContext context = arg0.getSession().getServletContext();

        count = (Integer) context.getAttribute("onlineCount");

        int co = count.intValue();

        count = new Integer(co - 1);

        count = count >= 0 ? count : 0;

        context.setAttribute("onlineCount", count);

    }

    public static Integer getCount() {

        return count;

    }

    public long getAll(){

        return all;

    }

    public long getToday(){

        return today;

    }

}


在项目数据库中设计一张数据表来专门存储数据

       经过我的深思熟虑,我就想把在线人数存储在session中,而今日访问量和总访问量则存储在mysql数据库中。所以我的数据表字段设计如下:

     visit_id:某天访问量的id

     visit_date:访问日期

     visit_count:某天的访问量

       到此,数据库设计完成,你们可能会说怎么没有存储总访问量的字段呢?因为我是通过数据库的sum函数来对每条数据的visit_count字段进行求和,从而得到总的访问量。

 具体代码如下:

package com.pwt.utils;

import com.pwt.model.vo.VisitTotalVo;

import com.pwt.service.IVisitTotalService;

import org.springframework.stereotype.Component;

import javax.servlet.ServletContext;

import javax.servlet.http.HttpSessionEvent;

import javax.servlet.http.HttpSessionListener;

import java.text.SimpleDateFormat;

import java.util.Date;

import java.util.HashMap;

import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;

/**

 * @author pwt

*/

@Component

public class SessionCounter implements HttpSessionListener {

    @Autowired

    private IVisitTotalService iVisitTotalService;

    private static Map sessionMap = new HashMap();

    public SessionCounter() {}

    @Override

    public void sessionCreated(HttpSessionEvent arg0) {

        ServletContext context = arg0.getSession().getServletContext();

        Date date = new Date();

        boolean flag = true;

        for(Object key : sessionMap.keySet()){

            if(key.toString().equals(arg0.getSession().getId())){

                flag = false;

            }

        }

        if(flag){

            sessionMap.put(arg0.getSession().getId(), arg0.getSession());

        }

        context.setAttribute("onlineCount", sessionMap.size());

        VisitTotalVo visitTotalVo = new VisitTotalVo();


        SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd");

        try {

            visitTotalVo.setVisitDate(new java.sql.Date(sdf.parse(sdf.format(date)).getTime()));

            iVisitTotalService.queryVisitTotalByVisitDate(visitTotalVo);

        } catch (Exception e) {

            e.printStackTrace();

        }

    }

    @Override

    public void sessionDestroyed(HttpSessionEvent arg0) {

        boolean flag = false;

        for(Object key : sessionMap.keySet()){

            if(key.toString().equals(arg0.getSession().getId())){

                flag = true;

            }

        }

        if(flag){

            sessionMap.remove(arg0.getSession().getId());

        }

        ServletContext context = arg0.getSession().getServletContext();

        context.setAttribute("onlineCount", sessionMap.size());

    }

}


      从代码中可以看到,我直接在监听器中调用了service层的方法,如果你直接这样运行项目的话,项目会出现空指针异常,原因是监听器属于sevlet容器,不属于 Spring 框架的管理范围,拿不到spring注解注入的bean。要想让项目不会报错,我是这样解决的:

代码:

package com.pwt.utils;

import com.pwt.service.IVisitTotalService;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;

@Component

public class InjectServiceUtil {

    @Autowired

    private IVisitTotalService iVisitTotalService;

    @PostConstruct

    public void init(){

        InjectServiceUtil.getInstance().iVisitTotalService = this.iVisitTotalService;

    }

    /**

     *  实现单例 start

    */

    private static class SingletonHolder {

        private static final InjectServiceUtil INSTANCE = new InjectServiceUtil();

    }

    private InjectServiceUtil (){}

    public static final InjectServiceUtil getInstance() {

        return SingletonHolder.INSTANCE;

    }

    /**

     *  实现单例 end

    */

    public static IVisitTotalService getIVisitTotalService(){

        return InjectServiceUtil.getInstance().iVisitTotalService;

    }

}


修改监听器如下:

package com.pwt.utils;

import com.pwt.model.vo.VisitTotalVo;

import com.pwt.service.IVisitTotalService;

import org.springframework.stereotype.Component;

import javax.servlet.ServletContext;

import javax.servlet.http.HttpSessionEvent;

import javax.servlet.http.HttpSessionListener;

import java.text.SimpleDateFormat;

import java.util.Date;

import java.util.HashMap;

import java.util.Map;

/**

 * @author pwt

*/

@Component

public class SessionCounter implements HttpSessionListener {

    private static IVisitTotalService iVisitTotalService;

    private static Map sessionMap = new HashMap();

    public SessionCounter() {}

    @Override

    public void sessionCreated(HttpSessionEvent arg0) {

        ServletContext context = arg0.getSession().getServletContext();

        Date date = new Date();

        boolean flag = true;

        for(Object key : sessionMap.keySet()){

            if(key.toString().equals(arg0.getSession().getId())){

                flag = false;

            }

        }

        if(flag){

            sessionMap.put(arg0.getSession().getId(), arg0.getSession());

        }

        context.setAttribute("onlineCount", sessionMap.size());

        VisitTotalVo visitTotalVo = new VisitTotalVo();

        iVisitTotalService = InjectServiceUtil.getIVisitTotalService();

        SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd");

        try {

            visitTotalVo.setVisitDate(new java.sql.Date(sdf.parse(sdf.format(date)).getTime()));

            iVisitTotalService.queryVisitTotalByVisitDate(visitTotalVo);

        } catch (Exception e) {

            e.printStackTrace();

        }

    }

    @Override

    public void sessionDestroyed(HttpSessionEvent arg0) {

        boolean flag = false;

        for(Object key : sessionMap.keySet()){

            if(key.toString().equals(arg0.getSession().getId())){

                flag = true;

            }

        }

        if(flag){

            sessionMap.remove(arg0.getSession().getId());

        }

        ServletContext context = arg0.getSession().getServletContext();

        context.setAttribute("onlineCount", sessionMap.size());

    }

}

这样项目运行就不会再出现空指针异常。最后两种思路还需要配置web.xml文件:

<listener>

  <listener-class>com.pwt.utils.SessionCounter</listener-class>

</listener>

<!-- session配置过期时间 -->

<session-config>

  <session-timeout>3</session-timeout>

</session-config>

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 205,033评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,725评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,473评论 0 338
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,846评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,848评论 5 368
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,691评论 1 282
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,053评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,700评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 42,856评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,676评论 2 323
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,787评论 1 333
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,430评论 4 321
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,034评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,990评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,218评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,174评论 2 352
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,526评论 2 343