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

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

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

udp_v1_1">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地址和端口号Port
            struct sockaddr_in local; // 这个 local 在哪里定义呢？用户空间的特定函数的栈帧上，不在内核中！ 
            bzero(&local, sizeof(local)); // 清空上述字段ud
            local.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_102">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_211">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_299">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.niftyadmin.cn/n/5009081.html

相关文章

小程序路由传参的方法

小程序路由传参的方法

小程序路由传参的方法有以下几种&#xff1a; Query参数传递&#xff1a;在跳转页面时&#xff0c;可以通过url后面加上?keyvalue的方式传递参数&#xff0c;例如&#xff1a;wx.navigateTo({url: /pages/detail/detail?id123}) 路由跳转传递&#xff1a;可以通过wx.navigat…
阅读更多...
十四、内置模块path、邂逅Webpack和打包过程、css-loader

十四、内置模块path、邂逅Webpack和打包过程、css-loader

一、内置模块path &#xff08;1&#xff09;path介绍 &#xff08;2&#xff09; path常见的API 这里重点讲一下path.resolve()。 看上面的例子&#xff0c;从右往左开始解析&#xff0c;所以一开始解析的就是 /abc.txt &#xff0c;这个时候就会把它当成一个绝对路径了&am…
阅读更多...
亿发软件：智慧门店商超系统，2023新零售POS数字运营一体化管理

亿发软件：智慧门店商超系统，2023新零售POS数字运营一体化管理

2023年9月6日&#xff0c;山东济宁一家超市因为酸奶价格标签错误而引发了广泛关注。标签原本显示几十个人为9.9元&#xff0c;但特价销售价却标为10元。这一小小的错误却在社交媒体上引发了轩然大波&#xff0c;让超市一度处于舆论的风口浪尖。超市工作人员回应&#xff0c;表示…
阅读更多...
云计算时代的采集利器

云计算时代的采集利器

大家好&#xff01;在今天的知识分享中&#xff0c;我们将探讨一个在云计算环境中的爬虫应用利器——独享IP。如果你是一名爬虫程序员&#xff0c;或者对数据采集和网络爬虫有浓厚的兴趣&#xff0c;那么这篇文章将向你展示独享IP在云计算环境下的应用价值。 1. 什么是独享IP&…
阅读更多...
2023高教社杯全国大学生数学建模竞赛E题代码解析

2023高教社杯全国大学生数学建模竞赛E题代码解析

2023高教社杯全国大学生数学建模竞赛E题 黄河水沙监测数据分析 代码解析 因为一些不可抗力&#xff0c;下面仅展示部分python代码&#xff08;第一问的部分&#xff09;&#xff0c;其余代码看文末 首先导入包&#xff1a; import numpy as np import pandas as pd import m…
阅读更多...
《Java程序设计》实验报告

《Java程序设计》实验报告

实验内容&#xff1a;面向对象程序设计 1、定一个名为Person的类&#xff0c;其中含有一个String类型的成员变量name和一个int类型的成员变量age&#xff0c; 分别为这两个变量定义访问方法和修改方法&#xff0c;另外再为该类定义一个名为speak的方法&#xff0c; 在其中输出n…
阅读更多...
SpringBoot集成Microsoft office 365账号方案（InsCode AI 创作助手）

SpringBoot集成Microsoft office 365账号方案（InsCode AI 创作助手）

SpringBoot集成微软office 365账号需要进行以下步骤&#xff1a; 1. 注册Azure AD应用程序 要使用Microsoft Graph API访问Office 365数据&#xff0c;我们需要先注册一个Azure AD应用程序&#xff0c;以便获取相应的应用程序ID和机密。 2. 添加API权限 在Azure门户中为我们…
阅读更多...
从线上化走向智能化，数字办公助力企业实现“效率+安全”双提升｜爱分析报告

从线上化走向智能化，数字办公助力企业实现“效率+安全”双提升｜爱分析报告

[图片] 报告关键发现 对于党政用户而言&#xff0c;数字办公是内部最为重要的系统。党政机关跨部门、跨层级协同要求越来越高&#xff0c;在数字办公系统升级过程中&#xff0c;应当更为关注如何拉通流程、避免数据泄露风险等问题。此外&#xff0c;从2023年开始&#xff0c;党…
阅读更多...
最新文章

Copyright @ 2022~2023