嵌入式学习day16-22（2024.04.06-13）

文章目录

  • C语言网络编程
    • socket
      • 主机与网络字节序转换
        • inet_addr、inet_aton（ip转换）
        • inet_ntoa 网络字节序转换为IP字符串
        • 端口转换为网络字节序
        • 网络字节序转换为端口
        • atoi （字符串转换为整数）
    • UDP通信流程
      • UDP多进程并发服务器
      • 服务端
      • 客户端
    • TCP通信流程
      • 客户端
      • 服务端
      • TCP粘包
      • 并发服务器

C语言网络编程

socket

在这里插入图片描述

Linux提供的socket
socket套接字类型
1、流式套接字（TCP）
2、数据报套接字（UDP）
3、原始套接字
在这里插入图片描述
网络数据流在cpu中以不同的方式存储，有小端和大端两种方式（小端与人的读写同向，大端与人的读逆向）
在这里插入图片描述
网络传输时先判断是否为小端，若为小端则进行转换。可以用共用体判断是大端还是小端存储。

主机与网络字节序转换

inet_addr、inet_aton（ip转换）

在这里插入图片描述

inet_ntoa 网络字节序转换为IP字符串
端口转换为网络字节序
网络字节序转换为端口

在这里插入图片描述

atoi （字符串转换为整数）

UDP通信流程

在这里插入图片描述
发送流程
1、创建socket函数
int socket(int domain, int type, int protocol);
udp_socket = socket(AF_INET, SOCK_DGRAM, 0);
2、sendto，发送函数
发送端代码

#include<stdio.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<string.h>
#include<stdlib.h>
#include<unistd.h>
void send_data(int sockfd,struct sockaddr_in *addr,int len){int n=0;char buf[1024]={0};while(1){putchar('>');memset(buf,0,sizeof(buf));fgets(buf,sizeof(buf),stdin);buf[strlen(buf)-1] = '\0'; // ’\n‘ ==>'\0'n = sendto(sockfd,buf,strlen(buf),0,(struct sockaddr *)addr,len);//发送写buf实际长度，收时写buf最大长度if(n < 0){perror("[ERROR] sendto():");exit(EXIT_FAILURE);}if(strncmp(buf,"quit",4) == 0){printf("END SEND\n");break;}printf("\033[43msend message:\033[0m %s \n",buf);}return ;
}int main(int argc,char *argv[]){int sockfd;struct sockaddr_in peer_addr;int len = sizeof(peer_addr);if(argc != 3){fprintf(stderr,"Usage : %s ip port !\n",argv[0]);exit(EXIT_FAILURE);}//1、通过socket创建文件描述符sockfd = socket(AF_INET,SOCK_DGRAM,0);if(sockfd == -1){perror("[ERROR] socket():");exit(EXIT_FAILURE);}//2、填充服务器ip和端口号memset(&peer_addr,0,sizeof(peer_addr)); //初始化结构体peer_addr.sin_family=AF_INET;peer_addr.sin_port=htons(atoi(argv[2]));peer_addr.sin_addr.s_addr = inet_addr(argv[1]);//3、发送数据send_data(sockfd,&peer_addr,len);//4、关闭文件描述符close(sockfd);return 0;
}

接收流程
1、创建socket
2、绑定ip和端口到socket bind
3、接收数据 recvfrom

#include<stdio.h>
#include<string.h>
#include<stdlib.h>
#include<unistd.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
void recv_data(int sockfd){//接收数据函数int n = 0;char buf[1024] = {0};struct sockaddr_in client_addr;int len = sizeof(client_addr);while(1){memset(buf,0,sizeof(buf));n = recvfrom(sockfd,buf,sizeof(buf),0,(struct sockaddr *)&client_addr,&len); //接收发送方IP port 以及数据if(n < 0){perror("[error] recvfrom():");exit(EXIT_FAILURE);}printf("===================================================\n");printf("\033[34m Recv from IP = %s \033[0m\n",inet_ntoa(client_addr.sin_addr));printf("\033[34m Recv from PORT = %d \033[0m\n",ntohs(client_addr.sin_port));printf("Recv  %d bytes:\033[35m %s\033[0m\n",n,buf);if(strncmp(buf,"quit",4) == 0){printf("\033[31mEND RECV\033[0m\n");break;}}}int main(int argc,char *argv[]){//参数判断if(argc != 3){printf("\033[31m %s 参数错误: ip port\033[0m\n");exit(EXIT_FAILURE);}int sockfd;struct sockaddr_in my_addr;int len = sizeof(my_addr);//1、创建socketsockfd = socket(AF_INET,SOCK_DGRAM,0);if(sockfd < 0){perror("[ERROR] socket():");exit(EXIT_FAILURE);}//2、填充ip和端口memset(&my_addr,0,sizeof(my_addr)); //初始化结构体my_addr.sin_family = AF_INET;my_addr.sin_port = htons(atoi(argv[2]));my_addr.sin_addr.s_addr = inet_addr(argv[1]);//3、绑定端口if(bind(sockfd,(struct sockaddr *)&my_addr,len)<0){perror("[ERROR] bind():");exit(EXIT_FAILURE);}		printf("\033[35m wait recv from port %s \033[0m \n",argv[2]);//4、接收数据recv_data(sockfd);//关闭描述符close(sockfd);return 0;	
}

UDP多进程并发服务器

在这里插入图片描述

在这里插入图片描述

服务端

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>/*udp 多进程服务器端*/
/*
1、创建主进程，用与接收客户端请求
2、接收客户端请求后，分配新的socket以及端口用于和客户端连接*/void send_client(struct sockaddr_in *seradd,struct sockaddr_in *newcadd,struct sockaddr_in *newclient);int main(int argc,char *argv[]){/*变量定义*/int sfd; //主进程socketint len;//记录结构体长度int rev;//接收函数返回值struct sockaddr_in seradd;//填充服务端信息struct sockaddr_in cliadd;//接收客户端信息char buf[1024] = {0};  //接收数据缓冲区pid_t cpid; //接收子进程号/*代码*/len = sizeof(seradd);//创建主进程//1、创建socketsfd = socket(AF_INET,SOCK_DGRAM,0);if(sfd == -1){perror("error in socket():");exit(EXIT_FAILURE);}//2、填充信息到结构体memset(&seradd,0,len);seradd.sin_family = AF_INET;seradd.sin_port = htons(atoi(argv[2]));seradd.sin_addr.s_addr = inet_addr(argv[1]);//3、绑定ip和端口至socketrev = bind(sfd,(struct sockaddr *)&seradd,len);if(rev == -1){	perror("error in bind():");exit(EXIT_FAILURE);}//接收数据while(1){memset(buf,0,sizeof(buf));memset(&cliadd,0,len);rev = recvfrom(sfd,buf,sizeof(buf),0,(struct sockaddr *)&cliadd,&len);if(rev == -1){perror("error in recvfrom():");exit(EXIT_FAILURE);}//输出客户端信息printf("The connect from:\033[32m %s %d\033[0m\n",inet_ntoa(cliadd.sin_addr),ntohs(cliadd.sin_port));printf("data : \033[31m %s \033[0m\n",buf);//创建子进程cpid = fork();if(cpid == -1){perror("error in fork():");exit(EXIT_FAILURE);}else if(cpid == 0){struct sockaddr_in new_seradd;//创建新的端口等struct sockaddr_in new_client;//创建新的端口等memset(&new_seradd,0,len);memset(&new_client,0,len);new_client = cliadd;send_client(&seradd,&new_seradd,&new_client);exit(EXIT_SUCCESS);}}return 0;
}/*函数*/void send_client(struct sockaddr_in *seradd,struct sockaddr_in *newcadd,struct sockaddr_in *newclient){struct sockaddr_in * new_ser; //接收目的ip,并分配新portstruct sockaddr_in * client; //接收目的ip,并分配新portint sfd;int len;int rev;char buf[1024]={0};len = sizeof(struct sockaddr_in);new_ser = newcadd;client = newclient;sfd = socket(AF_INET,SOCK_DGRAM,0);if(sfd == -1){perror("error in socket():");exit(EXIT_FAILURE);}//输出客户端信息new_ser->sin_family = seradd->sin_family;new_ser->sin_port = htons(0);new_ser->sin_addr.s_addr = seradd->sin_addr.s_addr;rev = bind(sfd,(struct sockaddr *)new_ser,len);if(rev == -1){perror("error in rev():");exit(EXIT_FAILURE);}printf("以新端口发送数据\n");	rev =  sendto(sfd,"SEND NEW PORT",sizeof("SEND NEW PORT"),0,(struct sockaddr*)client,len);if(rev == -1){perror("error in sendto():");exit(EXIT_FAILURE);}printf("以新端口接收数据\n");	while(1){memset(buf,0,sizeof(buf));rev = recvfrom(sfd,buf,sizeof(buf),0,(struct sockaddr *)new_ser,&len);if(rev == -1){perror("error in recvfrom():");exit(EXIT_FAILURE);}printf("data:\033[32m%s\n\033[0m",buf);}close(sfd);return ;}

客户端

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>/*udp 多进程客户端*/
/*
1、创建socket，并发送一条信息
2、接收打一条信息 （struct sockaddr_in.sin_port 新更换端口）*/int main(int argc,char *argv[]){/*变量定义*/int sfd;int len;int rev;struct sockaddr_in seradd;char buf[1024] = {0};/*代码*/len = sizeof(seradd);//创建主进程//1、创建socketsfd = socket(AF_INET,SOCK_DGRAM,0);if(sfd == -1){perror("error in socket():");exit(EXIT_FAILURE);}//2、填充信息到结构体memset(&seradd,0,len);seradd.sin_family = AF_INET;seradd.sin_port = htons(atoi(argv[2]));seradd.sin_addr.s_addr = inet_addr(argv[1]);//3、发送信息获取端口号rev = sendto(sfd,"CONNECT",strlen("CONNECT"),0,(struct sockaddr *)&seradd,len);if(rev == -1){perror("error in sendto():");exit(EXIT_FAILURE);}//4、接收新的端口号	memset(buf,0,sizeof(buf));memset(&seradd,0,len);//接收新的端口号至结构体rev = recvfrom(sfd,buf,1024,0,(struct sockaddr *)&seradd,&len);if(rev == -1){perror("error in recvfrom when acquire new port:");exit(EXIT_FAILURE);}printf("接收新端口成功!!!\n");printf("请发送数据：\n");//正常接收发送数据while(1){memset(buf,0,sizeof(buf));fgets(buf,1024,0);
//		scanf("%s",buf);
//		printf("\n");printf("接收数据：%s\n",buf);rev = sendto(sfd,buf,sizeof(buf),0,(struct sockaddr *)&seradd,len);if(rev == -1){perror("error in sendto():");exit(EXIT_FAILURE);}rev = strncmp("exit",buf,4);printf("rev = %d\n",rev);if(rev == 0){printf("退出！！！！\n");break;}
/*	rev = recvfrom(sfd,buf,1024,0,(struct sockaddr *)&seradd),&len);if(rev == -1){perror("error in recvfrom when acquire new port:");exit(EXIT_FAILURE);}
*/	}/*资源关闭*/close(sfd);return 0;
}

TCP通信流程

客户端

流程：
1、创建socket
2、填充结构体 （bzeor() 清零函数）
3、创建连接 connect
4、发送数据 send (udp 为 sendto)
5、接收数据 recv （udp recvfrom） recv返回0，表示断开连接

服务端

1、创建socket
2、绑定ip 与 端口 bind
3、设置套接字为监听状态，建立监听队列 listen
4、与客户端三次握手建立连接 accept，成功创建一个新的套接字
5、使用新的套接字 接收发送消息 send recv

TCP粘包

原因：
解决方法：
1、使用定长的数据包
2、发送时 数据长度+数据（发送不定长数据）

并发服务器

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

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

相关文章

解决调用相同url数据不刷新问题

解决调用相同url数据不刷新问题

原代码 原因 谷歌浏览访问相同接口默认调用缓存数据 解决方案 添加时间戳
阅读更多...
fpga基础|如何在XDC文件中使用get_pins/ports/cells/nets/clocks查找指定的对象

fpga基础|如何在XDC文件中使用get_pins/ports/cells/nets/clocks查找指定的对象

大家好&#xff0c;我是数字小熊饼干&#xff0c;一个练习时长两年半的ic打工人。我在两年前通过自学跨行社招加入了IC行业。现在我打算将这两年的工作经验和当初面试时最常问的一些问题进行总结&#xff0c;并通过汇总成文章的形式进行输出&#xff0c;相信无论你是在职的还是…
阅读更多...
【NPS】内网穿透工具之 NPS

【NPS】内网穿透工具之 NPS

一、linux 安装 nps nps-releases&#xff1a;https://github.com/ehang-io/nps/releases 1.1、在 ubuntu下安装对应版本&#xff08;非docker&#xff09; 可以看到如下指令 wget https://ghproxy.com/https://github.com/ehang-io/nps/releases/download/v0.26.10/linux…
阅读更多...
plotly绘图——热力图

plotly绘图——热力图

文章目录 介绍热力图基础热力图代码解释 多热力图代码解释 显示数字的热力图代码解释 介绍 plotly是一个易于使用&#xff0c;功能强大的python绘图库&#xff0c;用于构建可交互式的图表&#xff08;可以自行运行后使用鼠标拖拽图片试试&#xff09;&#xff0c;本系列文章将介…
阅读更多...
李廉洋：4.16黄金，原油最新资讯，亚盘面走势分析及策略。

李廉洋：4.16黄金，原油最新资讯，亚盘面走势分析及策略。

周一&#xff0c;10年期美国国债收益率攀升3个基点&#xff0c;至4.55%&#xff0c;原因是投资者在权衡中东紧张局势加剧演变为全面地区战争的风险。美国国债将成为市场关注的焦点&#xff0c;上周美国国债收益率上升12个基点&#xff0c;至去年11月以来的最高水平&#xff0c;…
阅读更多...
在windows中anaconda中安装fasttext (whl 文件安装)

在windows中anaconda中安装fasttext (whl 文件安装)

Anaconda安装第三方包&#xff08;whl文件&#xff09; windows 安装fasttext 一直不成功&#xff0c;python 版本3.8 网上教程都是 https://www.lfd.uci.edu/~gohlke/pythonlibs/#fasttext 下载然后安装&#xff0c;但是这个网站里我没找到哈哈哈。。。 然后就是成功方案&am…
阅读更多...
Sonar下启动发生错误,elasticsearch启动错误

Sonar下启动发生错误,elasticsearch启动错误

Download | SonarQube | Sonar (sonarsource.com) 1.首先我的sonar版本为 10.4.1 &#xff0c;java版本为17 2.sonar启动需要数据库,我先安装了mysql, 但是目前sonar从7.9开始不支持mysql&#xff0c;且java版本要最少11,推荐使用java17 3.安装postsql,创建sonar数据库 4.启…
阅读更多...
【Spring】依赖注入(DI)时常用的注解@Autowired和@Value

【Spring】依赖注入(DI)时常用的注解@Autowired和@Value

目录 1、Autowired 自动装配 1.1、要实现自动装配不是一定要使用Autowired 1.2、Autowired的特性 &#xff08;1&#xff09;首先会根据类型去spring容器中找(bytype),如果有多个类型&#xff0c;会根据名字再去spring容器中找(byname) &#xff08;2&#xff09;如果根据名…
阅读更多...
基于注解以及配置类使用SpringIoc

基于注解以及配置类使用SpringIoc

四 基于注解方式使用SpringIoc 和 XML 配置文件一样&#xff0c;注解本身并不能执行&#xff0c;注解本身仅仅只是做一个标记&#xff0c;具体的功能是框架检测到注解标记的位置&#xff0c;然后针对这个位置按照注解标记的功能来执行具体操作。 本质上&#xff1a;所有一切的…
阅读更多...
策略为王股票软件源代码-----如何修改为自己的高级指标公式栏目----------51

策略为王股票软件源代码-----如何修改为自己的高级指标公式栏目----------51

阅读更多...
extends继承

extends继承

目录 什么时候用继承? 继承的格式? 继承的特点 子类可以继承父类的哪些呢&#xff1f; 是否可以继承父类的构造方法呢&#xff1f; 是否可以继承成员变量&#xff1f; 是否可以继承成员方法&#xff1f; 在Java中&#xff0c;extends关键字用于实现继承关系。通过使用…
阅读更多...
Go gin框架（详细版）

Go gin框架（详细版）

目录 0. 为什么会有Go 1. 环境搭建 2. 单-请求&&返回-样例 3. RESTful API 3.1 首先什么是RESTful API 3.2 Gin框架支持RESTful API的开发 4. 返回前端代码 go.main index.html 5. 添加静态文件 main.go 改动的地方 index.html 改动的地方 style.css 改动…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023