1、面試題
集群部署時的分布式session如何實現?
2、面試官心里分析
面試官問了你一堆dubbo是怎么玩兒的,你會玩兒dubbo就可以把單塊系統弄成分布式系統,然后分布式之后接踵而來的就是一堆問題,最大的問題就是分布式事務、接口冪等性、分布式鎖,還有最后一個就是分布式session。
當然了,分布式系統中的問題何止這么一點,非常之多,復雜度很高,但是這里就是說下常見的幾個,也是面試的時候常問的幾個。
3、面試題剖析
session是啥?瀏覽器有個cookie,在一段時間內這個cookie都存在,然后每次發請求過來都帶上一個特殊的jsessionid cookie,就根據這個東西,在服務端可以維護一個對應的session域,里面可以放點兒數據。
一般只要你沒關掉瀏覽器,cookie還在,那么對應的那個session就在,但是cookie沒了,session就沒了。常見於什么購物車之類的東西,還有登錄狀態保存之類的。
這個不多說了,懂java的都該知道這個。
但是你單塊系統的時候這么玩兒session沒問題啊,但是你要是分布式系統了呢,那么多的服務,session狀態在哪兒維護啊?
其實方法很多,但是常見常用的是兩種:
(1)tomcat + redis
這個其實還挺方便的,就是使用session的代碼跟以前一樣,還是基於tomcat原生的session支持即可,然后就是用一個叫做Tomcat RedisSessionManager的東西,讓所有我們部署的tomcat都將session數據存儲到redis即可。
在tomcat的配置文件中,配置一下
<Valve className="com.orangefunction.tomcat.redissessions.RedisSessionHandlerValve" /> <Manager className="com.orangefunction.tomcat.redissessions.RedisSessionManager" host="{redis.host}" port="{redis.port}" database="{redis.dbnum}" maxInactiveInterval="60"/>
搞一個類似上面的配置即可,你看是不是就是用了RedisSessionManager,然后指定了redis的host和 port就ok了。
<Valve className="com.orangefunction.tomcat.redissessions.RedisSessionHandlerValve" /> <Manager className="com.orangefunction.tomcat.redissessions.RedisSessionManager" sentinelMaster="mymaster" sentinels="<sentinel1-ip>:26379,<sentinel2-ip>:26379,<sentinel3-ip>:26379" maxInactiveInterval="60"/>
還可以用上面這種方式基於redis哨兵支持的redis高可用集群來保存session數據,都是ok的
(2)spring session + redis
分布式會話的這個東西重耦合在tomcat中,如果我要將web容器遷移成jetty,難道你重新把jetty都配置一遍嗎?
因為上面那種tomcat + redis的方式好用,但是會嚴重依賴於web容器,不好將代碼移植到其他web容器上去,尤其是你要是換了技術棧咋整?比如換成了spring cloud或者是spring boot之類的。還得好好思忖思忖。
所以現在比較好的還是基於java一站式解決方案,spring了。人家spring基本上包掉了大部分的我們需要使用的框架了,spirng cloud做微服務了,spring boot做腳手架了,所以用sping session是一個很好的選擇。
pom.xml
<dependency> <groupId>org.springframework.session</groupId> <artifactId>spring-session-data-redis</artifactId> <version>1.2.1.RELEASE</version> </dependency> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>2.8.1</version> </dependency>
spring配置文件中
<bean id="redisHttpSessionConfiguration" class="org.springframework.session.data.redis.config.annotation.web.http.RedisHttpSessionConfiguration"> <property name="maxInactiveIntervalInSeconds" value="600"/> </bean> <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig"> <property name="maxTotal" value="100" /> <property name="maxIdle" value="10" /> </bean> <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory" destroy-method="destroy"> <property name="hostName" value="${redis_hostname}"/> <property name="port" value="${redis_port}"/> <property name="password" value="${redis_pwd}" /> <property name="timeout" value="3000"/> <property name="usePool" value="true"/> <property name="poolConfig" ref="jedisPoolConfig"/> </bean>
web.xml
<filter> <filter-name>springSessionRepositoryFilter</filter-name> <filter-class>org.springframework.web.filter.DelegatingFilterProxy</filter-class> </filter> <filter-mapping> <filter-name>springSessionRepositoryFilter</filter-name> <url-pattern>/*</url-pattern> </filter-mapping>
示例代碼
@Controller @RequestMapping("/test") public class TestController { @RequestMapping("/putIntoSession") @ResponseBody public String putIntoSession(HttpServletRequest request, String username){ request.getSession().setAttribute("name", “leo”); return "ok"; } @RequestMapping("/getFromSession") @ResponseBody public String getFromSession(HttpServletRequest request, Model model){ String name = request.getSession().getAttribute("name"); return name; } }
上面的代碼就是ok的,給sping session配置基於redis來存儲session數據,然后配置了一個spring session的過濾器,這樣的話,session相關操作都會交給spring session來管了。接着在代碼中,就用原生的session操作,就是直接基於spring sesion從redis中獲取數據了。
實現分布式的會話,有很多種很多種方式,我說的只不過比較常見的兩種方式,tomcat + redis早期比較常用;近些年,重耦合到tomcat中去,通過spring session來實現。

