快捷導(dǎo)航

SpringSession通過(guò)Redis統(tǒng)計(jì)在線(xiàn)用戶(hù)數(shù)量的實(shí)現(xiàn)代碼

更新時(shí)間：2023年04月07日 09:33:13 作者：smileNicky

這篇文章主要介紹了SpringSession通過(guò)Redis統(tǒng)計(jì)在線(xiàn)用戶(hù)數(shù)量,本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下

最近遇到一個(gè)比較緊急的任務(wù)，要求統(tǒng)計(jì)在線(xiàn)用戶(hù)，目的是配合性能測(cè)評(píng)，要求證明自己系統(tǒng)的在線(xiàn)用戶(hù)能夠達(dá)標(biāo)，不過(guò)系統(tǒng)因?yàn)闅v史原因，并沒(méi)有這個(gè)功能，所以只能去springSession官網(wǎng)和網(wǎng)上搜資料，想到通過(guò)統(tǒng)計(jì)redis里緩存的數(shù)據(jù)

因?yàn)橄到y(tǒng)原先的邏輯是使用Spring Session加上Redis做的會(huì)話(huà)共享實(shí)現(xiàn)的單點(diǎn)登錄，登錄之后會(huì)在session設(shè)置一個(gè)key值表示用戶(hù)已經(jīng)登錄過(guò)，同時(shí)重寫(xiě)HttpServletRequestWrapper 設(shè)置remoteUser數(shù)據(jù)值

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里的數(shù)據(jù)

這個(gè)ssoLoginUser key是自己登錄時(shí)候設(shè)置的，根據(jù)業(yè)務(wù)修改，經(jīng)過(guò)測(cè)試，在登出系統(tǒng)時(shí)候，session設(shè)置過(guò)期獲取removeAttribute不能清redis里的key數(shù)據(jù)，所以只能在登出系統(tǒng)邏輯加上：

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");
		}
	}
}

進(jìn)行數(shù)據(jù)統(tǒng)計(jì)：

  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);

	/**
	 * 設(shè)置有效時(shí)間
	 *
	 * @param key Redis鍵
	 * @param timeout 超時(shí)時(shí)間
	 * @return true=設(shè)置成功；false=設(shè)置失敗
	 */
	public static boolean expire(final String key, final long timeout) {

		return expire(key, timeout, TimeUnit.SECONDS);
	}

	/**
	 * 設(shè)置有效時(shí)間
	 *
	 * @param key Redis鍵
	 * @param timeout 超時(shí)時(shí)間
	 * @param unit 時(shí)間單位
	 * @return true=設(shè)置成功；false=設(shè)置失敗
	 */
	public static boolean expire(final String key, final long timeout, final TimeUnit unit) {

		Boolean ret = redisTemplate.expire(key, timeout, unit);
		return ret != null && ret;
	}

	/**
	 * 刪除單個(gè)key
	 *
	 * @param key 鍵
	 * @return true=刪除成功；false=刪除失敗
	 */
	public static boolean del(final String key) {

		redisTemplate.delete(key);
		return true;
	}

	/**
	 * 刪除多個(gè)key
	 *
	 * @param keys 鍵集合
	 * @return 成功刪除的個(gè)數(shù)
	 */
	public static long del(final Collection<String> keys) {

		redisTemplate.delete(keys);
		return 0;
	}

	/**
	 * 存入普通對(duì)象
	 *
	 * @param key Redis鍵
	 * @param value 值
	 */
	public static void set(final String key, final Object value) {

		redisTemplate.opsForValue().set(key, value, 1, TimeUnit.MINUTES);
	}

	// 存儲(chǔ)普通對(duì)象操作

	/**
	 * 存入普通對(duì)象
	 *
	 * @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);
	}

	/**
	 * 獲取普通對(duì)象
	 *
	 * @param key 鍵
	 * @return 對(duì)象
	 */
	public static Object get(final String key) {

		return redisTemplate.opsForValue().get(key);
	}

	// 存儲(chǔ)Hash操作

	/**
	 * 往Hash中存入數(shù)據(jù)
	 *
	 * @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中存入多個(gè)數(shù)據(jù)
	 *
	 * @param key Redis鍵
	 * @param values Hash鍵值對(duì)
	 */
	public static void hPutAll(final String key, final Map<String, Object> values) {

		redisTemplate.opsForHash().putAll(key, values);
	}

	/**
	 * 獲取Hash中的數(shù)據(jù)
	 *
	 * @param key Redis鍵
	 * @param hKey Hash鍵
	 * @return Hash中的對(duì)象
	 */
	public static Object hGet(final String key, final String hKey) {

		return redisTemplate.opsForHash().get(key, hKey);
	}

	/**
	 * 獲取多個(gè)Hash中的數(shù)據(jù)
	 *
	 * @param key Redis鍵
	 * @param hKeys Hash鍵集合
	 * @return Hash對(duì)象集合
	 */
	public static List<Object> hMultiGet(final String key, final Collection<Object> hKeys) {

		return redisTemplate.opsForHash().multiGet(key, hKeys);
	}

	// 存儲(chǔ)Set相關(guān)操作

	/**
	 * 往Set中存入數(shù)據(jù)
	 *
	 * @param key Redis鍵
	 * @param values 值
	 * @return 存入的個(gè)數(shù)
	 */
	public static long sSet(final String key, final Object... values) {
		Long count = redisTemplate.opsForSet().add(key, values);
		return count == null ? 0 : count;
	}

	/**
	 * 刪除Set中的數(shù)據(jù)
	 *
	 * @param key Redis鍵
	 * @param values 值
	 * @return 移除的個(gè)數(shù)
	 */
	public static long sDel(final String key, final Object... values) {
		Long count = redisTemplate.opsForSet().remove(key, values);
		return count == null ? 0 : count;
	}

	// 存儲(chǔ)List相關(guān)操作

	/**
	 * 往List中存入數(shù)據(jù)
	 *
	 * @param key Redis鍵
	 * @param value 數(shù)據(jù)
	 * @return 存入的個(gè)數(shù)
	 */
	public static long lPush(final String key, final Object value) {
		Long count = redisTemplate.opsForList().rightPush(key, value);
		return count == null ? 0 : count;
	}

	/**
	 * 往List中存入多個(gè)數(shù)據(jù)
	 *
	 * @param key Redis鍵
	 * @param values 多個(gè)數(shù)據(jù)
	 * @return 存入的個(gè)數(shù)
	 */
	public static long lPushAll(final String key, final Collection<Object> values) {
		Long count = redisTemplate.opsForList().rightPushAll(key, values);
		return count == null ? 0 : count;
	}

	/**
	 * 往List中存入多個(gè)數(shù)據(jù)
	 *
	 * @param key Redis鍵
	 * @param values 多個(gè)數(shù)據(jù)
	 * @return 存入的個(gè)數(shù)
	 */
	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 開(kāi)始位置
	 * @param end 結(jié)束位置（start=0，end=-1表示獲取全部元素）
	 * @return List對(duì)象
	 */
	public static List<Object> lGet(final String key, final int start, final int end) {
		return redisTemplate.opsForList().range(key, start, end);
	}
}

ok，本博客只能學(xué)習(xí)參考，因?yàn)橹皇且o客戶(hù)一些在線(xiàn)用戶(hù)的證明而已，這個(gè)臨時(shí)的統(tǒng)計(jì)不能用于生產(chǎn)，要做比較齊全的在線(xiàn)用戶(hù)統(tǒng)計(jì)，需要花多點(diǎn)時(shí)間，有問(wèn)題希望能指出。ok，簡(jiǎn)單記錄一下，方便之后自己回顧

到此這篇關(guān)于SpringSession通過(guò)Redis統(tǒng)計(jì)在線(xiàn)用戶(hù)數(shù)量的文章就介紹到這了,更多相關(guān)Redis在線(xiàn)用戶(hù)數(shù)量?jī)?nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: