當前位置：首頁 > 运维知识 > linux >内容正文

linux

Linux下基于socket和多线程的聊天室小程序

發布時間：2023/11/30 linux 27 豆豆

生活随笔收集整理的這篇文章主要介紹了 Linux下基于socket和多线程的聊天室小程序小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

轉載：http://blog.csdn.net/robot__man/article/details/52460733

要求：基于TCP編寫，一個聊天室最多100人。?
客戶端：?
　　1、用戶需要登錄，登錄時只需要輸入一個昵稱即可無需判斷昵稱是否重復（如果其他功能都ok考慮）?
　　2、用戶登錄后連接服務器端，進入聊天室?
　　3、用戶可以輸入聊天信息，也可以收到別人的聊天信息。?
　　4、用戶可以用某個特殊單詞代表退出聊天室。

服務器端：?
　　1、啟動服務器，開放端口?
　　2、等待客戶端的連接，每連接上一個客戶端，啟動一個線程?
　　3、在線程中與客戶端交互，交互過程：如果有客戶端登錄、退出、提交聊天，都應該發給所有的客戶端。需要　　　保存所有客戶端。

額外功能：可以考慮實現TCP的文件傳輸。

server.c#include <stdio.h> #include <string.h> #include <stdlib.h> #include <unistd.h> #include <netinet/in.h> #include <arpa/inet.h> #include <sys/socket.h> #include <pthread.h>int sockfd;//服務器socket int fds[100];//客戶端的socketfd,100個元素，fds[0]~fds[99] int size =100 ;//用來控制進入聊天室的人數為100以內 char* IP = "192.168.10.143"; short PORT = 10222; typedef struct sockaddr SA;void init(){sockfd = socket(PF_INET,SOCK_STREAM,0);if (sockfd == -1){perror("創建socket失敗");exit(-1);}struct sockaddr_in addr;addr.sin_family = PF_INET;addr.sin_port = htons(PORT);addr.sin_addr.s_addr = inet_addr(IP);if (bind(sockfd,(SA*)&addr,sizeof(addr)) == -1){perror("綁定失敗");exit(-1);}if (listen(sockfd,100) == -1){perror("設置監聽失敗");exit(-1);} }void SendMsgToAll(char* msg){int i;for (i = 0;i < size;i++){if (fds[i] != 0){printf("sendto%d\n",fds[i]);send(fds[i],msg,strlen(msg),0);}} }void* service_thread(void* p){int fd = *(int*)p;printf("pthread = %d\n",fd);while(1){char buf[100] = {};if (recv(fd,buf,sizeof(buf),0) <= 0){int i;for (i = 0;i < size;i++){if (fd == fds[i]){fds[i] = 0;break;}}printf("退出：fd = %dquit\n",fd);pthread_exit((void*)i);}//把服務器接受到的信息發給所有的客戶端SendMsgToAll(buf);} }void service(){printf("服務器啟動\n");while(1){struct sockaddr_in fromaddr;socklen_t len = sizeof(fromaddr);int fd = accept(sockfd,(SA*)&fromaddr,&len);if (fd == -1){printf("客戶端連接出錯...\n");continue;}int i = 0;for (i = 0;i < size;i++){if (fds[i] == 0){//記錄客戶端的socketfds[i] = fd;printf("fd = %d\n",fd);//有客戶端連接之后，啟動線程給此客戶服務pthread_t tid;pthread_create(&tid,0,service_thread,&fd);break;}if (size == i){//發送給客戶端說聊天室滿了char* str = "對不起，聊天室已經滿了!";send(fd,str,strlen(str),0); close(fd);}}} }int main(){init();service(); }

client.c#include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> #include <pthread.h>int sockfd;//客戶端socket char* IP = "192.168.10.143";//服務器的IP short PORT = 10222;//服務器服務端口 typedef struct sockaddr SA; char name[30];void init(){sockfd = socket(PF_INET,SOCK_STREAM,0);struct sockaddr_in addr;addr.sin_family = PF_INET;addr.sin_port = htons(PORT);addr.sin_addr.s_addr = inet_addr(IP);if (connect(sockfd,(SA*)&addr,sizeof(addr)) == -1){perror("無法連接到服務器");exit(-1);}printf("客戶端啟動成功\n"); }void start(){pthread_t id;void* recv_thread(void*);pthread_create(&id,0,recv_thread,0);char buf2[100] = {};sprintf(buf2,"%s進入了聊天室",name);send(sockfd,buf2,strlen(buf2),0);while(1){char buf[100] = {};scanf("%s",buf);char msg[131] = {};sprintf(msg,"%s:%s",name,buf);send(sockfd,msg,strlen(msg),0);if (strcmp(buf,"bye") == 0){memset(buf2,0,sizeof(buf2));sprintf(buf2,"%s退出了聊天室",name);send(sockfd,buf2,strlen(buf2),0);break;}}close(sockfd); }void* recv_thread(void* p){while(1){char buf[100] = {};if (recv(sockfd,buf,sizeof(buf),0) <= 0){return;}printf("%s\n",buf);} }int main(){init();printf("請輸入您的名字：");scanf("%s",name);start();return 0; }

　　剛開始，我聲明的那個全局數組int fds[99],它是有99個元素，fds[0]~fds[98],我以為是到fds[99]，結果數組越界，向fds[99]指向的未知文件描述符發了個數據，而fds[99]指向的是監視進程的，向它發任何數據，進程都會莫名奇妙的終止。于是，服務器莫名奇妙的掛掉了，朋友用gdb調試，才發現Program received signal SIGPIPE, Broken pipe.這個問題我自己看了一天半也沒發現，最后還是在群里面，別人幫提出來的，感悟有以下幾點：?
1、Linux下寫程序，也有調試工具gdb，要學會使用，程序出錯了，如果看不出來，就可以來調試；?
2、程序員不是一直埋頭寫程序就行了，還是要多和別人交流，一切以解決問題為根本。

總結

以上是生活随笔為你收集整理的Linux下基于socket和多线程的聊天室小程序的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。

上一篇： libevent网络编程例子（1）
下一篇：免疫性不孕预防