SpringSession通过Redis统计在线用户数量的实现代码

 更新时间:2023年04月07日 09:33:13   作者:smileNicky  
这篇文章主要介绍了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);
	}
}

ok,本博客只能学习参考,因为只是要给客户一些在线用户的证明而已,这个临时的统计不能用于生产,要做比较齐全的在线用户统计,需要花多点时间,有问题希望能指出。ok,简单记录一下,方便之后自己回顾

到此这篇关于SpringSession通过Redis统计在线用户数量的文章就介绍到这了,更多相关Redis在线用户数量内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Redis:Redisson分布式锁的使用方式(推荐使用)

    Redis:Redisson分布式锁的使用方式(推荐使用)

    这篇文章主要介绍了Redis:Redisson分布式锁的使用方式(推荐使用),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-04-04
  • Redis 的 GeoHash详解

    Redis 的 GeoHash详解

    这篇文章主要介绍了Redis 的 GeoHash详解,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-11-11
  • linux服务器中搭建redis6.0.7集群

    linux服务器中搭建redis6.0.7集群

    这篇文章主要介绍了linux服务器中搭建redis6.0.7集群的相关资料,需要的朋友可以参考下
    2022-11-11
  • 使用Grafana监控Redis的操作方法

    使用Grafana监控Redis的操作方法

    这篇文章主要介绍了使用Grafana监控Redis,号称下一代可视化监控系统,结合SpringBoot使用,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-04-04
  • redis实现分布式全局唯一id的示例代码

    redis实现分布式全局唯一id的示例代码

    在某些场景中,我们需要生成全局的唯一ID,本文主要介绍了redis实现分布式全局唯一id的示例代码,具有一定的参考价值,感兴趣的可以了解一下
    2024-04-04
  • Redis 中spark参数executor-cores引起的异常解决办法

    Redis 中spark参数executor-cores引起的异常解决办法

    这篇文章主要介绍了Redis 中spark参数executor-cores引起的异常解决办法的相关资料,需要的朋友可以参考下
    2017-03-03
  • 使用AOP+redis+lua做方法限流的实现

    使用AOP+redis+lua做方法限流的实现

    本文主要介绍了使用AOP+redis+lua做方法限流的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2022-04-04
  • Redis键值设计的实践

    Redis键值设计的实践

    本文主要介绍了Redis键值设计的实践,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2023-01-01
  • Redis缓存-序列化对象存储乱码问题的解决

    Redis缓存-序列化对象存储乱码问题的解决

    这篇文章主要介绍了Redis缓存-序列化对象存储乱码问题的解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-06-06
  • redisson锁tryLock的正确使用方式

    redisson锁tryLock的正确使用方式

    这篇文章主要介绍了redisson锁tryLock的正确使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-12-12

最新评论