【C++ linux】SIGPIPE信号在网络通信程序导致程序异常中断

在网络通信的程序中，忽略SIGPIPE信号，防止程序异常退出

具体原因：

如果send到一个已关闭的socket上，内核就会发出SIGPIPE信号。这个信号
的缺省处理方法是终止进程，大多数时候这都不是我们期望的。也没有必要重新定义这
个信号的处理方法，大多数情况是直接屏蔽它，让send函数返回错误。

测试程序：

客户端

服务端关闭socket前后都向服务端发送报文

/** 程序名：demo01.cpp，此程序用于演示socket通讯的客户端的SIGPIPE信号。* 作者：毛毛。
*/
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include <netdb.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <time.h>
#include <signal.h>class tmp
{
public:tmp();~tmp();
};int main(int argc,char *argv[])
{if (argc!=3){printf("Using:./demo01 ip port\nExample:./demo01 127.0.0.1 5005\n\n"); return -1;}tmp tmpa;// 第1步：创建客户端的socket。int sockfd;if ( (sockfd = socket(AF_INET,SOCK_STREAM,0))==-1) { perror("socket"); return -1; }// 第2步：向服务器发起连接请求。struct hostent* h;if ( (h = gethostbyname(argv[1])) == 0 )   // 指定服务端的ip地址。{ printf("gethostbyname failed.\n"); close(sockfd); return -1; }struct sockaddr_in servaddr;memset(&servaddr,0,sizeof(servaddr));servaddr.sin_family = AF_INET;servaddr.sin_port = htons(atoi(argv[2])); // 指定服务端的通讯端口。memcpy(&servaddr.sin_addr,h->h_addr,h->h_length);if (connect(sockfd, (struct sockaddr *)&servaddr,sizeof(servaddr)) != 0)  // 向服务端发起连接清求。{ perror("connect"); close(sockfd); return -1; }int iret;char buffer[102400];// 第3步：与服务端通讯，发送一个报文后等待回复，然后再发下一个报文。for (int ii=0;ii<10;ii++){memset(buffer,0,sizeof(buffer));sprintf(buffer,"这是第%d个超级女生，编号%03d。\n",ii+1,ii+1);if ( (iret=send(sockfd,buffer,strlen(buffer),0))<=0) // 向服务端发送请求报文。{ perror("send"); break; }printf("发送：%s\n",buffer);sleep(2);   // 如果不sleep，客户端发送报文的时间会和服务端终止程序的时间相同，导致报文全部发送//signal(SIGPIPE,SIG_IGN);// 以下是SIGPIPE信号的测试代码，向关闭的socket发送数据iret=send(sockfd,buffer,strlen(buffer),0);   printf("iret1：%d,time(%ld)\n",iret,time(0));iret=send(sockfd,buffer,strlen(buffer),0);   printf("iret2：%d,time(%ld)\n",iret,time(0));iret=send(sockfd,buffer,strlen(buffer),0);   printf("iret3：%d,time(%ld)\n",iret,time(0));iret=send(sockfd,buffer,strlen(buffer),0);   printf("iret4：%d,time(%ld)\n",iret,time(0));memset(buffer,0,sizeof(buffer));// 如果对端socket关闭，recv返回值为0。if ( (iret=recv(sockfd,buffer,sizeof(buffer),0))<=0) // 接收服务端的回应报文。{printf("iret=%d\n",iret); break;}printf("接收：%s\n",buffer);sleep(1);  // 每隔一秒后再次发送报文。}// 第4步：关闭socket，释放资源。close(sockfd);
}tmp::tmp()
{printf("构造\n");
}tmp::~tmp()
{printf("析构\n");
}

服务端

服务端在接受一个报文后退出了程序，socket被关闭

/** 程序名：demo02.cpp，此程序用于演示socket通讯的服务端。* 作者：毛毛
*/
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include <netdb.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <time.h>int main(int argc,char *argv[])
{if (argc!=2){printf("Using:./demo02 port\nExample:./demo02 5005\n\n"); return -1;}// 第1步：创建服务端的socket。int listenfd;if ( (listenfd = socket(AF_INET,SOCK_STREAM,0))==-1) { perror("socket"); return -1; }// 第2步：把服务端用于通讯的地址和端口绑定到socket上。struct sockaddr_in servaddr;    // 服务端地址信息的数据结构。memset(&servaddr,0,sizeof(servaddr));servaddr.sin_family = AF_INET;  // 协议族，在socket编程中只能是AF_INET。servaddr.sin_addr.s_addr = htonl(INADDR_ANY);          // 任意ip地址。servaddr.sin_port = htons(atoi(argv[1]));  // 指定通讯端口。if (bind(listenfd,(struct sockaddr *)&servaddr,sizeof(servaddr)) != 0 ){ perror("bind"); close(listenfd); return -1; }int opt = 1; unsigned int len = sizeof(opt);setsockopt(listenfd,SOL_SOCKET,SO_REUSEADDR,&opt,len);// 第3步：把socket设置为监听模式。if (listen(listenfd,5) != 0 ) { perror("listen"); close(listenfd); return -1; }// 第4步：接受客户端的连接。int  clientfd;                  // 客户端的socket。int  socklen=sizeof(struct sockaddr_in); // struct sockaddr_in的大小struct sockaddr_in clientaddr;  // 客户端的地址信息。clientfd=accept(listenfd,(struct sockaddr *)&clientaddr,(socklen_t*)&socklen);printf("客户端（%s）已连接。\n",inet_ntoa(clientaddr.sin_addr));int iret;char buffer[102400];// 第5步：与客户端通讯，接收客户端发过来的报文后，回复ok。while (1){memset(buffer,0,sizeof(buffer));if ( (iret=recv(clientfd,buffer,sizeof(buffer),0))<=0) // 接收客户端的请求报文。{printf("iret=%d\n",iret); break;   }printf("接收：%s\n",buffer);printf("关闭服务端,time(%ld)\n",time(0));// 服务端接受到一个报文就退出程序exit(0);strcpy(buffer,"ok");if ( (iret=send(clientfd,buffer,strlen(buffer),0))<=0) // 向客户端发送响应结果。{ perror("send"); break; }printf("发送：%s\n",buffer);}// 第6步：关闭socket，释放资源。close(listenfd); close(clientfd);
}

客户端不忽略SIGPIPE信号

在成功发送一个报文后，开始发送测试报文，由于此时服务端已经关闭socket，所以测试报文只有第一个发送成功，然后程序异常退出。

注意：在客户端声明了tmp类，tmp类的构造和析构函数会printf提示，在程序异常结束后，tmp类并没有调用析构函数

服务端，成功接受一个报文后exit退出进程

客户端忽略SIGPIPE信号

客户端忽略SIGPIPE信号后，程序没有异常退出，程序结束时tmp类也调用了的析构函数，没有发送成功的测试报文send都返回了-1，最后一个iret是recv函数的返回值，表示对端socket关闭，

服务端

【C++ linux】SIGPIPE信号在网络通信程序导致程序异常中断相关推荐

Linux SIGPIPE信号产生原因与解决方法
TCP 四次握手产生SIGPIPE的原因 SIGPIPE信号产生的原因: 简单来说,就是客户端程序向服务器端程序发送了消息,然后关闭客户端,服务器端返回消息的时候就会收到内核给的SIGPIPE信号. ...
linux sigpipe信号,Linux下SIGPIPE信号及其处理
在Linux下写socket的程序的时候,如果尝试send到一个disconnected socket上,就会让底层抛出一个SIGPIPE信号. 这个信号的缺省处理方法是退出进程,大多数时候这都不是我 ...
Linux的Open Files设置过小导致程序退出并且Unable to create new native thread
1.视界 2. 背景我们在一台机器上部署了几个服务,但是总是有服务无缘无故挂掉.报错如下并且jps打印如下并且停止任务的时候如下 3. 查找问题
教你如何找到导致程序跑飞的指令
调试嵌入式程序时,你是否遇到过程序跑飞最终导致硬件异常中断的问题?遇到这种问题是否感觉比较难定位?不知道问题出在哪里,没有办法跟踪?尤其是当别人的程序踩了自己的内存,那就只能哭了:( 今天在论坛上看有 ...
iOS开发socket程序被SIGPIPE信号Terminate的问题
以前在iphone上写socket的程序的时候,如果尝试send到一个disconnected socket上,就会让底层抛出一个SIGPIPE信号. client端通过 pipe 发送信息到serv ...
linux 编程中忽略SIGPIPE信号
linux 编程中忽略SIGPIPE信号 SIGPIPE 简单来说,就是客户端程序向服务器端程序发送了消息,然后关闭客户端,服务器端返回消息的时候就会收到内核给的SIGPIPE信号. TCP的全双工信 ...
Linux / Server 端收到 SIGPIPE 信号的原因
server 端收到 SIGPIPE 信号的原因就是 Server 向已经关闭的 client 继续发送数据. 上错误代码: int SendData(char *pbuf , const size_ ...
linux java缓存失效_转载：Linux服务器Cache占用过多内存导致系统内存不足最终java应用程序崩溃解决方案...
原文链接: https://blog.csdn.net/u014740338/article/details/66975550 问题描述 Linux内存使用量超过阈值,使得Java应用程序无可用内存, ...
runtime无法执行grep_Runtime.getRuntime.exec()执行linux脚本导致程序卡死有关问题
Runtime.getRuntime.exec()执行linux脚本导致程序卡死问题问题: 在Java程序中,通过Runtime.getRuntime().exec()执行一个Linux脚本导致程序 ...

【C++ linux】SIGPIPE信号在网络通信程序导致程序异常中断

【C++ linux】SIGPIPE信号在网络通信程序导致程序异常中断相关推荐

最新文章

热门文章