工作需要,对接服务器的时候,客户端发送数据报错“Broken pipe”
原因是对一个已关闭的套接字write两次
细节讲解参考:https://www.cnblogs.com/jingzhishen/p/3453727.html
demo
客户端代码:
#include <stdio.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <unistd.h>
#include <netinet/in.h>
#include <string.h>
int main()
{
int sockfd = 0;
sockaddr_in addr = {0};
char str[100] = "hello";
sockfd = socket(AF_INET, SOCK_STREAM, 0);
addr.sin_addr.s_addr = htons(INADDR_ANY);
addr.sin_family = AF_INET;
addr.sin_port = 6768;
while (-1 == connect(sockfd, (sockaddr *)&addr, sizeof(addr)))
{
perror("connect err : ");
sleep(1);
}
sleep(1);
for (int i = 0; i < 2; i++)
{
#if 1
if (-1 == write(sockfd, str, strlen(str)))
{
perror("write err : ");
}
#else // read不会报错
if (0 > read(sockfd, str, sizeof(str)))
{
perror("read err : ");
}
#endif
}
close(sockfd);
printf("exit client\n");
return 0;
}
服务器端代码:
#include <stdio.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <unistd.h>
#include <netinet/in.h>
#include <string.h>
int main()
{
int sockfd = 0;
sockaddr_in addr = {0};
char str[100] = "hello";
sockfd = socket(AF_INET, SOCK_STREAM, 0);
addr.sin_addr.s_addr = htons(INADDR_ANY);
addr.sin_family = AF_INET;
addr.sin_port = 6768;
while (-1 == connect(sockfd, (sockaddr *)&addr, sizeof(addr)))
{
perror("connect err : ");
sleep(1);
}
sleep(1);
for (int i = 0; i < 2; i++)
{
#if 1
if (-1 == write(sockfd, str, strlen(str)))
{
perror("write err : ");
}
#else // read不会报错
if (0 > read(sockfd, str, sizeof(str)))
{
perror("read err : ");
}
#endif
}
close(sockfd);
printf("exit client\n");
return 0;
}