管理多个UDP套接字的超时

Manage timeouts for multiple UDP sockets

本文关键字：超时 套接字 UDP 管理      更新时间：2023-10-16

我必须为一门大学课程在Windows和Linux上编写一个TFTP (Trivial File Transfer Protocol)服务器。我正在使用c++，我想使用一个线程和select()来检查新的传入数据包。TFTP要求，如果数据包在一定时间内没有得到确认，则重新发送数据包。我想知道管理这些多个超时的最佳方法是什么。

我正在考虑创建一个std::列表，其中包含将连接与超时发生的绝对时间相关联的对象。列表通过增加超时时间来排序(所有超时在分配时都是相同的，所以新的超时总是最大的，可以到列表的末尾-否则我将需要一个映射而不是列表)。
由于我需要重置连接的超时，如果数据包及时到达，我想创建一个std::map，将连接与指向其在列表中的位置的迭代器关联起来。当一个连接的超时更新时，可以快速找到列表中的元素，更新并移动到列表的末尾(再次假设新的超时是最大的)。

这是处理问题的好方法还是有更简单的方法?

如果我理解正确的话，您有对连接/超时，并且您希望能够通过连接和超时访问这些对。通过连接，因为您必须在收到数据包时更改超时，通过超时，因为您需要知道下一个超时连接是什么。

如果您不反对boost，请查看multi_index。

如果你想滚动你自己的指针，你可以保留两组指针，给这两组指针不同的比较函数:

class Connection {
    ...
public:
    int GetTimeout() const;
    int GetID() const;
};
class TimeIsLess {
public:
    bool operator()(const Connection*c1, const Connection*c2) const {
        return c1->GetTimeout() < c2->GetTimeout();
    }
}
class IdIsLess {
public:
    bool operator()(const Connection*c1, const Connection*c2) const {
        return c1->GetId() < c2->GetId();
    }
}
std::set<Connection*,TimeIsLess> connectionsByTime;
std::set<Connection*,IdIsLess> connectionsById;

创建连接:

...
Connection * c = new Connection(id, timeout);
connectionsByTime.insert(c);
connectionsById.insert(c);
...

要获取下一个将超时的连接，只需获取第一个连接:

auto nextToTimeout = connectionsByTime.begin();
if (nextToTimeout != connectionsByTime.end())
{
    if ( (*nextToTimeout)->GetTimeout() < now )
    {
        // Close the connection
    }
}

要删除连接，必须从一个集合中移除指针，并从另一个集合中移除和删除指针。

这些都不是我编译的，所以不要指责我的错别字(:

相关文章：