作者kopepe ()
看板LinuxDev
标题[问题] 用socket select函式做聊天室的问题!
时间Tue Jun 24 03:43:49 2008
我自己测试了很久还是试不出来要怎麽让三个人可以同时聊天~
拜托各位帮我看一下程式码那里有错好吗?谢谢了!
server端程式:
#include "unp.h"
#include <stdio.h>
#include <stdlib.h>
int total_people;
int counter;
int i=0;
int main(int argc , char **argv)
{
int listenfd , connfd[i] , clifd[11];
int maxfdp1;
fd_set rset;
struct sockaddr_in servaddr;
char sendline[MAXLINE], recvline[MAXLINE];
socklen_t servlen;
ssize_t n;
int checkyesno;
int j;
int countdown=3;
listenfd = socket(AF_INET , SOCK_STREAM,0); //creat a listen socket
bzero(&servaddr, sizeof(servaddr)); //initial zero
servaddr.sin_family = AF_INET; //IPV4 address family
servaddr.sin_addr.s_addr = htonl(INADDR_ANY); // universal adderss
servaddr.sin_port = htons(SERV_PORT); // short port
bind(listenfd , (SA *) & servaddr , sizeof(servaddr) ); //make the servaddr
relates to socket
listen(listenfd , LISTENQ); // creat a listen socket
total_people =0;
while( (connfd[i] = Accept(listenfd , (SA *) &servaddr, &servlen) ) > 0)
{
//Close(listenfd);
servlen = sizeof(servaddr);
//str_cli(stdin , connfd[i]);
total_people++;
counter++;
printf("\n");
printf("Welcome ! Client%d came in.\n", total_people);
sprintf(sendline ,"Welcome ! \n");
//writen(connfd[i], sendline, strlen(sendline));
FD_ZERO(&rset);
FD_SET(fileno(stdin), &rset);
for(j=0 ; j<strlen(connfd) ; j++){
readline(connfd[i], recvline, MAXLINE) ;
writen(connfd[j], sendline, strlen(sendline));
Fputs(recvline , stdout);
}
FD_SET(connfd[i], &rset);
i++;
}//while loop
for ( ; ; )
{
printf("server test\n");
maxfdp1 = max(fileno(stdin), connfd[i]) + 1;
select(maxfdp1, &rset, NULL, NULL, NULL);
if (FD_ISSET(connfd[i], &rset)) // socket
{ /* socket is readable */
if (readline(connfd[i], recvline, MAXLINE) == 0)
err_quit("str_cli: server terminated prematurely");
Fputs(recvline, stdout);
sprintf(sendline ,"server socket\n");
writen(connfd[i], sendline, strlen(sendline));
checkyesno = atoi(recvline);
if(checkyesno == 2)
{
printf("This connection will disconnect after three seconds! \n");
while(countdown >0)
{
printf("%d second \n" , countdown);
countdown--;
sleep(1);
}
printf("disconnect the client %d\n", total_people);
}
else
continue;
for(j=0 ; j<strlen(connfd) ; j++)
writen(connfd[j], recvline, strlen(recvline));
} //if
if (FD_ISSET(fileno(stdin), &rset)) // stdin
{ /* input is readable */
if (Fgets(sendline, MAXLINE, stdin) == NULL)
continue; /* all done */
sprintf(sendline ,"server stdin\n");
for(j=0 ; j<strlen(connfd) ; j++)
writen(connfd[j], sendline, strlen(sendline));
}
//FD_ZERO(&rset);
}
total_people = total_people -1;
//}// while loop
exit(0);
Close(connfd[i]);
}//main
====================================================
client端程式:
#include "unp.h"
#include <stdio.h>
#include <stdlib.h>
int main(int argc , char **argv)
{
int clisockfd ;
struct sockaddr_in cliaddr;
int maxfdp1;
fd_set rset;
char sendline[MAXLINE] , recvline[MAXLINE];
socklen_t clilen;
int temp;
char *str2;
clisockfd = socket(AF_INET , SOCK_STREAM , 0);
bzero(&cliaddr , sizeof(cliaddr));
cliaddr.sin_family = AF_INET;
cliaddr.sin_port = htons(SERV_PORT);
Inet_pton(AF_INET , argv[1] , &cliaddr.sin_addr);
Connect(clisockfd , (SA *) &cliaddr , sizeof(cliaddr));
clilen = sizeof(cliaddr);
FD_ZERO(&rset);
FD_SET(fileno(stdin), &rset);
FD_SET(clisockfd, &rset);
while(1)
{
maxfdp1 = max(fileno(stdin), clisockfd) + 1;
select(maxfdp1, &rset, NULL, NULL, NULL);
if (FD_ISSET(clisockfd, &rset))
{ /* socket is readable */
if (readline(clisockfd, recvline, MAXLINE) == 0)
err_quit("str_cli: server terminated prematurely");
Fputs(recvline, stdout);
sprintf(recvline , "client socket\n");
Writen(clisockfd, recvline, strlen(recvline));
Readline(clisockfd, recvline, MAXLINE);
printf("client socket = %s\n" , recvline);
}
if (FD_ISSET(fileno(stdin), &rset)) { /* input is readable */
if (Fgets(sendline, MAXLINE, stdin) == NULL)
return; /* all done */
printf("client stdin\n");
Writen(clisockfd, sendline, strlen(sendline));
}
}
exit(0);
} // main
--
※ 发信站: 批踢踢实业坊(ptt.cc)
◆ From: 218.165.169.40
1F：推 dozer:程式码贴在网页上会比较好喔.... 06/24 09:59
2F：推 dozer:这样才翻两页就囧了 06/24 09:59
3F：→ kopepe:嗯!不常贴文 所以排版有点乱! 回归主题，我可以第二个使用 06/24 12:22
4F：→ kopepe:让第二个Client传送资料到server端，但传第二次server端就 06/24 12:24
5F：→ kopepe:接不到了，不知问题出在那?? 06/24 12:24
6F：推 homal:回归主题 就是重贴比较好.这样怎麽trace ? 06/24 23:43
8F：推 dozer:RAFB很赞耶 找的好! 06/25 22:45
9F：→ sho330:这..应该是作业7吧...检查看看是不是Low-water mark的问题? 06/26 10:58