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();
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85
  • 86
  • 87
  • 88
  • 89
  • 90
  • 91
  • 92
  • 93
  • 94
  • 95
  • 96
  • 97
  • 98
  • 99
  • 100
  • 101
  • 102
  • 103
  • 104
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;
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70

　　刚开始，我声明的那个全局数组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、程序员不是一直埋头写程序就行了，还是要多和别人交流，一切以解决问题为根本。


本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/384313.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

操作系统（一）计算机系统概述

操作系统（一）计算机系统概述

操作系统&#xff08;一&#xff09;计算机系统概述一、操作系统的概念二、功能和目标资源的管理者向上层提供服务对硬件的扩展三、操作系统的特征并发共享虚拟异步四、操作系统的发展与分类手工操作阶段批处理阶段单道批处理系统多道批处理系统分时操作系统实时操作系统操作系…
阅读更多...
Linux下使用socket传输文件的C语言简单实现

Linux下使用socket传输文件的C语言简单实现

转载&#xff1a;http://blog.csdn.net/ljd_1986413/article/details/7940938 服务器程序和客户端程序应当分别运行在两台计算机上。 在运行服务器端的计算机终端执行&#xff1a;./file_server 在运行客户端的计算终端上执行&#xff1a;./file_client ipaddr_server 然后根…
阅读更多...
操作系统（二）进程管理

操作系统（二）进程管理

ui 操作系统&#xff08;二&#xff09;进程管理一、进程程序和进程进程控制块&#xff08;PCB&#xff09;进程的组成进程的特征进程的状态与转换进程状态的转换进程的组织链接方式索引方式进程的控制进程的创建进程的终止进程阻塞进程唤醒进程切换进程通信共享存储消息传递管…
阅读更多...
gethostbyname()函数说明

gethostbyname()函数说明

转载&#xff1a;http://www.cnblogs.com/cxz2009/archive/2010/11/19/1881611.html gethostbyname()函数说明——用域名或主机名获取IP地址 包含头文件 #include <netdb.h> #include <sys/socket.h> 函数原型 struct hostent *gethostbyna…
阅读更多...
操作系统（三）内存管理

操作系统（三）内存管理

操作系统&#xff08;三&#xff09;内存管理一、程序执行过程装入的三种方式链接的三种方式二、内存管理的概念内存空间的分配与回收连续分配管理方式单一连续分配固定分区分配动态分区分配首次适应算法最佳适应算法最坏适应算法邻近适应算法非连续分配管理方式基本分页存储管…
阅读更多...
操作系统（四）文件管理

操作系统（四）文件管理

操作系统&#xff08;四&#xff09;文件管理一、文件系统基础1.文件逻辑结构无结构文件有结构文件2.文件目录文件控制块&#xff08;FCB&#xff09;目录结构单级目录两级目录结构多级目录结构无环图目录结构3.文件保护口令保护加密保护访问控制4.文件共享硬链接软链接5.文件系…
阅读更多...
struct stat结构体简介

struct stat结构体简介

转载&#xff1a;http://www.cnblogs.com/CSU-PL/archive/2013/06/06/3120757.html 在使用这个结构体和方法时&#xff0c;需要引入&#xff1a; <sys/types.h> <sys/stat.h> struct stat这个结构体是用来描述一个linux系统文件系统中的文件属性的结构。 可以有两种…
阅读更多...
如何在Ubuntu上安装GCC编译器

如何在Ubuntu上安装GCC编译器

如何在Ubuntu上安装GCC编译器1.首先更新包列表sudo apt update2.安装build-essential软件包&#xff1a; sudo apt install build-essential3.验证GCC编译器是否已成功安装&#xff0c;请使用gcc --version命令打印GCC版本 rootubuntu:/home/csd# gcc --version
阅读更多...
操作系统（五）输入/输出（I/O）管理

操作系统（五）输入/输出（I/O）管理

操作系统&#xff08;五&#xff09;输入/输出&#xff08;I/O&#xff09;管理一、I/O控制器二、I/O控制方式程序直接控制方式中断驱动方式DMA方式通道控制方式I/O软件层次结构假脱机技术设备的分配与回收缓冲区单缓冲双缓冲循环缓冲区缓冲池一、I/O控制器 I/O设备由机械部件…
阅读更多...
Linux下的I/O多路复用select，poll，epoll浅析

Linux下的I/O多路复用select，poll，epoll浅析

转载&#xff1a;http://blog.csdn.net/u011573853/article/details/52105365 一&#xff0c;什么是I/O多路复用 所谓的I/O多路复用在英文中其实叫 I/O multiplexing. 就是单个线程&#xff0c;通过记录跟踪每个I/O流(sock)的状态&#xff0c;来同时管理多个I/O流 。) I/O mu…
阅读更多...
计算机组成原理（一）计算机系统概述

计算机组成原理（一）计算机系统概述

计算机组成原理&#xff08;一&#xff09;计算机系统概述一、计算机系统层次结构冯诺伊曼机计算机工作过程多级层次结构一、计算机系统层次结构 冯诺伊曼机 特点&#xff1a; 计算机由五大部件组成指令和数据以同等地位存于存储 器&#xff0c;可按地址寻访指令和数据用二进…
阅读更多...
计算机组成原理（二）数据的表示和运算

计算机组成原理（二）数据的表示和运算

计算机组成原理&#xff08;二&#xff09;数据的表示和运算一、BCD码二、奇偶校验码三、海明码四、循环冗余校验码&#xff08;CRC&#xff09;五、乘法运算原码乘法补码乘法六、除法运算原码除法补码除法七、浮点数的表示与运算浮点数的运算一、BCD码 组合式BCD码&#xff1…
阅读更多...
select read write

select read write

转载&#xff1a;http://blog.csdn.net/beginning1126/article/details/8057498 [cpp] view plaincopy <p style"color: rgb(51, 51, 51); font-family: Arial; font-size: 14px; line-height: 26px; text-align: left; "><span style"font-size:14px;…
阅读更多...
数据结构（七）图的遍历（递归非递归方法）

数据结构（七）图的遍历（递归非递归方法）

图的遍历&#xff08;递归非递归方法&#xff09;#include<iostream> #include<stdio.h> #include<stack> #include<queue> using namespace std;typedef char VertexType; typedef int EdgeType;#define MAXVEX 100 #define INF 65535 bool visited[M…
阅读更多...
Linux IO复用区别与epoll详解

Linux IO复用区别与epoll详解

转载&#xff1a;http://blog.csdn.net/hacker00011000/article/details/52160590 一、select、poll、epoll之间的区别总结[整理] 　　select&#xff0c;poll&#xff0c;epoll都是IO多路复用的机制。I/O多路复用就通过一种机制&#xff0c;可以监视多个描述符&#xff0c;一…
阅读更多...
简单图和多重图

简单图和多重图

一、简单图    ① 不存在重复边&#xff1b;    ② 不存在顶点到自身的边&#xff1b; 二、多重图   ① 某两结点之间边数多于一条&#xff1b;   ② 允许顶点通过一条边和自己关联&#xff1b;
阅读更多...
C++笔记：select多路复用机制

C++笔记：select多路复用机制

转载&#xff1a;http://blog.csdn.net/qdx411324962/article/details/42499535 函数作用&#xff1a; 系统提供select函数来实现多路复用输入/输出模型。select系统调用是用来让我们的程序监视多个文件句柄的状态变化的。程序会停在select这里等待&#xff0c;直到被监视的文件…
阅读更多...
交叉编译执行应用程序出现：No such file or directory

交叉编译执行应用程序出现：No such file or directory

问题分析 当我在arm板子上执行交叉编译过的程序的时候发现了这个错误。通过百度查询基本都是缺少32位库什么的,但是都不能解决问题。 然后我用ll指令&#xff0c;也排除了权限的原因。 我们用ldd指令发现&#xff0c;它不是动态执行的&#xff0c;虽然我们可以使用-static指…
阅读更多...
select、poll、epoll 比较

select、poll、epoll 比较

转载&#xff1a;http://blog.csdn.net/dodo_328/article/details/39081183 1.Selet&#xff1a;本质上是通过设置或者检查存放fd标志位的数据结构来进行下一步处理。 缺点&#xff1a;1 单个进程可监视的fd数量被限制&#xff0c;因为受描述符集合fd_set限制&#xff0c;fd数量…
阅读更多...
C库函数 File

C库函数 File

C库函数常用的有&#xff1a;fopen, fclose, fread, fwrite, fgets, fputs, fscanf, fprintf, fseek, fgetc, fputc, ftell, feof, flush等&#xff0c; 当使用fopen打开一个文件时通常返回一个文件指针 FILE *fp。FILE类型是一个结构体&#xff0c;包含文件描述符&#xff08;…
阅读更多...
最新文章

Copyright @ 2022~2023