溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇“SpringSession怎么通過Redis統計在線用戶數量”文章的知識點大部分人都不太理解，所以小編給大家總結了以下內容，內容詳細，步驟清晰，具有一定的借鑒價值，希望大家閱讀完這篇文章能有所收獲，下面我們一起來看看這篇“SpringSession怎么通過Redis統計在線用戶數量”文章吧。
因為系統原先的邏輯是使用Spring Session加上Redis做的會話共享實現的單點登錄，登錄之后會在session設置一個key值表示用戶已經登錄過，同時重寫HttpServletRequestWrapper 設置remoteUser數據值
class RemoteUserRequestWrapper extends HttpServletRequestWrapper {
String userCode;
RemoteUserRequestWrapper(HttpServletRequest request) {
super(request);
this.userCode = (String) request.getSession()
.getAttribute(org.apache.commons.lang3.StringUtils.isBlank(sessionKeyName)?DEFAULT_SESSION_KEY_NAME:sessionKeyName);
}
@Override
public String getRemoteUser() {
return userCode;
}
}Spring Session緩存在redis里的數據
這個ssoLoginUser key是自己登錄時候設置的，根據業務修改，經過測試，在登出系統時候，session設置過期獲取removeAttribute不能清redis里的key數據，所以只能在登出系統邏輯加上：
Set<String> keys = RedisUtils.redisTemplate.keys("spring:session:sessions:*");
for(String key : keys){
if(key.indexOf("expires")==-1){
String s = (String)RedisUtils.redisTemplate.opsForHash().get(key, "sessionAttr:ssoLoginUser");
if(request.getRemoteUser().equals(s)) {
logger.info("loginusername:{}",s)
RedisUtils.redisTemplate.opsForHash().delete(key, "sessionAttr:ssoLoginUser");
}
}
}進行數據統計：
List<Map<String,Object>> list = new ArrayList<Map<String, Object>>();
List<Map<String,Object>> data = new ArrayList<Map<String, Object>>();
Set<String> keys = redisTemplate.keys("spring:session:sessions:*");
for(String key : keys){
if(key.indexOf("expires")==-1){
String s = (String)redisTemplate.opsForHash().get(key, "sessionAttr:ssoLoginUser");
if(StringUtils.isNotBlank(s)) {
System.out.println(s);
Map<String,Object> map = new HashMap<String,Object>(16);
map.put("usercode", s);
list.add(map);
}
}
}
return list;pom.xml：
<dependency> <groupId>org.springframework.session</groupId> <artifactId>spring-session-data-redis</artifactId> <version>1.2.2.RELEASE</version> <type>pom</type> </dependency> <dependency> <groupId>biz.paluch.redis</groupId> <artifactId>lettuce</artifactId> <version>3.5.0.Final</version> </dependency>
RedisUtils.java：
package com.common.utils.redis;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.context.ContextLoader;
import org.springframework.web.context.WebApplicationContext;
import java.util.Collection;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;
public class RedisUtils {
private RedisUtils() {
}
@SuppressWarnings("unchecked")
public static RedisTemplate<String, Object> redisTemplate =
ContextLoader.getCurrentWebApplicationContext().getBean(RedisTemplate.class);
/**
* 設置有效時間
*
* @param key Redis鍵
* @param timeout 超時時間
* @return true=設置成功；false=設置失敗
*/
public static boolean expire(final String key, final long timeout) {
return expire(key, timeout, TimeUnit.SECONDS);
}
/**
* 設置有效時間
*
* @param key Redis鍵
* @param timeout 超時時間
* @param unit 時間單位
* @return true=設置成功；false=設置失敗
*/
public static boolean expire(final String key, final long timeout, final TimeUnit unit) {
Boolean ret = redisTemplate.expire(key, timeout, unit);
return ret != null && ret;
}
/**
* 刪除單個key
*
* @param key 鍵
* @return true=刪除成功；false=刪除失敗
*/
public static boolean del(final String key) {
redisTemplate.delete(key);
return true;
}
/**
* 刪除多個key
*
* @param keys 鍵集合
* @return 成功刪除的個數
*/
public static long del(final Collection<String> keys) {
redisTemplate.delete(keys);
return 0;
}
/**
* 存入普通對象
*
* @param key Redis鍵
* @param value 值
*/
public static void set(final String key, final Object value) {
redisTemplate.opsForValue().set(key, value, 1, TimeUnit.MINUTES);
}
// 存儲普通對象操作
/**
* 存入普通對象
*
* @param key 鍵
* @param value 值
* @param timeout 有效期，單位秒
*/
public static void set(final String key, final Object value, final long timeout) {
redisTemplate.opsForValue().set(key, value, timeout, TimeUnit.SECONDS);
}
/**
* 獲取普通對象
*
* @param key 鍵
* @return 對象
*/
public static Object get(final String key) {
return redisTemplate.opsForValue().get(key);
}
// 存儲Hash操作
/**
* 往Hash中存入數據
*
* @param key Redis鍵
* @param hKey Hash鍵
* @param value 值
*/
public static void hPut(final String key, final String hKey, final Object value) {
redisTemplate.opsForHash().put(key, hKey, value);
}
/**
* 往Hash中存入多個數據
*
* @param key Redis鍵
* @param values Hash鍵值對
*/
public static void hPutAll(final String key, final Map<String, Object> values) {
redisTemplate.opsForHash().putAll(key, values);
}
/**
* 獲取Hash中的數據
*
* @param key Redis鍵
* @param hKey Hash鍵
* @return Hash中的對象
*/
public static Object hGet(final String key, final String hKey) {
return redisTemplate.opsForHash().get(key, hKey);
}
/**
* 獲取多個Hash中的數據
*
* @param key Redis鍵
* @param hKeys Hash鍵集合
* @return Hash對象集合
*/
public static List<Object> hMultiGet(final String key, final Collection<Object> hKeys) {
return redisTemplate.opsForHash().multiGet(key, hKeys);
}
// 存儲Set相關操作
/**
* 往Set中存入數據
*
* @param key Redis鍵
* @param values 值
* @return 存入的個數
*/
public static long sSet(final String key, final Object... values) {
Long count = redisTemplate.opsForSet().add(key, values);
return count == null ? 0 : count;
}
/**
* 刪除Set中的數據
*
* @param key Redis鍵
* @param values 值
* @return 移除的個數
*/
public static long sDel(final String key, final Object... values) {
Long count = redisTemplate.opsForSet().remove(key, values);
return count == null ? 0 : count;
}
// 存儲List相關操作
/**
* 往List中存入數據
*
* @param key Redis鍵
* @param value 數據
* @return 存入的個數
*/
public static long lPush(final String key, final Object value) {
Long count = redisTemplate.opsForList().rightPush(key, value);
return count == null ? 0 : count;
}
/**
* 往List中存入多個數據
*
* @param key Redis鍵
* @param values 多個數據
* @return 存入的個數
*/
public static long lPushAll(final String key, final Collection<Object> values) {
Long count = redisTemplate.opsForList().rightPushAll(key, values);
return count == null ? 0 : count;
}
/**
* 往List中存入多個數據
*
* @param key Redis鍵
* @param values 多個數據
* @return 存入的個數
*/
public static long lPushAll(final String key, final Object... values) {
Long count = redisTemplate.opsForList().rightPushAll(key, values);
return count == null ? 0 : count;
}
/**
* 從List中獲取begin到end之間的元素
*
* @param key Redis鍵
* @param start 開始位置
* @param end 結束位置（start=0，end=-1表示獲取全部元素）
* @return List對象
*/
public static List<Object> lGet(final String key, final int start, final int end) {
return redisTemplate.opsForList().range(key, start, end);
}
}以上就是關于“SpringSession怎么通過Redis統計在線用戶數量”這篇文章的內容，相信大家都有了一定的了解，希望小編分享的內容對大家有幫助，若想了解更多相關的知識內容，請關注億速云行業資訊頻道。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
