在傳統(tǒng)的單服務(wù)架構(gòu)中，一般來(lái)說(shuō)，只有一個(gè)服務(wù)器，那么不存在 Session

共享問(wèn)題，但是在分布式/集群項(xiàng)目中，Session 共享則是一個(gè)必須面對(duì)的問(wèn)題，先看一個(gè)簡(jiǎn)單的架構(gòu)圖：

在這樣的架構(gòu)中，會(huì)出現(xiàn)一些單服務(wù)中不存在的問(wèn)題，例如客戶端發(fā)起一個(gè)請(qǐng)求，這個(gè)請(qǐng)求到達(dá) Nginx 上之后，被
Nginx 轉(zhuǎn)發(fā)到 Tomcat A 上，然后在 Tomcat A 上往 session 中保存了一份數(shù)據(jù)，下次又來(lái)一個(gè)請(qǐng)求，這個(gè)請(qǐng)求被轉(zhuǎn)發(fā)到 Tomcat
B 上，此時(shí)再去 Session中獲取數(shù)據(jù)，發(fā)現(xiàn)沒(méi)有之前的數(shù)據(jù)。對(duì)于這一類(lèi)問(wèn)題的解決，思路很簡(jiǎn)單，就是將各個(gè)服務(wù)之間需要共享的數(shù)據(jù)，保存到一個(gè)公共的地方（主流方案就是 Redis）：

1 實(shí)戰(zhàn)

1.1 創(chuàng)建工程

首先 創(chuàng)建一個(gè) Spring Boot 工程，引入 Web、Spring Session 以及 Redis:

創(chuàng)建成功之后，pom.xml 文件如下：

<dependencies>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.session</groupId>
    <artifactId>spring-session-data-redis</artifactId>
  </dependency>
</dependencies>

注意：

這里我使用的 Spring Boot 版本是 2.1.4 ，如果使用當(dāng)前最新版 Spring Boot2.1.5的話，除了上面這些依賴之外，需要額外添加 Spring Security 依賴（其他操作不受影響，僅僅只是多了一個(gè)依賴，當(dāng)然也多了 Spring Security 的一些默認(rèn)認(rèn)證流程）。

1.2 配置 Redis

spring.redis.host=192.168.66.128
spring.redis.port=6379
spring.redis.password=123
spring.redis.database=0

1.3 使用

配置完成后 ，就可以使用 Spring Session 了，其實(shí)就是使用普通的 HttpSession ，其他的 Session 同步到 Redis 等操作，框架已經(jīng)自動(dòng)幫你完成了：

@RestController
public class HelloController {
  @Value("${server.port}")
  Integer port;
  @GetMapping("/set")
  public String set(HttpSession session) {
    session.setAttribute("user", "javaboy");
    return String.valueOf(port);
  }
  @GetMapping("/get")
  public String get(HttpSession session) {
    return session.getAttribute("user") + ":" + port;
  }
}

考慮到一會(huì) Spring Boot 將以集群的方式啟動(dòng) ，為了獲取每一個(gè)請(qǐng)求到底是哪一個(gè) Spring Boot 提供的服務(wù)，需要在每次請(qǐng)求時(shí)返回當(dāng)前服務(wù)的端口號(hào)，因此這里我注入了 server.port 。

接下來(lái) ，項(xiàng)目打包：

打包之后，啟動(dòng)項(xiàng)目的兩個(gè)實(shí)例：

java -jar sessionshare-0.0.1-SNAPSHOT.jar --server.port=8080
java -jar sessionshare-0.0.1-SNAPSHOT.jar --server.port=8081

然后先訪問(wèn) localhost:8080/set 向 8080 這個(gè)服務(wù)的 Session 中保存一個(gè)變量，訪問(wèn)完成后，數(shù)據(jù)就已經(jīng)自動(dòng)同步到 Redis 中 了 ：

然后，再調(diào)用 localhost:8081/get 接口，就可以獲取到 8080 服務(wù)的 session 中的數(shù)據(jù)：

此時(shí)關(guān)于 session 共享的配置就已經(jīng)全部完成了，session 共享的效果我們已經(jīng)看到了，但是每次訪問(wèn)都是我自己手動(dòng)切換服務(wù)實(shí)例，因此，接下來(lái)我們來(lái)引入 Nginx ，實(shí)現(xiàn)服務(wù)實(shí)例自動(dòng)切換。

1.4 引入 Nginx

很簡(jiǎn)單，進(jìn)入 Nginx 的安裝目錄的 conf 目錄下（默認(rèn)是在 /usr/local/nginx/conf），編輯 nginx.conf 文件:

在這段配置中：

• upstream 表示配置上游服務(wù)器
• javaboy.org 表示服務(wù)器集群的名字，這個(gè)可以隨意取名字
• upstream 里邊配置的是一個(gè)個(gè)的單獨(dú)服務(wù)
• weight 表示服務(wù)的權(quán)重，意味者將有多少比例的請(qǐng)求從 Nginx 上轉(zhuǎn)發(fā)到該服務(wù)上
• location 中的 proxy_pass 表示請(qǐng)求轉(zhuǎn)發(fā)的地址，/ 表示攔截到所有的請(qǐng)求，轉(zhuǎn)發(fā)轉(zhuǎn)發(fā)到剛剛配置好的服務(wù)集群中
• proxy_redirect 表示設(shè)置當(dāng)發(fā)生重定向請(qǐng)求時(shí)，nginx 自動(dòng)修正響應(yīng)頭數(shù)據(jù)（默認(rèn)是 Tomcat 返回重定向，此時(shí)重定向的地址是 Tomcat 的地址，我們需要將之修改使之成為 Nginx 的地址）。

配置完成后，將本地的 Spring Boot 打包好的 jar 上傳到 Linux ，然后在 Linux 上分別啟動(dòng)兩個(gè) Spring Boot 實(shí)例：

nohup java -jar sessionshare-0.0.1-SNAPSHOT.jar --server.port=8080 & nohup java -jar sessionshare-0.0.1-SNAPSHOT.jar --server.port=8081 &

其中

• nohup 表示當(dāng)終端關(guān)閉時(shí)，Spring Boot 不要停止運(yùn)行
• & 表示讓 Spring Boot 在后臺(tái)啟動(dòng)

配置完成后，重啟 Nginx：

/usr/local/nginx/sbin/nginx -s reload

Nginx 啟動(dòng)成功后，我們首先手動(dòng)清除 Redis 上的數(shù)據(jù)，然后訪問(wèn) 192.168.66.128/set 表示向 session 中保存數(shù)據(jù)，這個(gè)請(qǐng)求首先會(huì)到達(dá) Nginx 上，再由 Nginx 轉(zhuǎn)發(fā)給某一個(gè) Spring Boot 實(shí)例：

如上，表示端口為 8081 的 Spring Boot 處理了這個(gè) /set 請(qǐng)求，再訪問(wèn) /get 請(qǐng)求：

可以看到，/get 請(qǐng)求是被端口為 8080 的服務(wù)所處理的。

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

最新評(píng)論