嵌入式学习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、创建socket
	sockfd = 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; //主进程socket
	int len;//记录结构体长度
	int rev;//接收函数返回值
	struct sockaddr_in seradd;//填充服务端信息
	struct sockaddr_in cliadd;//接收客户端信息
	char buf[1024] = {0};  //接收数据缓冲区
	pid_t cpid; //接收子进程号

	/*代码*/
	len = sizeof(seradd);
	//创建主进程
	//1、创建socket
	sfd = 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和端口至socket
	rev = 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,并分配新port
	struct sockaddr_in * client; //接收目的ip,并分配新port
	int 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、创建socket
	sfd = 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、发送时 数据长度+数据（发送不定长数据）

并发服务器

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

沐风老师3DMAX物品摆放插件ObjectPlacer安装和使用方法详解

沐风老师3DMAX物品摆放插件ObjectPlacer安装和使用方法详解

3DMAX物品摆放插件ObjectPlacer安装和使用教程 3DMAX物品摆放插件ObjectPlacer&#xff0c;一键在曲面上摆放对象&#xff0c;如摆放家具物品、种植花草树木、布设电线杆交通标志等。它的功能是将对象与几何体对象&#xff08;网格、多边形、面片或NURBS&#xff09;的面法线对…
阅读更多...
RISCV指令集体系简读之RV32I

RISCV指令集体系简读之RV32I

RV32I 指令格式 用于寄存器-寄存器操作的R类型指令用于短立即数和访存load操作的I型指令用于访存store操作的s型指令用于条件跳转操作的B类型指令用于长立即数的U型指令用于无条件跳转的J型指令 特点&#xff1a; 所有指令都是32bits&#xff0c; 简化了指令解码&#xff1b;…
阅读更多...
LangChain学习笔记与样程

LangChain学习笔记与样程

LangChain 是一个开源的机器学习工具库&#xff0c;专门用于构建和部署基于语言的应用程序。这个库提供了一系列工具和接口&#xff0c;使开发者能够轻松地整合和使用大型语言模型&#xff0c;例如 OpenAI 提供的 GPT。LangChain 的核心特点包括模块化设计、灵活性和易用性&…
阅读更多...
linnux文件服务

linnux文件服务

1.FTP:文件传输协议。 基础:控制端口(身份验证) command 21/tcp 数据端口: data 20/tcp FTP Server默认配置:yum -y install vsftpd (安装vsftpd&#xff09; touch /var/ftp/abc.txt(创建文件) systemctl start vsftpd(启动文件&#xff09; systemctl …
阅读更多...
osg渲染过程

osg渲染过程

目录 1、渲染最简单代码 2、详解run方法 3、详细过程 4、回调函数 5、Node Visitor 1、渲染最简单代码 2、详解run方法 3、详细过程 3.1 advance()方法 进行帧计数 3.2 eventTraversal() eventTraversal()响应用户操作,eventTraversal()遍历的是事件队列&#xff0c;而…
阅读更多...
java:多线程

java:多线程

多线程 在java程序中同时执行多个线程,每个线程独立执行不同的任务. 可以提高程序的性能和资源利用率,增加程序的并发性. 多线程的作用 1,提高程序性能 可以将一个任务分解成多个子任务并行处理,从而提高程序的运行速度 2,提高资源利用率 可以更好地利用CPU资源,提高CPU…
阅读更多...
【每日刷题】Day15

【每日刷题】Day15

【每日刷题】Day15 &#x1f955;个人主页&#xff1a;开敲&#x1f349; &#x1f525;所属专栏&#xff1a;每日刷题&#x1f34d; 目录 1. 141. 环形链表 - 力扣&#xff08;LeetCode&#xff09; 2. 142. 环形链表 II - 力扣&#xff08;LeetCode&#xff09; 3. 143. 重…
阅读更多...
基于Python的卷积网络的车牌识别系统，附源码

基于Python的卷积网络的车牌识别系统，附源码

博主介绍&#xff1a;✌程序员徐师兄、7年大厂程序员经历。全网粉丝12w、csdn博客专家、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域和毕业项目实战✌ &#x1f345;文末获取源码联系&#x1f345; &#x1f447;&#x1f3fb; 精彩专栏推荐订阅&#x1f447;…
阅读更多...
CST电磁仿真的点/线/面设置操作【入门基础】

CST电磁仿真的点/线/面设置操作【入门基础】

选择点/线/面 通过Pick功能选择点/线/面的方法 Modeling > Picks > Picks > Pick Points, Edges or Faces Pick是在模型上或任意空间中选择Point、Edge、Face的功能。利用Pick功能可以轻松获取模型的位置、尺寸等信息&#xff0c;也可以在执行Modeling和Result Han…
阅读更多...
Xxl-job执行器自动注册不上的问题

Xxl-job执行器自动注册不上的问题

今天新建的项目要部署xxl-job&#xff0c;之前部署过好多次&#xff0c;最近没怎么部署&#xff0c;生疏了。部署完之后&#xff0c;服务一直没有注册到执行器管理里面&#xff0c;找了半天也没找到原因&#xff0c;看数据库里的xxl_job_registry表也是一直有数据进来。 后来看…
阅读更多...
46.HarmonyOS鸿蒙系统 App(ArkUI)网格布局

46.HarmonyOS鸿蒙系统 App(ArkUI)网格布局

Grid(){GridItem(){Button(按钮1).fontSize(28)}.backgroundColor(Color.Blue)GridItem(){Text(数学).fontSize(28)}.backgroundColor(Color.Yellow)GridItem(){Text(语文).fontSize(28)}.backgroundColor(Color.Green)GridItem(){Text(英语).fontSize(28)}.backgroundColor(Co…
阅读更多...
数据结构（算法）

数据结构（算法）

总结&#xff0c;建议看EXCEL的《算法》页签&#xff0c;不然感觉有点乱 备注原理/步骤时间复杂度空间复杂度串的应用模式匹配简单/暴力O(mn)　KMP　　O(mn)　树的应用树哈夫曼树1、带权路径长度WPL 2、外部排序-最佳归并树1、哈夫曼树的度&#xff0c;只有0和m&#xff08;m叉…
阅读更多...
七月审稿之提升模型效果的三大要素：prompt、数据质量、训练策略(含Reviewer2和PeerRead)​

七月审稿之提升模型效果的三大要素：prompt、数据质量、训练策略(含Reviewer2和PeerRead)​

前言 我带队的整个大模型项目团队超过40人了&#xff0c;分六个项目组&#xff0c;每个项目组都是全职带兼职&#xff0c;且都会每周确定任务/目标/计划&#xff0c;然后各项目组各自做任务拆解&#xff0c;有时同组内任务多时 则2-4人一组 方便并行和讨论&#xff0c;每周文档…
阅读更多...
Normalizing Flows

Normalizing Flows

需要学的是神经网络 f f f, 用于完成从source distribution (Pz)&#xff08;latent space&#xff0c;一般为高斯分布&#xff09;到 target distribution (Px) 的映射。 Normalizing Flows 是一种强大的生成模型&#xff0c;它通过学习一个可逆且易于计算的转换来将复杂的概…
阅读更多...
（弟弟14）递归•按顺序打印一个整数的每一位

（弟弟14）递归•按顺序打印一个整数的每一位

这里是目录哦 题目代码运行截图递归思路递归停止条件如何实现“按顺序”悟了✨加油&#x1f389; 题目 按顺序打印一个整数的每一位。 代码 #include<stdio.h> void Print(int n) {if (n > 9)//递归停止条件{Print(n / 10);//不断趋近递归停止条件}printf("%d…
阅读更多...
代码随想录算法训练营Day56|LC583 两个字符串的删除操作LC72 编辑距离

代码随想录算法训练营Day56|LC583 两个字符串的删除操作LC72 编辑距离

一句话总结&#xff1a;看起来复杂&#xff0c;动规分析以后就比较简单。 原题链接&#xff1a;583 两个字符串的删除操作 本质就是求两个字符串的最短子序列的长度。已经做过&#xff0c;不再详解。 class Solution {public int minDistance(String word1, String word2) {/…
阅读更多...
一文读懂自动化运维工具ansible及其使用

一文读懂自动化运维工具ansible及其使用

1. ansible简介 ansible是干什么的 ansible是目前最受运维欢迎的自动化运维工具&#xff0c;基于Python开发&#xff0c;集合了众多运维工具&#xff08;SaltStack puppet、chef、func、fabric&#xff09;的优点&#xff0c;实现了批量系统配置、批量程序部署、批量运行命令…
阅读更多...
麒麟服务器操作系统安装HTTP服务

麒麟服务器操作系统安装HTTP服务

往期好文&#xff1a;麒麟服务器操作系统安装TFTP服务 Hello&#xff0c;大家好啊&#xff01;今天我们将探讨如何在麒麟服务器操作系统上安装和配置HTTP服务&#xff0c;这是任何网络服务或应用的基础。无论你是想建立一个简单的网站&#xff0c;还是需要一个全功能的Web服务器…
阅读更多...
wangzherongyao 2024.04.15

wangzherongyao 2024.04.15

第一局&#xff1a;百里陪那只重置技能CD的辅助&#xff0c;对面有兰陵王&#xff0c;妲己&#xff0c;然后我补位廉颇被自己人和对面一阵嘲讽&#xff0c;真的不想说啥&#xff0c;对面盾山和妲己估计都没明白&#xff0c;我一只就能破他们队伍&#xff0c;所以看到没先出魔抗…
阅读更多...
在Windows上配置VS Code GO语言开发环境

在Windows上配置VS Code GO语言开发环境

&#x1f49d;&#x1f49d;&#x1f49d;欢迎莅临我的博客&#xff0c;很高兴能够在这里和您见面&#xff01;希望您在这里可以感受到一份轻松愉快的氛围&#xff0c;不仅可以获得有趣的内容和知识&#xff0c;也可以畅所欲言、分享您的想法和见解。 推荐:「stormsha的主页」…
阅读更多...
最新文章

Copyright @ 2022~2023