聊天室项目

服务器

#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…

数据库的分类和特点介绍

#基础概念# #入门 数据库的主要分类 关系型数据库&#xff08;RDBMS&#xff09; 数据以表格形式存储&#xff0c;通过预定义的关系模型建立数据间的连接&#xff0c;使用SQL作为查询语言。常见的例子包括MySQL、Oracle、SQL Server、PostgreSQL、IBM DB2等。 非关系型数据库…

SEDEX验厂审核重点

SEDEX验厂简介 在全球化的今天&#xff0c;供应链的透明性和可持续性越来越受到人们的关注。为了确保供应链的合规性和可持续性&#xff0c;许多企业开始采用SEDEX验厂这一方法。SEDEX验厂是一种基于国际劳工组织&#xff08;ILO&#xff09;核心劳工标准的供应链审核体系&…

数据库:2024/3/6

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

算法-买卖股票的最佳时机

1、题目来源 121. 买卖股票的最佳时机 - 力扣&#xff08;LeetCode&#xff09; 2、题目描述 给定一个数组 prices &#xff0c;它的第 i 个元素 prices[i] 表示一支给定股票第 i 天的价格。 你只能选择 某一天 买入这只股票&#xff0c;并选择在 未来的某一个不同的日子 卖…

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. 函数模…

凌鲨微应用API大全

linksaas-minapp/api 获取微应用信息 export interface MinAppInfo {userId: string; //用户ID(未登录为空字符串)userDisplayName: string;crossHttp: boolean;//打开redis代理时会设置redisProxyToken?: string;redisProxyAddr?: string;//打开mongo代理时会设置mongoPro…

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…

修改Yaml文件报错“块映射中的子元素无效”

开发环境 Golandpbyaml文件开发的 错误信息 新增了一个配置项&#xff0c;随后提示&#xff1a;“块映射中的子元素无效” 错误原因 yaml文件的格式要求严格&#xff0c;在:的后面要求有一个 空格&#xff0c;本次就是漏掉错误导致的犯错。 其他可能原因 以下答案来自GP…

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

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

流动性、价格发现与安全性:NFG在二级市场和交易所的联动效应

每天五分钟一套互联网知识&#xff0c;大家好我是啊浩说模式 在数字经济蓬勃发展的今天&#xff0c;非同质化代币&#xff08;NFT&#xff09;作为区块链技术的重要应用之一&#xff0c;正逐渐改变着传统艺术品、收藏品市场的格局。其中&#xff0c;NFG作为NFT领域的一个细分领…

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

一、什么是制片管理工具 制片管理工具是一种为制片人提供支持和协助的软件或工具&#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…