[Redis实现session数据demo：]

今天药忘吃喽~ 2023-10-12 11:04 10阅读 0赞

**目录**

前言:

Redis实现session数据共享接口：

代码讲解:

依赖:

结尾:

--------------------

## 前言: ##

> 主要记录一下笔记场景, 以免空虚

## Redis实现session数据共享接口： ##

import redis.clients.jedis.Jedis;
    
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpSession;
    import java.util.Enumeration;
    
    public class RedisSession {
        private Jedis jedis = null;
    
        public RedisSession() {
            jedis = new Jedis("localhost", 6379);
        }
    
        public HttpSession getSession(HttpServletRequest request) {
            String sessionId = request.getSession().getId();
            if (jedis.exists(sessionId)) {
                return new RedisHttpSession(sessionId, jedis);
            } else {
                return request.getSession();
            }
        }
    
        public class RedisHttpSession implements HttpSession {
            private String sessionId;
            private Jedis jedis;
    
            public RedisHttpSession(String sessionId, Jedis jedis) {
                this.sessionId = sessionId;
                this.jedis = jedis;
            }
    
            @Override
            public long getCreationTime() {
                return Long.parseLong(jedis.hget(sessionId, "creationTime"));
            }
    
            @Override
            public String getId() {
                return sessionId;
            }
    
            @Override
            public long getLastAccessedTime() {
                return Long.parseLong(jedis.hget(sessionId, "lastAccessedTime"));
            }
    
            @Override
            public void setMaxInactiveInterval(int interval) {
                jedis.hset(sessionId, "maxInactiveInterval", String.valueOf(interval));
            }
    
            @Override
            public int getMaxInactiveInterval() {
                String value = jedis.hget(sessionId, "maxInactiveInterval");
                if (value == null) {
                    return -1;
                } else {
                    return Integer.parseInt(value);
                }
            }
    
            @Override
            public Object getAttribute(String name) {
                return jedis.hget(sessionId, name);
            }
    
            @Override
            public Enumeration<String> getAttributeNames() {
                return jedis.hkeys(sessionId).elements();
            }
    
            @Override
            public void setAttribute(String name, Object value) {
                jedis.hset(sessionId, name, String.valueOf(value));
            }
    
            @Override
            public void removeAttribute(String name) {
                jedis.hdel(sessionId, name);
            }
    
            @Override
            public void invalidate() {
                jedis.del(sessionId);
            }
    
            @Override
            public boolean isNew() {
                return false;
            }
        }
    }

### 代码讲解: ###

*  示例中，我们使用了Jedis客户端库来连接Redis数据库。我们创建了一个RedisSession类，并定义了两个方法：getSession和RedisHttpSession。
 *  getSession方法用于获取HttpSession对象。我们首先获取当前请求的Session ID，然后判断该Session ID是否存在于Redis数据库中。如果存在，则返回一个RedisHttpSession对象，否则返回原始的HttpSession对象。
 *  RedisHttpSession类实现了HttpSession接口，并使用Redis数据库来存储Session数据。我们使用hset命令将Session数据存储到名为"SESSION\_ID"的哈希表中，使用hget命令从哈希表中获取Session数据。我们还实现了setMaxInactiveInterval、getAttribute、setAttribute、removeAttribute、invalidate等方法，用于设置、获取和删除Session数据。

### 依赖: ###

> <dependency>  
> <groupId>redis.clients</groupId>  
> <artifactId>jedis</artifactId>  
> <version>3.6.0</version>  
> </dependency>  
>

### 结尾: ###

> 需要使用Redis数据库，您需要先安装Redis数据库，并在Java项目中引入Jedis客户端库。另外，您还需要在代码中配置Redis数据库的连接信息，例如主机名、端口号