消息队列溢出避免

Question

我正在使用C++中的消息队列模板对消息进行排队，这恰好发生在队列中，SIP队列的大小是固定的，并且当我增加消息的速率和数量时，我就能够检测到消息队列中的过流。

我想避免消息队列溢出。因此，如果有人能指导我在消息队列中使用实用的避免溢出技术，这将有很大帮助。

关于流行的POSIX消息队列溢出避免的建议也是受欢迎的，因为我会从中得到一些想法。

Answer 1

您可以检测到溢出情况，这是很好的。接下来，您只需要定义溢出时的行为。通常有两种选择:阻塞或失败。

显然，阻塞队列需要一个互斥和条件变量：

std::unique_lock<std::mutex> lock(mutex);
while ( full() ) {
  cond.wait_for(lock, std::chrono::microseconds(milliseconds));
  // TODO: or define a max wait time and fail accordingly.
};
add(message);
return;

并在队列被消耗且不再溢出时执行cond.notify_one()。

Answer 2

通常用于消息队列的不是溢出--因为溢出太晚了。你有高水印之类的东西。(低Watermakr也值得一提，因为当您一致使用低水印时，这意味着您的队列可能太长或处理程序太多)。

一旦你击中高水印，你的信号给用户。您还可以实现几种策略，消除消息的语义。例如，您可能开始跳过每一条消息。您可以使用“溢出缓冲区”--非常轻量级的处理程序，它只需读取队列中的所有消息并将其存储在某种缓冲区中，可能就像文件一样简单，以便以后进行处理。您可能会做很多事情，但同样，您是在上这样做的，而不是在队列已经满的时候。