嵌入式学习-网络编程-Day4

思维导图

Day4.png

广播通信模型

#include <myhead.h>
int main(int argc, char const *argv[])
{int rfd =socket(AF_INET,SOCK_DGRAM,0);if(rfd==-1){perror("socket error");return -1;}//填充地址信息结构体struct sockaddr_in rin;rin.sin_family=AF_INET;rin.sin_port=htons(6789);rin.sin_addr.s_addr=inet_addr("192.168.123.255");//3绑定if(bind(rfd,(struct sockaddr*)&rin,sizeof(rin))==-1){perror("bind error");return -1;}//接收消息char rbuf[128]="";while (1){//清空数组bzero(rbuf,sizeof(rbuf));//接受消息recvfrom(rfd,rbuf,sizeof(rbuf),0,0,0);printf("收到消息为:%s\n",rbuf);}//关闭套接字close(rfd);return 0;
}
#include <myhead.h>
int main(int argc, char const *argv[])
{//创建套接字int sfd=socket(AF_INET,SOCK_DGRAM,0);if(sfd==-1){perror("socket error");return -1;}//将套接字设置成允许广播int broadcast=1;if(setsockopt(sfd,SOL_SOCKET,SO_BROADCAST,&broadcast,sizeof(broadcast))==-1){perror("setsockopt error");return -1;}//绑定(随意)//填充接收端地址信息结构体struct sockaddr_in cin;cin.sin_family=AF_INET;cin.sin_port=htons(6789);cin.sin_addr.s_addr=inet_addr("192.168.123.255");//发送消息char sbuf[128]="";while(1){printf("请输入>>>");fgets(sbuf,sizeof(sbuf),stdin);sbuf[strlen(sbuf)-1]=0;//发送到广播地址sendto(sfd,sbuf,sizeof(sbuf),0,(struct sockaddr*)&cin,sizeof(cin));}//关闭套接字close(sfd);return 0;
}

组播通信模型

#include <myhead.h>
int main(int argc, char const *argv[])
{//创建套接字int rfd =socket(AF_INET,SOCK_DGRAM,0);if(rfd==-1){perror("socket error");return -1;}//设置网络属性struct ip_mreqn im;im.imr_multiaddr.s_addr=inet_addr("224.1.2.3");im.imr_address.s_addr=inet_addr("192.168.122.60");//本机IPim.imr_ifindex=2;        //网络索引if((setsockopt(rfd,IPPROTO_IP,IP_ADD_MEMBERSHIP,&im,sizeof(im)))==-1){perror("setsockopt error");return -1;}printf("加入多播组成功\n");//填充地址信息结构体//绑定struct sockaddr_in rin;rin.sin_family=AF_INET;rin.sin_port=htons(9999);rin.sin_addr.s_addr=inet_addr("224.1.2.3");if((bind(rfd,(struct sockaddr*)&rin,sizeof(rin)))==-1){perror("bind error");return -1;}//接收消息char rbuf[128]="";while(1){bzero(rbuf,sizeof(rbuf));recvfrom(rfd,rbuf,sizeof(rbuf),0,0,0);printf("收到消息为:%s\n",rbuf);}//关闭套接字close(rfd);return 0;
}
#include <myhead.h>
int main(int argc, char const *argv[])
{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(9999);sin.sin_addr.s_addr=inet_addr("224.1.2.3");char sbuf[128]="";while(1){printf("请输入>>>");fgets(sbuf,sizeof(sbuf),stdin);sbuf[strlen(sbuf)-1]=0;sendto(sfd,sbuf,sizeof(sbuf),0,(struct sockaddr*)&sin,sizeof(sin));printf("发送成功\n");}close(sfd);return 0;
}

流式域套接字模型

#include <myhead.h>
int main(int argc, char const *argv[])
{//创建套接字int sfd=socket(AF_UNIX,SOCK_STREAM,0);if(sfd==-1){perror("socket error");return -1;}//由于域套接字的绑定函数,只能绑定一个不存在的套接字文件中//所以在绑定之前需要判断当前文件是否存在//判断文件是否存在函数if(access("./unix",F_OK)==0){//表示文件存在,删除该文件if(unlink("./unix")==-1){perror("unlink error");return -1;}}//填充地址信息结构体struct sockaddr_un sun;sun.sun_family=AF_UNIX;strcpy(sun.sun_path,"./unix");//绑定地址信息结构体if((bind(sfd,(struct sockaddr*)&sun,sizeof(sun)))==-1){perror("bind error");return -1;}puts("bind success");//监听if(listen(sfd,128)==-1){perror("listen error");return -1;}//阻塞接受客户端的连接请求struct sockaddr_un cun;socklen_t socklen=sizeof(cun);int newfd=accept(sfd,(struct sockaddr*)&cun,&socklen);if(newfd==-1){perror("accept error");return -1;}//收发数据char buf[128]="";while(1){bzero(buf,sizeof(buf));int res=recv(newfd,buf,sizeof(buf),0);if(res==0){printf("客户端已经下线\n");}printf("[%s]:%s\n",cun.sun_path,buf);}//关闭套接字close(newfd);close(sfd);return 0;
}
#include <myhead.h>int main(int argc, const char *argv[])
{//1.创建套接字int cfd  = socket(AF_UNIX,SOCK_STREAM,0/*IPPROTO_TCP*/);if(cfd==-1){perror("socket error");return -1;}printf("cfd=%d\n",cfd);//2.绑定(随意)if(access("./linux",F_OK)==0){if(unlink("./lunix")==-1){perror("unlink error");return -1;}        }struct sockaddr_un cun;cun.sun_family=AF_UNIX;strcpy(cun.sun_path,"./lunix");if((bind(cfd,(struct sockaddr*)&cun,sizeof(cun)))==-1){perror("bind error");return -1;}    puts("bind success");//3.连接服务器//3.1填充地址信息结构体struct sockaddr_un sun;sun.sun_family=AF_UNIX;strcpy(sun.sun_path,"./unix");//3.2链接if(connect(cfd,(struct sockaddr*)&sun,sizeof(sun))==-1){perror("connect error");return -1;}printf("链接成功\n");//4.收发数据char buf[128]="";while(1){bzero(buf,sizeof(buf));printf("请输入>>>");fgets(buf,sizeof(buf),stdin);buf[strlen(buf)-1]=0;//发送给服务器send(cfd,buf,sizeof(buf),0);printf("发送成功\n");if(strcmp(buf,"quit")==0){break;}}//5.关闭套接字close(cfd);return 0;
}

报式域套接字模型

#include <myhead.h>
#define SER_PORT 9999
#define SER_IP "192.168.122.36"int main(int argc, char const *argv[])
{//创建套接字int sfd=socket(AF_UNIX,SOCK_DGRAM,0);if(sfd==-1){perror("");return -1;}printf("sfd=%d\n",sfd);if(access("./linux",F_OK)==0){if(unlink("./lunix")==-1){perror("unlink error");return -1;}        }//2绑定struct sockaddr_un sun;sun.sun_family=AF_UNIX;strcpy(sun.sun_path,"./linux");//2.2绑定if(bind(sfd,(struct sockaddr*)&sun,sizeof(sun))==-1){perror("bind error");return -1;}//3.数据收发char buf[128]="";struct sockaddr_un cun;socklen_t socklen=sizeof(cun);while(1){bzero(buf,sizeof(buf));//read(sfd,buf,sizeof(buf));//读取信息,并将客户端地址信息结构体存储到cin中recvfrom(sfd,buf,sizeof(buf),0,(struct sockaddr*)&cun,&socklen);printf("读取的消息为:%s\n",buf);//将字符串连接后回发strcat(buf,"=-=");// if((write(sfd,buf,sizeof(buf)))==-1)if((sendto(sfd,buf,sizeof(buf),0,(struct sockaddr*)&cun,sizeof(cun)))==-1){perror("sendto error");return -1;}}close(sfd);return 0;
}
#include <myhead.h>
int main(int argc, char const *argv[])
{//创建用于通信的套接字文件描述符int cfd = socket(AF_UNIX,SOCK_DGRAM,0);if(cfd==-1){perror("socket error");return -1;}if(access("./unix",F_OK)==0){if(unlink("./unix")==-1){perror("unlink error");return -1;}        }struct sockaddr_un cun;cun.sun_family=AF_UNIX;strcpy(cun.sun_path,"./unix");if(bind(cfd,(struct sockaddr*)&cun,sizeof(cun))==-1){perror("bind error");return -1;}struct sockaddr_un sun;sun.sun_family=AF_UNIX;strcpy(sun.sun_path,"./linux");char buf[128]="";while(1){printf("请输入:");fgets(buf,sizeof(buf),stdin);buf[strlen(buf)-1]=0;sendto(cfd,buf,sizeof(buf),0,(struct sockaddr*)&sun,sizeof(sun));if(strcmp(buf,"quit")==0){break;}recvfrom(cfd,buf,sizeof(buf),0,0,0);printf("收到消息为:%s\n",buf);}return 0;
}

作业:编写一个客户端,通过TFTP服务器实现文件的上传和下载

#include<myhead.h>
#define SER_PORT 69
#define SER_IP "192.168.122.71"int do_download(int cfd,struct sockaddr_in sin)
{//向服务器发送下载请求char buf[516] = "";//组装请求数据short *p1 = (short *)buf;*p1 = htons(1);char *p2 = buf+2;char filename[20]="";printf("请输入要下载的文件名>>>");scanf("%s",filename);getchar(); strcpy(p2, filename);char *p3 = p2+strlen(p2)+1;strcpy(p3, "octet");int len = 4+strlen(p2) + strlen(p3);   //要发送的长度//向服务器发送请求if((sendto(cfd, buf, len, 0, (struct sockaddr*)&sin, sizeof(sin)))==-1){perror("sendto error");return -1;}printf("下载请求已发送\n");socklen_t addrlen = sizeof(sin);int fd = -1;int res=0;unsigned short b_id = 0;//块编号char ack[4]="";//循环收发 while(1){//客户端收取数据包bzero(buf,sizeof(buf));if((res=recvfrom(cfd,buf,sizeof(buf),0,(struct sockaddr*)&sin,&addrlen))==-1){perror("recv error");break;}//printf("收到的前四个字节为:[%d%d%d%d]\n",buf[0],buf[1],buf[2],buf[3]);b_id=ntohs(*(short *)(buf+2));if(buf[1]==3){if((fd=open(filename,O_WRONLY|O_CREAT|O_APPEND,0664))==-1){perror("open error");return -1;}//write(fd,buf+4,res-4);if(write(fd,buf+4,res-4)==-1){perror("write all");break;}//ACK//发送ACK包bzero(ack,sizeof(ack));*(short*)ack=htons(4);*(short *)(ack + 2) = htons(b_id);if((sendto(cfd,ack,4,0,(struct sockaddr*)&sin,sizeof(sin)))==-1){perror("sendto error");break;}if(res <516 ){puts("下载完成");break;}}if(buf[1]==5){puts("error num");//char *err_id=(buf+3);//printf("errid=%d\n",*err_id);break;}}//puts("下载完成");close(fd);return 0;
}int do_upload(int cfd,struct sockaddr_in sin)
{//向服务器发送上传请求char buf[516] = "";//组装请求数据short *p1 = (short *)buf;*p1 = htons(2);char *p2 = buf+2;char filename[20]="";printf("请输入要上传的文件名>>>");scanf("%s",filename);getchar(); strcpy(p2, filename);if(access(filename,F_OK)==-1){perror("文件不存在");return -1;}char *p3 = p2+strlen(p2)+1;strcpy(p3, "octet");int len = 4+strlen(p2) + strlen(p3);   //要发送的长度//向服务器发送请求if((sendto(cfd, buf, len, 0, (struct sockaddr*)&sin, sizeof(sin)))==-1){perror("sendto error");return -1;}printf("上传请求已发送\n");socklen_t addrlen = sizeof(sin);int fd = -1;int res=0;unsigned short b_id = 0;//块编号char ack[4]="";while(1){//客户端收取数据包bzero(ack,sizeof(ack));if((recvfrom(cfd,ack,sizeof(ack),0,(struct sockaddr*)&sin,&addrlen))==-1){perror("recv error");break;}printf("收到的前四个字节为:[%d%d%d%d]\n",ack[0],ack[1],ack[2],ack[3]);b_id=ntohs(*(short *)(ack+2));printf("b_id=%d\n",b_id);if(ack[1]==4){puts("11");fd=open(filename,O_RDONLY);printf("fd=%d\n",fd);if(fd==-1){perror("open error");break;}puts("aa");res=read(fd,buf+4,512);printf("res=%d\n",res);if(res==-1){perror("read error");break;}puts("bb");bzero(buf,sizeof(buf));*(short*)buf=htons(3);*(short *)(buf + 2) = htons(b_id+1);if(sendto(cfd,buf,res+4,0,(struct sockaddr*)&sin,sizeof(sin))==-1){perror("sendto error");break;}puts("cc");if(res<512){puts("上传成功");break;}}if(buf[1]==5){puts("error num");char *err_id=(buf+3);printf("errid=%d\n",*err_id);break;}}close(fd);return 0;}int main(int argc, const char *argv[])
{//1、创建用于通信的套接字文件描述符int cfd = socket(AF_INET, SOCK_DGRAM, 0);if(cfd == -1){perror("socket error");return -1;}//2、绑定(可选)//3、填充服务器的地址信息结构体struct sockaddr_in sin;sin.sin_family = AF_INET;sin.sin_port = htons(SER_PORT);sin.sin_addr.s_addr = inet_addr(SER_IP);char menu;//制作菜单框架while(1){printf("\t\t====1.download====\n");printf("\t\t====2.upload  ====\n");printf("\t\t====0.exit    ====\n");printf("Please enter function options:");scanf("%c",&menu);while(getchar() != '\n');//对菜单选项多分支选择switch(menu){case '1':    {do_download(cfd,sin);  //下载}break;case '2':{do_upload(cfd,sin);     //上传}break;case '0':exit(1);default:{printf("enter error!!!");}}printf("Enter any key to clear the screen:");while(getchar() != '\n');system("clear");}//5、关闭套接字close(cfd);return 0;
}

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

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

相关文章

2024年甘肃省职业院校技能大赛信息安全管理与评估 样题一 模块二

竞赛需要完成三个阶段的任务&#xff0c;分别完成三个模块&#xff0c;总分共计 1000分。三个模块内容和分值分别是&#xff1a; 1.第一阶段&#xff1a;模块一 网络平台搭建与设备安全防护&#xff08;180 分钟&#xff0c;300 分&#xff09;。 2.第二阶段&#xff1a;模块二…

安泰功率信号源设计方法有哪些

在电子系统中&#xff0c;功率信号源是一个关键的组成部分&#xff0c;用于提供稳定、可靠的电能。这篇文章将详细介绍功率信号源的设计方法&#xff0c;包括选择功率源类型、设计电源拓扑结构、提高效率和管理电磁干扰等方面。 1.功率源类型的选择 选择适当的功率源类型是功率…

MSSQL-识别扩展extended event(扩展事件)中的时间单位

经常使用sqlserver extended event(扩展事件)&#xff0c;但是总是忘记扩展事件使用的时间单位&#xff0c;不确定它们是 秒、毫秒、还是微秒&#xff1f; 以下下代码能够从 相关DMV中提取description字段内容来识别时间单位&#xff1a; SELECT [p].[name] [package_name],[o…

07. 面向对象编程(一)

目录 1、前言 2、类和对象 2.1、定义类 2.2、定义方法 2.3、创建对象 2.4、访问控制 2.4.1、公共变量 2.4.2、私有变量 2.4.3、保护成员 2.4.4、总结 3、封装 4、继承 5、多态 6、小结 1、前言 在Python中&#xff0c;面向对象编程&#xff08;Object-Oriented …

vuex的初步使用-1

1. 介绍 Vuex 是一个 Vue 的 状态管理工具&#xff0c;状态就是数据。 简单讲&#xff1a;Vuex 就是一个插件&#xff0c;可以帮我们管理 Vue 通用的数据 (多组件共享的数据)。相对于一个仓库&#xff1a;存放组件共享的数据。 2. 安装 vuex 安装vuex与vue-router类似&…

基于Mapbox的Mvt矢量瓦片集成实践

目录 前言 一、数据说明 1、基本数据 2、属性数据 二、Mapbox集成Mvt矢量瓦片 1、关于访问令牌 2、定义html 3、初始地图 4、加载矢量瓦片 5、效果展示 总结 前言 熟悉矢量瓦片的朋友一定知道&#xff0c;在Webgis当中&#xff0c;矢量瓦片的格式除了pbf的格式&#x…

docker:环境安装

系列文章目录 docker&#xff1a;环境安装 文章目录 系列文章目录前言一、Debian安装1.镜像下载2.VM安装3.Debian安装 二、docker安装1.Debian12换源2.docker安装3.docker测试4.docker换源 总结 前言 因为CentOS7确定停服时间为6月30日&#xff0c;虽然对我这种小虾米没啥影响…

dubbox框架

1、dubbox介绍 Dubbo(读音[ˈdʌbəʊ])是阿里巴巴公司开源的一个基于Java的高性能RPC&#xff08;Remote Procedure Call&#xff09;框架&#xff0c;使得应用可通过高性能的 RPC 实现服务的输出和输入功能&#xff0c;可以和 Spring框架无缝集成。后期阿里巴巴停止了该项目…

HashMap集合万字源码详解(面试常考)

文章目录 HashMap集合1.散列2.hashMap结构3.继承关系4.成员变量5.构造方法6.成员方法6.1增加方法6.2将链表转换为红黑树的treeifyBin方法6.3扩容方法_resize6.3.1扩容机制6.3.2源码resize方法的解读 6.4 删除方法(remove)6.5查找元素方法(get)6.6遍历HashMap集合几种方式 7.初始…

vue安装组件报错In most cases you are behind a proxy or have bad network settings.

解决办法 步骤1 npm config get proxy npm config get https-proxy 如果2个返回值不为null&#xff0c;请执行下面代码&#xff0c;重置为null。否则&#xff0c;直接执行步骤2。 npm config set proxy null npm config set https-proxy null 步骤2 npm config set regis…

cv 不能正常读取中文路径

之前一直以为是PyQT的getOpenFileNames方法不能读取中文路径的。多次尝试后发现不是&#xff0c;是OpenCV的问题。 self.selected_imgPaths, _ QtWidgets.QFileDialog.getOpenFileNames(self, "打开图片", "./pending_images", "*.jpg;;*.JPG;;*.png…

【Windows取证篇】Window日志分析基础知识(一)

【Windows取证篇】Window日志分析基础知识&#xff08;一&#xff09; Windows系统审计是对系统中有关安全的活动进行记录、检查以及审核&#xff0c;一般是一个独立的过程。Window自带的事件查看器并没有提供删除特定日志的功能&#xff0c;我们在系统审计取证分析时&#xf…

基于Java+SSM志愿者服务管理系统详细设计和实现【附源码】

基于JavaSSM志愿者服务管理系统详细设计和实现【附源码】 &#x1f345; 作者主页 央顺技术团队 &#x1f345; 欢迎点赞 &#x1f44d; 收藏 ⭐留言 &#x1f4dd; &#x1f345; 文末获取源码联系方式 &#x1f4dd; &#x1f345; 查看下方微信号获取联系方式 承接各种定制系…

九、Qt C++ 数据库开发

《一、QT的前世今生》 《二、QT下载、安装及问题解决(windows系统)》《三、Qt Creator使用》 ​​​ 《四、Qt 的第一个demo-CSDN博客》 《五、带登录窗体的demo》 《六、新建窗体时&#xff0c;几种窗体的区别》 《七、Qt 信号和槽》 《八、Qt C 毕业设计》 《九、Qt …

Vue-23、Vue收集表单数据

1、效果 2、代码 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><title>收集表单数据</title><script type"text/javascript" src"https://cdn.jsdelivr.net/npm/vue2/dist/vue.js…

服务网关 Gateway

服务网关 Gateway Spring Cloud Gateway 是 Spring Cloud 生态系统中的网关&#xff0c;它基于 Spring5.0 SpringBoot2.0 WebFlux&#xff08;基于高性能的 Reactor 模式响应式通信框架 Netty&#xff0c;异步非阻塞模型&#xff09;等技术开发。旨在为微服务架构提供一种简…

Ubuntu系统使用快速入门实践(八)——出现的各种问题

Ubuntu系统使用快速入门实践系列文章 下面是Ubuntu系统使用系列文章的总链接&#xff0c;本人发表这个系列的文章链接均收录于此 Ubuntu系统使用快速入门实践系列文章总链接 下面是专栏地址&#xff1a; Ubuntu系统使用快速入门实践系列文章专栏 文章目录 Ubuntu系统使用快速…

Eclipse搭建python环境

一、下载eclipse eclipse官网下载参考链接 二、 下载PyDev ​PyDev 三、安装和配置pyDev 下载完PyDev&#xff0c;解压之后是下面两个文件夹&#xff0c;我下载的版本是PyDev 7.7 ,然后拷到eclipse对应的目录下就可以 四、然后新建一个python程序 1.新建一个项目 ​​…

【C语言】数据结构——排序三(归并与计数排序)

&#x1f497;个人主页&#x1f497; ⭐个人专栏——数据结构学习⭐ &#x1f4ab;点击关注&#x1f929;一起学习C语言&#x1f4af;&#x1f4ab; 目录 导读&#xff1a;1. 归并排序1.1 基本思想1.2 递归实现1.3 非递归实现 2. 计数排序2.1 基本思想2.2 代码实现 导读&#x…

VSCODE上使用IDEA上的快捷键:IntelliJ IDEA Keybindings

&#x1f341; 作者&#xff1a;知识浅谈&#xff0c;CSDN签约讲师&#xff0c;CSDN博客专家&#xff0c;华为云云享专家&#xff0c;阿里云专家博主 &#x1f4cc; 擅长领域&#xff1a;全栈工程师、爬虫、ACM算法 &#x1f492; 公众号&#xff1a;知识浅谈 &#x1f525;网站…