美文网首页
Tomcat Session Redis 集群

Tomcat Session Redis 集群

作者: Charles_Shang | 来源:发表于2016-08-03 10:30 被阅读200次

    Tomcat Redis 实现简单的session集群


    目前负载的处理方案

    1.IP HASH CODE强制指定机器

    在ngnix中配置IP HashCode 指定的IP永远会Hash到指定的一台机器上,前提假定的是,用户在一次会话中
    ,IP地址不会改变,那么用户的会话信息存储在一台机器上,并且用户的所有请求都反向代理到这台机器上,但是此方法有一个
    很致命的弊端,就是用户的网络状态不会发生改变,举例:若手机用户访问网页,期间由4G网络切换带了WIFI网络下,那么就会造成
    实际处理请求的机器发生改变,会话信息发生变动而出现问题。

    2.Session同步

    将多台web服务器的session信息保存在一处公共区域,如:数据库,缓存中间件等(redis,memcache),适合中小规模的集群选择
    ,用户的session存取信息全部存储在NOSQL的KEY-VALUE数据库中(本文将重点介绍),但是

    3.Session加密放入Cookie中

    将会话信息进行对称加密放进Cookie中,优点是不用将信息放在服务器中去考虑中间件存储Session单点故障问题,但是对于
    会话信息的管理非常严格,因为Cookie存储的信息长度有限。目前大厂基本都是用的cookie存储会话信息

    Tomcat Redis Session共享配置

    准备Jar包:

    1.jedis-2.2.1.jar
    2.tomcat-redis-session-manager-1.2-tomcat-7-1.2.jar (此Jar包生成方法下文会提到)
    3.commons-pool-1.6.jar

    将上述Jar包放置于tomcat的共享lib目录下,修改tomcat的CONF下的content.xml的文件内容如下

    <?xml version="1.0" encoding="UTF-8"?>
        <WatchedResource>WEB-INF/web.xml</WatchedResource>
        <Valve className="com.radiadesign.catalina.session.RedisSessionHandlerValve"/>
        <Manager className="com.radiadesign.catalina.session.RedisSessionManager"
             host="0.0.0.0"<!-- 自行设定redis地址 -->
             port="6379"
             database="0"
             password="******"
             maxInactiveInterval="60"/>
    </Context>
    

    下面建立两个JavaEE工程,启动两个tomcat并配置相同的context.xml信息,使用ngnix做负载均衡,ngnix的配置信息如下

    #user  nobody;
    worker_processes  1;
    
    #error_log  logs/error.log;
    #error_log  logs/error.log  notice;
    #error_log  logs/error.log  info;
    #pid        logs/nginx.pid;
    
    events {
        worker_connections  1024;
    }
    
    http {
        include       mime.types;
        default_type  application/octet-stream;
        client_max_body_size 300M;
    
        sendfile        on;
    
        keepalive_timeout  200;
    
        upstream redis-sync {
          server 127.0.0.1:8081;
          server 127.0.0.1:8080;
        }
    
        server {
            listen       80;
            server_name  localhost;
    
            #charset koi8-r;
    
            #access_log  logs/host.access.log  main;
    
            location /redis-sync {
                proxy_set_header  Host $host;
                proxy_set_header  X-Real-IP  $remote_addr;
                proxy_pass  http://redis-sync;
            }
        }
    }
    

    新建一个servlet信息

    package com.charles.servlet;
    
    import java.io.IOException;
    import javax.servlet.ServletException;
    import javax.servlet.annotation.WebServlet;
    import javax.servlet.http.HttpServlet;
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    
    /**
     * Servlet implementation class SessionSyncServlet
     */
    @WebServlet(name = "SessionSync", urlPatterns = "/SessionSync")
    public class SessionSyncServlet extends HttpServlet {
        private static final long serialVersionUID = 1L;
    
        /**
         * @see HttpServlet#HttpServlet()
         */
        public SessionSyncServlet() {
            super();
            // TODO Auto-generated constructor stub
        }
    
        /**
         * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)
         */
        protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException{
        //一个项目写session,一个项目读session
        //request.getSession().setAttribute("sessionSync", "I have written");
        //response.getWriter().write("A have written");
            Object obj = request.getSession().getAttribute("sessionSync");
            String out;
            if (obj != null) {
                out = "B Have getten session "obj.toString();
            } else {
                out = "null Session";
            }
            response.getWriter().write(out);
        }
    
        /**
         * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
         */
        protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
            // TODO Auto-generated method stub
        }
    
    }
    
    

    访问地址http://localhost/redis-sync/SessionSync
    会交替出现

    A have written
    B Have getten session I have written


    附录:补充 redis-session-tomcat 打包方式
    http://blog.jobbole.com/71999/ 里有详细介绍

    相关文章

      网友评论

          本文标题:Tomcat Session Redis 集群

          本文链接:https://www.haomeiwen.com/subject/rzeqsttx.html