网络编程套接字 | UDP套接字

前面的文章中我们叙述了网络编程套接字的一些预备知识点，从本文开始我们就将开始UDP套接字的编写。本文中的服务端与客户端都是在阿里云的云服务器进行编写与测试的。

udp_v1

在v1的版本中我们先来使用一下前面讲过得一些接口，简单的构建一个udp服务器：

// udp_server.cc
#include "udp_server.hpp"
#include <memory>using namespace std;
using namespace ns_server;
int main()
{unique_ptr<UdpServer> usvr(new UdpServer("1.1.1.1", 8082)); // 通过智能指针控制服务器的资源管理，并且向程序传入ip与端口号usvr->InitServer(); //服务器的初始化usvr->Start();return 0;
}

// udp_server.hpp
#pragma once#include <iostream>
#include <string>
#include <cerrno>
#include <cstring>
#include <cstdlib>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
namespace ns_server
{// 用于展示返回对应的错误提示enum{SOCKET_ERR = 1,BIND_ERR};const static uint16_t default_port = 8080;class UdpServer{public:UdpServer(std::string ip, uint16_t port = default_port) : ip_(ip), port_(port){std::cout << "server addr: " << ip << " : " << port_ << std::endl;}void InitServer(){// 1. 创建socket接口，打开网络文件sock_ = socket(AF_INET, SOCK_DGRAM, 0);if (sock_ < 0){std::cerr << "create socket error: " << strerror(errno) << std::endl;exit(SOCKET_ERR);}std::cout << "create socket success: " << sock_ << std::endl; // 3// 2. 给服务器指明IP地址和端口号Portstruct sockaddr_in local; // 这个 local 在哪里定义呢？用户空间的特定函数的栈帧上，不在内核中！ bzero(&local, sizeof(local)); // 清空上述字段udlocal.sin_family = AF_INET; // PF_INET 初始化socketaddr_in结构local.sin_port = htons(port_); // 本地主机序列构建的port_，需要从主机序列转变成网络序列// inet_addr: 1,2// 1. 字符串风格的IP地址，转换成为4字节int, "1.1.1.1" -> uint32_t -> 能不能强制类型转换呢？不能，这里要转化// 2. 需要将主机序列转化成为网络序列local.sin_addr.s_addr = inet_addr(ip_.c_str()); // sin_addr C++中的结构体在C++中可以进行转化，但是在C语言中不行// 这里需要将字符串转换uint32_t的类型，并且同时进行将主机序列转换成网络序列// inet_addr 函数将包含 IPv4 点十进制地址的字符串转换为IN_ADDR结构的正确地址。而在in_addr结构之中有in_addr_t s_addr的一个数据结构if (bind(sock_, (struct sockaddr*)&local, sizeof(local)) < 0) // 然后是绑定相关的套接字文件，此时需要就将前面在帧栈上定义的local进行绑定{std::cerr << "bind socket error: " << strerror(errno) << std::endl;exit(BIND_ERR);}std::cout << "bind socket success: " << sock_ << std::endl; //3}void Start() {}~UdpServer() {}private:int sock_;uint16_t port_;std::string ip_; // 后面需要去掉这个ip};
}

然后运行上述的程序会出现一个问题就是：

server addr: 1.1.1.1 : 8082
create socket success: 3
bind socket error: Cannot assign requested address

bind socket error: Cannot assign requested address 云服务器不需要bind ip地址，需要让服务器自己制定ip地址
云服务器，或者一款服务器，一般不要指明某一个确定的IP – 服务器可能有多张网卡，可能配有多个IP，我们要让我们的udpserver启动的时候bind本主机上的任意IP，然后我们对上述的v1版本进行修改。

// 需要修改的地方就是：
local.sin_addr.s_addr = INADDR_ANY; // 让我们的udpserver在启动的时候，bind本主机上的任意IP

server addr: 1.1.1.1 : 8082
create socket success: 3
bind socket success: 3

此时就可以正确的进行bind操作。

udp_v2

下面我们将上述的程序进行完善，添加上服务器正常工作的程序（我们想要完成的是客户端发送消息，服务端接收到消息并答应在终端上，同时将消息返回给客户端）

void Start()
{// 服务器的正常工作char buffer[1024];while (true){// 收// ssize_t 实际写入的大小 recvfrom(int sockfd 绑定的套接字, void *buf 接受数据存放的缓冲区, size_t len 缓冲区长度, int flags 读取方式(0), struct sockaddr *src_addr 需要知道client的IP和PORT 输入接收缓冲区, socklen_t *addrlen 实际结构体的大小); 输入输出型参数 需要知道谁发的数据struct sockaddr_in peer;socklen_t len = sizeof(peer); // 这里一定要写清楚，未来传入的缓冲区的大小int n = recvfrom(sock_, buffer, sizeof(buffer)-1/*因为这是以字符作为消息的类型，所以缓冲区预留一部分空间*/, 0, (struct sockaddr*)&peer, &len); // 消息的类型需要程序员来定义if (n > 0) buffer[n] = '\0';else continue;// 提取client信息std::string clientip = inet_ntoa(peer.sin_addr); // 把一个四字节的IP转化为字符串uint16_t clientport = ntohs(peer.sin_port); // 将从网络中获取的端口号转换成主机std::cout << clientip << "-" << clientport << "#" << buffer << std::endl;// 发sendto(sock_, buffer, strlen(buffer), 0, (struct sockaddr*)&peer, len); // 往文件中去写的时候，不需要携带\0}
}

然后对udp_server.cc文件进行修改，我们想要使用./udp_server port的形式来运行程序，在运行程序的时候将端口号进行传入

static void usage(string proc)
{std::cout << "Usage:\n\t" << proc << " port\n" << std::endl;
}
// ./udp_server port
int main(int argc, char* argv[])
{if (argc != 2){usage(argv[0]);exit(USAGE_ERR);}uint16_t port = atoi(argv[1]); // 此处为char*类型的数据若是要传入port需要进行转换unique_ptr<UdpServer> usvr(new UdpServer(port));// bind socket error: Cannot assign requested address 云服务器不需要bind ip地址，需要让服务器自己制定ip地址// 自己本地装的虚拟机或者是物理机器是允许的，usvr->InitServer(); //服务器的初始化usvr->Start();return 0;
}

然后是服务端的代码

// udp_client.cc
#include <string>
#include <cstring>
// 127.0.0.1 本地回环，表示的就是当前的主机，通常用来进行本地通信或者测试
static void usage(std::string proc)
{std::cout << "Usage:\n\t" << proc << " serverip serverport\n"<< std::endl;
}
// ./udp_client serverip serverport
int main(int argc, char *argv[])
{if (argc != 3){usage(argv[0]);exit(USAGE_ERR);}std::string serverip = argv[1];uint16_t serverport = atoi(argv[2]);int sock = socket(AF_INET, SOCK_DGRAM, 0);if (sock < 0){std::cerr << "create socket error" << std::endl;exit(SOCKET_ERR);}// client 这里要不要bind？ 要的！socket通信的本质[clientip:clientport, serverclient. serverport]// 要不要自己bind？不需要自己bind，os自动给我们进行bind！-- 为什么？client的port要随机让os分配防止client出现启动冲突// server为什么要自己bind -- 1. server的端口不能随意改变, 众所周知且不能随意改变；2. 同一家公司的port需要统一进行管理// 明确server是谁？struct sockaddr_in server;memset(&server, 0, sizeof(server));server.sin_family = AF_INET;server.sin_port = htons(serverport);server.sin_addr.s_addr = inet_addr(serverip.c_str());while (true){// 用户输入std::string message;std::cout << "please Enter# ";std::cin >> message;// 什么时候bind？在我们首次系统调用发送数据的时候，OS会在底层随机选择clientport + 自己的IP 1. bind 2. 构建发送的数据报文// 发送sendto(sock, message.c_str(), message.size(), 0, (struct sockaddr *)&server, sizeof(server));// 接收char buffer[2048];struct sockaddr_in temp;socklen_t len = sizeof(temp);int n = recvfrom(sock, buffer, sizeof(buffer), 0, (struct sockaddr *)&temp, &len);if (n > 0){buffer[n] = 0;std::cout << "server echo# " << buffer << std::endl;}}return 0;
}

在这里插入图片描述
这样我们就完成了一个简单的UDP网络通信程序。

udp_v3

下面我们还需要对上述的UDP网络通信进行修改，在上述的网络通信程序中服务端在接收到客户端的信息之后立即进行了处理，然后将信息进行返回，但是我们想要让信息的处理与网络IO进行分离，在第三版中我们就进行对应的修改。我们在工作空间中定义了using func_t = std::function<std::string (std::string)>;这样的参数为string，返回值为string的一个包装器，在udp_server类中新增了一个成员func_t service_;来进行业务处理。在编写构造函数的时候将这个成员初始化，那么我们就可以在外部传入一个执行业务的方法，在外部定义好了这个执行的方法，在外部即udp_server.cc中将业务处理完毕之后再进行网络IO。
下面就是对上述版本的修改

// udp_server.hpp
// 在Start()中发送消息前执行业务处理
void Start()
{// ...// 做业务处理std::string response = service_(buffer);// 发sendto(sock_, response.c_str(), response.size(), 0, (struct sockaddr*)&peer, len); // 往文件中去写的时候，不需要携带\0
}

然后我们就在cpp文件中处理上层业务

// udp_server.cc
std::string transactionString(std::string request)
{std::string result;char c;for(auto & r : request){if (islower(r)) {c = toupper(r);result.push_back(c);}else {result.push_back(r);}}return result;
}static bool isPass(const std::string& command)
{bool pass = true;auto pos = command.find("mv");if (pos != std::string::npos) pass = false;pos = command.find("rm");if (pos != std::string::npos) pass = false;return pass;
}std::string execteCommand(std::string command)
{// FILE *popen(const char *command, const char *type);// 1. 创建管道// 2. 创建子进程// 3. 通过FILE*将结果直接返回，可以让用户以读取文件的访问，获得命令执行的结果// 安全检查if (!isPass(command)) return "bad";// 业务逻辑处理FILE* fp = popen(command.c_str(), "r");if (fp == nullptr) return "None";// 获取结果char line[2048];std::string result;while (fgets(line, sizeof(line), fp) != NULL){result += line;}return result;fclose(fp);
}int main()
{// ...// 通过传入第一个transactionString函数可以将我们客户端输入的小写字符，在服务端转换成大写然后在返回客户端unique_ptr<UdpServer> usvr(new UdpServer(transactionString, port)); // 这个业务方法就是将客户端输入的指令发送到服务端，在服务端执行后再将执行的结果返回给客户端// unique_ptr<UdpServer> usvr(new UdpServer(execteCommand, port));
}

大小写转换业务：
在图片描述
读取客户端指令的业务
在这里插入图片描述

udp_v4

上述第三版的程序还有一些问题就是，程序运行的时候收发的处理都在start()函数中，但是这样一旦阻塞在发送或者阻塞在收取的时候，假如有多个客户端要连接服务端，就会有影响。那么在第四版中我们就将结合前面的讲述过的基于环形队列的生产消费模型来将接受与发送分别使用两个线程来处理。在第四版中我们想要实现的是一个简易的udp多人聊天程序。

// udp_server.hpp
class UdpServer
{
public:UdpServer(uint16_t port = default_port) :port_(port){pthread_mutex_init(&lock, nullptr);p = new Thread(1, std::bind(&UdpServer::Recv, this)); // 这里传入接受与发送的函数时如果直接传入会发生报错，以为Recv与Broadcast都是类的方法，而类的方法是有隐含的this指针的，此时就可以使用bind函数将this指针这个成员先绑定，然后就可以正常的运行。c = new Thread(2, std::bind(&UdpServer::Broadcast, this));}void Start(){// ...c->run();p->run();}void addUser(const std::string& name, const struct sockaddr_in& peer) // 构建一个新用户{LockGuard lockguard(&lock);// onlineuser[name] = peer;auto iter = onlineuser.find(name); // 遍历检测是否存在该用户if (iter != onlineuser.end()) return;onlineuser.insert(std::pair<const std::string, const struct sockaddr_in>(name, peer));}void Recv(){// 服务器的正常工作char buffer[1024];while (true){// 收// ssize_t 实际写入的大小 recvfrom(int sockfd 绑定的套接字, void *buf 接受数据存放的缓冲区, size_t len 缓冲区长度, int flags 读取方式(0), struct sockaddr *src_addr 需struct sockaddr_in peer;socklen_t len = sizeof(peer); // 这里一定要写清楚，未来传入的缓冲区的大小int n = recvfrom(sock_, buffer, sizeof(buffer)-1/*因为这是以字符作为消息的类型，所以缓冲区预留一部分空间*/, 0, (struct sockaddr*)&peer, &len); // 消息的类型需要程序员if (n > 0) buffer[n] = '\0';else continue;std::cout << "recv done ..." << std::endl;// 提取client信息std::string clientip = inet_ntoa(peer.sin_addr); // 把一个四字节的IP转化为字符串uint16_t clientport = ntohs(peer.sin_port); // 将从网络中获取的端口号转换成主机std::cout << clientip << "-" << clientport << "#" << buffer << std::endl;// 构建一个用户并检查std::string name = clientip;name += "-";name += std::to_string(clientport);// 如果不存在就插入，如果存在，什么都不做addUser(name, peer);std::string message = name + " >> " + buffer;rq.push(message); // 将接收到的信息存放入生产消费中}}void Broadcast(){while (true){std::string sendstring;rq.pop(&sendstring); // 从生产消费模型中获取信息std::vector<struct sockaddr_in> v; // 获取所有的用户使用数组进行记录{LockGuard lockguard(&lock); // 使用锁进行保护防止产生冲突for (auto user : onlineuser){v.push_back(user.second);}}for (auto user : v) // 依次将信息发送出去{sendto(sock_, sendstring.c_str(), sendstring.size(), 0, (struct sockaddr *)&user, sizeof(user));}}}~UdpServer(){pthread_mutex_destroy(&lock);c->join();p->join();delete p;delete c;}
private:// ...std::unordered_map<std::string, struct sockaddr_in> onlineuser; // 添加使用用户RingQueue<std::string> rq; // 基于环形队列的生产消费模型pthread_mutex_t lock; // 互斥锁Thread *c, *p; // 创建生产者与消费者线程
};

对于客户端同样可以使用多线程

udp_client.cc
void* recver(void* args)
{pthread_detach(pthread_self());int sock = *static_cast<int*>(args);while (true){// 接收char buffer[2048];struct sockaddr_in temp;socklen_t len = sizeof(temp);int n = recvfrom(sock, buffer, sizeof(buffer)-1, 0, (struct sockaddr *)&temp, &len);if (n > 0){buffer[n] = 0;std::cout << buffer << std::endl;}}
}
int main(int argc, char *argv[])
{// ...pthread_t tid;pthread_create(&tid, nullptr, recver, &sock);while (true){// 用户输入std::string message;std::cerr << "please Enter# "; // 往2号文件发送// std::cin >> message;getline(std::cin, message);// 发送sendto(sock, message.c_str(), message.size(), 0, (struct sockaddr *)&server, sizeof(server));}return 0;
}

在这里插入图片描述
如上图所示就可以看到在右图中两个不同的客户端发送的消息都可以被看到。

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

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

自建音乐服务器Navidrome之一

自建音乐服务器Navidrome之一

自建音乐服务器Navidrome之一 1. 前言1.1 官方网站 2. Navidrome 简介2.1 简介2.2 特性 3. 准备工作4. 视频教程5. 界面演示5.1 初始化页5.2 专辑页 1. 前言 之前给大家介绍过 Koel 音频流服务&#xff0c;就是为了解决大家的这个问题&#xff1a;下载下来的音乐&#xff0c;只…
阅读更多...
【Docker】镜像的创建、管理与发布

【Docker】镜像的创建、管理与发布

镜像的获取 镜像可以从以下方式获得&#xff1a; 从远程镜像仓库拉取&#xff0c;可以是公有仓库&#xff0c;也可以是私有仓库从Dockerfile构建从文件导入&#xff08;离线&#xff09;从容器提交 镜像的基本操作 跟镜像相关的命令如下&#xff1a; $ docker image --help…
阅读更多...
算法专题：前缀和

算法专题：前缀和

文章目录 Acwing&#xff1a;前缀和示例2845.统计趣味子数组的数目思路容易理解的写法&#xff1a;前缀和两层循环存在问题&#xff1a;超时 优化写法&#xff1a;两数之和思路&#xff0c;转换为哈希表 前缀和&#xff0c;就是求数组中某一段的所有元素的和。 求子数组中某一…
阅读更多...
嵌入式Linux驱动开发（LCD屏幕专题）（四）

嵌入式Linux驱动开发（LCD屏幕专题）（四）

单Buffer的缺点与改进方法 1. 单Buffer的缺点 如果APP速度很慢&#xff0c;可以看到它在LCD上缓慢绘制图案 即使APP速度很高&#xff0c;LCD控制器不断从Framebuffer中读取数据来显示&#xff0c;而APP不断把数据写入Framebuffer 假设APP想把LCD显示为整屏幕的蓝色、红色 很…
阅读更多...
关于火绒邮件监控引起的扫描任意IP会有25和110端口反馈

关于火绒邮件监控引起的扫描任意IP会有25和110端口反馈

之前测试过公司的外网IP&#xff0c;因为之前一直很注意对外映射的端口&#xff0c;都限制了可以访问的IP地址和端口&#xff0c;所以之前扫描的时候是一个端口都扫描不出来的。最近闲的无事&#xff0c;想着再扫描试试&#xff0c;结果发现居然开放了25和110端口&#xff0c;我…
阅读更多...
CMakeList.txt

CMakeList.txt

CMakeList.txt的写法 前言一个最近写好的CMakeList.txt对上边CMakeList.txt的说明修改 前言 复习一下CMakeList.txt的写法,以下面的一个CMakeList.txt为例 一个最近写好的CMakeList.txt cmake_minimum_required(VERSION 3.17)project(QtVTKProject)# INCLUSION OF Qt # set(…
阅读更多...
高级IO---五种IO模型多路转接之Select

高级IO---五种IO模型多路转接之Select

文章目录 五种IO模型1、阻塞IO2、非阻塞IO3、信号驱动IO4、多路转接IO5、异步IO总结IO 同步与异步阻塞与非阻塞设置非阻塞利用fcntl接口实现一个设置非阻塞的函数 多路转接之Selectselect函数原型fd_set结构返回值 socket就绪条件读就绪写就绪 select的特点select使用示例Util.…
阅读更多...
linux提权

linux提权

目录 一、linux提权靶场下载与安装 二、基础提权 1.sudo提权 2.suid提权 3.taskset执行bash 三、内核提权 相关网站 https://gtfobins.github.io/#sudohttps://blog.csdn.net/weixin_43873557/article/details/113784146 一、linux提权靶场下载与安装 #下载链接 http…
阅读更多...
【python】PySide中QMessageBox设置中文按钮及使用

【python】PySide中QMessageBox设置中文按钮及使用

PyQt、PySide使用QMessageBox的时候会发现按钮都是英文的&#xff0c;对于中文的应用软件来说会降低使用体验。本文将以问答对话框为例&#xff0c;介绍如何设置中文按钮&#xff0c;以及如何使用。 实验环境 本文实验环境为&#xff1a;Windows 10&#xff0c;Python 3.8&am…
阅读更多...
读高性能MySQL（第4版）笔记04_操作系统和硬件优化

读高性能MySQL（第4版）笔记04_操作系统和硬件优化

1. 从软件本身和它运行的典型工作负载来看&#xff0c;MySQL通常也更适合运行在廉价硬件上 2. 基本资源 2.1. CPU 2.2. 内存 2.3. 磁盘 2.4. 瓶颈 2.5. 网络资源 3. CPU 3.1. 最常见的瓶颈是CPU耗尽 3.2. 检查CPU使用率来确定工作负载是否受CPU限制 3.3. 低延迟&…
阅读更多...
MinIO集群模式信息泄露漏洞（CVE-2023-28432）

MinIO集群模式信息泄露漏洞（CVE-2023-28432）

前言&#xff1a;MinIO是一个用Golang开发的基于Apache License v2.0开源协议的对象存储服务。虽然轻量&#xff0c;却拥有着不错的性能。它兼容亚马逊S3云存储服务接口&#xff0c;非常适合于存储大容量非结构化的数据。该漏洞会在前台泄露用户的账户和密码。 0x00 环境配置 …
阅读更多...
c++中的list容器讲解

c++中的list容器讲解

文章目录 1. list的介绍及使用1.1 list的介绍1.2 list的使用1.2.1 list的构造1.2.2 list iterator的使用1.2.3 list capacity1.2.4 list element access1.2.6 list的迭代器失效 2. list的模拟实现2.1 模拟实现list 3. list与vector的对比 1. list的介绍及使用 1.1 list的介绍 …
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023