客户端发送100个sprintf(buf,“这是第%d个超级女生。”,i);,每发送一次,然后接收1次。
服务端使用echoserver,3个IO线程4个工作线程
这是客户端的结果,接收到了重复的结果
没有WORK线程的话,回显正常,有WORK线程就会出现这种情况
//客户端代码
#include <sys/types.h>
#include <netinet/in.h> // 定义 sockaddr_in 结构体
#include <arpa/inet.h> // 提供 inet_pton 和 inet_ntoa 等函数
#include <sys/socket.h> // 提供 socket()、bind() 等函数
#include <cstring>
#include <cstdio> //提供prinf()等函数
#include <stdlib.h> //atoi()
#include <iostream>
#include <unistd.h> //close()
int main(int argc, char **argv)
{
if (argc != 3)
{
printf("usage:./client ip port\n");
printf("example:./client 192.168.238.132 5000\n");
return -1;
}
int sockfd = 0;
struct sockaddr_in servaddr;
memset(&servaddr, 0, sizeof(servaddr));
if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
{
printf("socket fail!\n");
return -1;
}
servaddr.sin_family = AF_INET;
servaddr.sin_addr.s_addr = inet_addr(argv[1]);
servaddr.sin_port = htons(atoi(argv[2]));
//当无法建立连接时,connect() 返回失败,通常是 -1
//如果目标不可达,会立即返回
if (connect(sockfd, (sockaddr *)&servaddr, sizeof(servaddr)) != 0)
{
printf("connect(%s:%s) fail!\n", argv[1], argv[2]);
close(sockfd);
return -1;
}
printf("connect(%s:%s) ok!\n", argv[1], argv[2]);
char buf[1024];
for(size_t i = 0;i<100;i++)
{
memset(buf,0,sizeof(buf));
sprintf(buf,"这是第%d个超级女生。",i);
int len=strlen(buf);
char tmp[1024];
memset(tmp,0,sizeof(tmp));
memcpy(tmp,&len,4);
memcpy(tmp+4,buf,len);
send(sockfd, tmp, len+4, 0);
}
for(size_t i = 0;i<100;i++)
{
int len=0;
recv(sockfd,&len,4,0);
memset(buf,0,sizeof(buf));
recv(sockfd, buf,len, 0);
printf("recv:%s\n",buf);
}
//sleep(10);
return 0;
}