摘要：網(wǎng)關(guān)以及業(yè)務(wù)組件將對象存儲到或從獲取對象。二存在問題基于如上微服務(wù)的分布式架構(gòu)如果按照傳統(tǒng)方式，將對象存儲在內(nèi)存中。微服務(wù)架構(gòu)下共享對象實(shí)現(xiàn)說明客戶端請求到，基于管理將對象存儲到，并將生成的返回給客戶端。

一.簡單做一個(gè)背景說明
1.為說明問題，本文簡單微服務(wù)架構(gòu)示例如下

2.組件說明
分布式架構(gòu)，每個(gè)組件都是集群或者主備。具體說明如下：
zuul service:網(wǎng)關(guān)，API調(diào)用都走zuul service。
micro service1 & micro service2:業(yè)務(wù)功能實(shí)現(xiàn)，數(shù)據(jù)庫增刪改查。
eureka:組件注冊，zuul service,micro service等組件都注冊到eureka，管理組件調(diào)用地址。
db-master & db-slave:數(shù)據(jù)庫集群，一主兩從。
redis master & redis slave:redis集群，緩存。這里主要存儲session對象。

3.組件之間API調(diào)用
①：網(wǎng)關(guān)zuul接收到的API請求，路由至業(yè)務(wù)實(shí)現(xiàn)組件。
②：網(wǎng)關(guān)zuul以及業(yè)務(wù)組件將session對象存儲到redis、或從redis獲取session對象。
③：業(yè)務(wù)組件實(shí)現(xiàn)數(shù)據(jù)增刪改查。
④：業(yè)務(wù)組件之間通過springCloud feign組件進(jìn)行調(diào)用。
⑤：網(wǎng)關(guān)zuul以及micro service組件注冊到eureka組件，或從eureka獲取組件調(diào)用地址。

二.存在問題
基于如上微服務(wù)的分布式架構(gòu)如果按照傳統(tǒng)方式，將session對象存儲在內(nèi)存中。在zuul網(wǎng)關(guān)將路由請求至不同的micro service1或者micro service2時(shí)，內(nèi)存中的session對象將不能被共享，無法判斷用戶的登陸狀態(tài)，也無法獲取session對象存儲的全局?jǐn)?shù)據(jù)。

三.解決方案
1.Spring管理session對象
通過EnableRedisHttpSession注解支持基于Redis存儲session，全局共享session對象。

2.微服務(wù)架構(gòu)下共享session對象實(shí)現(xiàn)說明
1)客戶端API請求到zuul，zuul基于spring管理session將session對象存儲到redis，并將生成的sessionId返回給客戶端。
2)zuul將請求路由到micro service，將sessionId通過cookie頭帶給micro service。
3)micro service通過sessionId從redis獲取到已經(jīng)生成的session對象。
4)micro servcie1調(diào)用micro service2時(shí)，將sessionId也通過cookie頭帶給micro service2，micro service2通過sessionId從redis中獲取session對象。
5)客戶端再次調(diào)用時(shí)將a)步返回的sessionId增加到cookie頭，在redis中存儲的session失效之前zuul和micro service一直共享這個(gè)session。

5.具體實(shí)現(xiàn)
1)通過springframework的EnableRedisHttpSession注解管理session，zuul和micro service組件實(shí)現(xiàn)這個(gè)類以存儲、獲取redis中存儲的session對象。

import org.springframework.session.data.redis.config.annotation.web.http.EnableRedisHttpSession;
@Configuration
@EnableRedisHttpSession(maxInactiveIntervalInSeconds = GlobalConstants.SESSION_TIMOUT, redisFlushMode = RedisFlushMode.IMMEDIATE)
public class SessionConfig {
    
}

EnableRedisHttpSession注解參數(shù)說明：
maxInactiveIntervalInSeconds：session過期時(shí)間配置。
redisFlushMode：redis session刷新模式。配置為RedisFlushMode.IMMEDIATE，可以確保zuul存儲到redis的session對象在請求到micro service中能立即被獲取。在實(shí)際開發(fā)過程中出現(xiàn)由于沒有這個(gè)配置值，有時(shí)候zuul將session對象存儲到了redis，但是micro service無法立即獲取。

2)在zuul過濾器方法中調(diào)用addZuulRequestHeader增加請求頭，將sessionId通過cookie頭路由到micro service。

public class AccessFilter extends ZuulFilter {

    @Autowired
    HttpServletRequest httpServletRequest;
    @Autowired
    HttpServletResponse httpServletResponse;

    @Override
    public Object run() {
        RequestContext ctx = RequestContext.getCurrentContext();
        String sessionId = httpServletRequest.getSession().getId();
        ctx.addZuulRequestHeader("Cookie", "SESSION=" + sessionId);
        ctx.setSendZuulResponse(true);// 對該請求進(jìn)行路由
        ctx.setResponseStatusCode(200); // 返回200正確響應(yīng)

3)micro service1通過feign調(diào)用micro service2時(shí)，實(shí)現(xiàn)RequestInterceptor接口。通過增加cookie頭，將sessionId帶到micro service2。

@Configuration
public class MyRequestInterceptor implements RequestInterceptor {

    @Autowired
    HttpServletRequest request;

    @Override
    public void apply(RequestTemplate requestTemplate) {
        logger.info("MyRequestInterceptor apply begin.");
        try {
            String sessionId = RequestContextHolder.currentRequestAttributes().getSessionId();
            if (null != sessionId) {
                requestTemplate.header("Cookie", "SESSION=" + sessionId);
            }
        } catch (Exception e) {
            logger.error("MyRequestInterceptor exception: ", e);
        }
    }
}

6.驗(yàn)證
1)通過postman請求zuul服務(wù)地址，調(diào)用登陸接口。

2)查看各組件sessionId
zuul sessionId：

micro service1 sessionId:

micro service1調(diào)用micro service2 sessionId:

結(jié)論：可以看到zuul和micro service中sessionId都是相同的，都是586b*c9a4，通過這種方式實(shí)現(xiàn)了API調(diào)用過程中的session對象共享。