C++开发UDP通信：使用socket创建UDP服务器端和客户端

news/2024/5/18 13:01:22 标签: udp, c++, 网络

我的主页视频讲解

博客不经常在线，私信请到西瓜视频搜索“智能之心”，以智能之心赴智能之梦。

UDP通信步骤

引用UDP通信步骤
一、UDP套接字服务端架构步骤
1． //初始化套接字环境WSAStartup
2． //初始化地址和端口
3． //创建UDP套接字socket
4． //绑定端口bind
5． //用recvfrom接收数据
6． //用sendto发送数据
7． //退出或者返回第5步继续 二、UDP客户端架构步骤
1． //初始化套接字环境WSAStartup
2． //初始化地址和端口
3． //创建UDP套接字socket
4． //用sendto发送数据
5． //用recvfrom接收数据

UDP Socket

引用UDP Socket
UDP Socket网络编程的API不多，socket()用于创建套接字，close()用于关闭套接字，sendto()用于发送数据，recvfrom()用于接收数据。

bind()顾名思义是绑定，TCP可以绑定，UDP也可以，bind用于UDP等于告诉内核：这个套接字跟网络远端的一个对子关联上了。以后就可以直接调用send()往那个标识的主机上的进程发送UDP数据报了。
而没有bind之前，只能通过sendto()接口(通过参数指定目的地)。UDP套接字recv()返回的是UDP数据报的数据部分(Payload)，不包括UDP数据报首部，这是因为UDP首部的字段用于分发或者校验，不需要透传给应用程序。
在这里插入图片描述

每个函数含义

int socket(int domain, int type, int protocol)
  • domain：指明了协议族/域，通常 AF_INET, AF_INET6, AF_LOCAL;
  • type：套接口类型，主要 SOCK_STREAM(TCP), SOCK_DGRAM(UDP), SOCK_RAW(原始socket);
  • protocol：一般取为0。成功时，返回一个小的非负整数值，与文件描述符类似;
  • return：成功0; 失败-1;
int bind(int sockfd, const struct sockaddr* my_addr, socklen_t addrlen);

bind 功能是把一个本地协议地址赋予一个套接字，告知内核去选择该IP地址。

  • sockfd: 套接字实例;
  • my_addr：指向 sockaddr 结构体类型的指针;
  • addrlen：表示 my_addr 结构的长度，用 sizeof 操作符获取;
  • return：成功0; 失败-1;
ssize_t sendto(int sockfd, const void *buf, size_t len, int flags,
			   const struct sockaddr *dest_addr, socklen_t addrlen);
  • sockfd: 正在监听端口的套接口实例;
  • buf：要发送的数组;
  • len: 要发送的数组的字节大小;
  • flags: 填0即可;
  • dest_addr: 指定数据要发送到哪个主机，哪个进程;
  • addrlen: 表示 dest_addr 所指向内容的长度;
  • return：成功: 数据长度; 失败: -1;
ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags,
                 struct sockaddr *src_addr, socklen_t *addrlen);
  • sockfd: 正在监听端口的套接口实例;
  • buf: 要接收的数组;
  • len: 要接收的数组的字节大小;
  • flags: 填0即可;
  • src_addr: 获取接收的数据是从哪个主机地址发来的;
  • addrlen: 表示 src_addr 所指向内容的长度;
  • 返回值: 成功: 数据长度; 失败: -1;
int connect(int soctfd, const struct sockaddr * addr, int addrlen);

connect 功能是用于建立与指定socket的连接，可用可不用。

  • soctfd：标识一个未连接socket;
  • addr：指向要连接套接字的sockaddr结构体的指针;
  • addrlen：sockaddr结构体的字节长度;
  • return：成功0; 失败-1;
    a. 硬错：端口号错误，服务器进程未开启，收到RST，立刻返回ECONNREFUSED;
    b. 软错：IP不可达，协议ICMP，比如 no route to host，通常是发送arp请求无响应;

小工具使用

// 打印ip和port
std::printf("接收到一个连接, 其ip: %s, port: %d\n", inet_ntoa(m_RemoteAddress.sin_addr), ntohs(m_RemoteAddress.sin_port));

// 将ip转格式到sin_addr
inet_pton(AF_INET, ip, &m_RemoteAddress.sin_addr);

cpp_UDP

一、cpp_UDP客户端

#include <winsock2.h>
#include <WS2tcpip.h>
#include <iostream>

using namespace  std;

//添加动态库的lib
#pragma comment(lib, "ws2_32.lib")

int main() {
	SOCKET m_Socket;
	SOCKADDR_IN m_RemoteAddress; //远程地址
	int m_RemoteAddressLen;

	// socket环境
	WSADATA  wsaData;
	if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) {
		cout << "WSAStartup error:" << GetLastError() << endl;
		return false;
	}

	// socket对象
	m_Socket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
	if (m_Socket == INVALID_SOCKET)
	{
		closesocket(m_Socket);
		m_Socket = INVALID_SOCKET;
		return false;
	}

	// 远端地址
	const char* ip = "127.0.0.1";
	int	port = 1000;
	m_RemoteAddress.sin_family = AF_INET;
	m_RemoteAddress.sin_port = htons(port);
	m_RemoteAddressLen = sizeof(m_RemoteAddress);
	inet_pton(AF_INET, ip, &m_RemoteAddress.sin_addr);

	// 接收和发送
	char recvBuf[1024] = { 0 };
	char sendBuf[1024] = "Nice to meet you!";

	while (1) {
		int sendLen = sendto(m_Socket, sendBuf, strlen(sendBuf), 0, (sockaddr*)&m_RemoteAddress, m_RemoteAddressLen);
		if (sendLen > 0) {
			std::printf("发送到远程端连接, 其ip: %s, port: %d\n", inet_ntoa(m_RemoteAddress.sin_addr), ntohs(m_RemoteAddress.sin_port));
			cout << "发送到远程端的信息： " << sendBuf << endl;
		}

		int recvLen = recvfrom(m_Socket, recvBuf, 1024, 0, NULL, NULL);
		if (recvLen > 0) {
			std::printf("接收到一个连接, 其ip: %s, port: %d\n", inet_ntoa(m_RemoteAddress.sin_addr), ntohs(m_RemoteAddress.sin_port));
			cout << "接收到一个信息： " << recvBuf << endl;
		}
	}

	closesocket(m_Socket);
	WSACleanup();
	return true;
}

客户端实验

二、cpp_UDP服务端

#include <winsock2.h>
#include <WS2tcpip.h>
#include <iostream>

using namespace  std;

//添加动态库的lib
#pragma comment(lib, "ws2_32.lib")

int main() {
	SOCKET m_Socket;
	SOCKADDR_IN m_BindAddress;   //绑定地址
	SOCKADDR_IN m_RemoteAddress; //远程地址
	int m_RemoteAddressLen;


	// socket环境
	WSADATA  wsaData;
	if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) {
		cout << "WSAStartup error:" << GetLastError() << endl;
		return false;
	}

	// socket对象
	m_Socket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
	if (m_Socket == INVALID_SOCKET)
	{
		closesocket(m_Socket);
		m_Socket = INVALID_SOCKET;
		return false;
	}

	// 绑定占用<ip, port>
	const char* ip = "127.0.0.1";
	int port = 1000;
	m_BindAddress.sin_family = AF_INET;
	m_BindAddress.sin_addr.S_un.S_addr = inet_addr(ip);
	m_BindAddress.sin_port = htons(port);
	auto ret = bind(m_Socket, (sockaddr*)&m_BindAddress, sizeof(SOCKADDR));
	if (ret == SOCKET_ERROR)
	{
		closesocket(m_Socket);
		m_Socket = INVALID_SOCKET;
		return false;
	}

	// 接收和发送
	char recvBuf[1024] = { 0 };
	char sendBuf[1024] = "Nice to meet you, too!";
	m_RemoteAddressLen = sizeof(m_RemoteAddress);

	std::printf("已设置绑定占用的连接, 其ip: %s, port: %d\n", inet_ntoa(m_BindAddress.sin_addr), ntohs(m_BindAddress.sin_port));

	while (1) {
		int recvLen = recvfrom(m_Socket, recvBuf, 1024, 0, (sockaddr*)&m_RemoteAddress, &m_RemoteAddressLen);
		if (recvLen > 0) {
			std::printf("接收到一个连接, 其ip: %s, port: %d\n", inet_ntoa(m_RemoteAddress.sin_addr), ntohs(m_RemoteAddress.sin_port));
			cout << "接收到一个信息： " << recvBuf << endl;


		}
		int sendLen = sendto(m_Socket, sendBuf, strlen(sendBuf), 0, (sockaddr*)&m_RemoteAddress, m_RemoteAddressLen);
		if (sendLen > 0) {
			cout << "发送到远程端的信息： " << sendBuf << endl;
		}
	}

	closesocket(m_Socket);
	WSACleanup();
	return true;
}

服务端实验

C++ UDP 封装示例
udp: connect+send 或 sendto
UDP函数详解
在MFC全局使用UDP


http://www.niftyadmin.cn/n/176408.html

相关文章

UE4中如何对Movie Render Queue进行渲染设置

UE4中如何对Movie Render Queue进行渲染设置

Movie Render Queue 的渲染设置用于控制序列的渲染方式。它们包括抗锯齿、自定义控制台命令、输出格式、渲染模式和其他功能。本指南将介绍设置界面、可用设置列表以及将设置保存为预设的能力。1.学习Movie Render Queue的渲染设置先决条件&#xff1a;首先在 Unreal Engine 中…
阅读更多...
网络技术领域术语大全，含中英文及缩写，强烈建议收藏！

网络技术领域术语大全，含中英文及缩写，强烈建议收藏！

你好&#xff0c;这里是网络技术联盟站。 今天给大家分享的是网络技术领域相关的术语大全&#xff0c;在文末&#xff0c;我已经将本文整理成一个pdf文档了&#xff0c;大家可以下载到本地以便查阅。 自主访问控(DAC:Discretionary Access Control) 自主访问控制(DAC)是一个…
阅读更多...
计网知识总结

计网知识总结

计算机网络知识总结 OSI七层模型 应用层&#xff1a;计算机用户&#xff0c;以及各种应用程序和网络之间的接口&#xff0c;功能是**直接向用户提供服务&#xff0c;完成用户希望在网络上完成的各种工作。**该层的协议有&#xff1a;FTP&#xff08;文件传输协议&#xff09;、…
阅读更多...
猿创征文 |【高级篇】Java 进阶之JVM实战

猿创征文 |【高级篇】Java 进阶之JVM实战

文章目录⚡前言一、面试题解析二、JVM 理论详解⛅JVM的位置❄️JVM的体系结构⏳类加载器三、JVM 双亲委派机制四、Native 关键字五、PC寄存器 与 方法区六、栈与堆七、三种JVM、新生区、老年区、永久区⛵小结⚡前言 JVM 是 Java 实现 跨平台的基础&#xff0c;所有的Java 程序…
阅读更多...
新一代最强开源UI自动化测试神器Playwright（Java版）环境搭建

新一代最强开源UI自动化测试神器Playwright（Java版）环境搭建

Playwright 是专门为满足端到端测试的需要而创建的。Playwright 支持所有现代渲染引擎&#xff0c;包括 Chromium、WebKit 和 Firefox。在 Windows、Linux 和 macOS 上进行本地测试或在 CI 上进行测试&#xff0c;无外设或带本机移动仿真。 一.安装 在JAVA中&#xff0c;使用…
阅读更多...
Anaconda 修改默认虚拟环境安装位置

Anaconda 修改默认虚拟环境安装位置

项目场景&#xff1a; 使用Anaconda Prompt创建虚拟环境 问题描述 保存虚拟环境的默认地址是C盘&#xff0c;而我想将下载的虚拟环境保存到我自定义的位置。 解决方案&#xff1a; 1、使用 conda config --show查看envs_dirs的信息&#xff0c;一般第一个路径是默认路径。把…
阅读更多...
【Web前端】一文带你吃透CSS(完结篇)

【Web前端】一文带你吃透CSS(完结篇)

前端学习路线小总结： 基础入门：HTML CSS JavaScript三大主流框架：VUE REACT Angular深入学习：小程序 Node jQuery TypeScript 前端工程化文章目录 一.CSS布局-对齐1.水平对齐1.1元素居中对齐1.2文本居中对齐1.3图片居中对齐1.4使用定位方式实现左右对齐1.5使用浮动方式实
阅读更多...
小米路由器4A千兆版更换5G芯片和硬件布局后出现的刷机问题

小米路由器4A千兆版更换5G芯片和硬件布局后出现的刷机问题

最近又入手一台小米路由器4A千兆版&#xff0c;打算通过 CH341A 编程器刷成老毛子的&#xff0c;结果一拆机傻眼了&#xff0c;整个电路板上的芯片和硬件布局都换了。 这是老板子&#xff1a; 这是新板子&#xff1a; 两张图可以很清楚的看到有很大的变化&#xff0c;那么&a…
阅读更多...
最新文章

Copyright @ 2022~2023