项目：UDP聊天室

UDP

UDP（User Datagram Protocol）是一种无连接、不可靠、面向数据报的传输协议。与TCP相比，UDP更加轻量级，不提供像TCP那样的可靠性和流控制机制，但具备较低的通信延迟和较少的开销。

UDP具有以下几个特点：

1. 无连接性：UDP在通信之前不需要进行握手或建立连接，可以直接向目标主机发送数据报。这使得UDP的开销较低，适用于实时数据传输或需要快速响应的应用场景。

2. 不可靠性：UDP不保证数据报的可靠性传输，发送端一旦发送数据包就不会去确认是否到达目标主机。这意味着UDP数据包可能会在传输过程中丢失、重复、乱序，接收方需要自行处理这些问题。

3. 面向数据报：UDP将应用层交给它的数据封装成单个数据报发送，每个数据报都是独立的。接收方以数据报为单位进行处理，不会像TCP一样存在拆包和粘包的问题。

4. 快速：由于UDP没有连接的建立和断开过程，且不需要进行可靠性的保证，因此UDP的通信延迟较低。这使得UDP适用于需要实时性和高性能的应用，例如音视频传输、实时游戏等。

UDP常见的应用场景包括以下几个方面：

1. 实时数据传输：UDP适合用于实时数据传输，如音视频流、实时视频会议等。由于UDP的低延迟和快速性能，可以保证数据的及时到达，并避免了TCP的可靠性机制带来的可能的延迟。

2. DNS（Domain Name System）：UDP常用于DNS查询，客户端通过UDP向DNS服务器发送域名解析请求，DNS服务器返回响应信息。

3. 移动应用：UDP适合用于移动应用，如移动终端上的实时定位、实时数据传输等场景。由于UDP不需要进行连接的建立和断开，更加适应移动网络环境的不稳定性。

需要注意的是，由于UDP不提供可靠性保证，需要在应用层面上考虑数据的可靠性和完整性，例如通过应用层协议、数据校验和重传机制等手段来确保数据的正确传输。

要求

利用UDP协议，实现一套聊天室软件。服务器端记录客户端的地址，客户端发送消息后，服务器群发给各个客户端软件

问题思考：

l 客户端会不会知道其它客户端地址？
UDP客户端不会直接互连，所以不会获知其它客户端地址，所有客户端地址存储在服务器端。

l 有几种消息类型？
登录：服务器存储新的客户端的地址。把某个客户端登录的消息发给其它客户端。
聊天：服务器只需要把某个客户端的聊天消息转发给所有其它客户端。 退出：服务器删除退出客户端的地址，并把退出消息发送给其它客户端。

l 服务器如何存储客户端的地址？
数据结构使用链表最为简单

流程图

服务器

server.png

客户端

client.png

思路：

1.首先要实现客户端和服务器端的全双工通信，因此要用到多进程，多线程或IO多路复用，IO多路复用包括select，poll，epoll。其中epoll效率最高，支持百万级别的并发。

三种IO多路复用特点以及流程如下

2023-08-29T15:02:22.png

2.服务器采用有头单向链表，存储每个客户端的IP地址，链表节点结构体如下。

/* 链表结点结构体 */
typedef struct node_t
{struct sockaddr_in addr;   //IP地址结构体struct node_t *next;       //指针域
}node_t;

3.建立传送消息的结构体，结构体分为三部分，分别是消息类型，昵称和消息正文。服务器端根据判断消息类型进行不同的操作。消息结构体如下。
/ 消息对应的结构体(同一个协议) /

typedef struct msg_t
{int type;       //L登录  M聊天  Q退出char name[32];  //用户名char text[128]; //消息正文
} MSG_t;

4.客户端运行时，首先发送链接类型信息，进行链接。链接后发送信息，根据信息内容判断是否退出。

实现

此项目可以使用多进程，多线程，select，poll，epoll实现，此次我会用 多线程和epoll两种方式实现。其余方法相差不大。

多进程实现

head.h

#ifndef __HEAD_H__
#define __HEAD_H__
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <stdlib.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <string.h>
#include <pthread.h>
#include <semaphore.h>/* 链表结点结构体 */
typedef struct node_t
{struct sockaddr_in addr;   //IP地址结构体struct node_t *next;       //指针域
}node_t;/* 消息对应的结构体(同一个协议) */
typedef struct msg_t
{int type;       //L登录  M聊天  Q退出char name[32];  //用户名char text[128]; //消息正文
} MSG_t;enum type_t
{login,      //枚举后面要用逗号隔开  ---0message,    // ---1quit,       // ---2 
};
#endif

server.c

#include "head.h"
struct sockaddr_in saddr, caddr;
//创建链表
node_t *CreateList()
{node_t *p = (node_t *)malloc(sizeof(node_t));if (NULL == p){perror("CreateList is err");return NULL;}p->next = NULL;return p;
}//客户端链接
void server_link(int socked, node_t *p, MSG_t *msg)
{sprintf(msg->text, "%s连接", msg->name);printf("%s\n", msg->text);while (p->next){p = p->next;sendto(socked, msg, sizeof(*msg), 0, (struct sockaddr *)(&(p->addr)), sizeof(p->addr));}node_t *new = (node_t *)malloc(sizeof(node_t));new->next = NULL;new->addr=caddr;p->next = new;
}//客户端发送正文消息
void server_message(int socked, node_t *p, MSG_t *msg)
{while (p->next){p = p->next;if ((memcmp(&(p->addr), &caddr, sizeof(caddr))) == 0)continue;sendto(socked, msg, sizeof(*msg), 0, (struct sockaddr *)(&(p->addr)), sizeof(p->addr));}
}//客户端退出
void server_quit(int socked, node_t *p, MSG_t *msg)
{node_t *pdel = NULL;sprintf(msg->text, "%s退出", msg->name);printf("%s\n", msg->text);while (p->next){if ((memcmp(&(p->next->addr), &caddr, sizeof(caddr))) == 0){pdel = p->next;p->next = pdel->next;free(pdel);pdel = NULL;}else{p = p->next;sendto(socked, msg, sizeof(*msg), 0, (struct sockaddr *)(&(p->addr)), sizeof(p->addr));}}
}//6.服务器端发送消息,所有客户端接收
void *mypthread(void *socked)
{MSG_t msg;msg.type = message;strcpy(msg.name, "服务器");while (1){fgets(msg.text, sizeof(msg.text), stdin);if (msg.text[strlen(msg.text) - 1] == '\n')msg.text[strlen(msg.text) - 1] = '\0';sendto(*(int *)(socked), &msg, sizeof(msg), 0, (struct sockaddr *)(&saddr), sizeof(saddr));}pthread_exit(NULL);
}int main(int argc, char const *argv[])
{//1.建立socket套接字int socked = socket(AF_INET, SOCK_DGRAM, 0);if (socked < 0){perror("socket is err");return -1;}//2.bind服务器端口号和ip地址saddr.sin_family = AF_INET;saddr.sin_port = htons(atoi(argv[1]));saddr.sin_addr.s_addr = inet_addr("0.0.0.0");int len = sizeof(caddr);if ((bind(socked, (struct sockaddr *)(&saddr), sizeof(saddr))) < 0){perror("bind is err");return -1;}//3.建立多进程,主进程服务器接收,一个服务器发送pthread_t pid;pthread_create(&pid, NULL, mypthread, &socked);pthread_detach(pid);//4.主线程不断接收客户端发送的消息node_t *p = CreateList();MSG_t msg;while (1){if ((recvfrom(socked, &msg, sizeof(msg), 0, (struct sockaddr *)(&caddr), &len)) < 0){perror("recvfrom is err");return -1;}//5.根据消息类型进行分类讨论switch (msg.type){case login:server_link(socked, p, &msg);break;case message:server_message(socked, p, &msg);break;case quit:server_quit(socked, p, &msg);break;default:break;}}close(socked);return 0;
}

client.c

#include "head.h"
struct sockaddr_in saddr, caddr;
int len;
//5.子线程接收客户端数据
void *mypthread(void *socked)
{MSG_t msg;while (1){int temp = recvfrom(*(int *)(socked), &msg, sizeof(msg), 0, (struct sockaddr *)(&caddr), &len);if (temp < 0){perror("recvfrom err");exit(-1);}else{printf("\t\t\t\t%s(%s)\n",msg.text,msg.name);}}
}int main(int argc, char const *argv[])
{//1.建立socket套接字int socked = socket(AF_INET, SOCK_DGRAM, 0);if (socked < 0){perror("socket is err");return -1;}//2.绑定服务器ip和端口号saddr.sin_port = htons(atoi(argv[2]));saddr.sin_addr.s_addr = inet_addr(argv[1]);saddr.sin_family = AF_INET;len = sizeof(caddr);//3.连接服务器MSG_t msg;msg.type = login;printf("请输入名称:\n");fgets(msg.name, sizeof(msg.name), stdin);if (msg.name[strlen(msg.name) - 1] == '\n')msg.name[strlen(msg.name) - 1] = '\0';sendto(socked, &msg, sizeof(msg), 0, (struct sockaddr *)(&saddr), sizeof(saddr));//4.创建子进程接收服务器数据,主进程发送数据pthread_t pid;pthread_create(&pid, NULL, mypthread, &socked);pthread_detach(pid);//5.主线程发送客户端数据while (1){fgets(msg.text, sizeof(msg.text), stdin);if (msg.text[strlen(msg.text) - 1] == '\n')msg.text[strlen(msg.text) - 1] = '\0';if (strcmp(msg.text, "quit") == 0)msg.type = quit;elsemsg.type = message;sendto(socked, &msg, sizeof(msg), 0, (struct sockaddr *)(&saddr), sizeof(saddr));}close(socked);return 0;
}

Makefile

all:gcc client.c -o client -lpthreadgcc server.c -o server -lpthread
.PHONY:clean
clean:rm *.o

epoll实现

head.h

#ifndef __HEAD_H__
#define __HEAD_H__
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <stdlib.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <string.h>
#include <pthread.h>
#include <semaphore.h>
#include <sys/epoll.h>/* 链表结点结构体 */
typedef struct node_t
{struct sockaddr_in addr;   //IP地址结构体struct node_t *next;       //指针域
}node_t;/* 消息对应的结构体(同一个协议) */
typedef struct msg_t
{int type;       //L登录  M聊天  Q退出char name[32];  //用户名char text[128]; //消息正文
} MSG_t;enum type_t
{login,      //枚举后面要用逗号隔开  ---0message,    // ---1quit,       // ---2 
};
#endif

server.c

#include "head.h"
struct sockaddr_in saddr, caddr;
//创建链表
node_t *CreateList()
{node_t *p = (node_t *)malloc(sizeof(node_t));if (NULL == p){perror("CreateList is err");return NULL;}p->next = NULL;return p;
}//客户端链接
void server_link(int socked, node_t *p, MSG_t *msg)
{sprintf(msg->text, "%s连接", msg->name);printf("%s\n", msg->text);while (p->next){p = p->next;sendto(socked, msg, sizeof(*msg), 0, (struct sockaddr *)(&(p->addr)), sizeof(p->addr));}node_t *new = (node_t *)malloc(sizeof(node_t));new->next = NULL;new->addr = caddr;p->next = new;
}//客户端发送正文消息
void server_message(int socked, node_t *p, MSG_t *msg)
{while (p->next){p = p->next;if ((memcmp(&(p->addr), &caddr, sizeof(caddr))) == 0)continue;sendto(socked, msg, sizeof(*msg), 0, (struct sockaddr *)(&(p->addr)), sizeof(p->addr));}
}//客户端退出
void server_quit(int socked, node_t *p, MSG_t *msg)
{node_t *pdel = NULL;sprintf(msg->text, "%s退出", msg->name);printf("%s\n", msg->text);while (p->next){if ((memcmp(&(p->next->addr), &caddr, sizeof(caddr))) == 0){pdel = p->next;p->next = pdel->next;free(pdel);pdel = NULL;}else{p = p->next;sendto(socked, msg, sizeof(*msg), 0, (struct sockaddr *)(&(p->addr)), sizeof(p->addr));}}
}int main(int argc, char const *argv[])
{//1.建立socket套接字int socked = socket(AF_INET, SOCK_DGRAM, 0);if (socked < 0){perror("socket is err");return -1;}//2.bind服务器端口号和ip地址saddr.sin_family = AF_INET;saddr.sin_port = htons(atoi(argv[1]));saddr.sin_addr.s_addr = inet_addr("0.0.0.0");int len = sizeof(caddr);if ((bind(socked, (struct sockaddr *)(&saddr), sizeof(saddr))) < 0){perror("bind is err");return -1;}//3.主线程不断接收客户端发送的消息node_t *p = CreateList();MSG_t msg;//1).创建红黑树以及链表//树的跟节点/树的句柄int epfd = epoll_create(1);//2).上树struct epoll_event event;struct epoll_event events[32];event.events = EPOLLET | EPOLLIN;event.data.fd = 0;epoll_ctl(epfd, EPOLL_CTL_ADD, 0, &event);event.data.fd = socked;epoll_ctl(epfd, EPOLL_CTL_ADD, socked, &event);while (1){//3).阻塞等待文件描述符产生事件int ret = epoll_wait(epfd, events, 32, -1);if (ret < 0){perror("epoll err");return -1;}//4).根据文件描述符号,进行处理for (int i = 0; i < ret; ++i){if (events[i].data.fd == 0){msg.type = message;strcpy(msg.name, "客户端");fgets(msg.text, sizeof(msg.text), stdin);if (msg.text[strlen(msg.text) - 1] == '\n')msg.text[strlen(msg.text) - 1] = '\0';sendto(*(int *)(socked), &msg, sizeof(msg), 0, (struct sockaddr *)(&saddr), sizeof(saddr));}else if (events[i].data.fd == socked){if ((recvfrom(socked, &msg, sizeof(msg), 0, (struct sockaddr *)(&caddr), &len)) < 0){perror("recvfrom is err");return -1;}//4.根据消息类型进行分类讨论switch (msg.type){case login:server_link(socked, p, &msg);break;case message:server_message(socked, p, &msg);break;case quit:server_quit(socked, p, &msg);break;default:break;}}}}close(socked);return 0;
}

client.c

#include "head.h"
struct sockaddr_in saddr, caddr;
int len;
//5.子线程接收客户端数据
void *mypthread(void *socked)
{MSG_t msg;while (1){int temp = recvfrom(*(int *)(socked), &msg, sizeof(msg), 0, (struct sockaddr *)(&caddr), &len);if (temp < 0){perror("recvfrom err");exit(-1);}else{printf("\t\t\t\t%s(%s)\n", msg.text, msg.name);}}
}int main(int argc, char const *argv[])
{//1.建立socket套接字int socked = socket(AF_INET, SOCK_DGRAM, 0);if (socked < 0){perror("socket is err");return -1;}//2.绑定服务器ip和端口号saddr.sin_port = htons(atoi(argv[2]));saddr.sin_addr.s_addr = inet_addr(argv[1]);saddr.sin_family = AF_INET;len = sizeof(caddr);//3.连接服务器MSG_t msg;msg.type = login;printf("请输入名称:\n");fgets(msg.name, sizeof(msg.name), stdin);if (msg.name[strlen(msg.name) - 1] == '\n')msg.name[strlen(msg.name) - 1] = '\0';sendto(socked, &msg, sizeof(msg), 0, (struct sockaddr *)(&saddr), sizeof(saddr));//4.创建子进程接收服务器数据,主进程发送数据pthread_t pid;pthread_create(&pid, NULL, mypthread, &socked);pthread_detach(pid);//5.主线程发送客户端数据while (1){fgets(msg.text, sizeof(msg.text), stdin);if (msg.text[strlen(msg.text) - 1] == '\n')msg.text[strlen(msg.text) - 1] = '\0';if (strcmp(msg.text, "quit") == 0){msg.type = quit;sendto(socked, &msg, sizeof(msg), 0, (struct sockaddr *)(&saddr), sizeof(saddr));break;}elsemsg.type = message;sendto(socked, &msg, sizeof(msg), 0, (struct sockaddr *)(&saddr), sizeof(saddr));}return 0;
}

Makefile

all: gcc client.c -o client -lpthread gcc server.c -o server -lpthread.PHONY:clean clean: rm *.o

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

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

相关文章

Prometheus-PushGateway自定义监控项

Prometheus-PushGateway自定义监控项

文章目录 一、前言二、PushGateway安装三、PushGateway的使用四、PushGateway脚本思路 一、前言 pushgateway相比较exporter是主动向服务器发送请求&#xff0c;pushgateway本身也是一个程序&#xff0c;可以运行在任意节点上(不是必须在被监控端)&#xff0c;运行本身没有抓取…
阅读更多...
【持续记录】深度学习环境配置

【持续记录】深度学习环境配置

1080面对Transformer连勉强也算不上了&#xff0c;还是要去用小组公用的卡 完整记一个环境配置&#xff0c;方便后面自用✍️ nvidia-smi查看GPU信息 ** CUDA版本12.2 conda -V查询conda版本 22.9.0 新建conda环境 准备装python3.8 conda create --name caiman python3.8.2激…
阅读更多...
线性代数的本质(四)——行列式

线性代数的本质(四)——行列式

文章目录 行列式二阶行列式 n n n 阶行列式行列式的性质克拉默法则行列式的几何理解 行列式 二阶行列式 行列式引自对线性方程组的求解。考虑两个方程的二元线性方程组 { a 11 x 1 a 12 x 2 b 1 a 21 x 1 a 22 x 2 b 2 \begin{cases} a_{11}x_1a_{12}x_2b_1 \\ a_{21}x_…
阅读更多...
Idea启动报错start failed闪退， RestfulToolkit-fix插件问题

Idea启动报错start failed闪退， RestfulToolkit-fix插件问题

前一天下班时还在正常使用的Idea&#xff0c;早上再次启动就报错闪退&#xff0c;报错信息非常的快的闪退也没有看清楚。做过的唯一更改就是前一天安装了 RestfulToolkit-fix 插件。 1、先查看报错的日志 在Idea安装路径的bin/ idea.bat文件中末尾处添加pause语句 保存后双击…
阅读更多...
解决vue项目导出当前页Table为Excel

解决vue项目导出当前页Table为Excel

解决vue项目中导出当前页表格为Excel表格的方案 用到的技术&#xff1a; Vue2Element-uifile-saverxlsx 1、创建vue项目&#xff0c;安装element-ui 2、创建一个组件&#xff0c;组件内放入表格&#xff0c;和导出按钮 <template><div><!-- 导出的按钮 -->…
阅读更多...
工程管理系统简介 工程管理系统源码 java工程管理系统 工程管理系统功能设计

工程管理系统简介 工程管理系统源码 java工程管理系统 工程管理系统功能设计

鸿鹄工程项目管理系统 Spring CloudSpring BootMybatisVueElementUI前后端分离构建工程项目管理系统 1. 项目背景 一、随着公司的快速发展&#xff0c;企业人员和经营规模不断壮大。为了提高工程管理效率、减轻劳动强度、提高信息处理速度和准确性&#xff0c;公司对内部工程管…
阅读更多...
9.12 C++作业

9.12 C++作业

实现一个图形类&#xff08;Shape&#xff09;&#xff0c;包含受保护成员属性&#xff1a;周长、面积&#xff0c; 公共成员函数&#xff1a;特殊成员函数书写 定义一个圆形类&#xff08;Circle&#xff09;&#xff0c;继承自图形类&#xff0c;包含私有属性&#xff1a;半…
阅读更多...
ppt录制在哪？实用技巧分享！

ppt录制在哪？实用技巧分享！

在现代演示和培训中&#xff0c;PPT演示已经成为越来越流行的一种交流方式。而录制ppt也成为了很多商务演讲、教学讲解、产品演示等场合的必备技能。本文将为您介绍两种常见的ppt录制方式&#xff0c;帮助您轻松录制ppt演示的过程。 ppt录制在哪&#xff1f; ppt是一款流行的演…
阅读更多...
类和对象（3）

类和对象（3）

文章目录 1.回顾上节2. 拷贝构造3. 运算符重载&#xff08;非常重要&#xff09;4. 赋值运算符重载 1.回顾上节 默认成员函数&#xff1a;我们不写&#xff0c;编译器自动生成。我们不写&#xff0c;编译器不会自动生成 默认生成构造和析构&#xff1a; 对于内置类型不做处理对…
阅读更多...
分类预测 | MATLAB实现基于SVM-Adaboost支持向量机结合AdaBoost多输入分类预测

分类预测 | MATLAB实现基于SVM-Adaboost支持向量机结合AdaBoost多输入分类预测

分类预测 | MATLAB实现基于SVM-Adaboost支持向量机结合AdaBoost多输入分类预测 目录 分类预测 | MATLAB实现基于SVM-Adaboost支持向量机结合AdaBoost多输入分类预测预测效果基本介绍模型描述程序设计参考资料 预测效果 基本介绍 1.MATLAB实现基于SVM-Adaboost支持向量机结合Ada…
阅读更多...
【数据结构】—堆排序以及TOP-K问题究极详解（含C语言实现）

【数据结构】—堆排序以及TOP-K问题究极详解（含C语言实现）

食用指南&#xff1a;本文在有C基础的情况下食用更佳 &#x1f525;这就不得不推荐此专栏了&#xff1a;C语言 ♈️今日夜电波&#xff1a;ルミネセンス—今泉愛夏 1:01 ━━━━━━️&#x1f49f;──────── 5:05 …
阅读更多...
重建大师创建缓存目录失败，密集匹配失败是什么原因呢

重建大师创建缓存目录失败，密集匹配失败是什么原因呢

答&#xff1a;边缘瓦块点云比较稀疏就会有密集匹配失败。缓存目录修改下&#xff0c;修改浅一些&#xff0c;C/cache这样就行&#xff0c;进度条后方取消任务再重新提交。 重建大师是一款专为超大规模实景三维数据生产而设计的集群并行处理软件&#xff0c;输入倾斜照片&#…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023