一、前言 什么是 Web 监听器?Web 监听器是一种 Servlet 特殊类,它们能帮助开发者监听 Web 中特定的事件,比如 ServletContext、HttpSession 、ServletRequest 的创建和销毁;变量的创建、销毁和修改等。可以在某些动作前后增加处理,实现监控。 Web 监听器的使用场景很多,比如监听 Servlet 上下文用来初始化一些数据、监听 HTTP Session 用来获取当前在线的人数、监听客户端请求的 ServletRequest 对象来获取用户的访问信息等等。这一节中,我们主要通过这三个实际的使用场景来学习一下 Spring Boot 中监听器的使用。
二、监听 Servlet 上下文对象 2.1 介绍 监听 Servlet 上下文对象可以用来初始化数据,用于缓存。什么意思呢?我举一个很常见的场景,比如用户在点击某个站点的首页时,一般都会展现出首页的一些信息,而这些信息基本上或者大部分时间都保持不变,但这些信息都是来自数据库。如果用户的每次点击,都要从数据库中去获取数据的话,用户量少还可以接受,如果用户量非常大的话,这对数据库也是一笔很大的开销。
针对这种首页数据,如果大部分都不常更新的话,我们完全可以把它们缓存起来,每次用户点击的时候,我们都直接从缓存中拿,这样既可以提高首页的访问速度,又可以降低服务器的压力。如果做得更加灵活一点,可以再加个定时器,定期的来更新这个首页缓存。就类似与 CSDN 个人博客首页中排名的变化一样。
2.2 编码 下面我们针对这个功能,来写一个 Demo。在实际中,读者可以完全套用该代码,来实现自己项目中的相关逻辑。首先写一个 Service,模拟一下从数据库查询数据:
1 2 3 public interface UserService { public User getUser(); }
具体实现类:
1 2 3 4 5 6 7 8 9 10 11 @Service public class UserServiceImpl implements UserService { @Resource private ApplicationContext applicationContext; @Override public User getUser() { return new User(1L,"wno704","方法测试"); } }
然后写一个监听器,实现 ApplicationListener 接口,重写 onApplicationEvent 方法,将 ContextRefreshedEvent 对象传进去。如果我们想在加载或刷新应用上下文时,也重新刷新下我们预加载的资源,就可以通过监听 ContextRefreshedEvent 来做这样的事情。代码如下:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 @Component public class MyServletContextListener implements ApplicationListener<ContextRefreshedEvent> { @Override public void onApplicationEvent(ContextRefreshedEvent event) { // 先获取到 application 上下文 ApplicationContext applicationContext = event.getApplicationContext(); // 获取对应的 service UserService userService = applicationContext.getBean(UserService.class); User user = userService.getUser(); // 获取 application 域对象,将查到的信息放到 application 域中 ServletContext application = applicationContext.getBean(ServletContext.class); application.setAttribute("user", user); } }
正如注释中描述的那样,首先通过 contextRefreshedEvent 来获取 Application 上下文,再通过 Application 上下文获取 UserService 这个 Bean,项目中可以根据实际业务场景,也可以获取其他的 Bean,然后再调用自己的业务代码获取相应的数据,最后存储到 Application 域中,这样前端在请求相应数据的时候,我们就可以直接从 Application 域中获取信息,减少数据库的压力。
2.3 测试 下面写一个 Controller 直接从 Application 域中获取 user 信息来测试一下。
1 2 3 4 5 6 7 8 9 10 @RestController @RequestMapping("/listener") public class TestController { @GetMapping("/user") public User getUser(HttpServletRequest request) { ServletContext application = request.getServletContext(); return (User) application.getAttribute("user"); } }
启动项目,在浏览器中输入: http://localhost:8080/listener/user ,测试一下即可,如果正常返回 user 信息,那么说明数据已经缓存成功。不过 Application 是缓存在内存中,对内存会有消耗,实际中会把这部分信息存放在Redis缓存中。
三、监听 HTTP 会话 Session 对象 3.1 介绍 监听器还有一个比较常用的地方,就是用来监听 Session 对象,以获取在线用户数量。现在很多开发者都有自己的网站,监听 Session 来获取当前眼下用户数量是个很常见的使用场景。下面介绍下如何使用。
3.2 编码 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 @Component @Slf4j public class MyHttpSessionListener implements HttpSessionListener { /** * 记录在线的用户数量 */ public Integer count = 0; @Override public synchronized void sessionCreated(HttpSessionEvent httpSessionEvent) { log.info("新用户上线了"); count++; httpSessionEvent.getSession().getServletContext().setAttribute("count", count); } @Override public synchronized void sessionDestroyed(HttpSessionEvent httpSessionEvent) { log.info("用户下线了"); count--; httpSessionEvent.getSession().getServletContext().setAttribute("count", count); } }
可以看出,首先该监听器需要实现 HttpSessionListener 接口,然后重写 sessionCreated 和 sessionDestroyed 方法,在 sessionCreated 方法中传递一个 HttpSessionEvent 对象,之后将当前 Session 中的用户数量加 1,sessionDestroyed 方法刚好相反,不再赘述。
3.3 测试 接下来,我们写一个 Controller 测试一下。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 @RestController @RequestMapping("/listener") public class TestController { /** * 获取当前在线人数,该方法有bug * @param request * @return */ @GetMapping("/total") public String getTotalUser(HttpServletRequest request) { Integer count = (Integer) request.getSession().getServletContext().getAttribute("count"); return "当前在线人数:" + count; } }
该 Controller 直接获取当前 Session 中的用户数量,启动服务器,在浏览器中输入: http://localhost:8080/listener/total , 可以看到返回的结果是 1。
再打开一个浏览器,请求相同的地址可以看到 count 是 2,这没有问题。但是如果关闭一个浏览器再打开,理论上应该还是 2,但是实际测试却是 3。原因是 Session 销毁的方法没有执行(可以在后台控制台观察日志打印情况),当重新打开时,服务器找不到用户原来的 Session,于是又重新创建了一个 Session,那怎么解决该问题呢?我们可以将上面的 Controller 方法改造一下:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 @GetMapping("/total2") public String getTotalUser(HttpServletRequest request, HttpServletResponse response) { Cookie cookie; try { // 把 sessionId 记录在浏览器中 cookie = new Cookie("JSESSIONID", URLEncoder.encode(request.getSession().getId(), "utf-8")); cookie.setPath("/"); //设置 cookie 有效期为 2 天,设置长一点 cookie.setMaxAge( 48*60 * 60); response.addCookie(cookie); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } Integer count = (Integer) request.getSession().getServletContext().getAttribute("count"); return "当前在线人数:" + count; }
可以看出,该处理逻辑是让服务器记得原来那个 Session,即把原来的 sessionId 记录在浏览器中,下次再打开时,把这个 sessionId 传过去,这样服务器就不会重新再创建了。重启一下服务器,在浏览器中再次测试一下,即可避免上面的问题。
四、监听客户端请求 Servlet Request 对象 4.1 介绍 使用监听器获取用户的访问信息比较简单,实现 ServletRequestListener 接口即可,然后通过 Request 对象获取一些信息。
4.2 编码 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 @Component @Slf4j public class MyServletRequestListener implements ServletRequestListener { @Override public void requestInitialized(ServletRequestEvent servletRequestEvent) { HttpServletRequest request = (HttpServletRequest) servletRequestEvent.getServletRequest(); log.info("session id为:{}", request.getRequestedSessionId()); log.info("request url为:{}", request.getRequestURL()); request.setAttribute("name", "wno704"); } @Override public void requestDestroyed(ServletRequestEvent servletRequestEvent) { log.info("request end"); HttpServletRequest request = (HttpServletRequest) servletRequestEvent.getServletRequest(); log.info("request域中保存的name值为:{}", request.getAttribute("name")); } }
4.3 测试 编写一个controller测试
1 2 3 4 5 @GetMapping("/request") public String getRequestInfo(HttpServletRequest request) { System.out.println("requestListener中的初始化的name数据:" + request.getAttribute("name")); return "success"; }
然后访问: http://localhost:8080/listener/request
五、自定义监听器 5.1 编写监听器 1 2 3 4 5 6 7 8 9 10 11 12 public class ListenerTest implements ServletContextListener { @Override public void contextInitialized(ServletContextEvent sce) { System.out.println("监听器初始化..."); } @Override public void contextDestroyed(ServletContextEvent sce) { System.out.println("监听器销毁..."); } }
5.2 注册监听器 注册监听器为 Bean,在 WebConfig 配置类中添加如下代码:
1 2 3 4 5 6 7 8 @Configuration public class WebConfig { @Bean public ServletListenerRegistrationBean<ListenerTest> servletListenerRegistrationBean() { return new ServletListenerRegistrationBean<ListenerTest>(new ListenerTest()); } }
5.3 测试 当启动或者关闭容器时,结果如下: