聊天室项目

服务器

#include <myhead.h>
#define SER_IP "192.168.122.39"
#define SER_PORT 8888
typedef struct Node  //链表存储客户端的所有信息
{struct sockaddr_in cin;  //存储客户端的网络地址信息struct Node *next;
}*List;
typedef struct Message//消息结构体
{char type;char name[20];char text[128];
}msg_t;
struct sockaddr_in cin;  //客户端地址信息结构体//单链表节点创建函数
List create_node()
{List p=(List)malloc(sizeof(struct Node));if(NULL==p)return NULL;p->next=NULL;return p;
}
//客户端链表尾插
List insert_rear(List head,struct sockaddr_in cin)
{List s=create_node();if(NULL==s)return head;s->cin=cin;if(NULL==head){head=s;return s;}else{List p=head;while(p->next!=NULL)p=p->next;p->next=s;return head;}
}
//客户端接入服务器通知函数
void chat_all_join(List head,msg_t msg,int sfd)
{List p=head;char buf[50]="";while(p->next!=NULL){snprintf(buf,sizeof(buf),"[%s:%d]%s加入聊天室\n",inet_ntoa(p->cin.sin_addr),\ntohs(p->cin.sin_port),msg.name);sendto(sfd,buf,sizeof(buf),0,(struct sockaddr*)&(p->cin),sizeof(p->cin));p=p->next;}
}
//客户端消息转发函数
void chat_all(List head,struct Message msg,int sfd,struct sockaddr_in cin)
{List p=head;char rbuf[200]="";while(p->next!=NULL){snprintf(rbuf,sizeof(rbuf),"[%s:%d]%s:%s\n",inet_ntoa(p->cin.sin_addr),\ntohs(p->cin.sin_port),msg.name,msg.text);sendto(sfd,rbuf,sizeof(rbuf),0,(struct sockaddr*)&(p->cin),sizeof(p->cin));p=p->next;}snprintf(rbuf,sizeof(rbuf),"[%s:%d]%s:%s\n",inet_ntoa(p->cin.sin_addr),\ntohs(p->cin.sin_port),msg.name,msg.text);sendto(sfd,rbuf,sizeof(rbuf),0,(struct sockaddr*)&(p->cin),sizeof(p->cin));}
//客户端发送退出消息函数
void chat_all_quit(List head,struct Message msg,int sfd)
{char wbuf[200]="";	List p=head;while(p->next!=NULL){snprintf(wbuf,sizeof(wbuf),"[%s:%d]%s:退出了聊天室\n",inet_ntoa(p->cin.sin_addr),\ntohs(p->cin.sin_port),msg.name);sendto(sfd,wbuf,sizeof(wbuf),0,(struct sockaddr*)&(p->cin),sizeof(p->cin));p=p->next;}snprintf(wbuf,sizeof(wbuf),"[%s:%d]%s:退出了聊天室\n",inet_ntoa(p->cin.sin_addr),\ntohs(p->cin.sin_port),msg.name);sendto(sfd,wbuf,sizeof(wbuf),0,(struct sockaddr*)&(p->cin),sizeof(p->cin));
}
//链表中删除该地址信息
List exit_chat(List head)
{if(head->next==NULL)//只有一个客户端时{free(head);head=NULL;return head;}List p=head;while(p->next!=NULL)  //两个以上客户端{if(memcmp(&(p->next->cin),&cin,sizeof(cin))==0)//找到p下一个节点地址信息符合的{List del=p->next;p->next=del->next;free(del);del=NULL;break;}else{p=p->next;}}return head;
}
int main(int argc, const char *argv[])
{//创建通信的套接字文件描述符int sfd=-1;if((sfd=socket(AF_INET,SOCK_DGRAM,0))==-1){perror("socket error");return -1;}//快速刷新端口号int reuse=-1;if(setsockopt(sfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse))==-1){perror("setsockopt error");return -1;}//给当前套接字绑定结构体信息struct sockaddr_in sin;sin.sin_family=AF_INET;sin.sin_port=htons(SER_PORT);sin.sin_addr.s_addr=inet_addr(SER_IP);if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))==-1){perror("bind error");return -1;}//准备文件描述符容器fd_set readfds,tempfds;FD_ZERO(&readfds);FD_SET(0,&readfds);FD_SET(sfd,&readfds);int maxfd=sfd;//定义变量存放客户端地址信息结构体,及客户端消息struct sockaddr_in cin;socklen_t socklen=sizeof(cin);struct Message msg;List head=NULL;char buf[128]="";while(1){tempfds=readfds;if(select(maxfd+1,&tempfds,NULL,NULL,NULL)==-1){perror("select error");return -1;}//收到消息if(FD_ISSET(sfd,&tempfds)){recvfrom(sfd,&msg,sizeof(msg),0,(struct sockaddr*)&cin,&socklen);switch(msg.type){case 'L':  //客户端加入{head=insert_rear(head,cin);  //尾插入链表chat_all_join(head,msg,sfd);		printf("[%s:%d]%s加入聊天室\n",inet_ntoa(cin.sin_addr),\ntohs(cin.sin_port),msg.name);};break;case 'C':  //客户端消息{chat_all(head,msg,sfd,cin);printf("[%s:%d]%s:%s\n",inet_ntoa(cin.sin_addr),\ntohs(cin.sin_port),msg.name,msg.text);};break;case 'Q':  //客户端退出{chat_all_quit(head,msg,sfd);printf("[%s:%d]%s退出聊天室\n",inet_ntoa(cin.sin_addr),\ntohs(cin.sin_port),msg.name);head=exit_chat(head);};break;default:printf("type error\ttype=%c\n",msg.type);return -1;}}//发送消息if(FD_ISSET(0,&tempfds)){memset(buf,0,sizeof(buf));fgets(buf,sizeof(buf),stdin);buf[strlen(buf)-1]='\0';char wbuf[56]="";snprintf(wbuf,sizeof(wbuf),"***system***%s\n",buf);List p=head;while(p!=NULL){sendto(sfd,wbuf,sizeof(wbuf),0,(struct sockaddr*)&(p->cin),sizeof(p->cin));p=p->next;}}}return 0;
}

客户端

#include <myhead.h>
#define SER_IP "192.168.122.39"
#define SER_PORT 8888
//#define CLI_IP ""
//#define CLI_PORT
struct Message
{char type;char name[20];char text[128];};
int main(int argc, const char *argv[])
{struct Message msg;//创建通信用套接字文件描述符int cfd=-1;if((cfd=socket(AF_INET,SOCK_DGRAM,0))==-1){perror("socket error");}//填写服务器的地址信息结构体struct sockaddr_in sin;sin.sin_family=AF_INET;sin.sin_port=htons(SER_PORT);sin.sin_addr.s_addr=inet_addr(SER_IP);//发送客户端的登录信息printf("请输入昵称:");fgets(msg.name,sizeof(msg.name),stdin);msg.name[strlen(msg.name)-1]='\0';msg.type='L';if(sendto(cfd,&msg,sizeof(msg),0,(struct sockaddr*)&sin,sizeof(sin))==-1){perror("sendto info error");return -1;}else{printf("加入聊天服务器成功\n");}//准备文件描述符容器fd_set readfds,tempfds;FD_ZERO(&readfds);FD_SET(0,&readfds);FD_SET(cfd,&readfds);int maxfd=cfd;while(1){tempfds=readfds;int res=select(maxfd+1,&tempfds,NULL,NULL,NULL);if(res==-1){perror("select error");return -1;}//发数据if(FD_ISSET(0,&tempfds)){memset(msg.text,0,sizeof(msg.text));read(0,msg.text,sizeof(msg.text));msg.text[strlen(msg.text)-1]='\0';//客户端退出if(strcmp(msg.text,"quit")==0){msg.type='Q';sendto(cfd,&msg,sizeof(msg),0,(struct sockaddr*)&sin,sizeof(sin));printf("本机已下线\n");close(cfd);return 0;}//与其他客户端通信else{msg.type='C';sendto(cfd,&msg,sizeof(msg),0,(struct sockaddr*)&sin,sizeof(sin));}}//收数据if(FD_ISSET(cfd,&tempfds)){char buf[128]="";//不接收服务器的地址信息结构体recvfrom(cfd,buf,sizeof(buf),0,NULL,NULL);printf("%s",buf);fflush(stdout);}}return 0;
}

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

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

相关文章

洛谷 P1731 [NOI1999] 生日蛋糕

题目 题目链接 自己没看题解写的&#xff0c;摸石头过河&#xff0c;解释一下 首先&#xff0c;输入输出都是正整数。先搞定输入&#xff0c;再判断条件&#xff0c;如果无解&#xff0c;输出0&#xff0c;否则输出蛋糕外表面面积Q&#xff08;这里用全局变量&#xff0c;开l…

数据库:2024/3/6

作业1&#xff1a;使用C语言完成数据库的增删改 代码&#xff1a; #include <myhead.h>//定义添加员工信息函数 int Add_worker(sqlite3 *ppDb) {//准备sql语句printf("请输入要添加的员工信息:\n");//从终端获取员工信息char rbuf[128]"";fgets(r…

React学习

&#x1f4d1;前言 本文主要是【React】——React基础的文章&#xff0c;如果有什么需要改进的地方还请大佬指出⛺️ &#x1f3ac;作者简介&#xff1a;大家好&#xff0c;我是听风与他&#x1f947; ☁️博客首页&#xff1a;CSDN主页听风与他 &#x1f304;每日一句&#x…

C++ 哈希表OJ

目录 1、1. 两数之和 2、面试题 01.02. 判定是否互为字符重排 3、217. 存在重复元素 4、 219. 存在重复元素 II 5、49. 字母异位词分组 频繁查找某一个数的时候可以使用哈希表&#xff0c;哈希表可以使用容器&#xff0c;也可以使用数组模拟&#xff0c;当元素是字符串中的字…

算法打卡day9|栈与队列篇01|Leetcode 232.用栈实现队列、225. 用队列实现栈

栈与队列理论基础 栈&#xff08;Stack&#xff09; 栈是一种后进先出&#xff08;LIFO&#xff09;的数据结构,即最近添加到栈中的元素将是第一个被移除的元素。 栈通常有两个主要的操作&#xff1a;push 用于添加一个元素到栈顶&#xff0c;而 pop 用于移除栈顶的元素。此外…

二维码样式修改如何在线处理?在电脑上改二维码图案的方法

随着网络的不断发展&#xff0c;二维码的应用场景不断增多&#xff0c;很多人都会将内容放到二维码中&#xff0c;通过扫码的方式将储存在云端的数据调取显示。而面对不同的用途时&#xff0c;对二维码的样式也会有单独的要求&#xff0c;比如需要改变颜色、加入文字、logo、尺…

网络调试助手使用MQTT协议与Mosquitto通信(3)

一、连接报文 一开始设备需要连接到mqtt服务器&#xff0c;连接时的数据包内需要携带对应的设备ID&#xff0c;以及用户名和密码。这使用默认的用户名和密码。设备ID每一个设备都需要设置为不同的&#xff0c;两个相同的ID只能允许一台设备在线&#xff0c;另一个相同的ID的设备…

【C++庖丁解牛】模版初阶

&#x1f4d9; 作者简介 &#xff1a;RO-BERRY &#x1f4d7; 学习方向&#xff1a;致力于C、C、数据结构、TCP/IP、数据库等等一系列知识 &#x1f4d2; 日后方向 : 偏向于CPP开发以及大数据方向&#xff0c;欢迎各位关注&#xff0c;谢谢各位的支持 目录 1. 泛型编程2. 函数模…

Dgraph 入门教程二《 快速开始》

1、Clound 云 云地址&#xff1a;Dgraph Cloud 登录Clound 云后&#xff0c;可以用云上的东西操作&#xff0c;可以用谷歌账号或者github账号登录。 启动云 &#xff08;1&#xff09;在云控制台&#xff0c;点击 Launch new backend. &#xff08;2&#xff09;选择计划&…

【PowerMockito:编写单元测试过程中原方法使用@Value注解注入的属性出现空指针】

错误场景 执行到Value的属性时会出现空指针&#xff0c;因为Value的属性为null 解决方法 在测试类调用被测试方法前&#xff0c;提前设置属性值&#xff0c;属性可以先自己定义好 ReflectionTestUtils.setField(endpointConnectionService, "exportUdpList", lis…

工业深度学习异常缺陷检测实战

在工业生产过程中&#xff0c;由于现有技术、工作条件等因素的不足和局限性&#xff0c;极易影响制成品的质量。其中&#xff0c;表面缺陷是产品质量受到影响的最直观表现&#xff0c;因此&#xff0c;为了保证合格率和可靠的质量&#xff0c;必须进行产品表面缺陷检测。 “缺陷…

制片管理工具:提高制片效率的必备工具

一、什么是制片管理工具 制片管理工具是一种为制片人提供支持和协助的软件或工具&#xff0c;并提供一种集中管理制作进度、任务分配、成本预算、资源管理和进度跟踪的方式。它可以帮助制片人在项目的开发、制作和发布方面更有效地进行规划和监督&#xff0c;确保整个流程能够…

LLM | Gemma的初体验

一起来体验一下吧~ 技术报告书&#xff1a;jgoogle/gemma-7b-it Hugging Facegemma-report.pdf (storage.googleapis.com) 代码1 &#xff1a;google-deepmind/gemma: Open weights LLM from Google DeepMind. (github.com) 代码2 &#xff1a;https://github.com/google/gem…

报名开启丨掘金海外,探寻泛娱乐社交APP出海新风口

随着国内泛娱乐行业用户规模趋于见顶&#xff0c;泛娱乐社交APP转向出海是必然趋势。 根据行业数据显示&#xff0c;有超过35%的国内实时社交企业已启动或者正在规划出海&#xff0c;而其中出海商户的音视频流量增长均超过了100&#xff05;。尤其是在东南亚、中东、拉美等新兴…

Maya笔记 软选择

文章目录 1什么是软选择2注意3如何打开软选择3.1方法一3.2方法二 4调整软选择的范围5衰减模式5.1体积模式5.2表面模式 6衰减曲线 1什么是软选择 也就是渐变选择&#xff0c;从中心点向外影响力度越来越小 软选择针对的是点线面这些模型元素 下图中展示了对被软选择的区域移动…

Rust入门:Rust如何调用C静态库的函数

关于Rust调用C&#xff0c;因为接口比较复杂&#xff0c;貌似Rust不打算支持。而对于C函数&#xff0c;则相对支持较好。 如果要研究C/Rust相互关系的话&#xff0c;可以参考&#xff1a; https://docs.rs/cxx/latest/cxx/ Rust ❤️ C 这里只对调用C静态库做一个最简短的介…

干货教程【软件篇】如何在Windows上安装Python环境以及设置国内源(Miniconda/Anaconda安装)

本文章涉及的所有安装包均在文章下方公众号中&#xff0c;回复python即可获取资源。 也可关注我们的官方网站&#xff1a; 考拉AI 小白安装前须了解一下 Python解释器是用来解释运行我们编写的Python代码。 Python标准库是Python自带的一系列标准模块&#xff0c;提供了各种…

浏览器修改接口返回数据展示在页面上

前端自己调试&#xff0c;想修改接口返回来的数据&#xff0c;然后展示在页面上 举例 接口返回了数据&#xff0c;想要修改此数据 这时就可以修改数据了&#xff0c;修改完成保存 然后刷新页面就会使用本地保存的数据了

Linux编程3.4 进程-进程标识

1、相关函数 #include<unistd.h> #include<sys/types.h> pid_t getpid(void); 获得当前进程ID uid_t getuid(void); 获得当前进程的实际用户ID uit_t geteuid(void); 获得当前进程的有效用户ID git_t getgid(void); 获得当前进程的用户组ID pit_t getppid(…

信号处理--基于单通道脑电信号EEG的睡眠分期评估

背景 睡眠对人体健康很重要。监测人体的睡眠分期对于人体健康和医疗具有重要意义。 亮点 架构在第一层使用两个具有不同滤波器大小的 CNN 和双向 LSTM。 CNN 可以被训练来学习滤波器&#xff0c;以从原始单通道 EEG 中提取时不变特征&#xff0c;而双向 LSTM 可以被训练来将…