Java简单实现session保存到redis的方法示例

布满荆棘的人生 2024-02-19 14:43 3阅读 0赞

这篇文章主要介绍了Java简单实现session保存到redis的方法,结合实例形式分析了Java将session存入redis缓存服务器的相关设置、实现技巧与操作注意事项,需要的朋友可以参考下

本文实例讲述了Java简单实现session保存到redis的方法。分享给大家供大家参考，具体如下：

在负载均衡情况下，如果用户访问不同的机器，如果没有做session同步，用户就会被提出，这样用户体验非常不好，所以我们很有必要做session同步，把session放到reids缓存服务器就能很好的解决问题。下面是代码简单的实现。

**一、配置web.xml过滤器：**

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 </td> 
 <td> <code>&lt;</code><code>filter</code><code>&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>filter-name</code><code>&gt;sessionFilter&lt;/</code><code>filter-name</code><code>&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>filter-class</code><code>&gt;org.springframework.web.filter.DelegatingFilterProxy&lt;/</code><code>filter-class</code><code>&gt;</code> <code>&lt;/</code><code>filter</code><code>&gt;</code> <code>&lt;</code><code>filter-mapping</code><code>&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>filter-name</code><code>&gt;sessionFilter&lt;/</code><code>filter-name</code><code>&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>url-pattern</code><code>&gt;/*&lt;/</code><code>url-pattern</code><code>&gt;</code> <code>&lt;/</code><code>filter-mapping</code><code>&gt;</code> </td> 
 </tr> 
 </tbody> 
</table>

**二、配置对应的过滤器名字：**

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 </td> 
 <td> <code>&lt;</code><code>bean</code> <code>id</code><code>=</code><code>"sessionFilter"</code> <code>class</code><code>=</code><code>"com.plateno.interceptor.SessionFilter"</code><code>&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>property</code> <code>name</code><code>=</code><code>"redisTemplate"</code> <code>ref</code><code>=</code><code>"redisTemplate"</code><code>/&gt;</code> <code>&lt;/</code><code>bean</code><code>&gt;</code> </td> 
 </tr> 
 </tbody> 
</table>

**三、SessionFilter的实现：**

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 </td> 
 <td> <code>public</code> <code>class</code> <code>SessionFilter </code><code>extends</code> <code>GenericFilterBean { </code> <code>&nbsp;&nbsp;</code><code>private</code> <code>RedisTemplate redisTemplate;</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>void</code> <code>doFilter(ServletRequest request, ServletResponse response,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>FilterChain chain) </code><code>throws</code> <code>IOException, ServletException { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>"filter"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>HttpServletRequest re = (HttpServletRequest)request;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>HttpServletResponse res = (HttpServletResponse)response;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>TerryHttpServletRequestWrapper wrapper = </code><code>new</code> <code>TerryHttpServletRequestWrapper(re,res,redisTemplate);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>chain.doFilter(wrapper, response);</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>RedisTemplate getRedisTemplate() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>redisTemplate;</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>void</code> <code>setRedisTemplate(RedisTemplate redisTemplate) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.redisTemplate = redisTemplate;</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

**四、TerryHttpServletRequestWrapper的实现：**

**五、CacheHttpSession的实现：**

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 </td> 
 <td> <code>public</code> <code>class</code> <code>CacheHttpSession </code><code>extends</code> <code>HttpSessionWrapper { </code> <code>&nbsp;&nbsp;</code><code>private</code> <code>String sid;</code> <code>&nbsp;&nbsp;</code><code>private</code> <code>RedisTemplate redisTemplate;</code> <code>&nbsp;&nbsp;</code><code>private</code> <code>StringRedisSerializer stringSerializer = </code><code>new</code> <code>StringRedisSerializer();</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>CacheHttpSession(HttpSession session,String sid,RedisTemplate redisTemplate) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>super</code><code>(session);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.sid = sid;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.redisTemplate = redisTemplate;</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@SuppressWarnings</code><code>(</code><code>"unchecked"</code><code>)</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>Enumeration&lt;String&gt; getAttributeNames() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code> <code>byte</code><code>[] key = stringSerializer.serialize(sid);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Object result = redisTemplate.execute(</code><code>new</code> <code>RedisCallback&lt;Object&gt;() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code> <code>Object doInRedis(RedisConnection connection)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>throws</code> <code>DataAccessException { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Set&lt;</code><code>byte</code><code>[]&gt; set = connection.keys(key);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>set;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>});</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code><code>(result != </code><code>null</code><code>) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Set&lt;</code><code>byte</code><code>[]&gt; s = (Set&lt;</code><code>byte</code><code>[]&gt;)result;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Set&lt;String&gt; ss = </code><code>new</code> <code>HashSet&lt;String&gt;();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>for</code><code>(</code><code>byte</code><code>[] b : s) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>ss.add(stringSerializer.deserialize(b));</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Enumeration&lt;String&gt; en = </code><code>new</code> <code>Vector(ss).elements();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>en;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>null</code><code>;</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@SuppressWarnings</code><code>(</code><code>"unchecked"</code><code>)</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>void</code> <code>setAttribute(String name, Object value) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code> <code>byte</code><code>[] key = stringSerializer.serialize(name);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code> <code>byte</code><code>[] v = stringSerializer.serialize((String)value);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>redisTemplate.execute(</code><code>new</code> <code>RedisCallback&lt;Object&gt;() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code> <code>Object doInRedis(RedisConnection connection)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>throws</code> <code>DataAccessException { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>connection.set(key, v);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>null</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>});</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>Object getAttribute(String name) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code> <code>byte</code><code>[] key = stringSerializer.serialize(name);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@SuppressWarnings</code><code>(</code><code>"unchecked"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Object value = redisTemplate.execute(</code><code>new</code> <code>RedisCallback&lt;Object&gt;() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code> <code>Object doInRedis(RedisConnection connection)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>throws</code> <code>DataAccessException { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>connection.get(key);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>});</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>value;</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>String getId() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>sid;</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

**六、HttpSessionWrapper的实现：**

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 </td> 
 <td> <code>public</code> <code>class</code> <code>HttpSessionWrapper </code><code>implements</code> <code>HttpSession { </code> <code>&nbsp;&nbsp;</code><code>private</code> <code>HttpSession session;</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>HttpSessionWrapper(HttpSession session) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.session = session;</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>long</code> <code>getCreationTime() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>this</code><code>.session.getCreationTime();</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>String getId() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>this</code><code>.session.getId();</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>long</code> <code>getLastAccessedTime() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>this</code><code>.session.getLastAccessedTime();</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>ServletContext getServletContext() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>this</code><code>.session.getServletContext();</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>void</code> <code>setMaxInactiveInterval(</code><code>int</code> <code>interval) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.session.setMaxInactiveInterval(interval);</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>int</code> <code>getMaxInactiveInterval() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>this</code><code>.session.getMaxInactiveInterval();</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>HttpSessionContext getSessionContext() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>this</code><code>.session.getSessionContext();</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>Object getAttribute(String name) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>this</code><code>.session.getAttribute(name);</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>Object getValue(String name) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>this</code><code>.session.getValue(name);</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>Enumeration&lt;String&gt; getAttributeNames() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>this</code><code>.session.getAttributeNames();</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>String[] getValueNames() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>this</code><code>.session.getValueNames();</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>void</code> <code>setAttribute(String name, Object value) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.session.setAttribute(name,value);</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>void</code> <code>putValue(String name, Object value) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.session.putValue(name,value);</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>void</code> <code>removeAttribute(String name) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.session.removeAttribute(name);</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>void</code> <code>removeValue(String name) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.session.removeValue(name);</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>void</code> <code>invalidate() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.session.invalidate();</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>boolean</code> <code>isNew() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>this</code><code>.session.isNew();</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

以上代码就能把session保存到redis，当然这其中还有很多问题，比如sessionId的生成，session过去，对象序列化（测试为了方便统一用了string），等等很多问题。以后有时间再完善。

更多关于java相关内容感兴趣的读者可查看本站专题：《[Java+MySQL数据库程序设计总结][Java_MySQL]》、《[Java操作Excel技巧总结][Java_Excel]》、《[Java数据结构与算法教程][Java]》、《[Java文件与目录操作技巧汇总][Java 1]》及《[Java操作DOM节点技巧总结][Java_DOM]》

希望本文所述对大家java程序设计有所帮助。

[Java_MySQL]: https://www.jb51.net/Special/941.htm
[Java_Excel]: https://www.jb51.net/Special/958.htm
[Java]: https://www.jb51.net/Special/632.htm
[Java 1]: https://www.jb51.net/Special/687.htm
[Java_DOM]: https://www.jb51.net/Special/830.htm