这是javaweb教学书上的一道题，要求统计在线人数，同时显示当前在线的每个用户的信息，类似于达到这样的效果：
javaweb.png
关于在线人数的统计可以创建一个会话监听器OnlineListener它实现了HttpSessionListener接口，每当有会话创建时则，就会调用sessionCreated()方法，然后在里面对OnlineCount加1，当会话被销毁时调用sessionDestroyed()，对OnlineCount减1，再将OnlineCount保存为ServletContext属性
同时需要显示每一个用户的信息，所以需要对每一个用户的会话进行记录，我认为可以用SessionID去代表每一个用户，然后将每一个会话的SessionID和Session对应起来，这里可以用一个map集合，将id作为键。所以我这里创建了一个MySession类专门用于对Session进行管理，即保存Session同时根据SessionID得到Session。最后在显示页面Servlet里进行遍历，获取用户信息。
以下是相关代码实现：
这是用户需要提交的表单的简单实现：
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=GBK">
<title>Insert title here</title>
</head>
<body>
<form action="/TomcatTest/guest.do" method="post">
name:<input type="text" name="name"><br>
message:<input type="text" name="message"><br>
<input type="submit" name="submit" value="send">
</form>
</body>
</html>
这是监听器的实现：
package com.zoro.listener;
import java.util.Date;
import java.util.LinkedList;
import java.util.List;
import javax.servlet.http.HttpSession;
import javax.servlet.http.HttpSessionEvent;
import javax.servlet.http.HttpSessionListener;
//监听器的实现
//实现在线人数的统计
public class OnlineListener implements HttpSessionListener {
public static int onlineCount;
public OnlineListener(){
onlineCount = 0;
}
/*会话session创建时处理*/
public void sessionCreated(HttpSessionEvent sessionEvent){
//每创建一个会话count加1
onlineCount++;
//获取当前会话，进行会话管理
HttpSession session = sessionEvent.getSession();
//添加session
MySessionContext.AddSession(session);
//由session获取会话，并将在线人数设置为ServletContext属性
session.getServletContext().setAttribute("online", new Integer(onlineCount));
System.out.println("online people:"+onlineCount);
//获取会话创建时间
long a = session.getCreationTime();
Date createTime = new Date(a);
System.out.println(createTime);
//将会话创建时间设置为会话属性
session.setAttribute("createTime", createTime);
}
/*会话销毁时处理*/
public void sessionDestroyed(HttpSessionEvent sessionEvent){
onlineCount--;
HttpSession session = sessionEvent.getSession();
System.out.println("one session is destroyed");
sessionEvent.getSession().getServletContext().setAttribute("online", new Integer(onlineCount));
//从会话列表中删除销毁的会话
MySessionContext.DelSession(session);
}
}
这是MySessionContext的实现，用于对Session进行管理：
package com.zoro.listener;
import java.util.HashMap;
import javax.servlet.http.HttpSession;
/*用于对会话session进行存储管理*/
public class MySessionContext {
//创建一个静态的hashmap用于存储
private static HashMap mymap = new HashMap();
/*将sessionID和session添加至map中*/
public static synchronized void AddSession(HttpSession session) {
if (session != null) {
mymap.put(session.getId(), session);
}
}
/*根据sessionID从map中删除session*/
public static synchronized void DelSession(HttpSession session) {
if (session != null) {
mymap.remove(session.getId());
}
}
/*根据sessionID获取session*/
public static synchronized HttpSession getSession(String session_id) {
if (session_id == null)
return null;
return (HttpSession) mymap.get(session_id);
}
/*获取存储session的map*/
public static synchronized HashMap getIdMap(){
return mymap;
}
}
这是用于显示的Servlet：
package com.zoro.wrap;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.Date;
import java.util.Enumeration;
import java.util.HashSet;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import com.zoro.listener.*;
public class guestServlet extends HttpServlet {
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
//通过request对象获取会话信息
HttpSession session = req.getSession();
//设置浏览器在多久没有请求的情况下，httpsession自动失效
//session.setMaxInactiveInterval(30);
//创建日期对象存储会话创建时的日期
Date date = (Date)(session.getAttribute("createTime"));
//获取用户浏览器的相关信息
String userAgent = req.getHeader("user-agent");
//将想关信息设置为会话属性
session.setAttribute("info",userAgent );
//获取会话ID
String id = session.getId();
System.out.println("id:"+id);
//将会话id存储为会话属性
session.setAttribute("id", id);
//Enumeration header = req.getHeaderNames();
//设置请求字符编码和响应字符编码
req.setCharacterEncoding("GB2312");
resp.setCharacterEncoding("GB2312");
resp.setHeader("content-type","text/html;charset=GB2312");
//这里是无关信息只是打印一下
String name = req.getParameter("name");
session.setAttribute("name",name );
String message = req.getParameter("message");
System.out.println(message);
//创建响应对象
resp.setContentType("text/html; charset=GB2312");
PrintWriter out = resp.getWriter();
//编写输出页面
out.println("<html>");
out.println("<meta http-equiv=\"content-type\" content=\"text/html;charset=GBK\">");
out.println("<head>");
out.println("<title>guest book</title>");
out.println("</head>");
out.println("<body>");
//输出当前在线人数
out.println("online number:" + OnlineListener.onlineCount+"<br>");
//获取map的键集的遍历器，这里的map键key是会话id，值value是对应session
Iterator<String> it = MySessionContext.getIdMap().keySet().iterator();
//利用键集遍历器将创建的会话遍历
while(it.hasNext()){
String sessionID = it.next();
System.out.println("Sessionid:"+sessionID);
HttpSession session1 =(HttpSession)MySessionContext.getIdMap().get(sessionID);
out.println(session1.getAttribute("createTime")+"<br>");
out.println(session1.getAttribute("name")+","+session1.getAttribute("info")+"<br><br>");
}
out.println("</body");
out.println("</html>");
out.close();
}
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
System.out.println("post");
doGet(req,resp);
}
}
当然最后还要配置web.xml文件，主要是配置Servlet和Listener。做完后打开tomcat，在多个浏览器提交表单后，最后显示的效果如图：
Paste_Image.png
由于知识有限，所以写得很繁琐，有待改进
网友评论