AI 助理
备案控制台
开发者社区 人工智能 文章 正文

程序技术好文：网络编程中的SIGPIPE信号

2024-06-27 369
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 程序技术好文：网络编程中的SIGPIPE信号

处理 SIGPIPE


　　在网络编程中经常会遇到SIGPIPE信号，默认情况下这个信号会终止整个进程，当然你并不想让进程被SIGPIPE信号杀死。我们不禁会这样思考：


在什么场景下会产生SIGPIPE信号？


要怎样处理SIGPIPE信号？


　　SIGPIPE产生的原因是这样的：如果一个 socket 在接收到了 RST packet 之后，程序仍然向这个 socket 写入数据，那么就会产生SIGPIPE信号。


　　这种现象是很常见的，譬如说，当 client 连接到 server 之后，这时候 server 准备向 client 发送多条消息，但在发送消息之前，client 进程意外奔溃了，那么接下来 server 在发送多条消息的过程中，就会出现SIGPIPE信号。下面我们看看 server 的代码：


#include


#include [span style="color: rgba(0, 0, 255, 1)">string.h>


#include


#include


#include


#include


#include


#define MAXLINE 1024


void handle_client(int fd)


{


// 假设此时 client 奔溃, 那么 server 将接收到 client 发送的 FIN


sleep(5);


// 写入第一条消息


char msg1【MAXLINE】 = {"first message"};


ssize_t n = write(fd, msg1, strlen(msg1));


printf("write %ld bytes\n", n);


// 此时第一条消息发送成功，server 接收到 client 发送的 RST


sleep(1);


// 写入第二条消息，出现 SIGPIPE 信号，导致 server 被杀死


char msg2【MAXLINE】 = {"second message"};


n = write(fd, msg2, strlen(msg2));


printf("%ld, %s\n", n, strerror(errno));


}


int main()


{


unsigned short port = 8888;


struct sockaddr_in server_addr;


bzero(&server_addr, sizeof(server_addr));


server_addr.sin_family = AF_INET;


server_addr.sin_addr.s_addr = htonl(INADDR_ANY);


server_addr.sin_port = htons(port);


int listenfd = socket(AF_INET , SOCK_STREAM , 0);


bind(listenfd, (struct sockaddr )&server_addr, sizeof(server_addr));

listen(listenfd, 128);

int fd = accept(listenfd, NULL, NULL);

handle_client(fd);

return 0;

}

root@ubuntu:~/c++# ./pipe


write 13 bytes

root@ubuntu:~/c++#


客户端

deamon启动

$ gcc -o server server.c


$ ./server & # 后台运行 server

$ nc localhost 8888 # 运行 nc 连接到 server

^C # Ctrl-C 杀死 nc

write 13 bytes

【1】+ Broken pipe ./server

让我们分析一下整个过程：

client 连接到 server 之后，client 进程意外奔溃，这时它会发送一个 FIN 给 server。

此时 server 并不知道 client 已经奔溃了，所以它会发送第一条消息给 client。但 client 已经退出了，所以 client 的 TCP 协议栈会发送一个 RST 给 server。

server 在接收到 RST 之后，继续写入第二条消息。往一个已经收到 RST 的 socket 继续写入数据，将导致SIGPIPE信号，从而杀死 server。

对 server 来说，为了不被SIGPIPE信号杀死，那就需要忽略SIGPIPE信号：

int main()

{


signal(SIGPIPE, SIG_IGN); // 忽略 SIGPIPE 信号

// ...

}

重新运行上面的程序，server 在发送第二条消息的时候，write()会返回-1，并且此时errno的值为EPIPE，所以这时并不会产生SIGPIPE信号：

char msg2【MAXLINE】 = {"second message"};

n = write(fd, msg2, strlen(msg2));

printf("%ld, %s\n", n, strerror(errno)); // -1, Broken pipe

demo2

server

#include


#include [span style="color: rgba(0, 0, 255, 1)">string.h>

#include


#include //代码效果参考：http://www.jhylw.com.cn/494023547.html

#include


#include


#include


#define SERV_PORT 8000

int main(int argc, const char argv【】)


{


struct sockaddr_in serverAdd;


struct sockaddr_in clientAdd;


bzero(&serverAdd, sizeof(serverAdd));


serverAdd.sin_family = AF_INET;


serverAdd.sin_addr.s_addr = htonl(INADDR_ANY);


serverAdd.sin_port = htons(SERV_PORT);


socklen_t clientAddrLen;


int listenfd = socket(AF_INET, SOCK_STREAM, 0);


int yes = 1;


setsockopt(listenfd,


SOL_SOCKET, SO_REUSEADDR,


(void )&yes, sizeof(yes));

if (listenfd < 0) {


printf("创建socket失败\n");

return -1;

}

int bindResult = bind(listenfd, (struct sockaddr )&serverAdd, sizeof(serverAdd));


if (bindResult < 0) {


printf("绑定端口失败\n");


//代码效果参考：http://www.jhylw.com.cn/015124015.html

close(listenfd);

return -1;


}


listen(listenfd, 20);


int connfd;


unsigned char recvMsg【246988】;


unsigned long long totalSize = 0;


clientAddrLen = sizeof(clientAdd);


connfd = accept(listenfd,(struct sockaddr )&clientAdd,&clientAddrLen);

if (connfd < 0) {


print#include


#include [span style="color: rgba(0, 0, 255, 1)">string.h>

#include


#include


#include


#include


#include


#define SERV_PORT 8000

int main(int argc, const char argv【】)


{


struct sockaddr_in serverAdd;


struct sockaddr_in clientAdd;


bzero(&serverAdd, sizeof(serverAdd));


serverAdd.sin_family = AF_INET;


serverAdd.sin_addr.s_addr = htonl(INADDR_ANY);


serverAdd.sin_port = htons(SERV_PORT);


socklen_t clientAddrLen;


int listenfd = socket(AF_INET, SOCK_STREAM, 0);


int yes = 1;


setsockopt(listenfd,


SOL_SOCKET, SO_REUSEADDR,


(void )&yes, sizeof(yes));

if (listenfd < 0) {


printf("创建socket失败\n");

return -1;

}

int bindResult = bind(listenfd, (struct sockaddr )&serverAdd, sizeof(serverAdd));


if (bindResult < 0) {


printf("绑定端口失败\n");


close(listenfd);


return -1;


}


listen(listenfd, 20);


int connfd;


unsigned char recvMsg【246988】;


unsigned long long totalSize = 0;


clientAddrLen = sizeof(clientAdd);


connfd = accept(listenfd,(struct sockaddr )&clientAdd,&clientAddrLen);

if (connfd < 0) {


printf("连接失败\n");

return -1;

}

else{


// 这里我们用于测试，只接收一个连接

close(listenfd);

}

close(connfd);

return 0;

}f("连接失败\n");

return -1;

}

else{


// 这里我们用于测试，只接收一个连接

close(listenfd);

}

close(connfd);

return 0;

}

client

#include


#include [span style="color: rgba(0, 0, 255, 1)">string.h>

#include


#include


#include


#include


#include


#define SERV_PORT 8000

#define SERV_ADDR "10.10.16.82"

int main(int argc, const char argv【】)


{


struct sockaddr_in serverAdd;


bzero(&serverAdd, sizeof(serverAdd));


serverAdd.sin_family = AF_INET;


serverAdd.sin_addr.s_addr = inet_addr(SERV_ADDR);


serverAdd.sin_port = htons(SERV_PORT);


int connfd = socket(AF_INET, SOCK_STREAM, 0);


int connResult = connect(connfd, (struct sockaddr )&serverAdd, sizeof(serverAdd));

if (connResult < 0) {


printf("连接失败\n");

close(connfd);

return 0;

}

ssize_t writeLen;

char sendMsg【5000】 = {0};

unsigned long long totalSize = 0;

while (1) {


writeLen = write(connfd, sendMsg, sizeof(sendMsg));

if (writeLen < 0) {


printf("发送失败 errno = %s\n",strerror(errno));

return 0;

}

else

{


totalSize += writeLen;

printf("发送成功 totalSize = %ld\n",totalSize);

}


}


close(connfd);

return 0;

}

【root@bogon ~】# ./client

发送成功 totalSize = 5000

发送成功 totalSize = 10000

发送成功 totalSize = 15000

发送成功 totalSize = 20000

发送成功 totalSize = 25000

发送失败 errno = Connection reset by peer

可以看到客户端发送第130001-135000个字节的时候程序在write方法处崩溃，是因为TCP套接字发送缓冲区的大小为131768字节，在发送前130000个字节的时候发送缓冲区还未满，因此write方法返回成功，接着继续发送

假设server和client 已经建立了连接，server调用了close, 发送FIN 段给client，此时server不能再通过socket发送和接收数据，此时client调用read，如果接收到FIN 段会返回0，但client此时还是可以write 给server的，write调用只负责把数据交给TCP发送缓冲区就可以成功返回了，所以不会出错，而server收到数据后应答一个RST段，表示服务器已经不能接收数据，连接重置，client收到RST段后无法立刻通知应用层，只把这个状态保存在TCP协议层。如果client再次调用write发数据给server，由于TCP协议层已经处于RST状态了，因此不会将数据发出，而是发一个SIGPIPE信号给应用层，SIGPIPE信号的缺省处理动作是终止程序。

当一个进程向某个已收到RST的套接字执行写操作时，（此时写操作返回EPIPE错误）内核向该进程发送一个SIGPIPE信号，该信号的默认行为是终止进程，因此进程必须捕获它以免不情愿地被终止；

继续修改客户端程序如下，服务端不变：

【root@bogon ~】# ./client

发送成功 totalSize = 5000

读取失败 errno = 104 and Connection reset by peer


#include


#include [span style="color: rgba(0, 0, 255, 1)">string.h>

#include


#include


#include


#include


#include


#define SERV_PORT 8000

#define SERV_ADDR "10.10.16.82"

int main(int argc, const char argv【】)


{


struct sockaddr_in serverAdd;


bzero(&serverAdd, sizeof(serverAdd));


serverAdd.sin_family = AF_INET;


serverAdd.sin_addr.s_addr = inet_addr(SERV_ADDR);


serverAdd.sin_port = htons(SERV_PORT);


int connfd = socket(AF_INET, SOCK_STREAM, 0);


int connResult = connect(connfd, (struct sockaddr *)&serverAdd, sizeof(serverAdd));


if (connResult < 0) {


printf("连接失败\n");


close(connfd);


return 0;


}


ssize_t writeLen;


char recvMsg【65535】;


ssize_t readLen;


char sendMsg【5000】 = {0};


unsigned long long totalSize = 0;


while (1) {


writeLen = write(connfd, sendMsg, sizeof(sendMsg));


if (writeLen < 0) {


printf("发送失败 errno = %s\n",strerror(errno));

文章标签：
网络协议
机器学习/深度学习
C语言
关键词：
网络信号
程序网络
好文网络
技术网络编程
技术好文网络
hnrk7epeorhrk
目录
相关文章
哈你真皮
|
5月前
|
机器学习/深度学习 小程序 算法
基于bp神经网络的adp程序
基于bp神经网络的adp小程序
哈你真皮
112 0
JJLIN距离
|
19天前
|
监控 前端开发 安全
Netty 高性能网络编程框架技术详解与实践指南
本文档全面介绍 Netty 高性能网络编程框架的核心概念、架构设计和实践应用。作为 Java 领域最优秀的 NIO 框架之一，Netty 提供了异步事件驱动的网络应用程序框架，用于快速开发可维护的高性能协议服务器和客户端。本文将深入探讨其 Reactor 模型、ChannelPipeline、编解码器、内存管理等核心机制，帮助开发者构建高性能的网络应用系统。
JJLIN距离
149 0
陌陌谣
|
3月前
|
监控 算法 安全
基于 C# 基数树算法的网络屏幕监控敏感词检测技术研究
随着数字化办公和网络交互迅猛发展，网络屏幕监控成为信息安全的关键。基数树（Trie Tree）凭借高效的字符串处理能力，在敏感词检测中表现出色。结合C#语言，可构建高时效、高准确率的敏感词识别模块，提升网络安全防护能力。
陌陌谣
83 2
蓝易云
|
5月前
|
调度 Python
探索Python高级并发与网络编程技术。
可以看出，Python的高级并发和网络编程极具挑战，却也饱含乐趣。探索这些技术，你将会发现：它们好比是Python世界的海洋，有穿越风暴的波涛，也有寂静深海的奇妙。开始旅途，探索无尽可能吧！
蓝易云
114 15
Deephub
|
5月前
|
机器学习/深度学习 算法 PyTorch
Perforated Backpropagation：神经网络优化的创新技术及PyTorch使用指南
深度学习近年来在多个领域取得了显著进展，但其核心组件——人工神经元和反向传播算法自提出以来鲜有根本性突破。穿孔反向传播（Perforated Backpropagation）技术通过引入“树突”机制，模仿生物神经元的计算能力，实现了对传统神经元的增强。该技术利用基于协方差的损失函数训练树突节点，使其能够识别神经元分类中的异常模式，从而提升整体网络性能。实验表明，该方法不仅可提高模型精度（如BERT模型准确率提升3%-17%），还能实现高效模型压缩（参数减少44%而无性能损失）。这一革新为深度学习的基础构建模块带来了新的可能性，尤其适用于边缘设备和大规模模型优化场景。
Deephub
186 16
Perforated Backpropagation：神经网络优化的创新技术及PyTorch使用指南
陌陌谣
|
5月前
|
监控 算法 JavaScript
基于 JavaScript 图算法的局域网网络访问控制模型构建及局域网禁止上网软件的技术实现路径研究
本文探讨局域网网络访问控制软件的技术框架，将其核心功能映射为图论模型，通过节点与边表示终端设备及访问关系。以JavaScript实现DFS算法，模拟访问权限判断，优化动态策略更新与多层级访问控制。结合流量监控数据，提升网络安全响应能力，为企业自主研发提供理论支持，推动智能化演进，助力数字化管理。
陌陌谣
122 4
云故事栏目组2号
|
6月前
|
存储 双11 数据中心
数据中心网络关键技术，技术发明一等奖！
近日，阿里云联合清华大学与中国移动申报的“性能可预期的大规模数据中心网络关键技术与应用”项目荣获中国电子学会技术发明一等奖。该项目通过端网融合架构，实现数据中心网络性能的可预期性，在带宽保障、时延控制和故障恢复速度上取得重大突破，显著提升服务质量。成果已应用于阿里云多项产品及重大社会活动中，如巴黎奥运会直播、“双十一”购物节等，展现出国际领先水平。
云故事栏目组2号
244 18
蓝易云
|
6月前
|
安全 网络安全 定位技术
网络通讯技术：HTTP POST协议用于发送本地压缩数据到服务器的方案。
总的来说，无论你是一名网络开发者，还是普通的IT工作人员，理解并掌握POST方法的运用是非常有价值的。它就像一艘快速，稳定，安全的大船，始终为我们在网络海洋中的冒险提供了可靠的支持。
蓝易云
189 22
陌陌谣
|
6月前
|
存储 监控 算法
基于 Python 哈希表算法的局域网网络监控工具：实现高效数据管理的核心技术
在当下数字化办公的环境中，局域网网络监控工具已成为保障企业网络安全、确保其高效运行的核心手段。此类工具通过对网络数据的收集、分析与管理，赋予企业实时洞察网络活动的能力。而在其运行机制背后，数据结构与算法发挥着关键作用。本文聚焦于 PHP 语言中的哈希表算法，深入探究其在局域网网络监控工具中的应用方式及所具备的优势。
陌陌谣
154 7

热门文章

最新文章

  • 1
    CMSIS-NN：ARM Cortex-M处理器的高效神经网络内核——论文解读
  • 2
    网络交换机分类与功能解析
  • 3
    程序员应该掌握的网络命令telnet、ping和curl
  • 4
    DevOps 流水线的网络安全盲区与防御策略
  • 5
    粒子群算法优化RBF神经网络的MATLAB实现
  • 6
    卷积神经网络深度解析：从基础原理到实战应用的完整指南
  • 7
    2025年华为杯A题|通用神经网络处理器下的核内调度问题研究生数学建模|思路、代码、论文|持续更新中....
  • 8
    Nmap网络扫描工具详细使用教程
  • 9
    JavaScript：构建动态网络的引擎
  • 10
    【表面粗糙度】基于粒子群PSO算法优化-BP神经网络的表面粗糙度研究（Matlab代码实现）
  • 1
    Go语言网络编程：使用 net/http 构建 RESTful API
    183
  • 2
    Go 网络编程：HTTP服务与客户端开发
    250
  • 3
    Go网络编程：基于TCP的网络服务端与客户端
    125
  • 4
    探索Python高级并发与网络编程技术。
    114
  • 5
    Cpp网络编程Winsock API
    249
  • 6
    Java网络编程，多线程，IO流综合小项目一一ChatBoxes
    252
  • 7
    Python 高级编程与实战：深入理解网络编程与异步IO
    108
  • 8
    即时通讯初学者必知必会的20个网络编程和通信安全知识点
    152
  • 9
    Go语言的网络编程与TCP_UDP
    194
  • 10
    不为人知的网络编程(十九)：能Ping通，TCP就一定能连接和通信吗？
    223

    • 相关课程

    更多
  • 云计算工程师解析与实战-网络专家篇（体验版）
  • 云网络白皮书-阿里云网络系列课
  • Python网络编程
  • 企业上云攻略-阿里云网络产品应用系列教程
  • Linux网络进阶 - TCP/IP协议及OSI七层模型
  • 网络管理者必知-2分钟了解新出台的《网络安全法》

    • 相关电子书

    更多
  • Session：更加安全、可靠的数据中心网络产品更新
  • Session：极简易用的全球化网络产品更新
  • Session：弹性、高可用、可观测的应用交付网络产品更新
    • 下一篇
    阿里云免费云服务器:个人用户每月750小时免费