UDP通信实现

2024-09-06 23:04
文章标签 实现 udp 通信

本文主要是介绍UDP通信实现,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

目录

前言

一、基础知识

1、跨主机传输

        1、字节序

         2、主机字节序和网络字节序

         3、IP转换

2、套接字

3、什么是UDP通信 

二、如何实现UDP通信 

        1、socket():创建套接字

        2、bind():绑定套接字 

         3、sendto():发送指定套接字文件数据

         4、recvfrom():接收指定地址信息的数据

 三、具体实现代码


前言

        在前面我们知道,在使用UDP通信是在传输层选择使用UDP协议,并且在传输层只有两个协议,分别是UDP和TCP协议,在本节中,我们就来学习如何实现UDP通信

一、基础知识

1、跨主机传输

        1、字节序

字节序:不同类型的CPU主机,内存存储多字节数据时的存在不同序列存储方式

        a、小端字节序(小端存储):低序字节存储在内存低地址上,高序字节存储在内存高地址上

        b、大端字节序(大端存储):低序字节存储在内存高地址上,高序字节存储在内存低地址上

        short、int、long 有字节序的概念

        char、float、字符串没有字节序的说法

如何查看电脑是大端存储还是小端存储

//查看电脑大端存储还是小端存储
#include<stdio.h>
int main(int argc, const char *argv[])
{int a=0x87654321;char *p=&a;printf("a=%#x\n",*p);return 0;
}

我的电脑输出的是a=0x21,说明是小段存储,其实大多数电脑都是小端存储

        

         2、主机字节序和网络字节序

  •         主机字节序:主机本身在计算机中存储多字节数据的方式(大端、小端:CPU)现目前电脑一般都是小端
  •         网络字节序:数据在网络中规定的传输方式,网络字节序使用大端字节序方式传输

        所以在跨主机传输过程中,需要使用统一的字节序,即网络字节序,避免兼容性问题

        主机字节序转换为网络字节序,便于传输:

#include <arpa/inet.h>uint32_t htonl(uint32_t hostlong);
功能:把 hostlong 主机字节序整型转换为网络字节序,返回值就是网络字节序整数uint16_t htons(uint16_t hostshort);
功能:把 hostshort 主机字节序短整型转换为网络字节序,返回值就是网络字节序短整数

        网络字节序转换为主机字节序,便于解析识别:

#include <arpa/inet.h>uint32_t ntohl(uint32_t netlong);
功能:把 netshort 网络字节序 整型 转换为主机存储的主机字节序,返回值就是 主机字节序整数uint16_t ntohs(uint16_t netshort);
功能:把 netshort 网络字节序短整型 转换为主机存储的主机字节序,返回值就是 主机字节序

         3、IP转换

        在主句传输数据时会对大于两个字节的数据进行网络字节序的转换,那么IP地址通常是大于两个字节的,也同样要进行IP转换

        IP地址整数转换为二进制网络字节序的IP地址 :

#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>in_addr_t inet_addr(const char *cp);
功能:将 ip地址字符串 转换为 IP地址整数(网络字节序IP地址)参数:const char *cp:要转换的 IP地址的点分十进制字符串首地址返回值:
成功,返回 转换后的 网络字节序的IP地址   typedef uint32_t in_addr_t; 

        IP地址的二进制网络字节序转换为IP地址的整数:

#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>char *inet_ntoa(struct in_addr in);
功能:把 IP地址转换为 点分十进制字符串格式参数:struct in_addr in:指定要转换的IP地址 的结构体类型,结构体中的成员为 IP地址类型:typedef uint32_t in_addr_t;struct in_addr {in_addr_t s_addr;//IP地址 网络字节序 整数};

2、套接字

        最早套接字和共享内存、消息队列、管道一样,只能实现一个主机内部的进程间通信,随着TCP/IP网络模型的引入,使得套接字能够支持不同主机之间的进程间通信,socket函数,创建一个套接字文件,可以在内核空间中创建两块缓冲区,用于发送数据,接收数据。也包含对应的TCP/IP协议规则

         使用socket()函数创建套接字文件

#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>int socket(int domain, int type, int protocol);
功能:创建socket套接字,用于网络通信参数:
参数1:int domain:地址族,协议族AF_UNIX, AF_LOCAL   Local communication              unix(7)AF_INET             IPv4 Internet protocols          ip(7)AF_INET6            IPv6 Internet protocols          ipv6(7)
参数2:int type:类型SOCK_STREAM:字节流套接字,流式套接字,默认使用TCP协议SOCK_DGRAM:数据报套接字,报式套接字,默认使用UDP协议SOCK_RAW:原始套接字,其协议需要在第三个参数中指定
参数3:int protocol:协议0:使用默认协议IPPROTO_TCPIPPROTO_UDP返回值:
成功,返回 套接字文件描述符(套接字)
失败,返回-1,设置errno

3、什么是UDP通信 

        根据传输层的协议不同,通信的实现、通信的方式也各不相同,是不同的方式完成通信

        传输层:TCP、UDP

        通信方式有两种:UDP通信 与 TCP通信

         UDP通信的步骤:

二、如何实现UDP通信 

        1、socket():创建套接字

#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>int socket(int domain, int type, int protocol);
功能:创建socket套接字,用于网络通信,在内核空间中创建套接字文件(有两个缓冲区:发送缓冲区、接收缓冲区),返回该套接字文件缓冲区的文件描述符参数:
参数1:int domain:地址族,协议族AF_UNIX, AF_LOCAL   Local communication              unix(7)AF_INET             IPv4 Internet protocols          ip(7)AF_INET6            IPv6 Internet protocols          ipv6(7)
参数2:int type:类型SOCK_STREAM:字节流套接字,流式套接字,默认使用TCP协议SOCK_DGRAM:数据报套接字,报式套接字,默认使用UDP协议SOCK_RAW:原始套接字,其协议需要在第三个参数中指定
参数3:int protocol:协议0:使用默认协议IPPROTO_TCPIPPROTO_UDP返回值:
成功,返回 套接字文件描述符(套接字)
失败,返回-1,设置errno

        2、bind():绑定套接字 

#include <sys/types.h>          /* See NOTES */
#include <sys/socket.h>int bind(int sockfd, const struct sockaddr *addr,
socklen_t addrlen);功能:绑定地址信息到指定的套接字文件描述符上,为套接字通信指定使用的IP、port参数:
参数1:int sockfd:指定要将地址信息绑定到哪个套接字上,套接字文件描述符
参数2:const struct sockaddr *addr:地址信息结构体的指针,通用的一个地址结构体,由于存在不同的地址族选择,所以地址的表示方式不一样,为了统一表示,所以参数为通用的地址信息结构体类型用来表示有一个地址信息结构体:通用结构体struct sockaddr {sa_family_t sa_family;char        sa_data[14];}真实的地址信息结构体需要根据地址族来指定不同的地址族有不同的地址信息结构体AF_INET地址族的地址信息结构体:struct sockaddr_in {sa_family_t    sin_family;//指定地址族,AF_INETin_port_t      sin_port;//端口号的网络字节序,2个字节struct in_addr sin_addr;//使用的ip地址的网络字节序(结构体类型)};struct in_addr {//ip地址的网络字节序结构体uint32_t       s_addr;//ip地址网络字节序};
参数3:           socklen_t addrlen:真实的地址信息结构体大小返回值:
成功,返回0
失败,返回-1,设置errno

         3、sendto():发送指定套接字文件数据

#include <sys/types.h>
#include <sys/socket.h>ssize_t sendto(int sockfd, const void *buf, size_t len, int flags,
const struct sockaddr *dest_addr, socklen_t addrlen);
功能:发送数据给指定的接收方,即当前进程套接字发送数据给指定的ip、port进程参数:
参数1:int sockfd:套接字,通信:使用指定的套接字描述符来发送数据(数据传入哪个套接字的缓冲区用于发送)
参数2:const void *buf:指定要发送的数据的首地址(把指定地址的数据进行发送)
参数3:size_t len:发送多少个字节
参数4:int flags:选项0:阻塞方式发送,当缓冲区满,阻塞等待,不继续执行MSG_DONTWAIT:非阻塞方式发送,当缓冲区满,不等待,返回错误失败
参数5:const struct sockaddr *dest_addr:地址信息结构体,指定将数据发送给谁(ip、port),填写对方的地址信息地址信息根据地址族不同,结构体信息内容不同如果:AF_INETAF_INET地址族的地址信息结构体:struct sockaddr_in {sa_family_t    sin_family;//指定地址族,AF_INETin_port_t      sin_port;//端口号的网络字节序,2个字节struct in_addr sin_addr;//使用的ip地址的网络字节序(结构体类型)};struct in_addr {//ip地址的网络字节序结构体uint32_t       s_addr;//ip地址网络字节序};
参数6:
socklen_t addrlen:真实的地址信息结构体的大小返回值:
成功,返回发送的字节数
失败,返回-1,设置errno                                                

         4、recvfrom():接收指定地址信息的数据

#include <sys/types.h>
#include <sys/socket.h>ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags,struct sockaddr *src_addr, socklen_t *addrlen);
功能:接收数据包,同时可以接收到数据包从哪里来(额可以获取发送方的地址信息)参数:
参数1:int sockfd:通信使用的套接字文件描述符,指定获取哪个套接字的数据(对方发送发送到ip、port的套接字缓冲区)
参数2:void *buf:存储读取到的数据,接收的数据存储的地址
参数3:size_t len:要读取多少个字节
参数4:int flags:选项   0:阻塞方式接收,当缓冲区为空,没有接收到数据时,阻塞等待,不继续执行MSG_DONTWAIT:非阻塞方式接收,当缓冲区为空(没有数据),不等待,返回错误失败 
参数5:struct sockaddr *src_addr:地址信息结构体,不同的地址族地址信息结构体不同,不同的地址族使用对应的结构体来存储,发送方的地址信息如果不想知道发送方的地址信息,则填NULL
参数6:socklen_t *addrlen:地址信息结构体的大小,指针对应空间存储如果不想获取,则填NULL返回值:
成功,返回收到的字节数     
失败,返回-1,设置错误码           

 三、具体实现代码

         在实现通信之前,我们使用下面网络调试助手来进行通信传输

通过网盘分享的文件:scomm.exe
链接: https://pan.baidu.com/s/1OkiZLT_CeoryEZepaOSGqQ 提取码: 8a85

 首先,更改下面的代码

#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <string.h>
#include <pthread.h>#define PORT 20000
#define DEST_PORT 10000
#define DEST_IP "192.168.124.29"
#define BUF_SIZE 128int sockfd;
struct sockaddr_in destaddr;void *send_thread(void *arg) {char buf[BUF_SIZE];while (1) {bzero(buf, BUF_SIZE);fgets(buf, BUF_SIZE, stdin);sendto(sockfd, buf, strlen(buf), 0, (struct sockaddr*)&destaddr, sizeof(struct sockaddr_in));}return NULL;
}void *recv_thread(void *arg) {char buf[BUF_SIZE];while (1) {struct sockaddr_in rcv_addr;socklen_t rcv_addr_len = sizeof(rcv_addr);int size = recvfrom(sockfd, buf, BUF_SIZE - 1, 0, (struct sockaddr*)&rcv_addr, &rcv_addr_len);if (size > 0) {buf[size] = '\0';printf("Received: %s\n", buf);}}return NULL;
}int main(int argc, const char *argv[]) {// 创建套接字,使用UDP通信sockfd = socket(AF_INET, SOCK_DGRAM, 0);if (sockfd < 0) {perror("socket creation failed");return -1;}// 绑定套接字struct sockaddr_in udpaddr;udpaddr.sin_family = AF_INET;udpaddr.sin_port = htons(PORT);udpaddr.sin_addr.s_addr = INADDR_ANY;if (bind(sockfd, (struct sockaddr*)&udpaddr, sizeof(struct sockaddr_in)) < 0) {perror("bind failed");close(sockfd);return -1;}// 设置对方的信息destaddr.sin_family = AF_INET;destaddr.sin_port = htons(DEST_PORT);destaddr.sin_addr.s_addr = inet_addr(DEST_IP);// 创建发送和接收线程pthread_t send_tid, recv_tid;pthread_create(&send_tid, NULL, send_thread, NULL);pthread_create(&recv_tid, NULL, recv_thread, NULL);// 等待线程完成pthread_join(send_tid, NULL);pthread_join(recv_tid, NULL);// 关闭套接字close(sockfd);return 0;
}

 但是代码中的IP地址要更改

更改步骤:

1、将下面的DEST_IP改为打开网络调试助手的IP地址,

        如何查找打开的网络调试助手的代码和端口

在这里查看网络端口和接收端的IP地址,每个人的不一样,因此要读者自己去设置

这篇关于UDP通信实现的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

C++中unordered_set哈希集合的实现

《C++中unordered_set哈希集合的实现》std::unordered_set是C++标准库中的无序关联容器,基于哈希表实现,具有元素唯一性和无序性特点,本文就来详细的介绍一下unorder... 目录一、概述二、头文件与命名空间三、常用方法与示例1. 构造与析构2. 迭代器与遍历3. 容量相关4

C++中悬垂引用(Dangling Reference) 的实现

《C++中悬垂引用(DanglingReference)的实现》C++中的悬垂引用指引用绑定的对象被销毁后引用仍存在的情况,会导致访问无效内存,下面就来详细的介绍一下产生的原因以及如何避免,感兴趣... 目录悬垂引用的产生原因1. 引用绑定到局部变量,变量超出作用域后销毁2. 引用绑定到动态分配的对象,对象

SpringBoot基于注解实现数据库字段回填的完整方案

《SpringBoot基于注解实现数据库字段回填的完整方案》这篇文章主要为大家详细介绍了SpringBoot如何基于注解实现数据库字段回填的相关方法,文中的示例代码讲解详细,感兴趣的小伙伴可以了解... 目录数据库表pom.XMLRelationFieldRelationFieldMapping基础的一些代

Java HashMap的底层实现原理深度解析

《JavaHashMap的底层实现原理深度解析》HashMap基于数组+链表+红黑树结构,通过哈希算法和扩容机制优化性能,负载因子与树化阈值平衡效率,是Java开发必备的高效数据结构,本文给大家介绍... 目录一、概述:HashMap的宏观结构二、核心数据结构解析1. 数组(桶数组)2. 链表节点(Node

Java AOP面向切面编程的概念和实现方式

《JavaAOP面向切面编程的概念和实现方式》AOP是面向切面编程,通过动态代理将横切关注点(如日志、事务)与核心业务逻辑分离,提升代码复用性和可维护性,本文给大家介绍JavaAOP面向切面编程的概... 目录一、AOP 是什么?二、AOP 的核心概念与实现方式核心概念实现方式三、Spring AOP 的关

Python实现字典转字符串的五种方法

《Python实现字典转字符串的五种方法》本文介绍了在Python中如何将字典数据结构转换为字符串格式的多种方法,首先可以通过内置的str()函数进行简单转换;其次利用ison.dumps()函数能够... 目录1、使用json模块的dumps方法:2、使用str方法:3、使用循环和字符串拼接:4、使用字符

Linux下利用select实现串口数据读取过程

《Linux下利用select实现串口数据读取过程》文章介绍Linux中使用select、poll或epoll实现串口数据读取,通过I/O多路复用机制在数据到达时触发读取,避免持续轮询,示例代码展示设... 目录示例代码(使用select实现)代码解释总结在 linux 系统里,我们可以借助 select、

Linux挂载linux/Windows共享目录实现方式

《Linux挂载linux/Windows共享目录实现方式》:本文主要介绍Linux挂载linux/Windows共享目录实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录文件共享协议linux环境作为服务端(NFS)在服务器端安装 NFS创建要共享的目录修改 NFS 配

通过React实现页面的无限滚动效果

《通过React实现页面的无限滚动效果》今天我们来聊聊无限滚动这个现代Web开发中不可或缺的技术,无论你是刷微博、逛知乎还是看脚本,无限滚动都已经渗透到我们日常的浏览体验中,那么,如何优雅地实现它呢?... 目录1. 早期的解决方案2. 交叉观察者:IntersectionObserver2.1 Inter

Spring Gateway动态路由实现方案

《SpringGateway动态路由实现方案》本文主要介绍了SpringGateway动态路由实现方案,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随... 目录前沿何为路由RouteDefinitionRouteLocator工作流程动态路由实现尾巴前沿S