能夠實現簡單的多人聊天和私聊

伺服器接收來自客戶端的連線請求，當有客戶端傳送過來資料時，伺服器將資料儲存到全域性緩衝區，並將資料迴圈傳送給已經連線的客戶端

不解釋直接上程式碼：

伺服器：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <unistd.h>

#define PORT 8081				//設定埠資訊	
#define BUFFER_SIZE 1024		//設定最大發送資訊位元組
#define MAX_SIZE 10			//最大連線數

struct Msg{				//傳送訊息的結構體包含姓名 傳送的資訊 該客戶端的套接字描述符
	
	char name[20];
	char message[BUFFER_SIZE];
	int socket;
	int flge;

};

int connfd[MAX_SIZE];    //把連線進來的客戶端放在陣列中

void *recv_fun(void *arg); //接受資訊函式

int main()
{
	struct sockaddr_in sin,cin; //宣告兩個套接字
	
	int sfd,cfd;
	
	int Length = sizeof(struct sockaddr_in); //套接字結構體的大小
	
	//char buf[BUFFER_SIZE];   
	
	int n;
	
    if((sfd=socket(AF_INET,SOCK_STREAM,0))==-1){		//建立套接字
		
		printf("socket error\n");
		
		exit(1);
	}
	
	//為套接字設定ip協議 設定埠號  並自動獲取本機ip轉化為網路ip
	sin.sin_family=AF_INET;
	
	sin.sin_port=htons(PORT);
	
	sin.sin_addr.s_addr=htonl(INADDR_ANY);
	
	bzero(&(sin.sin_zero),8);
	
	if(bind(sfd,(struct sockaddr *)&sin,sizeof(sin))<0){	//繫結套接字
	
		printf("bind error\n");
		
		exit(1);
		
	}
	
	printf("Bind success!\n");

	if(listen(sfd,MAX_SIZE)==-1){	//監聽最大連線數
	
		printf("listen error\n");
		
		exit(1);
	}
	
	printf("listening....\n");
	
	int i;
	
	for(i=0; i<MAX_SIZE; i++)   //剛開始先把存放客戶端的陣列設定初始值為－1
	
		connfd[i] = -1;
		
	
	printf("Weiting.......\n");
	
		//等待客戶端連線	
	
	while(1){
	
	
		int i;
		
		for(i=0; i<MAX_SIZE; i++){	//尋找到沒有儲存客戶端的一個位置
		
			if(connfd[i] == -1){
			
			break;
			
			}
		
		}
			//讓該位置儲存下一個連線進來的客戶端
		if((connfd[i]=accept(sfd, (struct sockaddr *)&cin, &Length)) == -1){//連線客戶端
		
			printf("accept error\n");
			
			exit(1);
		}else
		
		printf("有人加入編號為：%d\n", i);   //輸入連線進來的客戶端的編號
		
		pthread_t th1;
		
		pthread_create(&th1, NULL, recv_fun, (void*)&connfd[i]);   // 建立一個執行緒把接受資訊的函式加入到主函式中
		
	}
	
	
	return 0;
}

void *recv_fun(void *arg){

	int fd = *((int *)arg);		//用來儲存剛才發訊息過來的客戶端的編號
	
	struct Msg msg;		//宣告一個結構體用來接收發送過來的資訊
	
	int flge, num_send, num_recv;
	
	while(1){
		
		int n=recv(fd, (char*)&msg, sizeof(msg), 0);	//接受傳送過來的資訊儲存到msg的結構體中
		
		if(n<=0){//判斷是否接收成功
		
			printf("recv error\n");
			
			connfd[msg.socket] = -1;
			
			pthread_exit(NULL);
			
			exit(1);
			 
		}
		
		int i;
		
		for(i=0; i<MAX_SIZE; i++){  //如果客戶端要私聊的話，先遍歷陣列找到要私聊的客戶端的位置
		
			if(fd == connfd[i])
			
				break;
		}
		
		msg.socket = i;
		//在伺服器中顯示一下發送的資訊
		printf("接受到編號為：%d,%s訊息為：%s,\n\n\n", msg.socket, msg.name, msg.message);
		
		if(msg.flge == -1){//-1時為群聊
		
			for(i=0; i<MAX_SIZE; i++){//從開始位置一直找到最後一個存放客戶端的位置除去自己其他的客戶端都發送一邊資訊
				
				if(connfd[i] != fd && connfd[i] != -1){
					
					num_send=send(connfd[i], (char*)&msg, sizeof(msg), 0);
					
					if(num_send < 0){
					
						printf("send error\n");
					
					}	
				}
			}
		}else{//如果不是群聊的話就把資訊傳送給指定位置的客戶端上
		
			num_send=send(connfd[msg.flge], (char*)&msg, sizeof(msg), 0);
			
			if(num_send < 0 ){
				
				printf("send error\n");
			}
		
		} 
	
	}

}
 

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <arpa/inet.h>
#include <netinet/in.h>

#define PORT 8081		//設定埠資訊這是埠號要與伺服器埠號相同
#define BUFFER_SIZE 1024		//設定最大發送資訊位元組
#define HOST_ADDR "127.0.0.1"	//設定伺服器的ip因為都是本地連線即伺服器的埠為127.0.0.1

struct Msg{	//傳送資訊的結構體包含客戶端的資訊， 傳送訊息  套接字描述符 和要群發和私聊的判斷符
	
	char name[20];
	char message[BUFFER_SIZE];
	int socket;
	int flge;

};
struct Msg msg;

void *send_fun(void *arg);		//傳送資訊函式
void *recv_fun(void *arg);		//接受資訊函式

int main()
{
	int sfd;
	
	//char buf[BUFFER_SIZE];
	
	struct sockaddr_in sin;
	
	
   if((sfd=socket(AF_INET,SOCK_STREAM,0))==-1){//建立一個套接字AF_INET代表ipV4協議 SOCK_STREAM 是用TCP連線型別的有序位元組流協議
			printf("socket error\n");
			
			exit(1);
			
	}
		
	//設定套接字地址資訊AF_INET代表使用ipv4, htons(PORT)把本地埠轉化為網路埠s代表轉化為短型的 inte_pton函式就是把開始設定的ip轉化為網路的ip並使用ipv4協議給套接字sin的ip
	sin.sin_family=AF_INET;
	
	sin.sin_port=htons(PORT);
	
   inet_pton(AF_INET,HOST_ADDR,&sin.sin_addr);  
   
   /* if(inet_aton(HOST_ADDR,&sin.sin_addr)== -1)//與上面轉化一樣
    {
        printf("inet_aton error.\n");
        return -1;
    }
	*/
	
	bzero(&(sin.sin_zero),8);//為套接字補8個0
	
	if(connect(sfd,(struct sockaddr *)&sin,sizeof(sin))==-1)//連線客戶端，sfd為套接字描述符， 第二個引數表示把sockaddr_in型別的sin轉化為sockaddr型別的， 第三個引數為sin的位元組數
	{
		printf("connet error\n");
		
		close(sfd);
		
		exit(1);
	}
	
	printf("輸入姓名：");
	
	scanf("%s", msg.name);
	
	pthread_t th1, th2;	//宣告兩個執行緒變數
	
	//分別把send_fun函式和recv_fun函式加入到主函式中
	if(pthread_create(&th1, NULL, send_fun, (void*)&sfd)){
	
		perror("Create phtread error\n");
		
		exit(1);
	
	}
	
	if(pthread_create(&th2, NULL, recv_fun, (void*)&sfd)){
	
		perror("Create phtread error\n");
		
		exit(1);
	
	}
	//等待執行緒結束 
	pthread_join(th1, NULL);
	
	pthread_join(th2, NULL);
	
	close(sfd);
	
	return 0;
}
	
	
void *send_fun(void *arg){

	int sfd= *((int *)arg);
	
	
	while(1){
	
		printf("請選擇聊天方式：\n-1 群聊 \n輸入其他客戶端編號私聊\n請選擇：\n");
		
		scanf("%d", &msg.flge);//輸入標記符後面用來判斷是私聊還是群聊
		
		printf("輸入聊天內容：");
		
		scanf("%s", msg.message);//聊天資訊
		
		int n = send(sfd, (char *)&msg, sizeof(msg), 0);//傳送資訊
		
		if(n!= sizeof(msg)){
			
			perror("send error\n");
			
			exit(1);
		
		}
		
	}

}
	
	
void *recv_fun(void *arg){

	int sfd=*((int*)arg);
	
	struct Msg msg;
	
	while(1){
	
		int n=recv(sfd, (char*)&msg, sizeof(msg), 0);//接受資訊函式
	
		if(n == -1){
		
		perror("recv error\n");
		
		exit(1);
		
		}
		//輸出接受的資訊
		printf("\n編號為:%d, 姓名為:%s, 發的資訊為:%s\n\n", msg.socket, msg.name, msg.message);
		
	}

}
 

伺服器接收來自客戶端的連線請求，當有客戶端傳送過來資料時，

伺服器將資料儲存到全域性緩衝區，並將資料迴圈傳送給已經連線的客戶端