Java自学者论坛

 找回密码
 立即注册

手机号码,快捷登录

恭喜Java自学者论坛(https://www.javazxz.com)已经为数万Java学习者服务超过8年了!积累会员资料超过10000G+
成为本站VIP会员,下载本站10000G+会员资源,会员资料板块,购买链接:点击进入购买VIP会员

JAVA高级面试进阶训练营视频教程

Java架构师系统进阶VIP课程

分布式高可用全栈开发微服务教程Go语言视频零基础入门到精通Java架构师3期(课件+源码)
Java开发全终端实战租房项目视频教程SpringBoot2.X入门到高级使用教程大数据培训第六期全套视频教程深度学习(CNN RNN GAN)算法原理Java亿级流量电商系统视频教程
互联网架构师视频教程年薪50万Spark2.0从入门到精通年薪50万!人工智能学习路线教程年薪50万大数据入门到精通学习路线年薪50万机器学习入门到精通教程
仿小米商城类app和小程序视频教程深度学习数据分析基础到实战最新黑马javaEE2.1就业课程从 0到JVM实战高手教程MySQL入门到精通教程
查看: 656|回复: 0

集群情况下Session共享解决方案 redis

[复制链接]
  • TA的每日心情
    奋斗
    2024-11-24 15:47
  • 签到天数: 804 天

    [LV.10]以坛为家III

    2053

    主题

    2111

    帖子

    72万

    积分

    管理员

    Rank: 9Rank: 9Rank: 9

    积分
    726782
    发表于 2021-9-5 10:33:11 | 显示全部楼层 |阅读模式

    1、集群情况下session会产生什么原因?

        由于session存放在服务器端,集群下用户可能访问不同的服务器,则可能session无法共享。

      2、Session共享解决方案

        1)NGINX做的负载均衡可以绑定ip_hash,从而使同一个IP访问同一个服务器 ------------------该方案使得集群失去意义。

        2)利用数据库同步session----------------------太过复杂

        3)利用cookie同步session(保存一个session到本地,再次访问将其带到服务器端)----------------------安全性差、http请求都需要带参数增加了带宽消耗

        4)使用session集群,存放到redis中(spring-session)

       3、spring-session项目,解决session共享问题

     

    <!--spring boot 与redis应用基本环境配置 -->
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-redis</artifactId>
    </dependency>
    <!--spring session 与redis应用基本环境配置,需要开启redis后才可以使用,不然启动Spring boot会报错 -->
    <dependency>
      <groupId>org.springframework.session</groupId>
      <artifactId>spring-session-data-redis</artifactId>
    </dependency>

    创建SessionConfig

    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
    import org.springframework.session.data.redis.config.annotation.web.http.EnableRedisHttpSession;
    
    //这个类用配置redis服务器的连接
    //maxInactiveIntervalInSeconds为SpringSession的过期时间(单位:秒)
    @EnableRedisHttpSession(maxInactiveIntervalInSeconds = 1800)
    Public class SessionConfig {
    
        // 冒号后的值为没有配置文件时,制动装载的默认值
        @Value("${redis.hostname:localhost}")
        String HostName;
        @Value("${redis.port:6379}")
        int Port;
    
        @Bean
        Public JedisConnectionFactory connectionFactory() {
            JedisConnectionFactory connection = new JedisConnectionFactory();
            connection.setPort(Port);
            connection.setHostName(HostName);
            return connection;
        }
    }

    初始化Session:

    //初始化Session配置
    Public class SessionInitializer extends AbstractHttpSessionApplicationInitializer{
      Public SessionInitializer() {
        super(SessionConfig.class);
        }
    }

    控制层代码

    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpSession;
    
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.boot.SpringApplication;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class SessionController {
    
        @Value("${server.port}")
        private String PORT;
    
        @RequestMapping("/index")
        public String index() {
            return "index:" + PORT;
        }
    
        /**
         * @methodDesc: 功能描述:(往session存放值)
         */
        @RequestMapping("/setSession")
        public String setSession(HttpServletRequest request, String sessionKey, String sessionValue) {
            HttpSession session = request.getSession(true);
            session.setAttribute(sessionKey, sessionValue);
            return "success,port:" + PORT;
        }
    
        /**
         * @methodDesc: 功能描述:(从Session获取值)
         */
        @RequestMapping("/getSession")
        public String getSession(HttpServletRequest request, String sessionKey) {
            HttpSession session =null;
            try {
             session = request.getSession(false);
            } catch (Exception e) {
            e.printStackTrace();
            }
            String value=null;
            if(session!=null){
                value = (String) session.getAttribute(sessionKey);
            }
            return "sessionValue:" + value + ",port:" + PORT;
        }
    
    }

     六、高并发解决方案

       业务数据库  -》 数据水平分割(分区分表分库)、读写分离

      业务应用 -》 逻辑代码优化(算法优化)、公共数据缓存

      应用服务器 -》 反向静态代理、配置优化、负载均衡(apache分发,多tomcat实例)

      系统环境 -》 JVM调优

      页面优化 -》 减少页面连接数、页面尺寸瘦身

      动态资源和静态资源分离

      CDN加速

      服务分布式部署

     

    哎...今天够累的,签到来了1...
    回复

    使用道具 举报

    您需要登录后才可以回帖 登录 | 立即注册

    本版积分规则

    QQ|手机版|小黑屋|Java自学者论坛 ( 声明:本站文章及资料整理自互联网,用于Java自学者交流学习使用,对资料版权不负任何法律责任,若有侵权请及时联系客服屏蔽删除 )

    GMT+8, 2024-12-22 01:49 , Processed in 0.060305 second(s), 30 queries .

    Powered by Discuz! X3.4

    Copyright © 2001-2021, Tencent Cloud.

    快速回复 返回顶部 返回列表