Java自学者论坛

 找回密码
 立即注册

手机号码,快捷登录

恭喜Java自学者论坛(https://www.javazxz.com)已经为数万Java学习者服务超过8年了!积累会员资料超过10000G+
成为本站VIP会员,下载本站10000G+会员资源,会员资料板块,购买链接:点击进入购买VIP会员

JAVA高级面试进阶训练营视频教程

Java架构师系统进阶VIP课程

分布式高可用全栈开发微服务教程Go语言视频零基础入门到精通Java架构师3期(课件+源码)
Java开发全终端实战租房项目视频教程SpringBoot2.X入门到高级使用教程大数据培训第六期全套视频教程深度学习(CNN RNN GAN)算法原理Java亿级流量电商系统视频教程
互联网架构师视频教程年薪50万Spark2.0从入门到精通年薪50万!人工智能学习路线教程年薪50万大数据入门到精通学习路线年薪50万机器学习入门到精通教程
仿小米商城类app和小程序视频教程深度学习数据分析基础到实战最新黑马javaEE2.1就业课程从 0到JVM实战高手教程MySQL入门到精通教程
查看: 488|回复: 0

Linux下send函数 Broken pipe错误的解决方法

[复制链接]
  • TA的每日心情
    奋斗
    2024-11-24 15:47
  • 签到天数: 804 天

    [LV.10]以坛为家III

    2053

    主题

    2111

    帖子

    72万

    积分

    管理员

    Rank: 9Rank: 9Rank: 9

    积分
    726782
    发表于 2021-6-11 07:54:31 | 显示全部楼层 |阅读模式

    在linux下写socket的程序的时候,如果尝试send到一个disconnected socket上,就会让底层抛出一个SIGPIPE信号。

    client端通过 pipe 发送信息到server端后,就关闭client端, 这时server端,返回信息给 client 端时就产生Broken pipe 信号了。

    对于产生信号,我们可以在产生信号前利用方法 signal(int signum, sighandler_t handler) 设置信号的处理。如果没有调用此方法,系统就会调用默认处理方法:中止程序,显示提示信息(就是我们经常遇到的问题)。我们可以调用系统的处理方法,也可以自定义处理方法。

    对一个已经收到FIN包的socket调用read方法, 如果接收缓冲已空, 则返回0,
    这就是常说的表示连接关闭. 但第一次对其调用write方法时, 如果发送缓冲没问题,
    会返回正确写入(发送). 但发送的报文会导致对端发送RST报文,
    因为对端的socket已经调用了close, 完全关闭, 既不发送, 也不接收数据. 所以,
    第二次调用write方法(假设在收到RST之后), 会生成SIGPIPE信号, 导致进程退出.

    为了避免进程退出, 可以捕获SIGPIPE信号, 或者忽略它,
    给它设置SIG_IGN信号处理函数:

    signal(SIGPIPE, SIG_IGN);

    这样, 第二次调用write方法时, 会返回-1, 同时errno置为SIGPIPE.
    程序便能知道对端已经关闭.

    PS: Linux下的SIGALRM似乎会每1秒钟往后偏移1毫秒,
    但Windows下经过测试完全准时, 不差1毫秒.

    头文件 #include <signal.h>

    struct sigaction sa;
    sa.sa_handler = SIG_IGN;//设定接受到指定信号后的动作为忽略
    sa.sa_flags = 0;
    if (sigemptyset(&sa.sa_mask) == -1 || //初始化信号集为空
    sigaction(SIGPIPE, &sa, 0) == -1) { //屏蔽SIGPIPE信号
    perror("failed to ignore SIGPIPE; sigaction");
    exit(EXIT_FAILURE);
    }

    pthread线程里如何屏蔽SIGPIPE异常
    在pthread中,可能会遇到Program received signal SIGPIPE, Broken
    pipe的问题,解决方法是每一个线程启动之前时,先执行下面代码:

    #ifndef WIN32
    sigset_t signal_mask;
    sigemptyset (&signal_mask);
    sigaddset (&signal_mask, SIGPIPE);
    int rc = pthread_sigmask (SIG_BLOCK, &signal_mask, NULL);
    if (rc != 0) {
    printf("block sigpipe error\n");
    }

    哎...今天够累的,签到来了1...
    回复

    使用道具 举报

    您需要登录后才可以回帖 登录 | 立即注册

    本版积分规则

    QQ|手机版|小黑屋|Java自学者论坛 ( 声明:本站文章及资料整理自互联网,用于Java自学者交流学习使用,对资料版权不负任何法律责任,若有侵权请及时联系客服屏蔽删除 )

    GMT+8, 2025-2-2 09:56 , Processed in 0.058126 second(s), 28 queries .

    Powered by Discuz! X3.4

    Copyright © 2001-2021, Tencent Cloud.

    快速回复 返回顶部 返回列表