spring boot统计在线人数( 完整代码)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
import javax.servlet.http.HttpSessionBindingEvent;
import javax.servlet.http.HttpSessionBindingListener;

import com.rt.core.data.DataMap;

/**
 * Title:监测前台用户在线人数
 * @author SQW
 * @Date:2019-03-19
 */
//@WebListener
public class  OnLineUser implements HttpSessionBindingListener {

	public OnLineUser() {
		
	}
	private Vector<DataMap> listenUser = new Vector<DataMap>();
	public int getCount() {
		listenUser.trimToSize();// 调整Vector listenUser的容量为Vector listenUser的大小
		return listenUser.capacity();// 返回listenUser的容量
	}
	public boolean existUser(String userId) {
		listenUser.trimToSize();
		boolean existUser = false;
		for (int i = 0; i < listenUser.capacity(); i++) {
			if (userId.equals(listenUser.get(i).get("userId").toString())) {
				existUser = true;
				break;
			}
		}
		return existUser;
	}
	public boolean deleteUser(String userId) {
		listenUser.trimToSize();
		if (existUser(userId)) {
			int currUserIndex = -1;
			for (int i = 0; i < listenUser.capacity(); i++) {
				if (userId.equals(listenUser.get(i).get("userId").toString())) {
					currUserIndex = i;
					break;
				}
			}
			if (currUserIndex != -1) {
				listenUser.remove(currUserIndex);
				listenUser.trimToSize();
				return true;
			}
		}
		return false;
	}
	public Vector<DataMap> getOnLineUser() {
		return listenUser;
	}
	public void valueBound(HttpSessionBindingEvent e) {
		
		listenUser.trimToSize();
		System.out.print(e.getName() + "    登入到系统 " + (new Date()));
		System.out.println("      在线用户数为：" + getCount());
		
	}
	public void valueUnbound(HttpSessionBindingEvent e) {
		listenUser.trimToSize();
		String userId = e.getName();
		deleteUser(userId);
		System.out.print(userId + "    退出系统 " + (new Date()));
		System.out.println("      在线用户数为：" + getCount());
	}
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
//在登录controller中进行声明
public static OnLineUser onLine=new OnLineUser();
......
################上面为登录的正常用户验证方法###############
int count=onLine.getCount();
System.out.println("当前在线人数:"+count);
	
//userMap为当前登录的用户
Vector<DataMap> vt = onLine.getOnLineUser();
vt.add(userMap);
session.setAttribute(userMap.get("userId").toString(),onLine);
//将session超时时间设置为30分钟		
session.setMaxInactiveInterval(60*30);