项目：基于UDP的网络聊天室

项目需求：
1.如果有用户登录，其他用户可以收到这个人的登录信息
2.如果有人发送信息，其他用户可以收到这个人的群聊信息
3.如果有人下线，其他用户可以收到这个人的下线信息
4.服务器可以发送系统信息

服务器代码：

#include <myhead.h>
typedef struct group
{char type;char name[20];char text[128];
}gp_t;typedef struct Node
{int PORT;struct Node* next;
}*Linklist;Linklist create_node()
{Linklist s=(Linklist)malloc(sizeof(struct Node));if(NULL == s)return NULL;s->PORT =0;s->next =NULL;return s;
}Linklist insert_rear(Linklist head,int element)
{Linklist s=create_node();s->PORT=element;if(NULL == head){head = s;return head;}Linklist p = head;while(p->next != NULL){p=p->next;}p->next = s;return head;
}int lenth(Linklist head)
{if(head == NULL)return 0;int count=0;Linklist p=head;while(p!=NULL){count++;p=p->next;}free(p);p=NULL;return count;
}int find_element(Linklist head,int element)
{Linklist p=head;for(int i=0;i<lenth(head);i++){if(p->PORT == element)return i;p=p->next;}
}Linklist del_head(Linklist head)
{if(head->next == NULL){free(head);head=NULL;return head;}Linklist del=head->next;head->PORT=del->PORT;head->next=del->next;free(del);del=NULL;return head;
}Linklist del_rear(Linklist head)
{if(head->next == NULL){free(head);head = NULL;return head;}Linklist del=head;while(del->next->next!=NULL){del=del->next;}free(del->next);del->next=NULL;return head;
}Linklist del_pos(Linklist head,int pos)
{if(pos == lenth(head)-1){head = del_rear(head);return head;}else if(pos == 0){head = del_head(head);return head;}else{Linklist p=head;for(int i=0;i<pos-1;i++){p=p->next;}Linklist r=p->next;p->next=r->next;free(r);r=NULL;return head;}
}Linklist del(Linklist head,int element)
{if(head ==NULL)return head;int pos = find_element(head,element);head = del_pos(head,pos);return head;}int main(int argc, const char *argv[])
{if(argc != 3){printf("请输入服务器IP和端口号!\n");return -1;}int sfd = socket(AF_INET,SOCK_DGRAM,0);if(sfd == -1){perror("socket error");return -1;}struct sockaddr_in sin;sin.sin_family = AF_INET;sin.sin_port = htons(atoi(argv[2]));sin.sin_addr.s_addr = inet_addr(argv[1]);if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))==-1){perror("bind error");return -1;}printf("bind success\n");struct sockaddr_in cin;cin.sin_family = AF_INET;socklen_t socklen = sizeof(cin);Linklist Usr_PORT=NULL;gp_t usr;char buf[149] = "";char rbuf[130] = "";struct pollfd fds[2];fds[0].fd = 0;fds[0].events = POLLIN;fds[1].fd = sfd;fds[1].events = POLLIN;int res = 0;  //接收select的返回值while(1){res = poll(fds,2,-1);if(res == -1){perror("poll error");return -1;}else if(res == 0){printf("time out");return -1;}bzero(buf,sizeof(buf));if(fds[0].revents == POLLIN){strcpy(buf,"system:");fgets(buf+7,sizeof(buf)-7,stdin);buf[strlen(buf)-1] = '\0';Linklist p = Usr_PORT;while(p!= NULL){cin.sin_port = htons(p->PORT);sendto(sfd,buf,sizeof(buf),0,(struct sockaddr*)&cin,sizeof(cin));p=p->next;}}if(fds[1].revents == POLLIN){recvfrom(sfd,&usr,sizeof(usr),0,(struct sockaddr*)&cin,&socklen);if(usr.type == 'L'){Usr_PORT = insert_rear(Usr_PORT,ntohs(cin.sin_port));printf("[%s:%d]已经上线\n",usr.name,ntohs(cin.sin_port));sprintf(buf,"-----%s已经上线-----",usr.name);printf("buf = %s\n",buf);Linklist p = Usr_PORT;while(p->next!= NULL){cin.sin_port = htons(p->PORT);sendto(sfd,buf,sizeof(buf),0,(struct sockaddr*)&cin,sizeof(cin));p=p->next;}}else if(usr.type == 'C'){sprintf(buf,"%s:%s",usr.name,usr.text);Linklist p = Usr_PORT;int NONE=ntohs(cin.sin_port);while(p!= NULL){if(NONE!=p->PORT){cin.sin_port = htons(p->PORT);sendto(sfd,buf,sizeof(buf),0,(struct sockaddr*)&(cin),sizeof(cin));}p=p->next;}}else if(usr.type == 'Q'){sprintf(buf,"-----%s已经下线-----",usr.name);printf("[%s:%d]已经离线\n",usr.name,ntohs(cin.sin_port));Usr_PORT = del(Usr_PORT,ntohs(cin.sin_port));Linklist p = Usr_PORT;while(p!= NULL){cin.sin_port = htons(p->PORT);sendto(sfd,buf,sizeof(buf),0,(struct sockaddr*)&cin,sizeof(cin));p=p->next;}}}}close(sfd);return 0;
}

客户端代码：

#include <myhead.h>typedef struct
{char type;char name[20];char text[128];
}gp_t;int main(int argc, const char *argv[])
{if(argc != 3){printf("请输入服务器IP和端口号!\n");return -1;}int cfd = socket(AF_INET,SOCK_DGRAM,0);if(cfd == -1){perror("socket error");return -1;}gp_t GP;char name[20] = "";printf("请输入用户名>>");scanf("%s",GP.name);getchar();struct sockaddr_in sin;sin.sin_family = AF_INET;sin.sin_port = htons(atoi(argv[2]));sin.sin_addr.s_addr = inet_addr(argv[1]);char buf[130] = "";char rbuf[128] = "";bzero(buf,sizeof(buf));GP.type = 'L';sendto(cfd,&GP,sizeof(GP),0,(struct sockaddr*)&sin,sizeof(sin));struct pollfd fds[2];fds[0].fd = 0;fds[0].events = POLLIN;fds[1].fd = cfd;fds[1].events = POLLIN;int res = 0;while(1){res = poll(fds,2,-1);if(res == -1){perror("poll error");return -1;}else if(res == 0){printf("time out\n");return -1;}bzero(buf,sizeof(buf));bzero(rbuf,sizeof(rbuf));if(fds[1].revents == POLLIN){recvfrom(cfd,rbuf,sizeof(rbuf),0,NULL,NULL);printf("%s\n",rbuf);}if(fds[0].revents == POLLIN){fgets(GP.text,sizeof(GP.text),stdin);GP.text[strlen(GP.text)-1]='\0';if(strcmp(GP.text,"quit")==0){GP.type = 'Q';sendto(cfd,&GP,sizeof(GP),0,(struct sockaddr*)&sin,sizeof(sin));goto A;}GP.type = 'C';sendto(cfd,&GP,sizeof(GP),0,(struct sockaddr*)&sin,sizeof(sin));}}
A:close(cfd);return 0;
}

在这里插入图片描述

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

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

相关文章

【C 语言经典100例】C 练习实例14 - 将一个正整数分解质因数

【C 语言经典100例】C 练习实例14 - 将一个正整数分解质因数

题目&#xff1a;将一个正整数分解质因数。例如&#xff1a;输入90,打印出90233*5。 程序分析&#xff1a;对n进行分解质因数&#xff0c;应先找到一个最小的质数k&#xff0c;然后按下述步骤完成&#xff1a; (1)如果这个质数恰等于&#xff08;小于的时候&#xff0c;继续执…
阅读更多...
《数据结构与测绘程序设计》试题详细解析（仅供参考）

《数据结构与测绘程序设计》试题详细解析（仅供参考）

一. 选择题&#xff08;每空2分&#xff0c;本题共30分&#xff09; &#xff08;1&#xff09;在一个单链表中&#xff0c;已知q所指结点是p所指结点的前驱结点&#xff0c;若在q和p之间插入结点s&#xff0c;则执行( B )。 A. s->nextp->next; p->nexts; …
阅读更多...
Vue 打包上线后的缓存问题

Vue 打包上线后的缓存问题

问题描述 在使用vue脚手架搭建前端工程时&#xff0c;经常会遇到打包上线后的缓存问题。具体表现为&#xff0c;当程序版本升级时&#xff0c;用户仍然访问到旧版本的页面。许多开发者会直接在index.html中加入类似以下代码来解决缓存问题&#xff1a; <meta http-equiv&q…
阅读更多...
Linux配置SFTP用户的详细过程

Linux配置SFTP用户的详细过程

0. 背景 Linux机器上已有路径/data/tomcat/apache-tomcat-8.5.96/webapps/webroot,需要在该路径之下配置一个目录对外暴露给业务人员使用。业务人员使用sftp协议上传文件。 下面是相关配置&#xff1a; SFTP 用户名&#xff1a;iios SFTP主目录&#xff1a;/data/tomcat/apa…
阅读更多...
用人部门职位说明书模板

用人部门职位说明书模板

用人部门职位说明书模板 岗位名称 岗位职责&#xff1a; 1. 2. 3. 4. 任职要求&#xff1a; 1. 2. 3. 4. 岗位名称 岗位职责&#xff1a; 1. 2. 3. 4. 任职要求&#xff1a; 1. 2. 3. 4. 【例如】 售前咨询顾问 岗位职责&#xff1a; 1、负责电子政务…
阅读更多...
王者荣耀游戏制作

王者荣耀游戏制作

1.创建所需要的包 2.创建怪物类 bear package beast;import wangzherogyao.GameFrame;public class Bear extends Beast {public Bear(int x, int y, GameFrame gameFrame) {super(x, y, gameFrame);setImg("img/bear.jpg");width 85;height 112;setDis(65);}} b…
阅读更多...
Encoder、Decoder和Encoder-Decoder

Encoder、Decoder和Encoder-Decoder

首先LLM有3种架构&#xff1a;Encoder-only、Decoder-only、encode-decode 整体情况 1、Encoder将可变长度的输入序列编码成一个固定长度的向量&#xff0c;比如在bert中应用的encoder&#xff0c;其实是输入和输出是等长的向量。通常情况下&#xff0c;encoder是用来提取特征…
阅读更多...
实现产品License验证功能

实现产品License验证功能

通过研究调查&#xff0c;可以利用Truelicense开源框架实现&#xff0c;下面分享一下如何利用Truelicense实现授权验证功能。 在此之前先介绍一下License授权和验证的原理&#xff1a; 1、 首先需要生成密钥对&#xff0c;方法有很多&#xff0c;JDK中提供的KeyTool即可生成…
阅读更多...
c++socket的select函数以及多路复用

c++socket的select函数以及多路复用

csocket的select函数以及多路复用 1.select函数原型使用示例及解释 2.select()函数返回值3.select()函数与socket阻塞的关系与原因4.select函数的意义5.深入理解select模型&#xff08;1&#xff09;特点&#xff08;2&#xff09;带外数据&#xff08;2&#xff09;select函数…
阅读更多...
和鲸全程支持：第二届粤港澳大湾区（黄埔）国际算法算例大赛初赛赛程圆满收官！

和鲸全程支持：第二届粤港澳大湾区（黄埔）国际算法算例大赛初赛赛程圆满收官！

随着新一轮科技革命与产业变革的加速演进&#xff0c;算法&#xff0c;作为一种战略性的科技、生产要素&#xff0c;已成为推动数字技术与实体经济深度融合的核心支撑。为助力地区大数据与人工智能算法的生态体系建设、赋能社会经济的高质量发展&#xff0c;琶洲实验室&#xf…
阅读更多...
如何与LEONI建立EDI连接？

如何与LEONI建立EDI连接？

莱尼LEONI是一家为汽车及其他行业提供能源数据管理产品、解决方案及服务的全球供应商。供应链范围从研发生产标准化电缆、特种电缆和数据电缆到高度复杂的布线系统和相关组件。本文将介绍如何与莱尼LEONI建立EDI连接。 什么是EDI&#xff1f; EDI全称Electronic Data Interch…
阅读更多...
C# WPF上位机开发（乘法计算小软件）

C# WPF上位机开发（乘法计算小软件）

【 声明&#xff1a;版权所有&#xff0c;欢迎转载&#xff0c;请勿用于商业用途。 联系信箱&#xff1a;feixiaoxing 163.com】 上面一篇文章&#xff0c;我们简单了解了怎么用xaml来设计界面。和传统的c# form不一样&#xff0c;它除了可以通过拖拽的方法来实现界面的编写之外…
阅读更多...
各种排序算法

各种排序算法

1.Arrays.sort---默认升序 //降序排序 Integer a[] {6,9,9}; Arrays.sort(a, Collections.reverseOrder()); for (int i 0; i < a.length; i) {System.out.print(a[i]); } 2.直接插入排序 ① 从第一个元素开始&#xff0c;该元素可以认为已经被排序 ② 取出下一个元素&…
阅读更多...
基于SSM的云鑫曦科技办公自动化管理系统设计与实现

基于SSM的云鑫曦科技办公自动化管理系统设计与实现

基于SSM的云鑫曦科技办公自动化管理系统设计与实现 摘 要: 随着时代的发展&#xff0c;单位办公方式逐渐从传统的线下纸张办公转向了使用个人pc的线上办公&#xff0c;办公效率低下的传统纸质化办公时代的淘汰&#xff0c;转型到信息化办公时代&#xff0c;面对当今数据逐渐膨…
阅读更多...
python每日一题——13最大子数组和

python每日一题——13最大子数组和

题目 用python做题&#xff0c;给出详细的解题思路和代码注释&#xff1a;给你一个整数数组 nums &#xff0c;请你找出一个具有最大和的连续子数组&#xff08;子数组最少包含一个元素&#xff09;&#xff0c;返回其最大和。子数组是数组中的一个连续部分。 示例 1&#xf…
阅读更多...
灰度发布专题---5、API网关灰度发布

灰度发布专题---5、API网关灰度发布

API网关灰度发布 前面说到Dubbo灰度发布&#xff0c;那网关代理层如何实现灰度发布呢&#xff0c;在网关层实现灰度发布&#xff0c;我们可以采用2种方式实现&#xff0c;分别是权重和灰度规则配置。在这之前我们先了解下Gateway的源码&#xff0c;更利于后面灰度分析。 Gate…
阅读更多...
笔记-PC端wireshark采集FPGA数据的操作

笔记-PC端wireshark采集FPGA数据的操作

wireshark采集FPGA的数据 目录 一、准备工作二、操作步骤 一、准备工作 1、软件&#xff1a;wireshark 2、平台&#xff1a;PC&#xff08;本人是win11&#xff09;、带有以太网功能的zynq平台 3、网线: 用网线连接zynq板子和PC的以太口端口 二、操作步骤 1、打开任务管理器…
阅读更多...
android开发：安卓13Wifi和热点查看与设置功能

android开发：安卓13Wifi和热点查看与设置功能

近日对安卓热点功能做了一些技术验证&#xff0c;目的是想利用手机开热点给设备做初始化&#xff0c;用的是安卓13&#xff0c;简言之&#xff1a; 热点设置功能不可用&#xff0c;不可设置SSID和密码&#xff0c;不可程序控制开启关闭&#xff0c;网上的代码统统都过时了Loca…
阅读更多...
JVM执行引擎

JVM执行引擎

目录 &#xff08;一&#xff09;执行引擎概述 &#xff08;二&#xff09;Java代码编译和执行过程 &#xff08;三&#xff09;机器码&#xff0c;指令&#xff0c;汇编语言&#xff0c;字节码 1、机器码 2、指令 3、指令集 4、汇编 5、字节码 &#xff08;四&#x…
阅读更多...
在Visual Studio Code中安装加速TypeScript程序开发的插件

在Visual Studio Code中安装加速TypeScript程序开发的插件

在Visual Studio Code中安装加速TypeScript程序开发的插件 Install Extensions on Visual Studio Code for TypeScript Application Development By Jackson 2023-11-28 众所周知&#xff0c;微软的Visual Studio Code是一款轻量级、功能强大的集成开发环境。它支持各种编程语…
阅读更多...
最新文章

Copyright @ 2022~2023