nginx+多tomcat+shiro+redis配置负载均衡session共享

桃扇骨 2023-02-13 14:39 88阅读 0赞

首先使用nginx配置负载均衡tomcat。可以到网上找一下教程，网上多。

我的是一个nginx，2个tomcat，1个redis数据库本机安装。

项目框架中使用shiro框架做权限控制。

在SpringMVC项目中连接redis数据。使用的是spring-context-jedis。

shiro框架部分的 自定义会话管理配置 是这样配置的

</bean>

<!-- 指定本系统SESSIONID, 默认为: SESSIONID 问题: 与SERVLET容器名冲突, 如JETTY, TOMCAT 等默认SESSIONID,

当跳出SHIRO SERVLET时如ERROR-PAGE容器会为SESSIONID重新分配值导致登录会话丢失! -->

<constructor-arg name="name" value="javafast.session.id"/>

</bean>

</bean>

<!-- <bean id="sessionDAO" class="com.javafast.common.security.shiro.session.CacheSessionDAO">

</bean> -->

上面的配置中，指定com.javafast.common.security.shiro.session.JedisSessionDAO，类为自定义Session容器使用redis。并且JedisSessionDAO里面写了关于Session的各种处理。

package com.javafast.common.security.shiro.session;

import java.io.Serializable;

import java.util.Collection;

import java.util.Date;

import java.util.Map;

import java.util.Set;

import javax.servlet.http.HttpServletRequest;

import org.apache.shiro.session.Session;

import org.apache.shiro.session.UnknownSessionException;

import org.apache.shiro.session.mgt.SimpleSession;

import org.apache.shiro.session.mgt.eis.AbstractSessionDAO;

import org.apache.shiro.subject.PrincipalCollection;

import org.apache.shiro.subject.support.DefaultSubjectContext;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import redis.clients.jedis.Jedis;

import com.google.common.collect.Sets;

import com.javafast.common.config.Global;

import com.javafast.common.utils.DateUtils;

import com.javafast.common.utils.JedisUtils;

import com.javafast.common.utils.StringUtils;

import com.javafast.common.web.Servlets;

/\*\*

\* 自定义授权会话管理类

\* @author JavaFast

\*/

public class JedisSessionDAO extends AbstractSessionDAO implements SessionDAO \{

private Logger logger = LoggerFactory.getLogger(getClass());

private String sessionKeyPrefix = "shiro\_session\_";

@Override

public void update(Session session) throws UnknownSessionException \{

if (session == null || session.getId() == null) \{

return;

HttpServletRequest request = Servlets.getRequest();

if (request != null)\{

String uri = request.getServletPath();

// 如果是静态文件，则不更新SESSION

if (Servlets.isStaticFile(uri))\{

return;

// 如果是视图文件，则不更新SESSION

if (StringUtils.startsWith(uri, Global.getConfig("web.view.prefix"))

&& StringUtils.endsWith(uri, Global.getConfig("web.view.suffix")))\{

return;

// 手动控制不更新SESSION

if (Global.NO.equals(request.getParameter("updateSession")))\{

return;

Jedis jedis = null;

try \{

jedis = JedisUtils.getResource();

// 获取登录者编号

PrincipalCollection pc = (PrincipalCollection)session.getAttribute(DefaultSubjectContext.PRINCIPALS\_SESSION\_KEY);

String principalId = pc != null ? pc.getPrimaryPrincipal().toString() : StringUtils.EMPTY;

jedis.hset(sessionKeyPrefix, session.getId().toString(), principalId + "|" + session.getTimeout() + "|" + session.getLastAccessTime().getTime());

jedis.set(JedisUtils.getBytesKey(sessionKeyPrefix + session.getId()), JedisUtils.toBytes(session));

// 设置超期时间

int timeoutSeconds = (int)(session.getTimeout() / 1000);

jedis.expire((sessionKeyPrefix + session.getId()), timeoutSeconds);

logger.debug("update \{\} \{\}", session.getId(), request != null ? request.getRequestURI() : "");

\} catch (Exception e) \{

logger.error("update \{\} \{\}", session.getId(), request != null ? request.getRequestURI() : "", e);

\} finally \{

JedisUtils.returnResource(jedis);

@Override

public void delete(Session session) \{

if (session == null || session.getId() == null) \{

return;

Jedis jedis = null;

try \{

jedis = JedisUtils.getResource();

jedis.hdel(JedisUtils.getBytesKey(sessionKeyPrefix), JedisUtils.getBytesKey(session.getId().toString()));

jedis.del(JedisUtils.getBytesKey(sessionKeyPrefix + session.getId()));

logger.debug("delete \{\} ", session.getId());

\} catch (Exception e) \{

logger.error("delete \{\} ", session.getId(), e);

\} finally \{

JedisUtils.returnResource(jedis);

@Override

public Collection<Session> getActiveSessions() \{

return getActiveSessions(true);

/\*\*

\* 获取活动会话

\* @param includeLeave 是否包括离线（最后访问时间大于3分钟为离线会话）

\* @return

\*/

@Override

public Collection<Session> getActiveSessions(boolean includeLeave) \{

return getActiveSessions(includeLeave, null, null);

/\*\*

\* 获取活动会话

\* @param includeLeave 是否包括离线（最后访问时间大于3分钟为离线会话）

\* @param principal 根据登录者对象获取活动会话

\* @param filterSession 不为空，则过滤掉（不包含）这个会话。

\* @return

\*/

@Override

public Collection<Session> getActiveSessions(boolean includeLeave, Object principal, Session filterSession)\{

Set<Session> sessions = Sets.newHashSet();

Jedis jedis = null;

try \{

jedis = JedisUtils.getResource();

Map<String, String> map = jedis.hgetAll(sessionKeyPrefix);

for (Map.Entry<String, String> e : map.entrySet())\{

if (StringUtils.isNotBlank(e.getKey()) && StringUtils.isNotBlank(e.getValue()))\{

String\[\] ss = StringUtils.split(e.getValue(), "|");

if (ss != null && ss.length == 3)\{// jedis.exists(sessionKeyPrefix + e.getKey()))\{

// Session session = (Session)JedisUtils.toObject(jedis.get(JedisUtils.getBytesKey(sessionKeyPrefix + e.getKey())));

SimpleSession session = new SimpleSession();

session.setId(e.getKey());

session.setAttribute("principalId", ss\[0\]);

session.setTimeout(Long.valueOf(ss\[1\]));

session.setLastAccessTime(new Date(Long.valueOf(ss\[2\])));

try\{

// 验证SESSION

session.validate();

boolean isActiveSession = false;

// 不包括离线并符合最后访问时间小于等于3分钟条件。

if (includeLeave || DateUtils.pastMinutes(session.getLastAccessTime()) <= 3)\{

isActiveSession = true;

// 符合登陆者条件。

if (principal != null)\{

PrincipalCollection pc = (PrincipalCollection)session.getAttribute(DefaultSubjectContext.PRINCIPALS\_SESSION\_KEY);

if (principal.toString().equals(pc != null ? pc.getPrimaryPrincipal().toString() : StringUtils.EMPTY))\{

isActiveSession = true;

// 过滤掉的SESSION

if (filterSession != null && filterSession.getId().equals(session.getId()))\{

isActiveSession = false;

if (isActiveSession)\{

sessions.add(session);

// SESSION验证失败

catch (Exception e2) \{

jedis.hdel(sessionKeyPrefix, e.getKey());

// 存储的SESSION不符合规则

else\{

jedis.hdel(sessionKeyPrefix, e.getKey());

// 存储的SESSION无Value

else if (StringUtils.isNotBlank(e.getKey()))\{

jedis.hdel(sessionKeyPrefix, e.getKey());

logger.info("getActiveSessions size: \{\} ", sessions.size());

\} catch (Exception e) \{

logger.error("getActiveSessions", e);

\} finally \{

JedisUtils.returnResource(jedis);

return sessions;

@Override

protected Serializable doCreate(Session session) \{

HttpServletRequest request = Servlets.getRequest();

if (request != null)\{

String uri = request.getServletPath();

// 如果是静态文件，则不创建SESSION

if (Servlets.isStaticFile(uri))\{

return null;

Serializable sessionId = this.generateSessionId(session);

this.assignSessionId(session, sessionId);

this.update(session);

return sessionId;

@Override

protected Session doReadSession(Serializable sessionId) \{

Session s = null;

HttpServletRequest request = Servlets.getRequest();

if (request != null)\{

String uri = request.getServletPath();

// 如果是静态文件，则不获取SESSION

if (Servlets.isStaticFile(uri))\{

return null;

s = (Session)request.getAttribute("session\_"+sessionId);

if (s != null)\{

return s;

Session session = null;

Jedis jedis = null;

try \{

jedis = JedisUtils.getResource();

//                   if (jedis.exists(sessionKeyPrefix + sessionId))\{

session = (Session)JedisUtils.toObject(jedis.get(

JedisUtils.getBytesKey(sessionKeyPrefix + sessionId)));

//                   \}

logger.debug("doReadSession \{\} \{\}", sessionId, request != null ? request.getRequestURI() : "");

\} catch (Exception e) \{

logger.error("doReadSession \{\} \{\}", sessionId, request != null ? request.getRequestURI() : "", e);

\} finally \{

JedisUtils.returnResource(jedis);

if (request != null && session != null)\{

request.setAttribute("session\_"+sessionId, session);

return session;

@Override

public Session readSession(Serializable sessionId) throws UnknownSessionException \{

try\{

return super.readSession(sessionId);

\}catch (UnknownSessionException e) \{

return null;

public String getSessionKeyPrefix() \{

return sessionKeyPrefix;

public void setSessionKeyPrefix(String sessionKeyPrefix) \{

this.sessionKeyPrefix = sessionKeyPrefix;

这样的session共享配置，不需要在tomcat上做修改。

session共享思路理解：

当浏览器发起第一次请求给服务器，shiro会话机制会写入一个shiro自己的sessionId 到Cookies中（并且sessionId需要命名，上面的xml配置中的<constructor-arg name="name" value="javafast.session.id"/>就是给session命名，这里涉及到JSESSIONID会话失效的问题）。并且这个sessionId也会保存到redis中，以key-值的形式保存。

浏览器发起第二次请求给服务器，请求中带着Cookies中存的sessionId，到达服务器后，shiro会进行判断和比较，到redis的数据库中，是否这个sessionId是有效的。

当nginx转发请求到不同的tomcat时。最然tomcat改变了，但是浏览器中的Cookies中的sessionId始终没有改变，redis中的sessionId也没有变。这样就实现了sessionId的共享。

个人理解shiro会话机制代替了web的session会话。sessionId共享后，没有在用到web（tomcat容器）的session机制。

Redis的使用技巧，可以在Redis中查看sessionId的存储情况

开启redis，redis安装目录下的redis-server.exe,可以双击，也可以在dos命令下启动redis。

链接Redis

redis-cli是原生Redis自带的命令行工具，可以帮助您通过简单的命令连接Redis实例，进行数据管理。

在Linux命令行使用如下命令连接Redis实例：

redis-cli -h <**host**> \-p <**port**> \-a <**password**>

windows7安装redis方法：

1、下载Redis的压缩包

https://github.com/dmajkic/redis/downloads

我下载的是redis-2.4.5-win32-win64.zip

下载完后将其解压放在自己要放的目录下

解压后的目录

![https://ask-fd.zol-img.com.cn/g5/M00/0B/07/ChMkJlogIeaIXwtVAABmHJWXFlIAAiolAI2vtQAAGY0599.jpg][https_ask-fd.zol-img.com.cn_g5_M00_0B_07_ChMkJlogIeaIXwtVAABmHJWXFlIAAiolAI2vtQAAGY0599.jpg]

如果你是32位的话就进32bit的文件夹，64位就进64bit文件夹

![https://ask-fd.zol-img.com.cn/g5/M00/0B/07/ChMkJlogIeaINfO3AABpasDdhgEAAiolAI3OrEAAGmC145.jpg][https_ask-fd.zol-img.com.cn_g5_M00_0B_07_ChMkJlogIeaINfO3AABpasDdhgEAAiolAI3OrEAAGmC145.jpg]

文件夹进去后会看到一下的几个文件

![https://ask-fd.zol-img.com.cn/g5/M00/0B/07/ChMkJlogIeaINrCpAAAzkNYwUKwAAiolAI3viEAADOo907.jpg][https_ask-fd.zol-img.com.cn_g5_M00_0B_07_ChMkJlogIeaINrCpAAAzkNYwUKwAAiolAI3viEAADOo907.jpg]

redis-benchmark.exe： 性能测试 模拟N个客户端发送set，get请求

redis-check-aof.exe：更新日志检查

redis-check-dump.exe：本地数据库检查

redis-server.exe：服务程序

接下来就是安装了

打开dos命令栏，进入到redis的目录下面，输入以下命令：

redis-server.exe redis.conf

安装成功

然后再打开一个dos命令栏，进入到redis的目录下，输入以下命令：

redis-cli.exe -h 127.0.0.1 -p 6379

测试一下

set key value 存值

get key 取值

如何查看redis中的数据

1、redis有五种数据类型：string，list，hash，set，zset，不同的数据类型查看值得方式不同。

2、string：get key

list：pop key

hash: hget hash-name key

set:smembers key

zset: zrange zset-name 0 -1

3、你可以通过keys \* 查看Redis中现有的key

[https_ask-fd.zol-img.com.cn_g5_M00_0B_07_ChMkJlogIeaIXwtVAABmHJWXFlIAAiolAI2vtQAAGY0599.jpg]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9hc2stZmQuem9sLWltZy5jb20uY24vZzUvTTAwLzBCLzA3L0NoTWtKbG9nSWVhSVh3dFZBQUJtSEpXWEZsSUFBaW9sQUkydnRRQUFHWTA1OTkuanBn?x-oss-process=image/format,png
[https_ask-fd.zol-img.com.cn_g5_M00_0B_07_ChMkJlogIeaINfO3AABpasDdhgEAAiolAI3OrEAAGmC145.jpg]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9hc2stZmQuem9sLWltZy5jb20uY24vZzUvTTAwLzBCLzA3L0NoTWtKbG9nSWVhSU5mTzNBQUJwYXNEZGhnRUFBaW9sQUkzT3JFQUFHbUMxNDUuanBn?x-oss-process=image/format,png
[https_ask-fd.zol-img.com.cn_g5_M00_0B_07_ChMkJlogIeaINrCpAAAzkNYwUKwAAiolAI3viEAADOo907.jpg]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9hc2stZmQuem9sLWltZy5jb20uY24vZzUvTTAwLzBCLzA3L0NoTWtKbG9nSWVhSU5yQ3BBQUF6a05Zd1VLd0FBaW9sQUkzdmlFQUFET285MDcuanBn?x-oss-process=image/format,png