linux-下用c语言编写的聊天室程序-服务器和客户端.doc

/*

* server.c

*

* Created on: 2012-6-15

* Author: root

*/

#include <stdio.h>

#include <stdlib.h>

#include <pthread.h>

#define PORT 7999

#define MAX_NUM 3 //client连接最大个数

#define MAX_CLIENT 15

#define MAX_SIZE 1024

pthread_rwlock_t idx_lock, wait_lock;

//client 信息

typedef struct _client {

int sockfd;

char name[20];

pthread_t pid;

char name[20];

pthread_t pid;

struct _client_ *next;

};

typedef struct _client_ c_client_c;

c_client_c *head = NULL;

c_client_c *temp_c1 = NULL, *temp_c2 = NULL;//等待的

//初始化client信息

void init_client() {

int i = 0;

for (i = 0; i < MAX_CLIENT; i++) {

//查找结构体数组中sockfd为-1的下标值

int find_fd(c_client *client) {

int i = 0;

while (i < MAX_NUM) {

// printf("====%d\n",client[i].sockfd);

if (client[i].sockfd == -1)

return -1;

}

char *q = p + n - 4;

if (p != NULL && p + 7 != q && strcmp(q, "\r\n\r\n") == 0)

return 0;

}

int cmpname(char *buf, c_client *p_client) {

int i = 0;

char *p = strtok(buf + 7, "\r\n\r\n");

while (client[i].sockfd != -1 && client[i].sockfd != p_client->sockfd && i

< MAX_NUM) {

if (strcmp(client[i].name, p) == 0)

return 0;

i++;

}

return 1;

}

//SHOW

sprintf(buf + strlen(buf), "%s\r\n", client[i].name);

}

}

sprintf(buf + strlen(buf), "\r\n");

send(p_client->sockfd, buf, strlen(buf), 0);

}

//ALL

sprintf(sendbuf, "AFROM\r\n%s\r\n%s", p_client->name, buf + 5);

for (i = 0; i < MAX_NUM; i++) {

if (client[i].sockfd != -1 && client[i].flg != -1)

if(send(client[i].sockfd, sendbuf, strlen(sendbuf), 0) <= 0){

}

for (i = 0; i < MAX_NUM; i++) {

if (client[i].sockfd != -1 && strcmp(client[i].name, name) == 0)

return client[i].sockfd;

}

return 0;

}

//TO

void sendto_one(c_client *p_client, char *buf) {

int i = 0;

char sendbuf[1024] = { 0 };

char name[20] = { 0 };

char *p = strtok(buf + 4, "\r\n");//TO\r\n：4个字符后取出\r\n前的名字

strcpy(name, p);

int sock = findname(name);

sprintf(sendbuf, "ERROR2\r\n%s用户不存在\r\n\r\n", name);

name) + 2);

if(send(sock, sendbuf, strlen(sendbuf), 0)<=0){

printf("send errrrrr\n");

exit(1);

}

}

}

int i=0;

int idx;

char buf[1024] = {0};

c_client_c *temp;

printf("--%s退出聊天室\n",p_client->name);

p_client->pid = -1;

p_client->flg = -1;

sprintf(buf,"NOTICE1\r\n%s退出聊天室\r\n\r\n",p_client->name);

memset(p_client->name,0,20);

for(i=0;i<MAX_NUM;i++){

if(client[i].sockfd != -1 && client[i].flg != -1)

send(client[i].sockfd,buf,strlen(buf),0);

}