Nginx健康检查

Nginx健康检查nginx_upstream_check_module

nginx健康检查介绍:

​ 主动健康检查，nignx定时主动地去ping后端的服务列表，当发现某服务出现异常时，把该服务从健康列表中移除，当发现某服务恢复时，又能够将该服务加回健康列表中。nginx自带的upstream轮询可以实现业务接口切换， nginx有一个开源的实现nginx_upstream_check_module模块能更加平滑的进行业务切换

nginx自带健康检查的缺陷：

  1. Nginx只有当有访问时后，才发起对后端节点探测。
  2. 如果本次请求中，节点正好出现故障，Nginx依然将请求转交给故障的节点,然后再转交给健康的节点处理。所以不会影响到这次请求的正常进行。但是会影响效率,因为多了一次转发
  3. 自带模块无法做到预警
  4. 被动健康检查, 应用服务器没挂,但是数据库连接池不够导致应用假死, Nginx任然认为它是一个正常节点, 继续把请求打在这台服务器上

使用第三访模块nginx_upstream_check_module：

  1. 区别于nginx自带的非主动式的心跳检测，淘宝开发的tengine自带了一个提供主动式后端服务器心跳检测模块
  2. 若健康检查包类型为http，在开启健康检查功能后，nginx会根据设置的间隔向指定的后端服务器端口发送健康检查包，并根据期望的HTTP回复状态码来判断服务是否健康。
  3. 后端真实节点不可用，则请求不会转发到故障节点
  4. 故障节点恢复后，请求正常转发

介绍nginx_upstream_check_module模块针对nginx1.20+

一、模块下载解压

nginx下载地址:https://nginx.org/en/download.html

nginx_upstream_check_module模块下载:

github地址: https://github.com/yaoweibin/nginx_upstream_check_module

taobao官网：http://tengine.taobao.org/document_cn/http_upstream_check_cn.html

下载

https://codeload.github.com/yaoweibin/nginx_upstream_check_module/zip/master

在这里插入图片描述

上传到服务器并解压

tar -zxvf nginx-1.22.1.tar.gz
unzip nginx_upstream_check_module-master.zip

在这里插入图片描述

二、官方步骤

安装

在这里插入图片描述

配置

在这里插入图片描述

三、自己安装步骤跟着官网来

安装patch

yum install -y patch#(重点: 已安装nginx一定是停止运行状态的)
# 注意check_1.20.1+.patch 版本要跟你的nginx版本对应上
#(一定要执行这行命令, 要不然健康检查会报错: http upstream check module can not find any check server, make sure you've added the check servers, client: xxx.xxx.xxx.xxx, server: localhost, request: "GET /status HTTP/1.1", host: "xxx.xxx.xxx.xxx:8087")# 执行patch命令一定要在(nginx源码目录)
patch -p1 < /home/app/nginx_upstream_check_module-master/check_1.20.1+.patch

在这里插入图片描述

安装nginx和模块nginx_upstream_check_module-master

# 进入nginx安装包目录, 执行下面命令, 根据自己的实际情况安装对应参数值改成自己的 (重点: nginx一定是停止运行状态的)
./configure --user=app --group=app --with-http_ssl_module --with-threads --with-file-aio --with-http_stub_status_module --add-module=/opt/app/nginx_upstream_check_module-master/ --prefix=/opt/app/nginxmake && make install

–prefix： nginx主目录
–user： nginx启动用户
–group： nginx启动组
–add-module： 添加模块
–with-http_ssl_model： 启动ssl模块

配置nginx

Nginx会每隔3000毫秒（3秒）向每个服务器发送一个GET请求/dist-app-ytgz-approve/health_check接口ip是对应的server后面的ip端口。如果服务器连续两次（rise=2）返回2xx或3xx状态码，那么Nginx就认为这个服务器是健康的。如果服务器连续五次（fall=5）没有响应或者返回非2xx或3xx的状态码，那么Nginx就认为这个服务器是不健康的，会自动将其剔除。

为什么请求接口带/dist-app-ytgz-approve那是因为我后台application.yaml里面配置的server.servlet.context-path: /dist-app-ytgz-approve

http {upstream approve {server xxx.xxx.xxx.xxx:9010;server xxx.xxx.xxx.xxx:9090;ip_hash;check interval=3000 rise=2 fall=5 timeout=5000 type=http;   check_http_send "GET /dist-app-ytgz-approve/health_check HTTP/1.0\r\n\r\n";    check_http_expect_alive http_2xx http_3xx;# Nginx会每隔3000毫秒（3秒）向每个服务器发送一个GET请求/dist-app-ytgz-approve/health_check接口ip是对应的server后面的ip端口。如果服务器连续两次（rise=2）返回2xx或3xx状态码，那么Nginx就认为这个服务器是健康的。如果服务器连续五次（fall=5）没有响应或者返回非2xx或3xx的状态码，那么Nginx就认为这个服务器是不健康的，会自动将其剔除。}server {listen       8087;server_name  localhost;location /dist-app-ytgz-approve {proxy_pass http://approve;proxy_set_header        Host $http_host;proxy_set_header        X-Real-IP $remote_addr;proxy_set_header        X-Forwarded-For $proxy_add_x_forwarded_for;proxy_set_header        X-Forwarded-Port $server_port;proxy_set_header        X-Forwarded-Proto $scheme;add_header X-Route-Ip $upstream_addr;add_header X-Route-Status $upstream_status;}location /status {check_status;access_log off;}}
}

后台健康检查接口

package com.dist.ytgz.approve.controller;import com.dist.common.util.LogUtil;
import com.dist.ytgz.approve.service.HealthCheckService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;/*** TODO** @author <a href="mailto:zhangxiao@dist.com.cn">Zhang Xiao</a>* @since*/
@RequestMapping
@RestController
public class HealthCheckController {@Autowiredprivate HealthCheckService healthCheckService;@GetMapping("/health_check")public ResponseEntity<String> healthCheck() {// 这里可以添加检查数据库连接数的逻辑// 如果数据库连接数正常，返回200状态码// 如果数据库连接数耗尽，返回503状态码Long startTime = System.currentTimeMillis();boolean isDatabaseHealthy = healthCheckService.checkDatabaseHealth();if (isDatabaseHealthy) {Long endTime = System.currentTimeMillis();LogUtil.error("健康检查总共耗时: " + (endTime-startTime) / 1000.0);return ResponseEntity.ok("Healthy");} else {Long endTime = System.currentTimeMillis();LogUtil.error("不健康检查总共耗时: " + (endTime-startTime) / 1000.0);return ResponseEntity.status(503).body("Unhealthy");}}}package com.dist.ytgz.approve.service.impl;import com.dist.ytgz.approve.service.HealthCheckService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import javax.persistence.EntityManager;
import javax.persistence.Query;/*** TODO** @author <a href="mailto:zhangxiao@dist.com.cn">Zhang Xiao</a>* @since*/
@Service
public class HealthCheckServiceImpl implements HealthCheckService {@Autowiredprivate EntityManager em;@Overridepublic boolean checkDatabaseHealth() {try {// 这里的SQL语句应该替换为适合您的数据库的语句Query query = em.createNativeQuery("SELECT count(1) from dual");query.getSingleResult();return true;} catch (Exception e) {// 如果查询失败，那么可能是数据库连接数耗尽，或者数据库服务器出现了其他问题return false;}}
}

四、启动nginx

nginx健康检查的日志信息

在这里插入图片描述

nginx服务器状态

在这里插入图片描述
server number: 是后端服务器的数量
generation: 是Nginx reload的次数
Index: 是服务器的索引
Upstream: 是在配置中upstream的名称
Name: 是服务器IP:PORT
Status: 是服务器的状态
Rise counts: 是服务器连续检查成功的次数
Fall counts: 是连续检查失败的次数
Check type: 是检查的方式
Check port: 是后端专门为健康检查设置的端口

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/617341.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

图解二叉树遍历方法-前序遍历、中序遍历、后序遍历

图解二叉树遍历方法-前序遍历、中序遍历、后序遍历

一、几个概念 二叉树&#xff08;binary tree&#xff09;&#xff1a;是 n&#xff08;n > 0&#xff09;个结点&#xff08;每个结点最多只有2棵子树&#xff09;的有限集合&#xff0c;该集合可为空集&#xff08;称为空二叉树&#xff09;&#xff0c;或由一个根节点和…
阅读更多...
使用Redis实现用户最近浏览记录

使用Redis实现用户最近浏览记录

系列文章目录 文章目录 系列文章目录前言 前言 前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到网站&#xff0c;这篇文章男女通用&#xff0c;看懂了就去分享给你的码吧。 Redis是一个key-va…
阅读更多...
使用VBA巧妙获取图表数据源区域

使用VBA巧妙获取图表数据源区域

在日常工作中&#xff0c;使用VBA操作Excel图表是经验遇到的工作创建。 示例图表如下&#xff1a; 使用如下代码可以更新图表的数据源区域&#xff0c;增加一个数据系列。 Sub UpdateChart()ActiveSheet.ChartObjects(1).ActivateActiveChart.SetSourceData Source:Range(&qu…
阅读更多...
牛客研究生复试刷题（1）

牛客研究生复试刷题（1）

KY30进制转换 1.最开始没有考虑到大数问题，可以说是没考虑完全，输入类型使用的是int64_t，只ac了一半测试用例。所以在数很大找不到合适的数据类型存储时，要考虑使用string来存放。 2.使用string存放数字的时候就要考虑：字符和数字之间的转换。字符转换成数字：str[i]-0，…
阅读更多...
从 0 搭建公司Jenkins服务 Centos7

从 0 搭建公司Jenkins服务 Centos7

从 0 搭建公司Jenkins服务 Centos7 安装 (运维人员) 安装环境 配置DNS安装JDK17安装Jenkins安装Docker安装GIT安装Ansible启动Jenkins安装插件配置凭据配置共享库配置 (开发经理)使用 (开发、测试人员) 安装 (运维人员) 安装环境 配置DNS 新安装系统的服务器无法解析域名&a…
阅读更多...
CMake 学习笔记2

CMake 学习笔记2

其他很好的总结 CMake教程系列-01-最小配置示例 - 知乎 CMake 保姆级教程&#xff08;上&#xff09; | 爱编程的大丙 10-补充(完结)_哔哩哔哩_bilibili 1、基本关键字 SET命令的补充 &#xff08;1&#xff09;SET命令设置执行标准 #增加-stdc11 set(CMAKE_CXX_STANDARD…
阅读更多...
二、Flask会话技术和模板语言

二、Flask会话技术和模板语言

Cookie Session # views.py: 路由 + 视图函数 import datetimefrom flask import Blueprint, render_template, request, redirect, session from .models import *# 蓝图 blue = Blueprint(user, __name__)# 首页 可以写两个路由，都是访问同一个函数 @blue.route(/) @blue.ro…
阅读更多...
【算法基础2】前缀和与差分

【算法基础2】前缀和与差分

目录 前缀和与差分1.综述2.前缀和&#xff08;1&#xff09;一维前缀和&#xff08;2&#xff09;二维前缀和&#xff08;子矩阵的和&#xff09; 3.差分&#xff08;1&#xff09;一维差分&#xff08;2&#xff09;二维差分&#xff08;差分矩阵&#xff09; 前缀和与差分 1…
阅读更多...
简介：基于Web的产品3D

简介：基于Web的产品3D

基于 Web 的产品 3D 通过可视化界面获得各种选项来个性化他们的产品&#xff0c;例如颜色、材料、尺寸、文字、徽标、零件等。 在过去几年中&#xff0c;随着 3D 建模和渲染软件的出现&#xff0c;3D 渲染现在更常用于营销和促销目的。设计师、制造商和营销人员使用 3D 产品渲…
阅读更多...
64B/66B编码

64B/66B编码

一、前言 8B/10B编码主要作用的优化直流平衡&#xff0c;从8bit中插2个bit进去&#xff0c;这样的话最终效果能够使长0或者长1的位数不超过5位&#xff0c;达到很好的效果。但是由于8B/10B编码的带宽利用率非常低&#xff0c;10G的带宽只有8G在传输有效数据&#xff0c;2G的带…
阅读更多...
Java | Leetcode Java题解之第27题移除元素

Java | Leetcode Java题解之第27题移除元素

题目&#xff1a; 题解&#xff1a; class Solution {public int removeElement(int[] nums, int val) {int left 0;int right nums.length;while (left < right) {if (nums[left] val) {nums[left] nums[right - 1];right--;} else {left;}}return left;} }
阅读更多...
GAN：对抗生成网络【通俗易懂】

GAN：对抗生成网络【通俗易懂】

一、概述 对抗生成网络&#xff08;GAN&#xff09;是一种深度学习模型&#xff0c;由两个神经网络组成&#xff1a;生成器G和判别器D。这两个网络被训练来协同工作&#xff0c;以生成接近真实数据的新样本。 生成器的任务是接收一个随机噪声向量&#xff0c;并将其转换为与真…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023