如何优雅的关闭GoWeb服务器
以下内容均为Let’s Go Further内容节选以及作者本人理解。
这里创建了一个后台进程用于捕获关闭信号，在后台进程中，主要内容为：
- 创建一个缓冲通道 quit
- 使用signal.Notify函数监听并捕获关机信号SIGINT,SIGTERM，在捕获关机信号后，缓冲通道取值操作才会执行，取消阻塞。
- 随后使用shutdown函数关闭服务器。工作原理是首先关闭所有打开的侦听器，然后关闭所有空闲连接，然后无限期地等待连接返回空闲状态，然后关闭。
- 如果关闭连接时发生错误，则将错误存储进入通道，主程序取出错误，取消阻塞。返回错误。
- 如果正常关闭连接，app.wg.Wait()等待全部后台进程全部运行结束后放行，随后向错误通道存储空值，放行主程序。此时连接和后台进程全部关闭，打印日志，结束。
package mainimport ("context""errors""fmt""net/http""os""os/signal""syscall""time"
)func (app *application) serve() error {srv := http.Server{Addr: fmt.Sprintf(":%d", app.config.port),Handler: app.routes(),IdleTimeout: time.Minute,ReadTimeout: 10 * time.Second,WriteTimeout: 30 * time.Second,//服务器可以编写自己的日志消息,实现Write方法变成io.Write接口可以将自定义日志传递进去//ErrorLog: log.New(logger, "", 0),}shutdownErr := make(chan error)//开启一个后台进程 捕获关闭信号，关闭所有连接和后台进程，实现优雅的关机go func() {//创建一个通道保存os.Signal值/*在这里使用缓冲通道，如果使用非缓冲通道，quit 通道 在信号发送的时刻没有准备去接收，会错过信号*/quit := make(chan os.Signal, 1)//使用signal.Notify监听SIGINT and SIGTERM信号并将他们传入quit通道。其他信号不会被捕获并保留他们默认的行为。signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM)//从通道中读取值，这个操作将被阻塞直到通道接收一个值s := <-quitapp.logger.PrintInfo("shutting down server", map[string]string{"signal": s.String(),})//创建一个5秒的上下文ctx, cancelFunc := context.WithTimeout(context.Background(), 5*time.Second)defer cancelFunc()//服务调用shutdown，如果成功关闭将返回nil，或者返回错误（当关闭一个监听器时遇到问题，或者在到达截止日期时没有完成）/*工作原理是首先关闭所有打开的侦听器，然后关闭所有空闲连接，然后无限期地等待连接返回空闲状态，然后关闭。*//*1. 关闭连接时没有返回错误，说明连接全部关闭，但是还有后台进程，告诉正在执行关闭后台进程，需要等待wg归零。2. 关闭连接出现错误。将err存入通道，放行主程序*///shutdown返回的是一个error类型的变量err := srv.Shutdown(ctx)//通道中存入错误，主程序取消阻塞，继续执行if err != nil {shutdownErr <- err}//正在完成后台进程app.logger.PrintInfo("completing background tasks", map[string]string{"addr": srv.Addr,})app.wg.Wait()//后台进程全部关闭后，放行主程序shutdownErr <- nil}()app.logger.PrintInfo("starting server", map[string]string{"addr": srv.Addr,"env": app.config.env,})//调用shutdown会造成ListenAndServer立刻返回一个http.ErrServerClosed错误。如果是这个错误，表明我们的程序优雅的关闭了err := srv.ListenAndServe()if !errors.Is(err, http.ErrServerClosed) {return err}//阻塞 关闭后才能继续执行err = <-shutdownErrif err != nil {return err}app.logger.PrintInfo("stopped server", map[string]string{"addr": srv.Addr,})return nil
}关于使用后台进程运行其他任务时，使用函数background来启动后台进程
func (app *application) background(fn func()) {//开启一个后台进程app.wg.Add(1)go func() {defer app.wg.Done()//使用延迟函数捕获可能出现的panicdefer func() {if err := recover(); err != nil {app.logger.PrintError(fmt.Errorf("%s", err), nil)}}()fn()}()
}
相关文章：
如何优雅的关闭GoWeb服务器
以下内容均为Let’s Go Further内容节选以及作者本人理解。 这里创建了一个后台进程用于捕获关闭信号，在后台进程中，主要内容为： 创建一个缓冲通道 quit使用signal.Notify函数监听并捕获关机信号SIGINT,SIGTERM，在捕获关机信号后…...
Python爬虫（5） --爬取网页视频
文章目录 爬虫爬取视频指定url发送请求UA伪装请求页面 获取想要的数据解析定位定位音视频位置 存放视频完整代码实现总结 爬虫 Python 爬虫是一种自动化工具，用于从互联网上抓取网页数据并提取有用的信息。Python 因其简洁的语法和丰富的库支持（如 requ…...
simulink离散传递函数得到差分方程并用C语言实现
一. 创建连续时间的传递函数 G ( s ) s 2 217 s s 2 384 s 8989 G(s) \frac{s^2217s}{s^2384s8989} G(s)s2384s8989s2217s 二. 离散连续时间的传递函数G(s) 2.1 在matlab中用c2d函数双线性变换法离散G(s)， 下面是matlab脚本代码 % 创建连续时间传递函数 …...
第十七届山东省职业院校技能大赛 中职组“网络安全”赛项任务书正式赛题
第十七届山东省职业院校技能大赛 中职组“网络安全”赛项任务书-A 目录 一、竞赛阶段 二、竞赛任务书内容 （一）拓扑图 （二）模块A 基础设施设置与安全加固(200分) （三）B模块安全事件响应/网络安全数据取证/…...
Redis内存碎片详解
什么是内存碎片? 你可以将内存碎片简单地理解为那些不可用的空闲内存。 举个例子：操作系统为你分配了 32 字节的连续内存空间，而你存储数据实际只需要使用 24 字节内存空间，那这多余出来的 8 字节内存空间如果后续没办法再被分配存储其他数…...
Python球球大作战
系列文章 序号直达链接表白系列1Python制作一个无法拒绝的表白界面2Python满屏飘字表白代码3Python无限弹窗满屏表白代码4Python李峋同款可写字版跳动的爱心5Python流星雨代码6Python漂浮爱心代码7Python爱心光波代码8Python普通的玫瑰花代码9Python炫酷的玫瑰花代码10Python多…...
机器学习（Machine Learning）的安全问题
最近看论文，看到了”对抗样本“的一些内容，然后又研究了一下其背后的东西，发现还有”机器学习的安全“这一问题，然后找了几篇博客看了一下，发现了篇2019年的比较有意思的文章，这里整理一下，方编…...
ROS1安装教程
一、环境准备 操作系统：Ubuntu 20.04 LTS 注：为保证系统干净，本文使用Docker进行 演示，如已安装相应的Ubuntu系统请忽略。 Docker安装Ubuntu系统步骤如下： # 拉取镜像 docker pull ubuntu:20.04# 创建容器 docker ru…...
大腾智能CAD：国产云原生三维设计新选择
在快速发展的工业设计领域，CAD软件已成为不可或缺的核心工具。它通过强大的建模、分析、优化等功能，不仅显著提升了设计效率与精度，还促进了设计思维的创新与拓展，为产品从概念构想到实体制造的全过程提供了强有力的技术支持。然而…...
Docker 入门：如何使用 Docker 容器化 AI 项目（一）
引言 在人工智能（AI）项目的开发和部署过程中，环境配置和依赖管理往往是开发者遇到的挑战之一。开发者通常需要在不同的机器上运行同样的代码，确保每个人使用的环境一致，才能避免 “在我的机器上可以运行”的尴尬问题。…...
【04-数据库面试】
如何创建一个新的数据库 数据库是现代信息技术中不可或缺的一部分，它为存储、检索和管理数据提供了强大的工具。无论是企业还是个人，都可能需要创建自己的数据库以满足特定的需求。本文将详细介绍创建一个新数据库的步骤，包括规划、选择数据…...
单元测试使用记录
什么是单元测试 简单来说就是对一个类中的方法进行测试，对输出的结果检查判断是否符合预期结果 但是在多年的工作中，从来没有哪个项目中真正系统的用到了单元测试，因此对它还是很陌生的，也就造成更加不会在项目中区使用它。 如何…...
《深入浅出 Servlet：Java Web 开发的基石》（二）
ServletConfig(熟练) ServletConfig对象对应web.xml文件中的<servlet>元素。例如你想获取当前Servlet在web.xml文件中的配置名，那么可以使用servletConfig.getServletName()方法获取！ 你不能自己去创建ServletConfig对象，Servlet的in…...
Pytorch | 从零构建MobileNet对CIFAR10进行分类
Pytorch | 从零构建MobileNet对CIFAR10进行分类 CIFAR10数据集MobileNet设计理念网络结构技术优势应用领域 MobileNet结构代码详解结构代码代码详解DepthwiseSeparableConv 类初始化方法前向传播 forward 方法 MobileNet 类初始化方法前向传播 forward 方法 训练过程和测试结果…...
冯诺依曼架构与哈佛架构的对比与应用
冯诺依曼架构（Von Neumann Architecture），也称为 冯诺依曼模型，是由著名数学家和计算机科学家约翰冯诺依曼（John von Neumann）在1945年提出的。冯诺依曼架构为现代计算机奠定了基础，几乎所有现代…...
【Java基础面试题032】Java中的字节码是什么？
回答重点 Java字节码是Java编译器将Java源代码编译后生成的 位于Java源代码与JVM执行的执行的机器码之间。 Java字节码由JVM解释或即时编译（JIT）为机器码执行 扩展知识 Java字节码的关键点 1）字节码结构： Java字节码是与平…...
K8s ConfigMap的基础功能介绍
在 Kubernetes 中，ConfigMap 是一种用于管理配置信息的资源对象，它允许你将 配置信息与代码解耦，方便管理和更新应用配置，而无需重新构建镜像或重启服务。 ConfigMap 的功能 存储配置信息： 可以以 键值对 的形式存储配…...
stm32制作CAN适配器4--WinUsb的使用
前面使用STM32G474芯片的USB模块做了一个CANFD程序，当时用的是HID模式，在实际使用时发现HID模块的通讯速率太慢了，只能1ms传输一帧，就会造成有些掉帧现象。 现在就把HID模块改为在Window下同样免驱的WinUsb来实现CANFD数据的传输。…...
深入理解 Java 中的 ArrayList 和 List：泛型与动态数组
深入理解 Java 中的 ArrayList 和 List：泛型与动态数组 在 Java 编程中，ArrayList 和 List 是最常用的集合类之一。它们帮助我们管理动态数据，支持按索引访问、增加、删除元素等操作。尤其在使用泛型时，理解它们之间的关系及应用…...
[react 3种方法] 获取ant组件ref用ts如何定义?
获取ant的轮播图组件, 我用ts如何定义? Strongly Type useRef with ElementRef | Total TypeScript import React, { ElementRef } from react; const lunboRef useRef<ElementRef<typeof Carousel>>(null); <Carousel autoplay ref{lunboRef}> 这样就…...
VS Code Copilot 与 Cursor 对比
选手简介 VS Code Copilot：算是“老牌”编程助手了，虽然Copilot在别的编辑器上也有扩展，不过体验最好的还是VS Code，毕竟都是微软家的所以功能集成更好一些；主要提供的是Complete和Chat能力，也就是代码补全…...
华为IPD流程6大阶段370个流程活动详解_第一阶段：概念阶段 — 81个活动
华为IPD流程涵盖了产品从概念到上市的完整过程，各阶段活动明确且相互衔接。在概念启动阶段，产品经理和项目经理分析可行性，PAC评审后成立PDT。概念阶段则包括产品描述、市场定位、投资期望等内容的确定，同时组建PDT核心组并准备项目环境。团队培训涵盖团队建设、流程、业务…...
Vue3组件封装技巧与心得
摘要： 日常开发中，用Vue组件进行业务拆分，代码解耦是一个很好的选择； 今天就来分享一下我在使用Vue3进行组件封装的一些技巧和心得，希望能够帮助到大家； 1. 组件特性： 在Vue中组件是一个独立的…...
15.初识接口1 C#
这是一个用于实验接口的代码 适合初认识接口的人 【CSDN开头介绍】（文心一言AI生成） 在C#编程世界中，接口（Interface）扮演着至关重要的角色，它定义了一组方法，但不提供这些方法的实现。它要求所…...
渗透测试-前端加密分析之RSA加密登录（密钥来源本地）
本文是高级前端加解密与验签实战的第5篇文章，本系列文章实验靶场为Yakit里自带的Vulinbox靶场，本文讲述的是绕过前端RSA加密来爆破登录。 分析 generateKey函数用来生成随机的RSA公私钥 加密的格式如下： {"username":"admin…...
题海拾贝：力扣 86.分隔链表
Hello大家好！很高兴我们又见面啦！给生活添点passion，开始今天的编程之路！ 我的博客：<但凡. 我的专栏：《编程之路》、《数据结构与算法之美》、《题海拾贝》 欢迎点赞，关注！ 1、题…...
《Mycat核心技术》第06章：Mycat问题处理总结
作者：冰河 星球：http://m6z.cn/6aeFbs 博客：https://binghe.gitcode.host 文章汇总：https://binghe.gitcode.host/md/all/all.html 星球项目地址：https://binghe.gitcode.host/md/zsxq/introduce.html 沉淀，…...
前端实现图片压缩
前端实现图片压缩的主要方法有： 使用 HTML5 的 API 利用 canvas 将图片绘制到画布上，然后通过 toDataURL 方法获取压缩后的图片数据。 使用第三方库 借助 compressorjs、browser-image-compression 等开源库，快速实现高质量的图片压缩功能。…...
Python OCR 文字识别
一.引言 文字识别，也称为光学字符识别（Optical Character Recognition, OCR），是一种将不同形式的文档（如扫描的纸质文档、PDF文件或数字相机拍摄的图片）中的文字转换成可编辑和可搜索的数据的技术。随着技…...
怿星科技联合赛力斯举办workshop活动，进一步推动双方合作
12月18日，由怿星科技与赛力斯汽车联合举办的workshop活动在赛力斯五云湖总部展开，双方嘉宾围绕智能汽车发展趋势、行业前沿技术、汽车电子网络与功能测试等核心议题展开了深度对话与交流，并现场参观演示了多套前沿产品。怿星科技CEO潘凯、汽车…...
Vue.js前端框架教程1：Vue应用启动和Vue组件
文章目录 Vue 应用Vue 应用的主要组成部分：启动 Vue 应用：Vue组件基础组件组件注册父子组件组件插槽（Slots）动态组件和 `keep-alive`Vue 应用 Vue 应用由几个主要部分组成，每个部分都有其特定的角色和职责。以下是 Vue 应用的主要组成部分以及如何启动一个 Vue 应用的介绍…...
LabVIEW深海气密采水器测控系统
LabVIEW的深海气密采水器测控系统通过高性价比的硬件选择与自主开发的软件，实现了高精度的温度、盐度和深度测量，并在实际海上试验中得到了有效验证。 项目背景 深海气密采水器是进行海底科学研究的关键工具，用LabVIEW开发了一套测控系统&am…...
SpringBoot 启动类 SpringApplication 二 run方法
配置 在Program arguments配置2个参数：--server.port8081 --spring.profiles.activedev。 run方法 run方法执行结束代表SpringBoot启动完成，即完成加载bean。 // ConfigurableApplicationContext 是IOC容器 public ConfigurableApplicationContext ru…...
【java基础系列】实现一个简单的猜数字小游戏
主要是用的java中的键盘录入和随机数两个api，实现这种人机交互的小游戏，可以用来锻炼基础算法思维 实现效果 实现代码 package com.gaofeng.day10;import java.util.Random; import java.util.Scanner;/*** author gaofeng* date 2024-12-22 - 9:21*/ …...
Liveweb视频融合共享平台在果园农场等项目中的视频监控系统搭建方案
一、背景介绍 在我国的大江南北遍布着各种各样的果园，针对这些地处偏僻的果园及农场等环境，较为传统的安全防范方式是建立围墙，但是仅靠围墙仍然无法阻挡不法分子的有意入侵和破坏，因此为了及时发现和处理一些难以察觉的问题&…...
clickhouse-题库
1、clickhouse介绍以及架构 clickhouse一个分布式列式存储数据库，主要用于在线分析查询 2、列式存储和行式存储有什么区别？ 行式存储： 1）、数据是按行存储的 2）、没有建立索引的查询消耗很大的IO 3）、建…...
kafka常用命令
安装kafka注意事项 修改 、vim kafka/config/server.properties 三个地方①brokerId ②logs地址③指定节点 一、创建主题 （必须指定分区，指定副本） #在kafka bin目录下执行以下命令 #①连接hadoop01 创建主题为TEST 分区1 副本3个 bin/ka…...
在 Django 中使用 SMTP 发送邮件是一个常见的需求
在 Django 中使用 SMTP 发送邮件是一个常见的需求，通常用于发送用户注册确认邮件、密码重置邮件等。下面是一个简单的示例，展示了如何在 Django 中配置 SMTP 发送邮件，并创建一个包含表单、路由和视图的界面来发送邮件。 1. 配置 Django 项目…...
JS中的原型与原型链
1. 基本概念 原型（Prototype）：每个对象都有一个内部属性 [[Prototype]]，通常通过 __proto__ 访问（非标准，但广泛支持）。 原型链（Prototype Chain）：对象通过原…...
STM32F407 | Embedded IDE01 - vscode搭建Embedded IDE开发环境（支持JLINK、STLINK、DAPLINK）
导言 Embedded IDE官网:https://em-ide.com/docs/intro 我猜肯定有部分人使用SI Keil开发STM32项目，也有vscode Keil开发STM32程序。SI或vscode编写代码，然后切换Keil编译、下载、调试程序。有一段时间，我也是这么干的。但是，程…...
放弃机器学习框架，如何用Python做物体检测？
每当我们听说“物体检测”时，就会想到机器学习和各种不同的框架。但实际上，我们可以在不使用机器学习或任何其他框架的情况下进行物体检测。在本文中，我将向你展示如何仅使用Python进行操作。 首先，我们定义一个模板图像…...
)
基于langchain的Agent(实现实时查询天气)
心血来潮，玩一下Agent，实现了多轮对话功能 import requests, jsonfrom langchain.agents import load_tools from langchain.agents import initialize_agent from langchain_community.llms.tongyi import Tongyi from langchain.memory import Conver…...
OB删除1.5亿数据耗费2小时
目录 回顾：mysql是怎么删除数据的？ 删除方案 代码实现 执行结果 结论 本篇是实际操作 批量处理数据以及线程池线程数设置 记录学习 背景：有一张用户标签表，存储数据量达4个亿，使用OceanBase存储，由于…...
深度学习之目标检测——RCNN
Selective Search 背景:事先不知道需要检测哪个类别,且候选目标存在层级关系与尺度关系 常规解决方法：穷举法，在原始图片上进行不同尺度不同大小的滑窗，获取每个可能的位置 弊端：计算量大，且尺度不能兼顾 Selective …...
Vue.js前端框架教程7：Vue计算属性和moment.js
文章目录 计算属性（Computed Properties）基本用法缓存机制计算属性 vs 方法使用场景计算属性的 setter 和 getter结论Moment.js 进行时间处理1. 安装 Moment.js2. 在 Vue 组件中引入 Moment.js3. 在全局使用 Moment.js4. 使用 Vue 插件的方式引入 Moment.js5. 常用日期格式化…...
了解RPC
本文来自智谱清言 --------- RPC（Remote Procedure Call，远程过程调用）是一种允许程序调用位于远程计算机上的子程序或服务的技术。这种技术使得构建分布式计算变得更加容易，因为它提供了强大的远程调用能力，同时保持…...
【Go】Go数据类型详解—指针
1. 前言 在我看来，一门编程语言语法的核心就在于数据类型。而各类编程语言的基本数据类型大致相同：int整型、float浮点型、string字符串类型、bool布尔类型，但是在一些进阶数据类型上就有所不同了。本文将会介绍Go语言当中核心的数据类型——…...
C++ 中的智能指针与内存管理：从基础到进阶
在 C 中，内存管理是一个至关重要的课题，尤其是当程序复杂度逐渐增加时。传统的手动内存管理方式（使用 new 和 delete）容易引发内存泄漏、悬挂指针等问题。为了简化内存管理，C11 引入了智能指针（std::unique…...
二、使用langchain搭建RAG:金融问答机器人--数据清洗和切片
选择金融领域的专业文档作为源文件 这里选择 《博金大模型挑战赛-金融千问14b数据集》，这个数据集包含若干公司的年报，我们将利用这个年报搭建金融问答机器人。 具体下载地址 这里 git clone https://www.modelscope.cn/datasets/BJQW14B/bs_challenge_…...
)
R 语言 | 绘图的文字格式(绘制上标、下标、斜体、文字标注等)
1. 上下标 # 注意y轴标签文字 library(ggplot2) ggplot(mtcars, aes(mpg, cyl))geom_point()ylab(label bquote(O[3]~(ug / m^3)))2. 希腊字母，如alpha ggplot(mtcars, aes(mpg, cyl))geom_point()ylab(label bquote(O[3]~(ug / m^3)))ggtitle(expression(alpha))…...