linux c socket 客户端循环十次向服务器发送数据(tcp连接),为啥只能接受第一次的?求代码
客户端实现的功能是发送一段字符串然后从服务器那接受服务器反馈的字符串。服务器端是接受客户端的字符串然后向客户端发送反馈接受成功的字符串。要求是客户端不停的向服务器端发送,...
客户端实现的功能是发送一段字符串 然后从服务器那接受服务器反馈的字符串。
服务器端是接受客户端的字符串然后向客户端发送反馈接受成功的字符串。
要求是客户端不停的向服务器端发送,服务器端不停的接受和反馈。
现在就是我自己写了一段代码,循环10次发送 但是只能接受到服务器端一条信息。
求高人能否给我完整代码。貌似要用到多线程的互锁机制。本人初学者。
分数大大的给 展开
服务器端是接受客户端的字符串然后向客户端发送反馈接受成功的字符串。
要求是客户端不停的向服务器端发送,服务器端不停的接受和反馈。
现在就是我自己写了一段代码,循环10次发送 但是只能接受到服务器端一条信息。
求高人能否给我完整代码。貌似要用到多线程的互锁机制。本人初学者。
分数大大的给 展开
3个回答
展开全部
只是做这些动作的话不需要多线程
找了下以前写的 改成了你说的10次发送
client.c:
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<errno.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
int main(int argc,char **argv)
{
char wbuf[] = "hello server";
char rbuf[128];
int i;
int sock;
struct sockaddr_in server = {0};
struct timeval timeo;
timeo.tv_sec = 0;
timeo.tv_usec = 1000 * 1000; //
socklen_t len = sizeof(timeo);
if( argc != 2)
{
printf("usage: ./client <ipaddress>\n");
return -1;
}
sock = socket(AF_INET, SOCK_STREAM, 0);
if(sock < 0)
{
perror("Create TCP Socket");
return -1;
}
setsockopt(sock, SOL_SOCKET, SO_SNDTIMEO, &timeo, len);
server.sin_family = AF_INET;
server.sin_port = htons(30000);
inet_pton(AF_INET, argv[1], &(server.sin_addr));
int res = connect(sock, (struct sockaddr*)&server, sizeof(server));
if (res < 0)
{
if(res == EINPROGRESS)
perror("connecting stream socket time out:");
else
perror("connecting stream socket error:");
close(sock);
return -1;
}
else
{
printf("Connect Server@%s\n",argv[1]);
for(i=0;i<10;i++)
{
int wsize = send(sock,wbuf,sizeof(wbuf),0);
if(wsize<=0)
{
perror("write error:");
close(sock);
return -1;
}
printf("1111111i=%d\n",i);
while(1)
{
int rsize=recv(sock,rbuf,sizeof(rbuf),0);
if(rsize>0)
{
rbuf[rsize]='\0';
printf("recv msg from server: %s\n",rbuf);
break;
}
if(rsize<0)
{
close(sock);
perror("read error:");
return -1;
}
}
}
close(sock);
return 0;
}
}
server.c:
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<errno.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
int main(int argc, char** argv)
{
int listenfd, connfd;
struct sockaddr_in servaddr = {0};
char rbuf[128];
char wbuf[] = "hello client";
int n;
if( (listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1 )
{
perror("Create TCP Socket");
return -1;
}
servaddr.sin_family = AF_INET;
servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
servaddr.sin_port = htons(30000);
if( bind(listenfd, (struct sockaddr*)&servaddr, sizeof(servaddr)) == -1)
{
perror("bind socket error:");
return -1;
}
if( listen(listenfd, 10) == -1)
{
perror("listen socket error:");
return -1;
}
printf("======waiting for client's request======\n");
while(1)
{
if( (connfd = accept(listenfd, (struct sockaddr*)NULL, NULL)) == -1)
{
perror("accept socket error:");
continue;
}
while(1)
{
n = recv(connfd, rbuf, sizeof(rbuf), 0);
if(n>0)
{
rbuf[n] = '\0';
printf("recvmsg from client: %s\n", rbuf);
n = send(connfd, wbuf, sizeof(wbuf),0);
if(n<=0)
{
perror("sned error:");
close(connfd);
break;
}
}
else if(n < 0)
{
perror("recv error:");
close(connfd);
break;
}
}
close(connfd);
}
close(listenfd);
return 0;
}
运行的时候 client
./client 你的serverip
端口我用的30000 写死在程序里了
找了下以前写的 改成了你说的10次发送
client.c:
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<errno.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
int main(int argc,char **argv)
{
char wbuf[] = "hello server";
char rbuf[128];
int i;
int sock;
struct sockaddr_in server = {0};
struct timeval timeo;
timeo.tv_sec = 0;
timeo.tv_usec = 1000 * 1000; //
socklen_t len = sizeof(timeo);
if( argc != 2)
{
printf("usage: ./client <ipaddress>\n");
return -1;
}
sock = socket(AF_INET, SOCK_STREAM, 0);
if(sock < 0)
{
perror("Create TCP Socket");
return -1;
}
setsockopt(sock, SOL_SOCKET, SO_SNDTIMEO, &timeo, len);
server.sin_family = AF_INET;
server.sin_port = htons(30000);
inet_pton(AF_INET, argv[1], &(server.sin_addr));
int res = connect(sock, (struct sockaddr*)&server, sizeof(server));
if (res < 0)
{
if(res == EINPROGRESS)
perror("connecting stream socket time out:");
else
perror("connecting stream socket error:");
close(sock);
return -1;
}
else
{
printf("Connect Server@%s\n",argv[1]);
for(i=0;i<10;i++)
{
int wsize = send(sock,wbuf,sizeof(wbuf),0);
if(wsize<=0)
{
perror("write error:");
close(sock);
return -1;
}
printf("1111111i=%d\n",i);
while(1)
{
int rsize=recv(sock,rbuf,sizeof(rbuf),0);
if(rsize>0)
{
rbuf[rsize]='\0';
printf("recv msg from server: %s\n",rbuf);
break;
}
if(rsize<0)
{
close(sock);
perror("read error:");
return -1;
}
}
}
close(sock);
return 0;
}
}
server.c:
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<errno.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
int main(int argc, char** argv)
{
int listenfd, connfd;
struct sockaddr_in servaddr = {0};
char rbuf[128];
char wbuf[] = "hello client";
int n;
if( (listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1 )
{
perror("Create TCP Socket");
return -1;
}
servaddr.sin_family = AF_INET;
servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
servaddr.sin_port = htons(30000);
if( bind(listenfd, (struct sockaddr*)&servaddr, sizeof(servaddr)) == -1)
{
perror("bind socket error:");
return -1;
}
if( listen(listenfd, 10) == -1)
{
perror("listen socket error:");
return -1;
}
printf("======waiting for client's request======\n");
while(1)
{
if( (connfd = accept(listenfd, (struct sockaddr*)NULL, NULL)) == -1)
{
perror("accept socket error:");
continue;
}
while(1)
{
n = recv(connfd, rbuf, sizeof(rbuf), 0);
if(n>0)
{
rbuf[n] = '\0';
printf("recvmsg from client: %s\n", rbuf);
n = send(connfd, wbuf, sizeof(wbuf),0);
if(n<=0)
{
perror("sned error:");
close(connfd);
break;
}
}
else if(n < 0)
{
perror("recv error:");
close(connfd);
break;
}
}
close(connfd);
}
close(listenfd);
return 0;
}
运行的时候 client
./client 你的serverip
端口我用的30000 写死在程序里了
展开全部
你想实现相互通讯的话,必须要起线程或者进程。线程比较麻烦,建议先研究进程吧。server收到服务端链接后,fork()一个进程,该进程对这一个客户端进行服务。
一般咱们都是堵塞的收发数据,都是服务端fork()一个进程后,调用读read操作,如收到数据(客户端请求),给予反馈,向客户端send数据。客户端成功链接后,发送数据,然后等待反馈。只能一个收,收到后在发,一直堵塞。当然也有非堵塞模式,这个关系超时操作,你先研究简单的吧。
你要做到类似qq的东西,那只能多进程并发,就是一个进程发送,一个进程收取。用fork函数。也就是,客户端和服务端收发数据都分别fork一个进程。
不知是不是你想要的答案。我的代码不能给你,给你个开源的,cppsocket,比较难。自己下载,可以参考下。
一般咱们都是堵塞的收发数据,都是服务端fork()一个进程后,调用读read操作,如收到数据(客户端请求),给予反馈,向客户端send数据。客户端成功链接后,发送数据,然后等待反馈。只能一个收,收到后在发,一直堵塞。当然也有非堵塞模式,这个关系超时操作,你先研究简单的吧。
你要做到类似qq的东西,那只能多进程并发,就是一个进程发送,一个进程收取。用fork函数。也就是,客户端和服务端收发数据都分别fork一个进程。
不知是不是你想要的答案。我的代码不能给你,给你个开源的,cppsocket,比较难。自己下载,可以参考下。
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
2011-08-10
展开全部
你尝试下客户端发送的10次之间加入间隔;看看下效果再说
追问
尝试了 貌似不行。。。。
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
推荐律师服务:
若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询