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
会交替出现