- 论坛徽章:
- 0
|
客户端代码:
int recv_alluser(int fd)
{
printf("---------------------好友列表--------------------\n\n" ;
int read_len = 0;
while (1)
{
char temp[MAX];
memset(temp, 0, MAX);
// sleep(1);
read_len = read(fd, temp, MAX);//接收服务器发来的信息
write(1, temp, strlen(temp));
if (read_len < 0)
{
printf("read user error\n" ;
break;
}
if (strcmp(temp, "end" == 0)//接收到end字符串结束程序
{
return 0;
}
}
return 0;
}
服务器端代码:
int send_alluser(int fd)
{
if (mysql_query(conn, "select * from user" != 0)
{
printf("mysql query alluser error %u:%s\n",mysql_errno(conn), mysql_error(conn));
if (write(fd, "", 0) < 0)
{
perror("write 0 error\n" ;
return -1;
}
return -1;
}
MYSQL_RES *result = mysql_store_result(conn);
if (result == NULL)
{
printf("mysql query alluser result error %u:%s\n",mysql_errno(conn), mysql_error(conn));
return -1;
}
MYSQL_ROW row;
while ((row = mysql_fetch_row(result)))//把result里的信息发到客户端
{
write(fd, "账号:", 7);
write(fd, row[0], strlen(row[0]));
write(fd, "\t用户名:", 11);
write(fd, row[1], strlen(row[1]));
write(fd, "\t状态:", ;
write(fd, row[4], strlen(row[4]));
write(fd, "\n", 1);
}
mysql_free_result(result);
char buf[10] = "end";
if(write(fd, buf, 10) <= 0)//数据库信息发送完毕,给客户端发送end字符串
{
perror("write alluser end \n" ;
return -1;
}
return 0;
}
到最后服务器把数据库中信息发送完毕后然后发送end字符串,客户端接收到end字符串后跳出while(1)循环运行下一个程序,运行结构是能输出end字符串,但是还是一直在等待,而且ctrl+c客户端后,服务器端会一直显示"write alluser end 。。。。。。,但是这个并没有循环啊,在线等大牛解答 |
|