nginx高併發簡單配置
啟動Nginx + Keepalived
3.1、什麼是Keepalived
Keepalived是一個免費開源的,用C編寫的類似於layer3, 4 & 7交換機制軟體,具備我們平時說的第3層、第4層和第7層交換機的功能。主要提供loadbalancing(負載均衡)和high-availability(高可用)功能,負載均衡實現需要依賴Linux的虛擬服務核心模組(ipvs),而高可用是通過VRRP協議實現多臺機器之間的故障轉移服務。
上圖是Keepalived的功能體系結構,大致分兩層:使用者空間(user space)和核心空間(kernel space)。
核心空間
使用者空間:
- WatchDog:負載監控checkers和VRRP程序的狀況
- VRRP Stack:負載負載均衡器之間的失敗切換FailOver,如果只用一個負載均稀器,則VRRP不是必須的。
- Checkers:負責真實伺服器的健康檢查healthchecking,是keepalived最主要的功能。換言之,可以沒有VRRP Stack,但健康檢查healthchecking是一定要有的。
- IPVS wrapper:使用者傳送設定的規則到核心ipvs程式碼
- Netlink Reflector:用來設定vrrp的vip地址等。
Keepalived的所有功能是配置keepalived.conf檔案來實現的。
3.2、安裝Keepalived
下載keepalived地址:http://www.keepalived.org/download.html
解壓安裝:
tar -zxvf keepalived-1.2.18.tar.gz -C /usr/local/ yum install -yopensslopenssl-devel(需要安裝一個軟體包) cd keepalived-1.2.18/ && ./configure --prefix=/usr/local/keepalived make&& make install
3.3、將Keepalived安裝成Linux系統服務
將keepalived安裝成Linux系統服務,因為沒有使用keepalived的預設安裝路徑(預設路徑:/usr/local),安裝完成之後,需要做一些修改工作: 首先建立資料夾,將keepalived配置檔案進行復制: mkdir /etc/keepalived cp /usr/local/keepalived/etc/keepalived/keepalived.conf /etc/keepalived/ 然後複製keepalived指令碼檔案: cp /usr/local/keepalived/etc/rc.d/init.d/keepalived /etc/init.d/ cp /usr/local/keepalived/etc/sysconfig/keepalived /etc/sysconfig/ ln -s /usr/local/sbin/keepalived /usr/sbin/ ln -s /usr/local/keepalived/sbin/keepalived /sbin/ 可以設定開機啟動:chkconfigkeepalived on,到此我們安裝完畢!
3.4、Keepalived常用命令
servicekeepalived start servicekeepalived stop
四、Keepalived的配置
4.1、配置NGINX的主備自動重啟
1、對配置檔案進行修改:vim /etc/keepalived/keepalived.conf
1)修改master NGINX配置
! Configuration File for keepalived global_defs { router_id bhz005 ##標識節點的字串,通常為hostname } ## keepalived會定時執行指令碼並且對指令碼的執行結果進行分析,動態調整vrrp_instance的優先順序。這裡的權重weight 是與下面的優先順序priority有關,如果執行了一次檢查指令碼成功,則權重會-20,也就是由100 - 20 變成了80,Master 的優先順序為80 就低於了Backup的優先順序90,那麼會進行自動的主備切換。 如果指令碼執行結果為0並且weight配置的值大於0,則優先順序會相應增加。 如果指令碼執行結果不為0 並且weight配置的值小於0,則優先順序會相應減少。 vrrp_scriptchk_nginx { script "/etc/keepalived/nginx_check.sh" ##執行指令碼位置 interval 2 ##檢測時間間隔 weight -20 ## 如果條件成立則權重減20(-20) } ## 定義虛擬路由 VI_1為自定義標識。 vrrp_instance VI_1 { state MASTER ## 主節點為MASTER,備份節點為BACKUP ## 繫結虛擬IP的網路介面(網絡卡),與本機IP地址所在的網路介面相同(我這裡是eth6) interface eth6 virtual_router_id 172 ## 虛擬路由ID號 mcast_src_ip 192.168.1.172 ## 本機ip地址 priority 100 ##優先順序配置(0-254的值) Nopreempt ## advert_int 1 ## 組播資訊傳送間隔,倆個節點必須配置一致,預設1s authentication { auth_type PASS auth_passbhz ## 真實生產環境下對密碼進行匹配 } track_script { chk_nginx } virtual_ipaddress { 192.168.1.170 ## 虛擬ip(vip),可以指定多個 } }
2)修改Backup NGINX配置
! Configuration File for keepalived global_defs { router_id bhz006 } vrrp_scriptchk_nginx { script "/etc/keepalived/nginx_check.sh" interval 2 weight -20 } vrrp_instance VI_1 { state BACKUP interface eth7 virtual_router_id 173 mcast_src_ip 192.168.1.173 priority 90 ##優先順序配置 advert_int 1 authentication { auth_type PASS auth_passbhz } track_script { chk_nginx } virtual_ipaddress { 192.168.1.170 } }
3)nginx_check.sh 指令碼
#!/bin/bash A=`ps -C nginx–no-header |wc -l` if [ $A -eq 0 ];then /usr/local/nginx/sbin/nginx sleep 2 if [ `ps -C nginx --no-header |wc -l` -eq 0 ];then killallkeepalived fi fi
4)再把master的keepalived配置檔案 copy到master機器(172)的/etc/keepalived/ 資料夾下,在把backup的keepalived配置檔案copy到backup機器(173)的 /etc/keepalived/ 資料夾下,最後把nginx_check.sh指令碼分別copy到兩臺機器的 /etc/keepalived/資料夾下。
5)nginx_check.sh指令碼授權。賦予可執行許可權:chmod +x /etc/keepalived/nginx_check.sh
6)啟動2臺機器的nginx之後。我們啟動兩臺機器的keepalived
/usr/local/nginx/sbin/nginx servicekeepalived start ps -ef | grepnginx ps -ef | grepkeepalived
7)看一下倆臺機器的ip a 命令下都會出現一個虛擬ip。測試再不關閉Keepalived下,kill掉NGINX,再觀察是否重啟。關閉Keepalived下,kill掉NGINX,再觀察是否重啟。
五、叢集情況下Session共享解決方案
5.1、叢集情況下session會產生什麼原因?
由於session存放在伺服器端,叢集下使用者可能訪問不同的伺服器,則可能session無法共享。
5.2、Session共享解決方案
1)NGINX做的負載均衡可以繫結ip_hash,從而使同一個IP訪問同一個伺服器 ------------------該方案使得叢集失去意義。
2)利用資料庫同步session----------------------太過複雜
3)利用cookie同步session(儲存一個session到本地,再次訪問將其帶到伺服器端)----------------------安全性差、http請求都需要帶引數增加了頻寬消耗
4)使用session叢集,存放到redis中(spring-session)
5.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加速
服務分散式部署