分布式系统下的session怎样存储

转x33g5p2x  于2022-02-11 转载在 其他  
字(5.6k)|赞(0)|评价(0)|浏览(615)

📒博客首页：崇尚学技术的科班人
🍣今天给大家带来的文章是《分布式系统下的session怎样存储》🍣
🍣希望各位小伙伴们能够耐心的读完这篇文章🍣
🙏博主也在学习阶段，如若发现问题，请告知，非常感谢🙏
💗同时也非常感谢各位小伙伴们的支持💗

1、什么是分布式系统？

（1）、定义

这里我引用名人Leslie Lamport一句话

  • 旨在支持应用程序和服务的开发，可以利用物理架构由 多个自治的处理元素 ，不共享主内存，但 通过网络发送消息合作 。

（2）、三个特点和三个概念

三个特点

  1. 多节点
  2. 消息通信
  3. 不共享内存

三个概念

  1. 分布式系统：假如微信订单系统上的多台服务器上，有的服务器上部署的是卖家端，而有的服务器上部署的是买家端，那么这样的集群就是分布式系统。
  2. 集群：假如一个项目中的系统上的多台服务器上，所有服务器上部署的都是相同的内容，那么这样的多台服务器所形成的就是集群。
  3. 分布式计算：就是我们把一个任务进行拆分成多个小任务，然后将多个小任务的结果结合在一起形成总的任务的结果，这样的过程就是分布式计算。

（3）、分布式和集群的区别和联系

  1. 分布式系统可以包含集群。比如说，我们的一个分布式项目，它上面的部署了很多的功能模块节点，它的每一个功能模块节点上可以部署了很多的集群。所以分布式系统中可以包含集群。
  2. 但是一个集群不一定是一个分布式系统。例如，我们一个All In One的项目，它上面部署了很多的集群节点，但是它就不是分布式系统。

2、广义的session

  1. 在我们的一个项目的用户的登录和登出模块，用户登录就是验证身份和存储信息，用户登出就是将浏览状态失效。
  2. http协议是无状态的，对于同一次http请求是没有上下文关系的。
  • 面临的问题：用户状态怎样存储？
    通过session（会话控制）来存储用户信息和用户浏览状态。

2.1、实现方式一：sessionId

  • 当浏览器发起请求的时候，服务器会创建一个JSESSIONID的key和value。服务器通过setCookie将JSESSIONID设置在http请求头上，客户端会将该信息存储在客户端内部，然后每一次请求都会带上该信息。

2.2、实现方式二：token

  • 如果是token方式的话，我们需要手动的在http请求头上或者url上设置token字段，请求发送到服务器的时候，服务器回去出token字段的相关值进行验证。如果要求十分严格的话，token会结合签名一起使用。

3、分布式系统下的session

1. 非分布式系统下的架构情况

2. 分布式系统下的架构情况

  • **水平扩展：**该扩展方法就是将一个服务器进行克隆的多部署几台服务器，每一台服务器上的部署的内容都是相同的。
  • **垂直扩展：**垂直扩展就是将一个服务项目进行拆分成多个模块然后部署在多个tomcat服务器上，这样多个服务器上的部署内容是不相同的。
  • **逃不开的问题：**那就是session该如何进行存储？

**解决该问题的最好的方法：**就是利用redis做缓存，然后多台tomcat从redis进行查询，进而获得对应用户的信息，进而进行后续操作。这样就能很好的解决分布式系统下的session问题。

4、解决办法

  • ReidsConstant
  1. /**
  2.  * redis常量
  3.  * @author ：小肖
  4.  * @date ：Created in 2022/2/7 21:41
  5.  */
  6. public interface RedisConstant {
  8.     String TOKEN_PREFIX = "token_%s";
  10.     Integer EXPIRE = 7200; // 设置过期时间，单位是s
  11. }
  • CookieConstant
  1. /**
  2.  * @author ：小肖
  3.  * @date ：Created in 2022/2/7 21:55
  4.  */
  5. public interface CookieConstant {
  7.     String TOKEN = "token";
  9.     Integer expire = 7200; // 单位是秒
  10. }
  • CookieUtil
  1. import javax.servlet.http.Cookie;
  2. import javax.servlet.http.HttpServletRequest;
  3. import javax.servlet.http.HttpServletResponse;
  4. import java.util.HashMap;
  5. import java.util.Map;
  7. /**
  8.  * @author ：小肖
  9.  * @date ：Created in 2022/2/7 21:47
  10.  */
  11. public class CookieUtil {
  13.     public static void set(HttpServletResponse response,
  14.                            String name,
  15.                            String value,
  16.                            int maxAge){
  17.         Cookie cookie = new Cookie(name,value);
  18.         cookie.setPath("/");
  19.         cookie.setMaxAge(maxAge);
  20.         response.addCookie(cookie);
  21.     }
  23.     public static Cookie get(HttpServletRequest request,
  24.                     String name){
  25.         Map<String, Cookie> cookieMap = getCookieMap(request);
  26.         if(cookieMap.containsKey(name)){
  27.             return cookieMap.get(name);
  28.         }else{
  29.             return null;
  30.         }
  31.     }
  33.     private static Map<String,Cookie> getCookieMap(HttpServletRequest request){
  34.         Map<String,Cookie> map = new HashMap<>();
  35.         Cookie[] cookies = request.getCookies();
  36.         if(cookies != null){
  37.             for(Cookie cookie : cookies){
  38.                 map.put(cookie.getName(),cookie);
  39.             }
  40.         }
  41.         return map;
  42.     }
  43. }
  • ProjectUrl
  1. import lombok.Data;
  2. import org.springframework.boot.context.properties.ConfigurationProperties;
  3. import org.springframework.stereotype.Component;
  5. /**
  6.  * @author ：小肖
  7.  * @date ：Created in 2022/2/7 15:19
  8.  */
  9. @ConfigurationProperties("projectUrl")
  10. @Data
  11. @Component
  12. public class ProjectUrl {
  14.     /**
  15.      * 微信公众平台授权url
  16.      */
  17.     public String wechatMpAuthorize;
  19.     /**
  20.      * 微信开放平台授权url
  21.      */
  22.     public String wechatOpenAuthorize;
  24.     /**
  25.      * 项目地址
  26.      */
  27.     public String sell;
  28. }
  • SellerUserController
  1. import com.xiao.bean.SellerInfo;
  2. import com.xiao.config.ProjectUrl;
  3. import com.xiao.constant.CookieConstant;
  4. import com.xiao.constant.RedisConstant;
  5. import com.xiao.enums.ResultEnum;
  6. import com.xiao.service.SellerService;
  7. import com.xiao.utils.CookieUtil;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.data.redis.core.StringRedisTemplate;
  10. import org.springframework.stereotype.Controller;
  11. import org.springframework.web.bind.annotation.GetMapping;
  12. import org.springframework.web.bind.annotation.RequestMapping;
  13. import org.springframework.web.bind.annotation.RequestParam;
  14. import org.springframework.web.servlet.ModelAndView;
  15. import javax.servlet.http.Cookie;
  16. import javax.servlet.http.HttpServletRequest;
  17. import javax.servlet.http.HttpServletResponse;
  18. import java.util.Map;
  19. import java.util.UUID;
  20. import java.util.concurrent.TimeUnit;
  22. /**
  23.  * 卖家用户信息
  24.  * @author ：小肖
  25.  * @date ：Created in 2022/2/7 21:26
  26.  */
  27. @Controller
  28. @RequestMapping("/seller")
  29. public class SellerUserController {
  31.     @Autowired
  32.     private SellerService sellerService;
  34.     @Autowired
  35.     private StringRedisTemplate redisTemplate;
  37.     @Autowired
  38.     private ProjectUrl projectUrl;
  40.     /**
  41.      * 该url可以和微信登录的扫码登录进行配置，可以作为returnUrl进行配置
  42.      * 登录
  43.      * @param openid
  44.      * @param response
  45.      * @param map
  46.      * @return
  47.      */
  48.     @GetMapping("/login")
  49.     public ModelAndView login(@RequestParam("openid") String openid,
  50.                               HttpServletResponse response,
  51.                               Map<String, Object> map) {
  52.         // 1. 查询数据库匹对信息
  53.         SellerInfo sellerInfo = sellerService.findSellerInfoByOpenid(openid);
  54.         if(sellerInfo == null){
  55.             map.put("msg", ResultEnum.LOGIN_FAIL.getMessage());
  56.             map.put("url","/sell/seller/order/list");
  57.             return new ModelAndView("common/error", map);
  58.         }
  60.         // 2. 向redis 中设置token
  61.         String token = UUID.randomUUID().toString();
  62.         Integer expire = RedisConstant.EXPIRE;
  63.         redisTemplate.opsForValue().set(String.format(RedisConstant.TOKEN_PREFIX,token),openid,expire, TimeUnit.SECONDS);
  65.         // 3. 添加cookie
  66.         CookieUtil.set(response, CookieConstant.TOKEN,token,expire);
  67.         return new ModelAndView("redirect:" + projectUrl.getSell() + "/sell/seller/order/list");
  68.     }
  70.     /**
  71.      * 登出
  72.      * @param request
  73.      * @param response
  74.      * @param map
  75.      * @return
  76.      */
  77.     @GetMapping("/logout")
  78.     public ModelAndView logout(HttpServletRequest request,
  79.                                HttpServletResponse response,
  80.                                Map<String, Object> map) {
  81.         Cookie cookie = CookieUtil.get(request, CookieConstant.TOKEN);
  82.         if(cookie != null){
  83.             // 1. 清除redis
  84.             redisTemplate.opsForValue().getOperations().delete(String.format(RedisConstant.TOKEN_PREFIX,cookie.getValue()));
  86.             // 2. 清除cookie
  87.             CookieUtil.set(response,CookieConstant.TOKEN,null,0);
  88.         }
  89.         map.put("msg",ResultEnum.LOGOUT_SUCCESS.getMessage());
  90.         map.put("url","/sell/seller/order/list");
  91.         return new ModelAndView("common/success",map);
  92.     }
  93. }
  • 其上实现的逻辑就是我们将用户的相关信息设置进redis缓存中，并设置相关的过期时间，如果用户登出的时候我们就将其在redis缓存中删除。

版权说明 : 本文为转载文章, 版权归原作者所有 版权申明

原文链接 : https://blog.csdn.net/weixin_56727438/article/details/122807249

内容来源于网络，如有侵权，请联系作者删除！

Javazookeeper分布式后端

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com