nginx upstream server主动健康检测模块ngx_http_upstream_check_module 使用和源码分析(下)

目录

  • 7. 实现一个UDP健康检测功能
    • 7.1 功能定义
    • 7.2 定义一个新的健康检测类型
    • 7.3 增加udp特定的健康检测需要的配置指令
      • 7.3.1 ngx_http_upstream_check_srv_conf_s结构体的扩展
      • 7.3.2 check_udp_send的实现
      • 7.3.3 check_udp_expect的实现
      • 7.3.4 16进制解码代码的实现
    • 7.4 ngx_http_upstream_check函数的修改
    • 7.5 ngx_http_upstream_check_connect_handler函数的修改
    • 7.6 ngx_http_upstream_check_udp_init函数实现
    • 7.7 ngx_http_upstream_check_udp_parse函数实现
    • 7.7 ngx_http_upstream_check_udp_reinit函数实现
    • 7.8 测试验证

本篇对ngx_http_upstream_check_module的源码进行扩展,来实现udp健康检查功能。

-关于配置和使用部分可以查看上篇:nginx upstream server主动健康检测模块ngx_http_upstream_check_module 使用和源码分析(上)
-关于源码分析部分可以查看中篇:nginx upstream server主动健康检测模块ngx_http_upstream_check_module 使用和源码分析(中)添加链接描述

7. 实现一个UDP健康检测功能

7.1 功能定义

  • 支持后端UDP请求定义
  • 支持通过nginx配置发送一个用户自定义的请求包
  • 支持通过nginx配置希望从上游服务器响应的报文内容,通过比对实际响应内容和希望的响应内容来判断上游服务器是否正常
  • 允许配置的希望响应报文内容部分匹配就认为OK
  • 允许用text字符串或者16进制编码的方式来设置请求报文内容和响应报文内容

7.2 定义一个新的健康检测类型

static ngx_check_conf_t  ngx_check_types[] = {
......{ NGX_HTTP_CHECK_UDP,ngx_string("udp"),ngx_null_string,0,ngx_http_upstream_check_send_handler,ngx_http_upstream_check_recv_handler,ngx_http_upstream_check_udp_init,ngx_http_upstream_check_udp_parse,ngx_http_upstream_check_udp_reinit,1,0 },
......
这里定义了名称为udp的新的健康检测类型,其中ngx_http_upstream_check_send_handler和ngx_http_upstream_check_recv_handler两个回调函数是复用原先的实现的,而ngx_http_upstream_check_udp_init、ngx_http_upstream_check_udp_parse和ngx_http_upstream_check_udp_reinit是需要后面重新来实现的。这几个函数的实现留待后面来阐述。其中NGX_HTTP_CHECK_UDP定义为:
	#define NGX_HTTP_CHECK_UDP                   0X0020

7.3 增加udp特定的健康检测需要的配置指令

static ngx_command_t  ngx_http_upstream_check_commands[] = {
......{ ngx_string("check_udp_send"),NGX_HTTP_UPS_CONF|NGX_CONF_TAKE1,ngx_http_upstream_check_udp_send,0,0,NULL },{ ngx_string("check_udp_expect"),NGX_HTTP_UPS_CONF|NGX_CONF_TAKE12,ngx_http_upstream_check_udp_expect,0,0,NULL },
......
}

7.3.1 ngx_http_upstream_check_srv_conf_s结构体的扩展

为了保存解析到的配置信息,需要对ngx_http_upstream_check_srv_conf_s结构体进行扩展,增加4个字段,定义如下:

struct ngx_http_upstream_check_srv_conf_s {ngx_uint_t                 port;ngx_uint_t                 fall_count;ngx_uint_t                 rise_count;ngx_msec_t                 check_interval;ngx_msec_t                 check_timeout;ngx_uint_t                 check_keepalive_requests;ngx_check_conf_t          *check_type_conf;ngx_str_t                  send;union {ngx_uint_t             return_code;ngx_uint_t             status_alive;} code;ngx_array_t               *fastcgi_params;ngx_uint_t                default_down;ngx_uint_t                unique;ngx_uint_t                udp : 1;       /* 是否udp socket */ngx_int_t                 match_part : 1; /* 是否只要部分匹配就可以了 */ngx_int_t                 match_offset; /* udp响应期望的内容从哪个字节开始匹配 */ngx_str_t                 expect;   /* udp响应的期望内容 */
};

7.3.2 check_udp_send的实现

check_udp_send配置指令用来读取准备发送到上游服务器的报文内容,格式如下:
   check_udp_send [raw:|text:]packet   
如果指定了raw格式,那么packet中的内容就是用16进制编码的报文,如果用text格式,那么packet内容就是一个普通的字符串,如果没有指定raw或者text,那么默认是text格式。下面来实现check_udp_send配置指令的解析函数ngx_http_upstream_check_udp_send函数:

static char *ngx_http_upstream_check_udp_send(ngx_conf_t *cf,ngx_command_t *cmd, void *conf)
{ngx_str_t                           *value;ngx_http_upstream_check_srv_conf_t  *ucscf;ngx_str_t                            tmp;ngx_str_t                            content;ngx_int_t                            r;value = cf->args->elts;ucscf = ngx_http_conf_get_module_srv_conf(cf,ngx_http_upstream_check_module);/* 如果是text格式,直接取text:后的字符内容即可 */if (value[1].len > 5 && ngx_strncmp(value[1].data, "text:", 5) == 0) {ucscf->send.data = value[1].data + 5;ucscf->send.len  = value[1].len - 5;} /* 如果是raw格式,则需要进行16进制的解码 */else if(value[1].len > 4 && ngx_strncmp(value[1].data, "raw:", 4) == 0) {

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

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

相关文章

【C语言】(18)内存操作函数

内存操作函数在C语言中是用来进行内存操作的一系列标准库函数&#xff0c;这些函数包含在<string.h>头文件中。 1.复制内存区域 void *memcpy(void *dest, const void *src, size_t n); 功能&#xff1a;从源src的位置开始复制n个字节到目标dest的位置。参数&#xff…

【C语言】GtkStack及标签页的关闭

一、GtkStack GtkStack 是 GTK&#xff08;GIMP Toolkit&#xff09;库中的一个容器类&#xff0c;用于管理多个子窗口部件&#xff08;widgets&#xff09;&#xff0c;但在任何给定时间内只显示其中一个。GtkStack 提供了一种在同一个空间位置显示不同内容的方式&#xff0c…

「优选算法刷题」:只出现一次的数字

一、题目 给你一个 非空 整数数组 nums &#xff0c;除了某个元素只出现一次以外&#xff0c;其余每个元素均出现两次。找出那个只出现了一次的元素。 你必须设计并实现线性时间复杂度的算法来解决此问题&#xff0c;且该算法只使用常量额外空间。 示例 1 &#xff1a; 输入…

npm修改镜像源

背景&#xff1a;切换npm镜像源是经常遇到的事&#xff0c;下面记录下具体操作命令 1. 打开终端运行"npm config get registry"命令来查看当前配置的镜像源 npm config get registry2. 修改成淘宝镜像源"https://registry.npmjs.org/" npm config set re…

嵌入式硬件工程师与嵌入式软件工程师

嵌入式硬件工程师与嵌入式软件工程师 纯硬件设备与嵌入式设备 纯硬件设备是指内部不包含微处理器&#xff0c;无需烧写软件就能够运行的电子设备。如天线、老式收音机、老式电视机、老式洗衣机等。这类设备通常功能简单&#xff0c;易于操作&#xff0c;用户通常只需要打开电…

已解决org.springframework.web.HttpMediaTypeNotSupportedException异常的正确解决方法,亲测有效!!!

已解决org.springframework.web.HttpMediaTypeNotSupportedException异常的正确解决方法&#xff0c;亲测有效&#xff01;&#xff01;&#xff01; 文章目录 问题分析 报错原因 解决思路 解决方法 总结 问题分析 在开发基于Spring框架的Web应用时&#xff0c;我们可能…

前端工程化之:webpack2-2(内置插件)

目录 一、内置插件 1.DefinePlugin 2.BannerPlugin 3.ProvidePlugin 一、内置插件 所有的 webpack 内置插件都作为 webpack 的静态属性存在的&#xff0c;使用下面的方式即可创建一个插件对象&#xff1a; const webpack require("webpack")new webpack.插件…

浅谈bypass Etw

文章目录 c#ExecuteAssemblybypass etw c# loader 一种是通过反射找到指定空间的类中method进行Invoke 另一种是通过EntryPoint.Invoke加载 反射加载 Assembly.Load()是从String或AssemblyName类型加载程序集&#xff0c;可以读取字符串形式的程序集 Assembly.LoadFrom()从指定…

JVM内存分析与优化

JVM内存模型分析 在minor gc过程中对象挪动后&#xff0c;引用如何修改&#xff1f; 对象在堆内部挪动的过程其实是复制&#xff0c;原有区域对象还在&#xff0c;一般不直接清理&#xff0c;JVM内部清理过程只是将对象分配指针移动到区域的头位置即可&#xff0c;比如扫描s0区…

力扣刷题-135.分发糖果

n 个孩子站成一排。给你一个整数数组 ratings 表示每个孩子的评分。 你需要按照以下要求&#xff0c;给这些孩子分发糖果&#xff1a; 每个孩子至少分配到 1 个糖果。相邻两个孩子评分更高的孩子会获得更多的糖果。 请你给每个孩子分发糖果&#xff0c;计算并返回需要准备的…

零基础学编程从哪里入手,在学习中可以线上会议答疑解惑

一、前言 零基础学编程可以先从容易学的语言入手&#xff0c;比如中文编程&#xff0c;然后再学其他编程语言则会比较轻松&#xff0c;初步掌握编程思路。很多IT人士一般学2到3种编程语言。 今天给大家分享的中文编程开发语言工具资料如下&#xff1a; 编程入门视频教程链接…

速度规划:s形曲线应用(变速 停车)opencv c++显示(3)

理论篇 先看该篇&#xff0c;这里沿用了里面的变量。 应用推导篇 分为变速和停车两部分&#xff08;字迹潦草&#xff0c;可结合代码看&#xff09; 代码篇 变速函数入口&#xff1a; velocityPlanner vp; vp.SetParameters(0, 1);停车函数入口&#xff1a; ParkingVelo…

uniCloud ---- schema2code

目录 schema2code有两种方式 label属性 component属性 group属性 应用 DB Schema里有大量的信息&#xff0c;其实有了这些信息&#xff0c;前端将无需自己开发表单维护界面&#xff0c;uniCloud可以自动生成新增、修改、列表、详情的前端页面&#xff0c;以及admin端的列…

电脑小白必看:如何备份电脑系统?

电脑系统坏了怎么办&#xff1f;扛着自己的笔记本或是台式机的主机去电脑修理店花几十上百重装系统&#xff1f;或是自己用光盘或是U盘启动盘花费数小时重新安装系统&#xff1f;还在为系统问题发愁吗&#xff1f;今天&#xff0c;小编给大家一个简单的方法&#xff0c;让你免去…

ERP 系统架构的设计与实践总结

企业资源计划&#xff08;ERP&#xff09;系统是一种集成多个业务功能的综合性软件解决方案。在设计和实践 ERP 系统架构时&#xff0c;需要考虑诸多因素&#xff0c;以确保系统能够满足企业的需求&#xff0c;并提供高效、可靠、安全的服务。本文将介绍一些关键的设计原则和实…

2024Node.js零基础教程(小白友好型),nodejs新手到高手,(六)NodeJS入门——http模块

047_http模块_获取请求行和请求头 hello&#xff0c;大家好&#xff0c;那第二节我们来介绍一下如何在这个服务当中来提取 HTT 请求报文的相关内容。首先先说一下关于报文的提取的方法&#xff0c;我在这个文档当中都已经记录好了&#xff0c;方便大家后续做一个快速的查阅。 …

情绪影响下的交谈与决策偏差

人是情感丰富的生物&#xff0c;我们的情绪状态不仅塑造着我们的感知和行为&#xff0c;更深深地影响着我们的判断与决策。尤其是在人际交流中&#xff0c;带着强烈情绪进行交谈往往容易导致误解、冲突甚至做出错误的判断。本文将围绕这一现象展开讨论&#xff0c;揭示情绪对交…

图像处理之《生成隐写流》论文阅读

一、文章摘要 生成隐写术(GS)是一种新的数据隐藏方式&#xff0c;其特点是直接从秘密数据生成隐写介质。现有的GS方法通常因性能差而受到批评。本文提出了一种新的基于流的GS方法——生成隐写流(GSF)&#xff0c;该方法可以直接生成隐写图像而不需要封面图像。我们将隐写图像生…

简单实验 spring cloud gateWay 路由实验 实验

1.概要 1.1 说明 微服务统一网关实验&#xff0c;这里简单实验一下路由的功能 1.2 实验步骤&#xff0c;使用下面这个工程作为基础工程添加了一个gateWay做如下使用 简单实践 spring cloud nacos nacos-server-2.3.0-CSDN博客 2 代码 2.1 工程文件 <?xml version&quo…

Qt程序设计-导出PDF

本文讲解如何实现导出PDF,包含如何使用HTML格式和添加图片。 实例如下: 创建项目,添加两个按钮,并在D盘提前准备好图片。 窗体的头文件 #ifndef MAINWINDOW_H #define MAINWINDOW_H#include <QMainWindow>#include <QPrinter> #include <QPainter> #i…