网络通信day5作业

发布时间：2026/7/9 19:47:46

网络通信day5作业

1>    使用select完成TCP客户端程序

客户端:

#include<myhead.h>#define FPORT 9999
#define FIP "192.168.125.130"#define KPORT 6666
#define KIP "192.168.125.130"int main(int argc, const char *argv[])
{//创建套接字文件描述符int cfd = 0;if((cfd = socket(AF_INET,SOCK_STREAM,0)) == -1){perror("socket error");return -1;}//允许重复引用int reuse = 1;if(setsockopt(cfd,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(KPORT);sin.sin_addr.s_addr = inet_addr(KIP);if(bind(cfd,(struct sockaddr*)&sin,sizeof(sin)) == -1){perror("bind error");return -1;}//连接服务器struct sockaddr_in cin;cin.sin_family = AF_INET;cin.sin_port = htons(FPORT);cin.sin_addr.s_addr = inet_addr(FIP);if(connect(cfd,(struct sockaddr*)&cin,sizeof(cin)) == -1){perror("connect");return -1;}//定义检测文件描述符的集合fd_set readfd;//清空集合FD_ZERO(&readfd);//将cfd和0加入集合FD_SET(cfd,&readfd);FD_SET(0,&readfd);char buf[128] = "";int res = -1;fd_set tempfd;while(1){tempfd = readfd;res = select(cfd+1,&tempfd,NULL,NULL,NULL);if(res < 0){perror("select error");return -1;}else if(res == 0){printf("time out\n");return -1;}//下面为处理的处理描述符if(FD_ISSET(0,&tempfd)){bzero(buf,sizeof(buf));fgets(buf,sizeof(buf),stdin);buf[strlen(buf)-1]=0;send(cfd,buf,sizeof(buf),0);printf("客服端输入为%s\n",buf);}if(FD_ISSET(cfd,&tempfd)){bzero(buf,sizeof(buf));int res = recv(cfd,buf,sizeof(buf),0);if(res == 0){printf("服务器下线\n");break;}printf("服务器发来的消息为%s\n",buf);}}close(cfd);return 0;
}

服务器:

#include<myhead.h>
#define PORT 9999
#define IP "192.168.125.130"int main(int argc, const char *argv[])
{int sfd = -1;if((sfd = socket(AF_INET,SOCK_STREAM,0)) == -1){perror("socket");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(PORT);sin.sin_addr.s_addr = inet_addr(IP);if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin)) == -1){perror("bind error");return -1;}if(listen(sfd,128)  == -1){perror("listen error");return -1;}struct sockaddr_in cin;socklen_t socklen = sizeof(cin);int newfd = -1;char buf[128] = "";fd_set readfds;FD_ZERO(&readfds);FD_SET(sfd,&readfds);FD_SET(0,&readfds);int res = 0;fd_set tempfds;int maxfd = sfd;char rbuf[128]="";struct sockaddr_in arr_cin[1024];while(1){tempfds = readfds;res = select(maxfd+1,&tempfds,NULL,NULL,NULL);if(res == -1){perror("select error");return -1;}else if(res == 0){printf("time out\n");return -1;}for(int index=0;index<=maxfd;index++){if(!FD_ISSET(index,&tempfds)){continue;}if(index == sfd){if((newfd = accept(sfd,(struct sockaddr*)&cin,&socklen)) == -1){perror("accept");return -1;}arr_cin[newfd] =cin;printf("[%s:%d]链接成功,newfd = %d\n\n",inet_ntoa(arr_cin[newfd].sin_addr),ntohs(arr_cin[newfd].sin_port),newfd);FD_SET(newfd,&readfds);if(newfd > maxfd){maxfd = newfd;}}else if(index == 0){scanf("%s",buf);printf("%s\n",buf);}else{bzero(rbuf,sizeof(rbuf));int res = recv(index,rbuf,sizeof(rbuf),0);if(res == 0){printf("客户端下线\n");close(index);FD_CLR(index,&readfds);for(int i =maxfd;i>0;i--){if(FD_ISSET(i,&readfds)){maxfd = i;break;}}continue;}printf("[%s:%d] :%s\n",inet_ntoa(arr_cin[index].sin_addr),ntohs(arr_cin[index].sin_port),rbuf);strcat(rbuf,"*_*");send(index,rbuf,sizeof(rbuf),0);}}}close(sfd);return 0;
}

效果图:


2>    使用poll完成TCP并发服务器

客户端:

#include<myhead.h>
#define SERPORT 9999
#define SERIP "192.168.125.130"#define CLIPORT 6666
#define CLIIP "192.168.125.130"int main(int argc, const char *argv[])
{int cfd = -1;if((cfd = socket(AF_INET,SOCK_STREAM,0)) == -1){perror("socket error");return -1;}printf("cfd = %d\n",cfd);int reuse = 1;if(setsockopt(cfd,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(CLIPORT);sin.sin_addr.s_addr = inet_addr(CLIIP);if(bind(cfd,(struct sockaddr*)&sin,sizeof(sin)) == -1){perror("bind error");return -1;}struct sockaddr_in cin;cin.sin_family = AF_INET;cin.sin_port = htons(SERPORT);cin.sin_addr.s_addr = inet_addr(SERIP);if(connect(cfd,(struct sockaddr*)&cin,sizeof(cin)) == -1){perror("connect error");return -1;}struct pollfd fds[2];fds[0].fd = 0;fds[0].events = POLLIN;fds[1].fd = cfd;fds[1].events = POLLIN;int res = -1;char wbuf[128] = "";while(1){res = poll(fds,2,-1);if(res < 0){perror("poll error");return -1;}else if(res == 0){printf("time out \n");return -1;}if(fds[0].revents == POLLIN){bzero(wbuf,sizeof(wbuf));fgets(wbuf,sizeof(wbuf),stdin);wbuf[strlen(wbuf)-1]=0;send(cfd,wbuf,sizeof(wbuf),0);}if(fds[1].revents == POLLIN){bzero(wbuf,sizeof(wbuf));int res = recv(cfd,wbuf,sizeof(wbuf),0);if(res == 0){printf("服务器已下线\n");break;}printf("[%s:%d]:%s\n",SERIP,SERPORT,wbuf);}}close(cfd);return 0;
}

服务器:

#include<myhead.h>#define PORT 9999
#define IP "192.168.125.130"int main(int argc, const char *argv[])
{//定义套接字文件描述符int cfd = -1;if((cfd = socket(AF_INET,SOCK_STREAM,0)) == -1){perror("socket error");return -1;}//端口快速重用int reuse = 1;if(setsockopt(cfd,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(PORT);sin.sin_addr.s_addr = inet_addr(IP);if(bind(cfd,(struct sockaddr*)&sin,sizeof(sin)) == -1){perror("bind error");return -1;}//设置为监听状态if(listen(cfd,128) == -1){perror("listen error");return -1;}//要检测的文件描述符集合对应的数组struct pollfd fds[1024];//定义客户端信息struct sockaddr_in add_cin[1024];//标准0fds[0].fd = 0;fds[0].events = POLLIN;//标准cfdfds[cfd].fd = cfd;fds[cfd].events = POLLIN;struct sockaddr_in cin;socklen_t socklen = sizeof(cin);int newfd = -1;int res = -1;int size = 4;//初始成员个数char buf[128]="";while(1){res = poll(fds,size,-1);if(res == -1){perror("poll error");return -1;}else if(res == 0){printf("time out\n");return -1;}for(int index=0;index<1024;index++){if(fds[index].revents != POLLIN){continue;}if(fds[cfd].revents == POLLIN)//if((fds[index].revents == POLLIN)&&(fds[index].fd == cfd)){//到此下面为操作文件描述符//设置为等待连接状态if((newfd = accept(cfd,(struct sockaddr*)&cin,&socklen)) == -1){perror("accept error");return -1;}//客户端加入数组add_cin[newfd]=cin;fds[size].fd = newfd;fds[size].events = POLLIN;size++;//printf("连接成功\n");printf("[%s,%d]连接成功,newfd=%d\n",inet_ntoa(add_cin[newfd].\sin_addr),ntohs(add_cin[newfd].sin_port),newfd);}else if((fds[index].revents == POLLIN)&&fds[index].fd == 0){bzero(buf,sizeof(buf));//终端输入fgets(buf,sizeof(buf),stdin);buf[strlen(buf)-1] = 0;printf("服务器输入为%s\n",buf);}else {bzero(buf,sizeof(buf));int resa = recv(fds[index].fd,buf,sizeof(buf),0);if(resa == 0){printf("客户端下线\n");close(fds[index].fd);fds[index] = fds[size];size--;continue;}printf("[%s,%d]发送%s\n",inet_ntoa(add_cin[newfd].sin_addr),\ntohs(add_cin[newfd].sin_port),buf);strcat(buf,"*_*");send(fds[index].fd,buf,sizeof(buf),0);}}}return 0;
}

 服务器:

#include<myhead.h>#define PORT 9999
#define IP "192.168.125.130"int main(int argc, const char *argv[])
{//定义套接字文件描述符int cfd = -1;if((cfd = socket(AF_INET,SOCK_STREAM,0)) == -1){perror("socket error");return -1;}//端口快速重用int reuse = 1;if(setsockopt(cfd,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(PORT);sin.sin_addr.s_addr = inet_addr(IP);if(bind(cfd,(struct sockaddr*)&sin,sizeof(sin)) == -1){perror("bind error");return -1;}//设置为监听状态if(listen(cfd,128) == -1){perror("listen error");return -1;}//要检测的文件描述符集合对应的数组struct pollfd fds[1024];//定义客户端信息struct sockaddr_in add_cin[1024];//标准0fds[0].fd = 0;fds[0].events = POLLIN;//标准cfdfds[cfd].fd = cfd;fds[cfd].events = POLLIN;struct sockaddr_in cin;socklen_t socklen = sizeof(cin);int newfd = -1;int res = -1;int size = 4;//初始成员个数char buf[128]="";while(1){res = poll(fds,size,-1);if(res == -1){perror("poll error");return -1;}else if(res == 0){printf("time out\n");return -1;}for(int index=0;index<1024;index++){if(fds[index].revents != POLLIN){continue;}if(fds[cfd].revents == POLLIN){//到此下面为操作文件描述符//设置为等待连接状态if((newfd = accept(cfd,(struct sockaddr*)&cin,&socklen)) == -1){perror("accept error");return -1;}//客户端加入数组add_cin[newfd]=cin;fds[newfd].fd = newfd;fds[newfd].events = POLLIN;size++;//printf("连接成功\n");printf("[%s,%d]连接成功,newfd=%d\n",inet_ntoa(add_cin[newfd].\sin_addr),ntohs(add_cin[newfd].sin_port),newfd);}else if((fds[index].revents == POLLIN)&&fds[index].fd == 0){bzero(buf,sizeof(buf));//终端输入fgets(buf,sizeof(buf),stdin);buf[strlen(buf)-1] = 0;printf("服务器输入为%s\n",buf);}else {bzero(buf,sizeof(buf));int resa = recv(fds[index].fd,buf,sizeof(buf),0);if(resa == 0){printf("客户端下线\n");close(fds[index].fd);//fds[index] = fds[size];//size--;continue;}printf("[%s,%d]发送%s\n",inet_ntoa(add_cin[newfd].sin_addr),\ntohs(add_cin[newfd].sin_port),buf);strcat(buf,"*_*");send(fds[index].fd,buf,sizeof(buf),0);}}}return 0;
}

效果图:

相关新闻

μC/OS-III 里面的环形表

μC/OS-III 里面的环形表

文章目录 1、时钟节拍任务2、定时器列表 μC/OS-III 里面两个地方用到了环形表&#xff0c;时钟节拍任务&#xff0c;定时器列表&#xff0c;通过排序后&#xff0c;效率是非常高的。 以下内容整理自 嵌入式实时操作系统uC/OS-Ⅲ 1、时钟节拍任务 2023/12/21 18:04:16 (1) 该…

2026/7/8 19:11:27
分布式全局ID之雪花算法

分布式全局ID之雪花算法

系列文章目录 提示&#xff1a;这里可以添加系列文章的所有文章的目录&#xff0c;目录需要自己手动添加 雪花算法 提示&#xff1a;写完文章后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 系列文章目录前言一、什么是雪花算法&#xff1f…

2026/7/3 22:11:46
Linux 音视频SDK开发实践

Linux 音视频SDK开发实践

一、兼容性适配处理 为什么需要兼容处理&#xff1f; 1、c兼容处理 主要有ABI兼容性问题&#xff0c;不同ubuntu系统依赖的ABI版本如下&#xff1a; ubuntu 18.04ubuntu 16.04ubuntu 14.04g7.55.44.8stdc版本libstdc.so.6.0.25libstdc.so.6.0.21libstdc.so.6.0.19GLIBCXXG…

2026/7/9 3:18:43

最新新闻

在线算法在实时推荐系统中的应用与性能保障7

在线算法在实时推荐系统中的应用与性能保障7

引言 实时推荐系统的背景与重要性在线算法的定义及其在推荐系统中的核心作用文章目标与结构概述 在线算法的基础理论 在线算法的核心概念与特点&#xff08;实时性、增量更新、有限历史数据&#xff09;常见在线算法分类&#xff08;如在线梯度下降、Bandit算法、流式聚类等…

2026/7/10 1:15:28
PIC微控制器驱动压电蜂鸣器的警报系统设计与实现

PIC微控制器驱动压电蜂鸣器的警报系统设计与实现

1. 项目背景与核心需求警报系统在现代电子设备中扮演着至关重要的角色&#xff0c;从工业控制到智能家居&#xff0c;清晰可辨的警报声能够及时提醒用户注意异常情况。本项目聚焦于使用EPT-14A4005P压电蜂鸣器和PIC18F25K42微控制器构建一套可靠的警报发声系统。EPT-14A4005P是…

2026/7/10 1:15:28
OCRAutoScore：基于多模态AI的智能阅卷系统架构解析

OCRAutoScore：基于多模态AI的智能阅卷系统架构解析

OCRAutoScore&#xff1a;基于多模态AI的智能阅卷系统架构解析 【免费下载链接】OCRAutoScore OCR自动化阅卷项目 项目地址: https://gitcode.com/gh_mirrors/oc/OCRAutoScore 在教育数字化转型的背景下&#xff0c;传统手工阅卷面临着效率低下、评分主观性强、数据分析…

2026/7/10 1:15:28
Dify企业级应用实战：从部署到集成的AI开发平台进阶指南

Dify企业级应用实战：从部署到集成的AI开发平台进阶指南

&#x1f680; 30款热门AI模型一站整合&#xff0c;DeepSeek/GLM/Qwen 随心用&#xff0c;限时 5 折。 &#x1f449; 点击领海量免费额度 最近两年&#xff0c;AI应用开发领域出现了一个有趣的现象&#xff1a;很多开发者&#xff0c;甚至一些中小团队&#xff0c;都开始尝…

2026/7/10 1:15:28
.NET 跨平台硬件信息库 Hardware.Info 深度指南

.NET 跨平台硬件信息库 Hardware.Info 深度指南

在 .NET 开发中&#xff0c;读取计算机硬件信息&#xff08;如 CPU 序列号、MAC 地址、内存状态、硬盘容量等&#xff09;是实现软件授权&#xff08;绑机&#xff09;、系统监控、性能看板等功能的刚需。 然而&#xff0c;传统的 ManagementObjectSearcher&#xff08;WMI&…

2026/7/10 1:15:28
CentOS 7.9 用 Docker 搭 Redis 主从+哨兵

CentOS 7.9 用 Docker 搭 Redis 主从+哨兵

写在前面 上周给客户搭生产&#xff0c;就一台 CentOS 7.9 的机子&#xff0c;Redis 还得有高可用。本来想单机凑合一下算了&#xff0c;结果客户不同意&#xff0c;说必须能自动切换。 行吧&#xff0c;最后就搞了个 1 主 2 从 3 哨兵&#xff0c;全部塞 Docker 里跑。步骤…

2026/7/10 1:14:28

日新闻

npm全局命令not found的7个精准修复方案

npm全局命令not found的7个精准修复方案

1. 项目概述&#xff1a;为什么“codex: command not found”成了2026年开发者桌面的高频报错&#xff1f; “codex: command not found”——这行红色错误提示&#xff0c;最近半年在终端里出现的频率&#xff0c;已经快赶上 git status 的刷新次数了。它不是某个冷门工具的…

2026/7/10 0:00:24
蓝牙 5.4 协议栈深度解析：从 HCI 到 L2CAP 的 7 层数据流

蓝牙 5.4 协议栈深度解析：从 HCI 到 L2CAP 的 7 层数据流

蓝牙 5.4 协议栈深度解析&#xff1a;从 HCI 到 L2CAP 的 7 层数据流当你的无线耳机与手机瞬间完成配对&#xff0c;或是键盘在十米外依然稳定响应时&#xff0c;背后是蓝牙协议栈在精密协调着每一次数据交互。作为最新演进的蓝牙5.4版本&#xff0c;其协议栈架构在保持向下兼容…

2026/7/10 0:00:24
安徽省豆包排名哪家实力强 - 招财兔数字员工

安徽省豆包排名哪家实力强 - 招财兔数字员工

产品名称：豆包排名 产品介绍：帮助全国各行各业的企业客户，优化在豆包等AI平台里的提及率和排名。联系人：杨经理联系电话：18452273182(杨科)本文来自博客园，作者：招财兔数字员工，转载请注明原文链接：https://w…

2026/7/10 0:00:24

周新闻

3步彻底解决Windows右键菜单混乱问题：ContextMenuManager使用全攻略

3步彻底解决Windows右键菜单混乱问题：ContextMenuManager使用全攻略

3步彻底解决Windows右键菜单混乱问题&#xff1a;ContextMenuManager使用全攻略 【免费下载链接】ContextMenuManager &#x1f5b1;️ 纯粹的Windows右键菜单管理程序 项目地址: https://gitcode.com/gh_mirrors/co/ContextMenuManager 你是否曾为Windows右键菜单中那些…

2026/7/9 15:31:50
GXDE OS下Wayland兼容性实战：从deepin-mutter原理到VMware Tools修复

GXDE OS下Wayland兼容性实战：从deepin-mutter原理到VMware Tools修复

如果你正在用 GXDE OS 或者任何基于 Deepin 的发行版&#xff0c;并且遇到了“检测到窗口系统采用 Wayland 协议&#xff0c;程序即将退出”这类弹窗&#xff0c;或者发现 VMware Tools 在 Ubuntu 24.04 这类默认 Wayland 的系统上启动失败&#xff0c;那这篇文章就是为你准备的…

2026/7/9 14:30:13
企业AI落地困境与AgenticOps实践指南

企业AI落地困境与AgenticOps实践指南

1. 企业AI落地的现实困境与破局之道过去两年&#xff0c;大模型技术呈现爆发式增长&#xff0c;从GPT-3到GPT-4&#xff0c;从LLaMA到DeepSeek&#xff0c;模型参数规模从百亿级跃升至万亿级&#xff0c;多模态能力从单一文本扩展到图文音视频的综合处理。然而在企业应用层面&a…

2026/7/9 11:54:04

月新闻

[C++]内存管理：串顺序存储的内存回收

[C++]内存管理：串顺序存储的内存回收

在串&#xff08;字符串&#xff09;的顺序存储中&#xff0c;内存回收的方式取决于字符串的存储方式以及所使用的编程语言和相关库。以下以 C 为例进行说明&#xff0c;因为 C 对内存管理有较为直接的控制。 1. 基于 char 数组的串顺序存储 如果使用普通的 char 数组来存储字…

2026/7/9 23:58:49
移动端游戏功耗测试实战：电流、功率、亮度和场景对比

移动端游戏功耗测试实战：电流、功率、亮度和场景对比

移动端游戏功耗测试：先控制变量，再比较优化是否真的省电 摘要：功耗测试最容易犯的错误，是拿两次不同温度、不同亮度、不同场景的平均功率直接比较。本文给出一套可复现的游戏功耗测试方法，覆盖引擎特性验证、版本回归和黑盒体验测试，并说明如何把功耗与帧率、温控、CPU/G…

2026/7/9 14:31:03
足球口袋教练 HarmonyOS 离线应用实战（03/20）：ArkUI 首页仪表盘搭建

足球口袋教练 HarmonyOS 离线应用实战（03/20）：ArkUI 首页仪表盘搭建

本文是“足球口袋教练 HarmonyOS 离线应用实战”系列第 3 篇。示例项目是一个 HarmonyOS / ArkTS / ArkUI 编写的离线足球训练助手&#xff0c;围绕真实页面、真实截图和可复现操作展开。 本篇要解决的问题 训练 App 的首页不能只展示欢迎语&#xff0c;它要解决“我现在该点哪…

2026/7/9 15:31:26