spring-session解决session一致性问题

偏执的太偏执、 2022-05-11 12:10 280阅读 0赞

**1.新建Maven项目，pom.xml加入如下：**

<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>2.0.0.RELEASE</version>
    		<relativePath /> 
    	</parent>
    	
    	<properties>
    		<weixin-java-mp.version>2.8.0</weixin-java-mp.version>
    		<maven.compiler.source>1.8</maven.compiler.source>
    		<maven.compiler.target>1.8</maven.compiler.target>
    		<maven.compiler.encoding>UTF-8</maven.compiler.encoding>
    		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    		<project.build.locales>zh_CN</project.build.locales>
    	</properties>
    
    	<dependencies>
    		<dependency>
    			<groupId>org.projectlombok</groupId>
    			<artifactId>lombok</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    			
    		</dependency>
    		
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>fastjson</artifactId>
    			<version>1.2.47</version>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-data-redis</artifactId>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.springframework.session</groupId>
    			<artifactId>spring-session-data-redis</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.apache.commons</groupId>
    			<artifactId>commons-pool2</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>redis.clients</groupId>
    			<artifactId>jedis</artifactId>
    		</dependency>
    
    	</dependencies>
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.apache.maven.plugins</groupId>
    				<artifactId>maven-compiler-plugin</artifactId>
    				<configuration>
    					<source>1.8</source>
    					<target>1.8</target>
    				</configuration>
    			</plugin>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    				<configuration>
    					<maimClass>com.meiteedu.WxMpApplication</maimClass>
    				</configuration>
    				<executions>
    					<execution>
    						<goals>
    							<goal>repackage</goal>
    						</goals>
    					</execution>
    				</executions>
    
    			</plugin>
    		</plugins>
    	</build>

**2.新建redis的配置类**

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服务器的连接
     * 
     * @author mayn
     *
     */
    // maxInactiveIntervalInSeconds为SpringSession的过期时间（单位：秒）
    @EnableRedisHttpSession(maxInactiveIntervalInSeconds = 1800)
    public class SessionConfig {
    
    	// 冒号后的值为没有配置文件时，制动装载的默认值
    	@Value("${redis.hostname:localhost}")
    	String hostName;
    	
    	@Value("${redis.port}")
    	int port;
    	
    	@Value("${redis.password}")
    	String password;
    
    	@SuppressWarnings("deprecation")
    	@Bean
    	public JedisConnectionFactory connectionFactory() {
    		JedisConnectionFactory connection = new JedisConnectionFactory();
    		connection.setPort(port);
    		connection.setHostName(hostName);
    		connection.setPassword(password);
    		return connection;
    	}
    }

**3.新建初始化redis配置类**

import org.springframework.session.web.context.AbstractHttpSessionApplicationInitializer;
    
    //初始化Session配置
    public class SessionInitializer extends AbstractHttpSessionApplicationInitializer{
        public SessionInitializer() {
            super(SessionConfig.class);
        }
    }

**4.新建一个启动类**

@SpringBootApplication
    @RestController
    public class TestSessionApp {
    	
    	@Value("${server.port}")
    	private String serverPort;
    
    	// 创建session 会话
    	// http://127.0.0.1:8080/createSession?name=aaa
    	@RequestMapping("/createSession")
    	public String createSession(HttpServletRequest request, String name) {
    		HttpSession session = request.getSession();
    		System.out.println("存入Session sessionid:信息" + session.getId() + ",name:" + name + ",serverPort:" + serverPort);
    		session.setAttribute("name", name);
    		return serverPort + "success";
    	}
    
    	// 获取session 会话
    	@RequestMapping("/getSession")
    	public Object getSession(HttpServletRequest request) {
    		// 参数为true的情况下，客户端使用对应的sessionid查不到对应的session，会创建一个新的session
    		// 参数为false的情况下，客户端使用对应的sessionid查不到对应的session，不会创建一个新的session
    		HttpSession session = request.getSession(false);
    		
    		if (session == null) {
    			return serverPort + "服务器上没有session...";
    		}
    		
    		System.out.println("获取Session sessionid:信息" + session.getId() + ",serverPort:" + serverPort);
    		Object value = session.getAttribute("name");
    		return serverPort + "-" + value;
    	}
    	
    	@RequestMapping("/getServerPort")
    	public String getServerPort () {
    		return serverPort;
    	}
    
    	public static void main(String[] args) {
    		SpringApplication.run(TestSessionApp.class, args);
    	}
    }

**5.启动两个集群环境，端口号分别为8080和8081**

**访问[http://127.0.0.1:8080/createSession?name=aaa][http_127.0.0.1_8080_createSession_name_aaa]，往8080服务器session上存取数据**

![70][]

**此时8081服务器的session也可以拿到8080服务器存取的数据了**

![70 1][]

**查看redis，session保存在redis里面**

![70 2][]

[http_127.0.0.1_8080_createSession_name_aaa]: http://127.0.0.1:8080/createSession?name=aaa
[70]: /images/20220505/626a8a5f45ea4e92954cc090bb17b312.png
[70 1]: /images/20220505/018e6a3b40c8440a9a59ea1f1399f5c3.png
[70 2]: /images/20220505/66c5019aa7564b9a856f9ad6a707c96f.png