嵌入式学习——Linux高级编程复习(UDP编程)——day43

news2024/11/25 4:33:12

1. UDP编程——函数接口

1.1 socket

        1. 定义

              int socket(int domain, int type, int protocol);

        2. 功能

                创建一个用来进程通信的套接字,返回文件描述符

        3. 参数

                domain:AF_INET           IPv4协议族
                type:SOCK_STREAM    流式套接字            tcp传输协议
                        SOCK_DGRAM    数据报套接字            udp传输协议
                        SOCK_RAW        原始套接字            
                protocol:
                        默认为0 

        4. 返回值

                成功返回套接字新文件描述符
                失败返回-1 

        5. 注意

1.2 inet_addr

        1. 定义

              in_addr_t inet_addr(const char *cp);

        2. 功能

                将字符串IP地址转换为二进制IP地址 

        3. 参数

                cp:字符串IP地址空间首地址

        4. 返回值

                成功返回二进制IP地址

        5. 注意

1.3 htons

        1. 定义

              uint16_t htons(uint16_t hostshort);

        2. 功能

                将本地字节序(小端)转换为网络字节序(大端)

        3. 参数

                hostshort:本地端口号

        4. 返回值

                返回网络字节序端口号

        

      uint16_t ntohs(uint16_t netshort);
      功能:
        将网络字节序(大端)转换为本地字节序(小端)

1.4 bind

        1. 定义

              int bind(int sockfd, const struct sockaddr *addr,
                        socklen_t addrlen);

        2. 功能

                将套接字与IP地址端口绑定在一起

        3. 参数

                sockfd:文件描述符 
                addr:结构体空间首地址 
                addrlen:信息的长度

        4. 返回值

                成功返回0 
                失败返回-1 

        5. 注意

1.5 sendto

        1. 定义

              ssize_t sendto(int sockfd, const void *buf, size_t len, int flags,
                              const struct sockaddr *dest_addr, socklen_t addrlen);

        2. 功能

                给另一个套接字发送消息

        3. 参数

                sockfd:套接字文件描述符
                buf:要发送数据存放空间的首地址
                len:要发送数据的长度
                flags:发送属性  默认为0 
                dest_addr:目的地址
                addrlen:目的地址信息长度

    struct sockaddr_in {
       sa_family_t    sin_family; /* address family: AF_INET */(协议族)
       in_port_t      sin_port;   /* port in network byte order */(端口号、小端存储要改成大端存储)
       struct in_addr sin_addr;   /* internet address */(IP地址)
   };

   /* Internet address. */
   struct in_addr {
       uint32_t       s_addr;     /* address in network byte order */
   };

        4. 返回值

                成功返回发送字节个数
                失败返回-1 

1.6 recvfrom

        1. 定义

              ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags,
                                struct sockaddr *src_addr, socklen_t *addrlen);

        2. 功能

                接收数据

        3. 参数

                sockfd:套接字文件描述符
                buf:存放接收到数据空间的首地址
                len:最多允许接收的字节数
                flags:属性 默认为0 
                src_addr:存放发送端地址信息空间首地址
                addrlen:想要接收发送端地址大小的变量空间首地址

        4. 返回值

                成功返回实际接收字节数
                失败返回-1 

        5. 注意

                该函数具有阻塞功能

2. UDP编程示例程序

2.1 单方向收发

        1. 头文件

#ifndef __HEAD_H__
#define __HEAD_H__

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/socket.h>
#include <netinet/ip.h>
#include <netinet/in.h>
#include <arpa/inet.h>

#endif

        2.发送端代码(send.c)

#include "head.h"

int main(int argc, char const *argv[])
{
	int sockfd = 0;
	char tmpbuff[1024] = {"hello world"};
	struct sockaddr_in recvaddr;
	ssize_t nsize = 0;

	sockfd = socket(AF_INET, SOCK_DGRAM, 0);
	if (-1 == sockfd)
	{
		perror("fail to socket");
		return -1;
	}

	recvaddr.sin_family = AF_INET;
	recvaddr.sin_port = htons(50000);
	recvaddr.sin_addr.s_addr = INADDR_ANY;
	nsize = sendto(sockfd, tmpbuff, strlen(tmpbuff)+1, 0, (struct sockaddr *)&recvaddr, sizeof(recvaddr));
	if (-1 == nsize)
	{
		perror("fail to sendto");
		return -1;
	}

	printf("send %ld bytes success\n", nsize);

	close(sockfd);

	return 0;
}

        3. 接收端代码(recv.c)

#include "head.h"

int main(int argc, char const *argv[])
{
	int sockfd = 0;
	int ret = 0;
	ssize_t nsize = 0;
	char tmpbuff[4096] = {0};
	struct sockaddr_in recvaddr;

	sockfd = socket(AF_INET, SOCK_DGRAM, 0);
	if (-1 == sockfd)
	{
		perror("fail to socket");
		return -1;
	}

	recvaddr.sin_family = AF_INET;
	recvaddr.sin_port = htons(50000);
	recvaddr.sin_addr.s_addr = INADDR_ANY;
	ret = bind(sockfd, (struct sockaddr *)&recvaddr, sizeof(recvaddr));
	if (-1 == ret)
	{
		perror("fail to bind");
		return -1;
	}

	nsize = recvfrom(sockfd, tmpbuff, sizeof(tmpbuff), 0, NULL, NULL);
	if (-1 == nsize)
	{
		perror("fail to recvfrom");
		return -1;
	}

	printf("recv %ld bytes success\n", nsize);
	printf("RECV:%s\n", tmpbuff);

	close(sockfd);

	return 0;
}

2.2 双向通信

        1. 头文件

#ifndef __HEAD_H__
#define __HEAD_H__

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/socket.h>
#include <netinet/ip.h>
#include <netinet/in.h>
#include <arpa/inet.h>

#endif

        2.发送端代码(send.c)

#include "head.h"

int main(int argc, char const *argv[])
{
	int sockfd = 0;
	char tmpbuff[4096] = {"你在吗?"};
	struct sockaddr_in recvaddr;
	ssize_t nsize = 0;

	sockfd = socket(AF_INET, SOCK_DGRAM, 0);
	if (-1 == sockfd)
	{
		perror("fail to socket");
		return -1;
	}	

	recvaddr.sin_family = AF_INET;
	recvaddr.sin_port = htons(50000);
	recvaddr.sin_addr.s_addr = INADDR_ANY;
	nsize = sendto(sockfd, tmpbuff, strlen(tmpbuff)+1, 0, (struct sockaddr *)&recvaddr, sizeof(recvaddr));
	if (-1 == nsize)
	{
		perror("fail to sendto");
		return -1;
	}

	memset(tmpbuff, 0, sizeof(tmpbuff));
	nsize = recvfrom(sockfd, tmpbuff, sizeof(tmpbuff), 0, NULL, NULL);
	if (-1 == nsize)
	{
		perror("fail to recvfrom");
		return -1;
	}

	printf("RECV:%s\n", tmpbuff);

	close(sockfd);

	return 0;
}

        3. 接收端代码(recv.c)

#include "head.h"

int main(int argc, char const *argv[])
{
	int sockfd = 0;
	int ret = 0;
	struct sockaddr_in recvaddr;
	struct sockaddr_in sendaddr;
	char tmpbuff[4096] = {0};
	ssize_t nsize = 0;
	socklen_t addrlen = sizeof(sendaddr);

	sockfd = socket(AF_INET, SOCK_DGRAM, 0);
	if (-1 == sockfd)
	{
		perror("fail to socket");
		return -1;
	}	

	recvaddr.sin_family = AF_INET;
	recvaddr.sin_port = htons(50000);
	recvaddr.sin_addr.s_addr = INADDR_ANY;
	ret = bind(sockfd, (struct sockaddr *)&recvaddr, sizeof(recvaddr));
	if (-1 == ret)
	{
		perror("fail to bind");
		return -1;
	}

	nsize = recvfrom(sockfd, tmpbuff, sizeof(tmpbuff), 0, (struct sockaddr *)&sendaddr, &addrlen);
	if (-1 == nsize)
	{
		perror("fail to recvfrom");
		return -1;
	}

	printf("[%s:%d]%s\n", inet_ntoa(sendaddr.sin_addr), ntohs(sendaddr.sin_port), tmpbuff);

	sprintf(tmpbuff, "%s --------echo", tmpbuff);
	nsize = sendto(sockfd, tmpbuff, strlen(tmpbuff), 0, (struct sockaddr *)&sendaddr, sizeof(sendaddr));
	if (-1 == nsize)
	{
		perror("fail to sendto");
		return -1;
	}

	close(sockfd);

	return 0;
}

2.3 使用UDP进行文件复制(CP)

        1.服务端

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <arpa/inet.h>
#include <string.h>
#include <time.h>
#include <fcntl.h>

typedef struct sockaddr * (SA);

int main(int argc, char *argv[])
{
    int sockfd = socket(AF_INET,SOCK_DGRAM,0);
    if(-1 == sockfd)
    {
        perror("socket");
        exit(1);
    }
    struct sockaddr_in ser,cli;
    //man 7 ip 
   bzero(&ser,sizeof(ser)); 
   bzero(&cli,sizeof(ser));
   ser.sin_family = AF_INET;
   ser.sin_port  = htons(50000);//host to net  short 
   ser.sin_addr.s_addr = INADDR_ANY ;//inet_addr("127.0.0.1")
    int ret = bind(sockfd,(SA)&ser,sizeof(ser));
    if(-1 == ret)
    {
        perror("bind");
        exit(1);
    }
    int fd = open("2.png",O_CREAT|O_WRONLY|O_TRUNC,0666);
    if(-1 == fd)
    {
        perror("open");
        exit(1);
    }
    while(1)
    {
        char buf[1024]={0};
        socklen_t len = sizeof(cli);
        int rd_ret = recvfrom(sockfd,buf,sizeof(buf),0,(SA)&cli,&len);
        if(0 == strcmp(buf,"^_^"))
        {
            break;
        }
        write(fd,buf,rd_ret);
        bzero(buf,sizeof(buf));
        strcpy(buf,"go on");
        sendto(sockfd,buf,strlen(buf),0,(SA)&cli,sizeof(cli));
    }
    close(fd);
    close(sockfd);
    return 0;
}

        2. 客户端

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <arpa/inet.h>
#include <string.h>
#include <fcntl.h>

typedef struct sockaddr * (SA);
int main(int argc, char *argv[])
{
    int sockfd = socket(AF_INET,SOCK_DGRAM,0);
    if(-1 == sockfd)
    {
        perror("socket");
        exit(1);
    }
    struct sockaddr_in ser,cli;
    //man 7 ip 
    bzero(&ser,sizeof(ser)); 
    bzero(&cli,sizeof(ser));
    ser.sin_family = AF_INET;
    ser.sin_port = htons(50000);//host to net  short 
    ser.sin_addr.s_addr = INADDR_ANY;
    int fd = open("/home/linux/1.png",O_RDONLY);
    if(-1 == fd)
    {
        perror("open");
        exit(1);
    }
    char buf[1024]={0};
        socklen_t len = sizeof(ser);
    while(1)
    {
        bzero(buf,sizeof(buf));
        int rd_ret = read(fd,buf,sizeof(buf));
        if(rd_ret<=0)
        {
            break;
        }
        sendto(sockfd,buf,rd_ret,0,(SA)&ser,len);
        bzero(buf,sizeof(buf));
        recvfrom(sockfd,buf,sizeof(buf),0,NULL,NULL);
    }

    strcpy(buf,"^_^");
    sendto(sockfd,buf,strlen(buf),0,(SA)&ser,len);
    close(fd);
    close(sockfd);
    return 0;
}

2.4 使用UDP进行两端聊天(chat)

        1. 服务端

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <arpa/inet.h>
#include <string.h>
#include <time.h>
#include <pthread.h>

typedef struct sockaddr * (SA);

struct sockaddr_in ser,cli;

void* th1(void* arg)
{
    int sockfd =* (int*)arg;
    while(1)
    {
        char buf[256]={0};
        socklen_t len = sizeof(cli);
        recvfrom(sockfd,buf,sizeof(buf),0,NULL,NULL);
        printf("from c:%s\n",buf);

    }

}

void* th2(void* arg)
{
    int sockfd =* (int*)arg;
    while(1)
    {
    
        printf("to c:");
        char buf[256]={0};
        fgets(buf,sizeof(buf),stdin);
        buf[strlen(buf)-1]='\0';
        sendto(sockfd,buf,strlen(buf),0,(SA)&cli,sizeof(cli));
    
    }

}

int main(int argc, char *argv[])
{
    int sockfd = socket(AF_INET,SOCK_DGRAM,0);
    if(-1 == sockfd)
    {
        perror("socket");
        exit(1);
    }
    //man 7 ip 
   bzero(&ser,sizeof(ser)); 
   bzero(&cli,sizeof(ser));
   ser.sin_family = AF_INET;
   ser.sin_port  = htons(50000);//host to net  short 
   ser.sin_addr.s_addr = INADDR_ANY;
    int ret = bind(sockfd,(SA)&ser,sizeof(ser));
    if(-1 == ret)
    {
        perror("bind");
        exit(1);
    }
    pthread_t tid1,tid2;
    socklen_t len = sizeof(cli);
    char buf[256]={0};
    recvfrom(sockfd,buf,sizeof(buf),0,(SA)&cli,&len);
    pthread_create(&tid1,NULL,th1,&sockfd);
    pthread_create(&tid2,NULL,th2,&sockfd);

    pthread_join(tid1,NULL);
    pthread_join(tid2,NULL);
    return 0;
}

        2. 客户端

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <arpa/inet.h>
#include <string.h>
#include <pthread.h>


typedef struct sockaddr * (SA);


struct sockaddr_in ser,cli;
void* th1(void* arg)
{
    int sockfd =* (int*)arg;
    while(1)
    {
        char buf[256]={0};
        socklen_t len = sizeof(cli);
        recvfrom(sockfd,buf,sizeof(buf),0,NULL,NULL);
        printf("from s:%s\n",buf);

    }

}
void* th2(void* arg)
{
    int sockfd =* (int*)arg;
    while(1)
    {
    
        printf("to s");
        char buf[256]={0};
        fgets(buf,sizeof(buf),stdin);
        buf[strlen(buf)-1]='\0';
        sendto(sockfd,buf,strlen(buf),0,(SA)&ser,sizeof(ser));
    
    }

}
int main(int argc, char *argv[])
{
    int sockfd = socket(AF_INET,SOCK_DGRAM,0);
    if(-1 == sockfd)
    {
        perror("socket");
        exit(1);
    }
    //man 7 ip 
    bzero(&ser,sizeof(ser)); 
    bzero(&cli,sizeof(ser));
    ser.sin_family = AF_INET;
    ser.sin_port  = htons(50000);//host to net  short 
    ser.sin_addr.s_addr = INADDR_ANY; 
    pthread_t tid1,tid2;
    char buf[256]="start";
    sendto(sockfd,buf,strlen(buf),0,(SA)&ser,sizeof(ser));
    pthread_create(&tid1,NULL,th1,&sockfd);
    pthread_create(&tid2,NULL,th2,&sockfd);

    pthread_join(tid1,NULL);
    pthread_join(tid2,NULL);

    return 0;
}

3. UDP特性
    1.实现简单
    2.占用资源较小
    3.不安全、不可靠

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

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

相关文章

MYSQL八、MYSQL的SQL优化

一、SQL优化 sql优化是指&#xff1a;通过对sql语句和数据库结构的调整&#xff0c;来提高数据库查询、插入、更新和删除等操作的性能和效率。 1、插入数据优化 要一次性往数据库表中插入多条记录&#xff1a; insert into tb_test values(1,tom); insert into tb_tes…

Day52 代码随想录打卡|二叉树篇---二叉搜索树中的众数

题目&#xff08;leecode T501&#xff09;&#xff1a; 给你一个含重复值的二叉搜索树&#xff08;BST&#xff09;的根节点 root &#xff0c;找出并返回 BST 中的所有 众数&#xff08;即&#xff0c;出现频率最高的元素&#xff09;。 如果树中有不止一个众数&#xff0c…

Radis初阶 Radis基本命令与在Springboot中访问Radis

阿里网盘链接 文章目录 初始NoSQL数据库对比MySQL数据库从结构方面&#xff1a;从关系方面&#xff1a;从查询方式&#xff1a;从事物方面&#xff1a; Redis入门Redis数据结构访问Radis通用命令&#xff08;tab键&#xff1a;自动补全&#xff09;KEYSDELEXISTSEXPIRETTL Str…

硬件SPI读写W25Q64

硬件SPI读写W25Q64 接线图&#xff08;和软件SPI一样&#xff09; 使用SPI1&#xff0c;SCK&#xff0c;接PA5&#xff1b;MISO&#xff0c;接PA6&#xff1b;MOSI&#xff0c;接PA7&#xff1b;NSS&#xff0c;可接PA4。 接线图对应&#xff1a;PA5接CLK引脚&#xff0c;PA6…

军事武器3D数字化交互展示创作平台大大降低成本

军事力量和装备是一个国家国防安全的重要支柱&#xff0c;这在全球范围内得到广泛认同&#xff0c;为了让入伍的新兵能快速熟悉和掌握武器装备操作流程&#xff0c;基于创新型的华锐3D云展平台工具&#xff0c;搭建的3D军事武器展示搭建编辑器&#xff0c;让部队的军事武器展示…

Apollo9.0 PNC源码学习之Control模块(一)—— 控制模块概览

0 前言 从planning的角度看control&#xff0c;首先需要了解的就是相关的数据接口&#xff0c;规划出的轨迹&#xff08;路径速度&#xff09;发给Control模块去执行 modules/planning/planning_component/planning_component.cc planning模块发布轨迹信息 planning_writer_ …

程序员基本功之git的使用

阿里网盘-资料链接 文章目录 git分布式版本控制工具git的基本概念开发过程中的问题常见的版本控制工具git分布式版本控制工具特点git系统所定制的若干目标git的工作流程图 GIT的安装和常用命令**创建本地git仓库步骤****本地git仓库的使用**git log详解 git分布式版本控制工具…

大模型系列:Prompt提示工程常用技巧和实践

前言 Prompt提示语是使用大模型解决实际问题的最直接的方式&#xff0c;本篇介绍Prompt提示工程常用的技巧&#xff0c;包括Zero-Shot、Few-Shot、CoT思维链、Least-to-Most任务分解。 内容摘要 Prompt提示工程简述Prompt的一般结构介绍零样本提示Zero-Shot少样本提示Few-Sho…

Ubuntu 18.04下普通用户的一次提权过程

Ubuntu 18.04下普通用户的一次提权过程 一.背景介绍:二.主要调试过程:三.相关命令:1.设置BMC密码,获取BMC IP2.找一台ubuntu搭建TFTP服务,用来替换grub.cfg文件3.从调试服务器的/boot/grub/grub.cfg中提取出recovery mode的配置,简化并生成新的配置文件grub.cfg,放在tftp服务的…

从零开始学习RecyclerView

1、实现最简单的一个控件列表 <?xml version"1.0" encoding"utf-8"?> <LinearLayout xmlns:android"http://schemas.android.com/apk/res/android"xmlns:tools"http://schemas.android.com/tools"android:layout_width&qu…

Maven常用命令介绍(Ⅰ)

基本命令 Maven生命周期 Maven的生命周期是对所有的构建过程进行抽象和统一。Maven的生命周期是抽象的&#xff0c;这意味着生命周期本身不做任何实际的工作&#xff0c;生命周期只是定义了一系列的阶段&#xff0c;并确定这些阶段的执行顺序。而在执行这些阶段时&#xff0c;…

08 SpringBoot 自定定义配置

SpringBoot自定义配置有三种方式&#xff1a; 使用PropertySource进行自定义配置 使用ImportResource进行自定义配置 使用Configuration进行自定义配置 PropertySource ​ 如果将所有的配置都集中到 application.properties 或 application.yml 中&#xff0c;那么这个配置文…

秋招突击——第四弹——Java的SSN框架快速入门——Maven

文章目录 引言Maven分模块开发与设计分模块开发的过程 依赖管理可选依赖与排除依赖 继承与聚合聚合继承 属性和版本管理属性扩大集中管理的范围版本管理 多环境开发多环境开发 私服简介安装私服资源操作流程分析上传和下载 总结 引言 前一个部分花了太多时间&#xff0c;后续得…

音视频集式流媒体边缘分布式集群拉流管理

一直以来&#xff0c;由于srs zlm等开源软件采用传统直播协议&#xff0c;即使后面实现了webrtc转发&#xff0c;由于信令交互较弱&#xff0c;使得传统的安防监控方案需要在公网云平台上部署大型流媒体服务器&#xff0c;而且节点资源不能统一管理调度&#xff0c;缺乏灵活性和…

链表经典题目:环形链表问题(LeetCode141.环形链表、LeetCode142.环形链表Ⅱ)

&#x1f4c7;文章目录 &#x1f4dc; LeetCode141. 环形链表&#x1f536;题目描述&#x1f537;思路分析✔️代码实现 &#x1f4dc; LeetCode142.环形链表Ⅱ&#x1f536;题目描述&#x1f537;思路①✔️代码实现&#x1f537;思路② &#x1f4d2;总结 &#x1f4dc; Leet…

父亲节马上到了-和我一起用Python写父亲节的祝福吧

前言 让我们一起用Python写一段父亲节的祝福吧 &#x1f4dd;个人主页→数据挖掘博主ZTLJQ的主页 个人推荐python学习系列&#xff1a; ☄️爬虫JS逆向系列专栏 - 爬虫逆向教学 ☄️python系列专栏 - 从零开始学python 话不多说先上代码 import tkinter as tk from doctest imp…

【GD32F303红枫派使用手册】第十六节 USART-DMA串口收发实验

16.1 实验内容 通过本实验主要学习以下内容&#xff1a; 串口DMA工作原理 使用DMA进行串口收发 16.2 实验原理 16.2.1 串口DMA工作原理 在前面ADC章节中&#xff0c;我们介绍了DMA的工作原理&#xff0c;这里就不多做介绍。从GD32F303用户手册中可以查到&#xff0c;各串…

CrossOver 2024软件安装包下载

CrossOver不像Parallels或VMware的模拟器&#xff0c;而是实实在在Mac OS X系统上运行的一个软件。CrossOvers能够直接在Mac上运行Windows软件与游戏&#xff0c;而不需虚拟机。它为Windows软件提供所需的资源&#xff0c;以达到在Mac OS X系统上运行Windows程序的目的。 安 装…

Android屏幕旋转流程(1)

&#xff08;1&#xff09;Gsensor的注册和监听 App -->I2C过程&#xff1a;App通过SensorManager.getSystemServer调用到SystemSensorManager&#xff0c;SystemSensorManager通过jni调用到SensorManager.cpp&#xff0c;后通过binder调用到SensorService。SensorService通…

使用Python和TCN进行时间序列预测:一个完整的实战示例

使用Python和TCN进行时间序列预测&#xff1a;一个完整的实战示例 时间卷积网络&#xff08;TCN&#xff09;已被证明在处理序列数据方面表现出色&#xff0c;尤其是在需要捕获长期依赖关系的任务中。在本文中&#xff0c;我们将通过一个简单的例子&#xff0c;展示如何使用Py…