集群与负载均衡系列——nginx ip_hash或redis实现共享session(2)

小灰灰 2022-06-17 14:08 183阅读 0赞

上一篇文章介绍了利用nginx进行集群与负载均衡。今天来说说如何共享session。

#       ip\_hash #

顾名思义，根据客户端ip，计算hash值并映射到相应服务器。那么同一个用户就始终申请同一个服务器上的服务，这样的话就保证了用户信息始终一致。

当然了，既然是hash，自然免不了hash冲突，而且服务器少的时候hash冲突肯定非常严重，这个时候，需要在代码中加入链表再进行查询。当然也可以链表+红黑树，类似于jdk8中的hashMap。自然也可以直接用hashMap。

这样的话，效率不是太高。通过hash映射的时间复杂度是1，通过链表的话是做for循环，时间复杂度自然就是n。如果通过红黑树的话，因为红黑树是平衡二叉树，所以时间负载度应该这样计算 n=1+2+4+8+...2^(N-1) (N为树的深度，n为节点总数) =2^N-1 所以N=log2n+1 也就是时间复杂度为log2n。

nginx配置如下

![Center][]

#       redis #

通过redis进行session共享，每个服务器都去redis中去取session信息，键值对可以是token-用户信息，可以对token设置失效时间，如果不存在token，则session超时或不存在。否则通过token就可以在任何服务器取到session。

举一个例子，为了简单起见，这里没有设置超时时间和token的计算

这里是通过spring-boot整合redis，在spring-mvc中创建一个controller。至于如何整合redis，不在这篇文章的讨论范围内，这里没有给出代码

@RestController
    public class UserController {
    
    	@Value("${server.port}")
    	private String port;
    	
    	@Autowired  
        private RedisTemplate<String, ?> redisTemplate;
    	
    	@RequestMapping(value = "/user/{token}",
    			method = RequestMethod.GET, 
    			produces = MediaType.TEXT_PLAIN_VALUE+";charset=UTF-8")
    	public void getUser(@PathVariable final String token,HttpServletRequest request,HttpServletResponse response){
    		String id = redisTemplate.execute(new RedisCallback<String>() {
    		public String doInRedis(RedisConnection connection) throws DataAccessException {
    			 RedisSerializer<String> serializer = redisTemplate.getStringSerializer();  
                             byte[] value =  connection.get(serializer.serialize(token));  
                             return serializer.deserialize(value);  
    			}   
                    });  
    		writeJson(port+":"+id,response);
    	}
    	
    	public void writeJson(Object object,HttpServletResponse response)
        {
            try
            {
            	//DisableCircularReferenceDetect避免$ref问题
                String json = JSON.toJSONStringWithDateFormat(object, "yyyy-MM-dd HH:mm:ss",SerializerFeature.DisableCircularReferenceDetect);
                response.setContentType("text/html;charset=utf-8");
                response.getWriter().write(json);
                System.out.println("123"+port);
                response.getWriter().flush();
            }
            catch (IOException e)
            {
                e.printStackTrace();
            }
        }
    	
    }

客户端传入token，根据token去redis中取session

nginx配置如下

![Center 1][]

![Center 2][]

两个服务器为

A、linux系统 192.168.160.128:8888

![Center 3][]

![Center 4][]

B、window系统 192.168.1.102:8080

![Center 5][]![Center 6][]

简单起见，假如token为test，session为admin

单独访问两个服务器结果如下：

![Center 7][]![Center 8][]

使用统一入口localhost，当然你可以在nginx中配置成其它的，比如wulinfeng.com等。这里叫localhost不太合理，偷懒了，希望不会让你产生歧义

![Center 9][]![Center 10][]

我们看到对于不同服务器，对于同一个token：test，都返回相同的信息admin。则说明可以用来共享session。

[Center]: /images/20220617/2377bd958b3e4589b87c62e4dd7abfd5.png
[Center 1]: /images/20220617/52fa5fa5cdaf4d18997e1c2ba4542468.png
[Center 2]: /images/20220617/6938550b6d8546f3beda26608667486d.png
[Center 3]: /images/20220617/e3fe89ec2d3242f2b5dceee2501e0b24.png
[Center 4]: /images/20220617/453333d0ceb1465ea19f50f124d85457.png
[Center 5]: https://img-blog.csdn.net/20170427232722622?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3VkdXlpc2h1YWk=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center
[Center 6]: /images/20220617/8ba1b7d812774dbcb90c31275dd7fd96.png
[Center 7]: https://img-blog.csdn.net/20170427232836143?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3VkdXlpc2h1YWk=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center
[Center 8]: /images/20220617/aba870df00f24127a2f226422890ba07.png
[Center 9]: https://img-blog.csdn.net/20170427233112162?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvZ3VkdXlpc2h1YWk=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center
[Center 10]: /images/20220617/cf1dd64855d9462cada73a601b5770dc.png