【Linux网络编程】IO多路转接之poll

news2024/11/15 3:24:46

poll

  • 1.poll初始
  • 2.poll函数接口
  • 3.poll服务器
  • 4.poll的优点缺点

在这里插入图片描述

点赞👍👍收藏🌟🌟关注💖💖
你的支持是对我最大的鼓励，我们一起努力吧!😃😃

1.poll初始

poll也是一种linux中多路转接的方案。它所对应的多路转接方案主要是解决select两个问题。

  1. select的文件描述符有上限的问题
  2. select每次都要重新设置关心的fd

下面通过poll接口来认识它是怎么解决select的问题的。

2.poll函数接口

在这里插入图片描述

struct pollfd * fds：这里可以把它想象一个动态数组、数组或者new/malloc出来的结构体数组

nfds_t nfds：代表这个数组的长度

int timeout：纯输入型，时间单位ms

  1. 大于0：在timeout以内 阻塞，超过timeout非阻塞返回一次
  2. 等于0 ：非阻塞
  3. 小于<0：阻塞

这个和select一模一样的意思。用起来更简单了。

返回值：同select一模一样

  1. 大于0：表示有几个fd就绪了
  2. 等于0：表示超时了
  3. 小于0：表示poll等待失败了

poll的作用和select一模一样：只负责等待！

在这里插入图片描述

这个struct pollfd 结构体 在传给poll表示 用户->内核：

int fd：你要关心一下这个fd哦

short events：关心的是这个fd的什么事件。我们把对应的事件设置进events里

输入看：fd+events

当poll返回时这个struct pollfd 结构体 表示内核->用户：

你要关心的fd上面的events中有那些事件已经就绪啦

short revents：就绪事件由revents返回

输出看：fd+revents

很显然这种设计解决了这样的问题：

  1. 输入输出分离！

现在，用户->内核，内核->用户，events和revents的分离！以前select就用一张位图表示不同含义，因为输入输出分离了所以决定了poll不需要对参数进行重新设定

events和revents类型是整数，对应的事件如下：

在这里插入图片描述

其中对我们来说常用的是POLLIN、POLLOUT、POLLERR ，这些都是大写的宏每一个占一个比特位，不同比特位表示不同事件。

所以用户->内核，只要将events设置成要关心的宏值，那么操作系统就帮我们进行关心了。当操作系统返回时只要把revents设置成对应的宏值，不就把那些事件就绪不就告诉我们了吗。

因为它的类型是short而没有用操作系统自己封装的各种各样的结构体，所以对于事件的设计，我们自己用户检测事件有没有设置或者就绪一定要由我们自己来做，按位与，按位或这样的操作。

  1. select等待fd有上限的问题

struct pollfd *fds不是一个数组吗，nfds_t nfds不就是该数组大小也就是上限吗，你怎么说poll解决了select等待fd上限的问题？

select是一个具体的数据类型fd_set，既然是一个具体的类型那就直接决定了数据类型大小只能由你的编译环境自己定，今天不一样了，因为这个数组由我们自己说的算！

3.poll服务器

前面不是写了select服务器吗，现在我们把它改成poll服务器

错误码封装

#pragma once

enum
{
    USAGG_ERR = 1,
    SOCKET_ERR,
    BIND_ERR,
    LISTEN_ERR
};

日志封装

#pragma once

#include<iostream>
#include<string>
#include<stdio.h>
#include <cstdarg>
#include<ctime>
#include<sys/types.h>
#include<unistd.h>
#include<fstream>

#define DEBUG  0
#define NORMAL  1
#define WARNING 2
#define ERROR   3
#define FATAL   4

#define LOG_NORMAL "log.txt"
#define LOG_ERR "log.error"

const char* level_to_string(int level)
{
    switch(level)
    {
        case DEBUG: return "DEBUG";
        case NORMAL: return "NORMAL";
        case WARNING: return "WARNING";
        case ERROR: return "ERROR";
        case FATAL: return "FATAL";
    }
}

//时间戳变成时间
char* timeChange()
{
    time_t now=time(nullptr);
    struct tm* local_time;
    local_time=localtime(&now);

    static char time_str[1024];

    snprintf(time_str,sizeof time_str,"%d-%d-%d %d-%d-%d",local_time->tm_year + 1900,\
                    local_time->tm_mon + 1, local_time->tm_mday,local_time->tm_hour, \
                    local_time->tm_min, local_time->tm_sec);

    return time_str;
}



void logMessage(int level,const char* format,...)
{
    //[日志等级] [时间戳/时间] [pid] [message]
    //[WARNING] [2024-3-21 10-46-03] [123] [创建sock失败]
#define NUM 1024
    //获取时间
    char* nowtime=timeChange();
    char logprefix[NUM];
    snprintf(logprefix,sizeof logprefix,"[%s][%s][pid: %d]",level_to_string(level),nowtime,getpid());

    //
    char logconten[NUM];
    va_list arg;
    va_start(arg,format);
    vsnprintf(logconten,sizeof logconten,format,arg);

    
    std::cout<<logprefix<<logconten<<std::endl;
  
};

套接字封装

#pragma once

#include <iostream>
#include <string>
#include <cstring>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include "log.hpp"
#include "err.hpp"

using namespace std;

class Sock
{
     const static int backlog = 32;

public:
    static int sock()
    {
        // 1. 创建socket文件套接字对象
        int sock = socket(AF_INET, SOCK_STREAM, 0);
        if (sock < 0)
        {
            logMessage(FATAL, "create socket error");
            exit(SOCKET_ERR);
        }
        logMessage(NORMAL, "create socket success: %d", sock);

        int opt = 1;
        setsockopt(sock, SOL_SOCKET, SO_REUSEADDR|SO_REUSEPORT, &opt, sizeof(opt));
        return sock;
    }

    static void Bind(int sock,int port)
    {
        // 2. bind绑定自己的网络信息
        struct sockaddr_in local;
        memset(&local, 0, sizeof(local));
        local.sin_family = AF_INET;
        local.sin_port = htons(port);
        local.sin_addr.s_addr = INADDR_ANY;
        if (bind(sock, (struct sockaddr *)&local, sizeof(local)) < 0)
        {
            logMessage(FATAL, "bind socket error");
            exit(BIND_ERR);
        }
        logMessage(NORMAL, "bind socket success");

    }

    static void Listen(int sock)
    {
        // 3. 设置socket 为监听状态
        if (listen(sock, backlog) < 0) 
        {
            logMessage(FATAL, "listen socket error");
            exit(LISTEN_ERR);
        }
        logMessage(NORMAL, "listen socket success");
    }

    static int Accept(int listensock, std::string *clientip, uint16_t *clientport)
    {
        struct sockaddr_in peer;
        socklen_t len = sizeof(peer);
        int sock = accept(listensock, (struct sockaddr *)&peer, &len);
        if (sock < 0)
            logMessage(ERROR, "accept error, next");
        else
        {
            logMessage(NORMAL, "accept a new link success, get new sock: %d", sock); // ?
            *clientip = inet_ntoa(peer.sin_addr);
            *clientport = ntohs(peer.sin_port);
        }

        return sock;
    }
};

调用逻辑

#include "pollServer.hpp"
#include "err.hpp"
#include <memory>

static void usage(std::string proc)
{
    std::cerr << "Usage:\n\t" << proc << " port" << "\n\n";
}

string service(string request)
{
    return request;
}


int main(int argc,char* argv[])
{
    if(argc != 2)
    {
        usage(argv[0]);
        exit(USAGG_ERR);
    }

    unique_ptr<pollServer> usl(new pollServer(service,atoi(argv[1])));
    usl->initServer();
    usl->start();
    
    return 0;

今天poll服务器，也是需要一个数组。只不过以前select数组纯纯的保存文件描述符，poll这里必须是保存struct pollfd结构体的数组。

一般我们如果把fd设置为-1或者小于0的值，操作系统就不会关注这样的文件描述符了。它只会关心大于等于0的fd。

在这里插入图片描述

因此我们要重新定义一个指针，构造析构都跟着改一下

class pollServer
{
    static const int defaultport = 8080;
    static const int defaultfd = -1;
    static const int defaultnum=2048;

    using func_t=function<string(string)>;

public:
    pollServer(func_t f,int port = defaultport) : _cbs(f),_port(port), _listensock(-1), _rfds(nullptr)
    {
    }
    
    ~pollServer()
    {
        if (_listensock != defaultfd)
            close(_listensock);
        if (_rfds)
            delete[] _rfds;
    }

private:
    int _listensock;
    int _port;
    struct pollfd* _rfds;
    func_t _cbs;
};

接下来初始化服务器这里创建结构体数组大小自己随意定

void initServer()
{
    // 1.创建套接字
    _listensock = Sock::sock();
    Sock::Bind(_listensock, _port);
    Sock::Listen(_listensock);

    _rfds=new struct pollfd[defaultnum];//大小这里自己随便定
    for (int i = 0; i < defaultnum; ++i)//数组初始化
    {
        _rfds[i].fd = defaultfd;
        _rfds[i].events=0;
        _rfds[i].revents=0;
    }
    _rfds[0].fd = _listensock; // 这个位置后面就不变了
    _rfds[0].events=POLLIN; //告诉内核帮我关心_listensock读事件
}

打印这里也改一下

void print()
{
    for (int i = 0; i < defaultnum; ++i)
    {
        if (_rfds[i].fd != defaultfd)
            cout << _rfds[i].fd << " ";
    }
    cout << endl;
}

现在当我们启动服务之后，就不需要每次调用select之前都需要重新设置fd了添加到读文件描述符集里面了，然后才能添加到select里面。现在直接把数组给poll。所以能明显感觉到poll比select简单

void start()
{
    int timenout=1000;
    for (;;)
    {
        int n=poll(_rfds,defaultnum,timenout);
        switch (n)
        {
        case 0:
            logMessage(NORMAL, "timeout...");
            break;
        case -1:
            logMessage(WARNING, "poll error, code: %d, err string: %s", errno, strerror(errno));
            break;
        default:
            // 说明有事件就绪了,目前只有一个监听事件就绪了
            logMessage(NORMAL, "have event ready!");
            HandlerEvent();//这里不用传了,因为就绪事件就在_rfds里
            break;
        }
    }
}

今天这里我们只处理读事件就绪的情况

// 1.handler event _rfds 中,不仅仅是有一个fd是就绪的,可能存在多个
// 2.我们的poll目前只处理了read事件
void HandlerEvent()
{
    // 你怎么知道那些fd就绪了呢? 我不知道,我只能遍历
    for (int i = 0; i < defaultnum; ++i)
    {
        // 不合法fd
        if (_rfds[i].fd == defaultfd)
            continue;

        // 合法fd,但必须曾经向内核设置过帮我关心对应fd读事件才能往下走
        if (!(_rfds[i].events & POLLIN))
            continue;

        if (_rfds[i].fd == _listensock && _rfds[i].revents & POLLIN)
            Accepter(_listensock);
        else if (_rfds[i].revents & POLLIN)
            Recver(i);
    }

处理_listensock读就绪事件

void Accepter(int listensock)
{

    logMessage(DEBUG, "Accepter in");

    // 走到这里,accept 函数,会不会被阻塞?

    // 走到这里就是, poll 告送我,_listensock就绪了,然后才能执行下面代码

    string clientip;
    uint16_t clientport;
    int sock = Sock::Accept(listensock, &clientip, &clientport);  accept = 等 + 获取
    if (sock < 0)
        return;
    logMessage(NORMAL, "accept success [%s:%d]", clientip.c_str(), clientport);

    // 得到一个sock套接字后，然后我们可以直接进行read/recv吗? 不能,整个代码只有poll有资格检测事件是否就绪
    // 将新的sock 托管给poll！
    // 将新的sock，托管给poll的本质，其实就是将sock，添加到_rfds数组里！
    int i = 0;
    for (; i < defaultnum; ++i)
    {
        if (_rfds[i].fd != defaultfd)
            continue;
        else
            break;
    }
    if (i == defaultnum)
    {
        logMessage(WARNING, "server if full, please wait");
        close(sock);
    }
    else
    {
        _rfds[i].fd = sock;
        _rfds[i].events = POLLIN;
        _rfds[i].revents = 0;
    }

    print();
    logMessage(DEBUG, "Accepter out");
}

处理普通sock读就绪事件

void ResetItem(int i)
{
    _rfds[i].fd = defaultfd;
    _rfds[i].events = 0;
    _rfds[i].revents = 0;
}

void Recver(int pos)
{
    logMessage(DEBUG, "in Recver");

    // 1. 读取request
    // 这样读取是有问题的！
    char buffer[1024];
    ssize_t s = recv(_rfds[pos].fd, buffer, sizeof(buffer) - 1, 0); // 这里在进行读取的时候，会不会被阻塞？
    if (s > 0)                                                      // 读取成功
    {
        buffer[s] = 0;
        logMessage(NORMAL, "client# %s", buffer);
    }
    else if (s == 0) // 对方关闭了文件描述符
    {
        close(_rfds[pos].fd);
        ResetItem(pos);
        logMessage(NORMAL, "client quit");
        return;
    }
    else // 读取失败
    {
        close(_rfds[pos].fd);
        ResetItem(pos);
        logMessage(ERROR, "client quit: %s", strerror(errno));
        return;
    }

    // 2. 处理request
    std::string response = _cbs(buffer);

    // 3. 返回response
    // write bug
    write(_rfds[pos].fd, response.c_str(), response.size());

    logMessage(DEBUG, "out Recver");
}

在这里插入图片描述

自此poll服务器就已经写完了，很显然poll服务器主体代码和select服务器一模一样，只不过poll在进行事件监听的时候明显要比select简洁，而且数组没有上限。

poll服务器完整代码

#pragma once

#include <iostream>
#include <functional>
#include <poll.h>
#include "sock.hpp"

using namespace std;

class pollServer
{
    static const int defaultport = 8080;
    static const int defaultfd = -1;
    static const int defaultnum = 2048;

    using func_t = function<string(string)>;

public:
    pollServer(func_t f, int port = defaultport) : _cbs(f), _port(port), _listensock(-1), _rfds(nullptr)
    {
    }

    void initServer()
    {
        // 1.创建套接字
        _listensock = Sock::sock();
        Sock::Bind(_listensock, _port);
        Sock::Listen(_listensock);

        _rfds = new struct pollfd[defaultnum]; // 大小这里自己随便定
        for (int i = 0; i < defaultnum; ++i)    ResetItem(i);
        _rfds[0].fd = _listensock; // 这个位置后面就不变了
        _rfds[0].events = POLLIN;  // 告诉内核帮我关心_listensock读事件
    }

    void print()
    {
        for (int i = 0; i < defaultnum; ++i)
        {
            if (_rfds[i].fd != defaultfd)
                cout << _rfds[i].fd << " ";
        }
        cout << endl;
    }

    void Accepter(int listensock)
    {

        logMessage(DEBUG, "Accepter in");

        // 走到这里,accept 函数,会不会被阻塞?

        // 走到这里就是, poll 告送我,_listensock就绪了,然后才能执行下面代码

        string clientip;
        uint16_t clientport;
        int sock = Sock::Accept(listensock, &clientip, &clientport);  accept = 等 + 获取
        if (sock < 0)
            return;
        logMessage(NORMAL, "accept success [%s:%d]", clientip.c_str(), clientport);

        // 得到一个sock套接字后，然后我们可以直接进行read/recv吗? 不能,整个代码只有poll有资格检测事件是否就绪
        // 将新的sock 托管给poll！
        // 将新的sock，托管给select的本质，其实就是将sock，添加到fdarray数组里！
        int i = 0;
        for (; i < defaultnum; ++i)
        {
            if (_rfds[i].fd != defaultfd)
                continue;
            else
                break;
        }
        if (i == defaultnum)
        {
            logMessage(WARNING, "server if full, please wait");
            close(sock);
        }
        else
        {
            _rfds[i].fd = sock;
            _rfds[i].events = POLLIN;
            _rfds[i].revents = 0;
        }

        print();
        logMessage(DEBUG, "Accepter out");
    }

    void ResetItem(int i)
    {
        _rfds[i].fd = defaultfd;
        _rfds[i].events = 0;
        _rfds[i].revents = 0;
    }

    void Recver(int pos)
    {
        logMessage(DEBUG, "in Recver");

        // 1. 读取request
        // 这样读取是有问题的！
        char buffer[1024];
        ssize_t s = recv(_rfds[pos].fd, buffer, sizeof(buffer) - 1, 0); // 这里在进行读取的时候，会不会被阻塞？
        if (s > 0)                                                      // 读取成功
        {
            buffer[s] = 0;
            logMessage(NORMAL, "client# %s", buffer);
        }
        else if (s == 0) // 对方关闭了文件描述符
        {
            close(_rfds[pos].fd);
            ResetItem(pos);
            logMessage(NORMAL, "client quit");
            return;
        }
        else // 读取失败
        {
            close(_rfds[pos].fd);
            ResetItem(pos);
            logMessage(ERROR, "client quit: %s", strerror(errno));
            return;
        }

        // 2. 处理request
        std::string response = _cbs(buffer);

        // 3. 返回response
        // write bug
        write(_rfds[pos].fd, response.c_str(), response.size());

        logMessage(DEBUG, "out Recver");
    }

    // 1.handler event _rfds 中,不仅仅是有一个fd是就绪的,可能存在多个
    // 2.我们的poll目前只处理了read事件
    void HandlerEvent()
    {
        // 你怎么知道那些fd就绪了呢? 我不知道,我只能遍历
        for (int i = 0; i < defaultnum; ++i)
        {
            // 不合法fd
            if (_rfds[i].fd == defaultfd)
                continue;

            // 合法fd,但必须曾经向内核设置过帮我关心对应fd读事件才能往下走
            if (!(_rfds[i].events & POLLIN))
                continue;

            if (_rfds[i].fd == _listensock && _rfds[i].revents & POLLIN)
                Accepter(_listensock);
            else if (_rfds[i].revents & POLLIN)
                Recver(i);
        }
    }

    void start()
    {
        int timenout = -1;
        for (;;)
        {
            int n = poll(_rfds, defaultnum, timenout);
            switch (n)
            {
            case 0:
                logMessage(NORMAL, "timeout...");
                break;
            case -1:
                logMessage(WARNING, "poll error, code: %d, err string: %s", errno, strerror(errno));
                break;
            default:
                // 说明有事件就绪了,目前只有一个监听事件就绪了
                logMessage(NORMAL, "have event ready!");
                HandlerEvent(); // 这里不用传了,因为就绪事件就在_rfds里
                break;
            }
        }
    }

    ~pollServer()
    {
        if (_listensock != defaultfd)
            close(_listensock);
        if (_rfds)
            delete[] _rfds;
    }

private:
    int _listensock;
    int _port;
    struct pollfd *_rfds;
    func_t _cbs;
};

4.poll的优点缺点

poll的优点就不用过多介绍，输入输出分离，而且没有select上限的问题

poll的主要缺点依旧是遍历问题，因为我们交给poll多个文件描述符，poll在底层去遍历去查找。随着等待的文件描述符变多，poll要线性遍历的方式检测所有文件描述符，这势必会带来效率的降低 。

正是因为poll有这样的问题，所有才有了下一个多路转接之epoll

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

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

相关文章

物联网D4——OLED显示屏

物联网D4——OLED显示屏

OLED简介 调试方式 SCL和SDA端口 在STM32微控制器中&#xff0c;SCL代表Serial Clock&#xff08;串行时钟线&#xff09;&#xff0c;它是IC&#xff08;Inter-Integrated Circuit&#xff09;总线协议的两个信号线之一。IC总线是一种常用的双向同步串行通信接口&#xff0c;…
阅读更多...
el-tooltip 提示框样式修改？

el-tooltip 提示框样式修改？

【element-plus el-tooltip官网地址&#xff1a; Tooltip 文字提示 | Element Plus】 <el-tooltippopper-class"Tooltip":content"content"placement"top"effect"light" ><span class"content">{{ content }}&l…
阅读更多...
Leecode热题100---3：无重复字符的最长子串

Leecode热题100---3：无重复字符的最长子串

题目&#xff1a;给定一个字符串 s &#xff0c;请你找出其中不含有重复字符的 最长子串的长度。 C&#xff1a; 指针法&#xff0c;使用at读取字符串中的值&#xff1b; #include <iostream> #include <string> #include <vector> #include <windows.…
阅读更多...
Image Sensor固定模式噪声（FPN）的消除方法

Image Sensor固定模式噪声（FPN）的消除方法

本文介绍Image Sensor固定模式噪声&#xff08;FPN&#xff09;的消除方法。 固定模式噪声&#xff08;FPN&#xff09;英文全称&#xff1a;Fixed Pattern Noise&#xff0c;在Image Sensor调试过程中还是比较常见的&#xff0c;它的特点是噪声位置固定不变&#xff0c;不随采…
阅读更多...
echarts树图 改文本显示的地方的样式

echarts树图 改文本显示的地方的样式

树图改文本显示的时候的样式 虽然有点越改越丑 其中有一些失败的尝试 forammter 无法识别html元素 所以对于tooptips有用的html元素定义获取返回在这里写的话是不生效的 rich配置项里面的backgroundColor官方说支持 html元素和canvas元素 已经图片url 没有详细试验 官网地址 h…
阅读更多...
vue3+ts（＜script setup lang=“ts“＞）刷新页面后保持下拉框选中效果

vue3+ts（＜script setup lang=“ts“＞）刷新页面后保持下拉框选中效果

效果图&#xff1a; 代码&#xff1a; <template><div class"app-layout"><div class"app-box"><div class"header"><div class"header-left"></div><div class"title">室外智…
阅读更多...
K8s 二进制部署 上篇

K8s 二进制部署 上篇

一 K8S按装部署方式&#xff1a; ① Minikube Minikube是一个工具&#xff0c;可以在本地快速运行一个单节点微型K8S&#xff0c;仅用于学习、预览K8S的一些特 性使用。 部署地址&#xff1a;https://kubernetes.io/docs/setup/minikube ② Kubeadmin Kubeadmin也是一个工…
阅读更多...
简单聊聊分布式和集群

简单聊聊分布式和集群

前言 分布式和集群&#xff0c;我们都听的比较多&#xff0c;分布式系统和集群的概念对于刚进入职场的小伙伴可能不是很清楚&#xff0c;这篇文章我们就一起看看两者到底是什么&#xff0c;有什么区别。 什么是分布式系统&#xff1f; 先看下书面解释&#xff1a; 分布式系统…
阅读更多...
【easyX】动手轻松掌握easyX 1

【easyX】动手轻松掌握easyX 1

01 简单绘图 在这个程序中&#xff0c;我们先初始化绘图窗口。其次&#xff0c;简单绘制两条线。 #include <graphics.h>//绘图库头文件 #include <stdio.h> int main() {initgraph(640, 480);//初始化640✖480绘图屏幕line(200, 240, 440, 240);//画线(200,240)…
阅读更多...
英语单词量测试

英语单词量测试

网址&#xff1a;https://preply.com/en/learn/english/test-your-vocab 测试结果&#xff1a; 细节&#xff1a;英语母语者有20000-35000个单词的词汇量&#xff0c;8岁孩子的词汇量在8000个左右。而不是我们教育系统里说的&#xff0c;6000个单词足够用了。足够用&#xff0…
阅读更多...
你写HTML的时候，会注重语义化吗？

你写HTML的时候，会注重语义化吗？

其实说到语义化&#xff0c;多年前端开发经验的老手估计也不会太在意&#xff0c;有时候工期太紧&#xff0c;有时候自己疏忽&#xff0c;也就不那么在意了&#xff0c;直接DIVCSS一把梭下去了。 目录 什么是HTML 什么是HTML语义化 HTML语义化所带来的好处 我把CSS样式引入…
阅读更多...
如何在 Linux 上检查 CPU 和硬盘温度

如何在 Linux 上检查 CPU 和硬盘温度

为了更好地监测您的Linux系统的硬件健康状况&#xff0c;如CPU与硬盘温度、风扇转速等关键指标&#xff0c;采用lm_sensors与hddtemp这两款强大工具是明智之选。以下是关于这些工具的详尽指南&#xff0c;包括它们的功能介绍、安装步骤以及如何配置lm_sensors&#xff0c;旨在为…
阅读更多...
在Ubuntu22.04搭建xfce远程桌面

在Ubuntu22.04搭建xfce远程桌面

由于Ubuntu22.04云服务器&#xff08;带GPU&#xff09;只开放部分端口&#xff0c;某些服务&#xff08;如nacos&#xff09;有Web前端需要访问&#xff0c;但是相应的端口并没有开放&#xff0c;只有SSH端口可以使用。于是&#xff0c;就在Ubuntu22.04上安装xfce桌面环境&…
阅读更多...
企业为什么进行大数据迁移以及注意事项

企业为什么进行大数据迁移以及注意事项

在当今数字化时代&#xff0c;数据的迁移成为了企业优化其数据架构、提高数据处理能力、确保业务连续性和数据安全的关键步骤。企业可能出于多种原因&#xff0c;如成本效益、性能提升、系统升级、数据集中管理或云服务集成等&#xff0c;选择将数据从一个存储系统迁移到另一个…
阅读更多...
3-3 基于RYU的流量风暴事件原理与响应策略

3-3 基于RYU的流量风暴事件原理与响应策略

在传统网络中&#xff0c;存在着一定的广播流量&#xff0c;占据了一部分的网络带宽。同时&#xff0c;在有环的拓扑中&#xff0c;如果不运行某些协议&#xff0c;广播数据还会引起网络风暴&#xff0c;使网络瘫痪。 如有以下的一个网络拓扑结构&#xff08;3_2_topoplus.py) …
阅读更多...
素数筛详解c++

素数筛详解c++

一、埃式筛法 代码 二、线性筛法&#xff08;欧拉筛法&#xff09; 主要的思想就是一个质数的倍数(倍数为1除外)肯定是合数&#xff0c;那么我们利用这个质数算出合数&#xff0c;然后划掉这个合数&#xff0c;下次就可以不用判断它是不是质数&#xff0c;节省了大量的时间。 …
阅读更多...
python使用opencv实现手势识别并控制ppt

python使用opencv实现手势识别并控制ppt

需要使用到的包 from collections import dequeimport cv2 import numpy as np import math import shutilimport sys import os import time#这个求出现频率最高的太慢了&#xff0c;所以把它放弃了 from collections import Counter准备好安装包后需要获取图片 def star():…
阅读更多...
解决找不到msvcr100.dll,无法继续执行代码的5种方案

解决找不到msvcr100.dll,无法继续执行代码的5种方案

当你在使用电脑过程中&#xff0c;系统突然弹出一个提示框&#xff0c;显示“找不到msvcr100.dll&#xff0c;无法继续执行代码”&#xff0c;msvcr100.dll是Microsoft Visual C Redistributable Package的一部分&#xff0c;它是一个至关重要的动态链接库文件&#xff0c;许多…
阅读更多...
从零入门激光SLAM（十六）——卡尔曼滤波基础

从零入门激光SLAM（十六）——卡尔曼滤波基础

一、卡尔曼滤波简介KF 卡尔曼滤波器&#xff08;Kalman Filter&#xff09;是一种用于估计动态系统状态的递归算法。它通过结合系统的动态模型和噪声观测数据&#xff0c;提供对系统状态的最优估计。卡尔曼滤波器广泛应用于信号处理、控制系统、导航、计算机视觉等领域。 卡尔…
阅读更多...
视频智能检测AI智能分析网关V4告警消息推送：公众号消息推送的配置步骤介绍

视频智能检测AI智能分析网关V4告警消息推送：公众号消息推送的配置步骤介绍

TSINGSEE青犀智能分析网关V4属于高性能、低功耗的软硬一体AI边缘计算硬件设备&#xff0c;目前拥有3种型号&#xff08;8路/16路/32路&#xff09;&#xff0c;支持Caffe/DarkNet/TensorFlow/PyTorch/MXNet/ONNX/PaddlePaddle等主流深度学习框架。硬件内部署了近40种AI算法模型…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023