嵌入式学习day16-22(2024.04.06-13)

2024-04-15 23:04

本文主要是介绍嵌入式学习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、发送时 数据长度+数据(发送不定长数据)

并发服务器

这篇关于嵌入式学习day16-22(2024.04.06-13)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/907173

相关文章

HarmonyOS学习(七)——UI(五)常用布局总结

自适应布局 1.1、线性布局(LinearLayout) 通过线性容器Row和Column实现线性布局。Column容器内的子组件按照垂直方向排列,Row组件中的子组件按照水平方向排列。 属性说明space通过space参数设置主轴上子组件的间距,达到各子组件在排列上的等间距效果alignItems设置子组件在交叉轴上的对齐方式,且在各类尺寸屏幕上表现一致,其中交叉轴为垂直时,取值为Vert

Ilya-AI分享的他在OpenAI学习到的15个提示工程技巧

Ilya(不是本人,claude AI)在社交媒体上分享了他在OpenAI学习到的15个Prompt撰写技巧。 以下是详细的内容: 提示精确化:在编写提示时,力求表达清晰准确。清楚地阐述任务需求和概念定义至关重要。例:不用"分析文本",而用"判断这段话的情感倾向:积极、消极还是中性"。 快速迭代:善于快速连续调整提示。熟练的提示工程师能够灵活地进行多轮优化。例:从"总结文章"到"用

【前端学习】AntV G6-08 深入图形与图形分组、自定义节点、节点动画(下)

【课程链接】 AntV G6:深入图形与图形分组、自定义节点、节点动画(下)_哔哩哔哩_bilibili 本章十吾老师讲解了一个复杂的自定义节点中,应该怎样去计算和绘制图形,如何给一个图形制作不间断的动画,以及在鼠标事件之后产生动画。(有点难,需要好好理解) <!DOCTYPE html><html><head><meta charset="UTF-8"><title>06

Java进阶13讲__第12讲_1/2

多线程、线程池 1.  线程概念 1.1  什么是线程 1.2  线程的好处 2.   创建线程的三种方式 注意事项 2.1  继承Thread类 2.1.1 认识  2.1.2  编码实现  package cn.hdc.oop10.Thread;import org.slf4j.Logger;import org.slf4j.LoggerFactory

学习hash总结

2014/1/29/   最近刚开始学hash,名字很陌生,但是hash的思想却很熟悉,以前早就做过此类的题,但是不知道这就是hash思想而已,说白了hash就是一个映射,往往灵活利用数组的下标来实现算法,hash的作用:1、判重;2、统计次数;

嵌入式QT开发:构建高效智能的嵌入式系统

摘要: 本文深入探讨了嵌入式 QT 相关的各个方面。从 QT 框架的基础架构和核心概念出发,详细阐述了其在嵌入式环境中的优势与特点。文中分析了嵌入式 QT 的开发环境搭建过程,包括交叉编译工具链的配置等关键步骤。进一步探讨了嵌入式 QT 的界面设计与开发,涵盖了从基本控件的使用到复杂界面布局的构建。同时也深入研究了信号与槽机制在嵌入式系统中的应用,以及嵌入式 QT 与硬件设备的交互,包括输入输出设

06 C++Lambda表达式

lambda表达式的定义 没有显式模版形参的lambda表达式 [捕获] 前属性 (形参列表) 说明符 异常 后属性 尾随类型 约束 {函数体} 有显式模版形参的lambda表达式 [捕获] <模版形参> 模版约束 前属性 (形参列表) 说明符 异常 后属性 尾随类型 约束 {函数体} 含义 捕获:包含零个或者多个捕获符的逗号分隔列表 模板形参:用于泛型lambda提供个模板形参的名

零基础学习Redis(10) -- zset类型命令使用

zset是有序集合,内部除了存储元素外,还会存储一个score,存储在zset中的元素会按照score的大小升序排列,不同元素的score可以重复,score相同的元素会按照元素的字典序排列。 1. zset常用命令 1.1 zadd  zadd key [NX | XX] [GT | LT]   [CH] [INCR] score member [score member ...]

【机器学习】高斯过程的基本概念和应用领域以及在python中的实例

引言 高斯过程(Gaussian Process,简称GP)是一种概率模型,用于描述一组随机变量的联合概率分布,其中任何一个有限维度的子集都具有高斯分布 文章目录 引言一、高斯过程1.1 基本定义1.1.1 随机过程1.1.2 高斯分布 1.2 高斯过程的特性1.2.1 联合高斯性1.2.2 均值函数1.2.3 协方差函数(或核函数) 1.3 核函数1.4 高斯过程回归(Gauss

【学习笔记】 陈强-机器学习-Python-Ch15 人工神经网络(1)sklearn

系列文章目录 监督学习:参数方法 【学习笔记】 陈强-机器学习-Python-Ch4 线性回归 【学习笔记】 陈强-机器学习-Python-Ch5 逻辑回归 【课后题练习】 陈强-机器学习-Python-Ch5 逻辑回归(SAheart.csv) 【学习笔记】 陈强-机器学习-Python-Ch6 多项逻辑回归 【学习笔记 及 课后题练习】 陈强-机器学习-Python-Ch7 判别分析 【学