负载均衡NGINX+redis实现SESSION共享

Posted 2021-04-15 猿人课堂

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了负载均衡NGINX+redis实现SESSION共享相关的知识，希望对你有一定的参考价值。

网上的例子，没搜索到JAVA的，看到C#什么的，感觉挺奇怪的，就正好自己借助别人的思路用JAVA实现

SESSION共享实现的方法，我选择了COOKIE，当然其他方法比如说，中间服务器，或者制定一个SESSION规则，将哪个SEESION分配到哪个服务器。选择COOKIE实现，最主要是方便，同时也有我现在做的是ERP系统，对于并发没有太多要求。

nginx的负载均衡，去官网http://nginx.org/ 下载，现在对于很多开源JAR包或者工具下载，建议去官网，因为有最新的文档和介绍，比国内网盘存的东西，认识更加清晰

负载均衡最基本的设置，在nginx.conf里面设置，我sheng'l

[plain] view plain copy

upstream mytomcats {
server 127.0.0.1:8080;
server 127.0.0.1:8081;
server 127.0.0.1:8082;
}

[plain] view plain copy

server {
listen 8088;
server_name localhost;shengl

[plain] view plain copy

<span style="white-space:pre;"> </span> ...........
}

这是没有设置会话固定，设置了的话，SESSION的测试很难测试了。

Redis是Key，Value的数据库，当成一个数据库就好了，主要是速度快。并且容易装和使用

JAVA代码实现的核心就是判断是否已经有COOKIE的SESSIONID值，没有COOKIE中的值就SET进去，讲的很很粗糙，具体测试代码如下，测一下就很明白了。

info.java

[java] view plain copy

package htd;
import java.io.IOException;
import java.util.Set;
import javax.servlet.ServletException;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import redis.clients.jedis.Jedis;
/**
* Servlet implementation class hzm
*/
public class info extends HttpServlet {
private static final long serialVersionUID = 1L;
/**
* Default constructor.
*/
public info() {
// TODO Auto-generated constructor stub
}
/**
* @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)
*/
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
// TODO Auto-generated method stub
Jedis jedis = new Jedis("localhost");
String sessionId=null;
//判断COOKIE是否存了SessionId
Cookie[] cookeArray=request.getCookies();
for(Cookie cookie:cookeArray){
if(cookie.getName().equals("sessionId")){
System.out.println("找到了"+sessionId);
sessionId=cookie.getValue();
}
}
if(sessionId==null){
System.out.println("找不到");
sessionId=request.getSession().getId();
}
Set<String> test=jedis.zrange(sessionId, 0, 3);
response.getWriter().write("{data:"+test.toString()+",seesionId:"+sessionId+"}");
response.getWriter().write("{place:"+request.getRealPath("\\")+"}");
jedis.close();
}
/**
* @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
*/
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
// TODO Auto-generated method stub
doGet(request, response);
}
}

[java] view plain copy

package htd;
import java.io.IOException;
import java.util.Set;
import javax.servlet.ServletException;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import redis.clients.jedis.Jedis;
/**
* Servlet implementation class login
*/
public class login extends HttpServlet {
private static final long serialVersionUID = 1L;
/**
* @see HttpServlet#HttpServlet()
*/
public login() {
super();
// TODO Auto-generated constructor stub
}
/**
* @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)
*/
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
// TODO Auto-generated method stub
String sessionId=null;
//判断COOKIE是否存了SessionId
Cookie[] cookeArray=request.getCookies();
for(Cookie cookie:cookeArray){
if(cookie.getName().equals("sessionId")){
sessionId=cookie.getValue();
}
}
if(sessionId==null){
sessionId=request.getSession().getId();
Cookie cookie = new Cookie("sessionId",sessionId);
cookie.setPath("/");
response.addCookie(cookie);
}
Jedis jedis = new Jedis("localhost");
Set<String> test=jedis.zrange(sessionId, 0, 3);
if(test==null||test.isEmpty()){
System.out.println("set一次=============");
String userName = request.getParameter("userName");
String password = request.getParameter("password");
String value = request.getParameter("value");
jedis.zadd(sessionId, 1,userName);
jedis.zadd(sessionId, 2,password);
jedis.zadd(sessionId, 3,value);
test=jedis.zrange(sessionId, 0, 3);
}
response.getWriter().write(test.toString()+"sessionID:"+sessionId);;
response.getWriter().write("{place:"+request.getRealPath("\\")+"}");
jedis.expire(sessionId,600);
jedis.close();
}
/**
* @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
*/
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
// TODO Auto-generated method stub
doGet(request, response);
}
}

web.xml配置SERVLET

[plain] view plain copy

<!DOCTYPE web-app PUBLIC
"-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"
"http://java.sun.com/dtd/web-app_2_3.dtd" >
<web-app>
<display-name>Archetype Created Web Application</display-name>
<servlet>
<servlet-name>info</servlet-name>
<display-name>info</display-name>
<description></description>
<servlet-class>htd.info</servlet-class>
</servlet>
<servlet>
<servlet-name>login</servlet-name>
<display-name>login</display-name>
<description></description>
<servlet-class>htd.login</servlet-class>
</servlet>
<servlet-mapping>
<servlet-name>info</servlet-name>
<url-pattern>/info</url-pattern>
</servlet-mapping>
<servlet-mapping>
<servlet-name>login</servlet-name>
<url-pattern>/login</url-pattern>
</servlet-mapping>
</web-app>

index.jsp

[html] view plain copy

<%@ page language="java" contentType="text/html; charset=ISO-8859-1"
pageEncoding="ISO-8859-1"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<script src="/htd/resources/jquery-3.1.1.min.js"></script>
<meta http-equiv="Content-Type" content="text/html; charset=ISO-8859-1">
<title>Insert title here</title>
</head>
<script>
function getCookie(name)
{
var arr,reg=new RegExp("(^| )"+name+"=([^;]*)(;|$)");
if(arr=document.cookie.match(reg))
return unescape(arr[2]);
else
return null;
}
function getHt(){
$.ajax({
type: "GET",
url: "/htd/info",
success: function(data){
$("#t1").text("t1=="+data);
}
});
}
getHt();
function submit(){
$.ajax({
type: "GET",
url: "/htd/login",
data: {userName:$('#userName').val(),
password:$('#password').val(),
value:$('#value').val()},
success: function(data){
$("#t2").text("t2=="+data);
getHt();
}
});
}
</script>
<body>
<input id="userName" name="userName" id="userName" type="text">userId</input>
<input id="password" name="password" id="password" type="text">password</input>
<input id="value" name="value" id="value" type="text">value</input>
<input id="but1" type="button" value="sub" onclick="javascript:submit();"/>
<p id="t1"></p>
<p id="t2"></p>
</body>
</html>

前台测试结果

文章来源于网络

以上是关于负载均衡NGINX+redis实现SESSION共享的主要内容，如果未能解决你的问题，请参考以下文章

nginx+tomcat+redis负载均衡,实现session共享

springboot+spring session+redis+nginx实现session共享和负载均衡

转 tomcat+nginx+redis实现均衡负载session共享

负载均衡NGINX+redis实现SESSION共享

nginx+apache+redis实现负载均衡动静分离session共享

转载tomcat+nginx+redis实现均衡负载session共享