C# - 限制消息队列

Question

我有将消息发送到 MessageQueue 的代码。

_queue.Send(new Message(myData));

该队列位于本地计算机上，并且从中 Receive() 的线程位于同一进程中。

如果消息插入速度快于提取速度，会发生什么情况？ Send() 会阻塞吗？ 有没有办法让我在向其中发送更多事件之前知道 MessageQueue 是否已满？ （我现在更愿意只记录myData而不发送事件）。

谢谢， 塞拉。

Answer 1

简短的回答：做简单的事情，不要限制发送。

长答案：
仅当分配用于保存的磁盘空间不足时，消息队列才会真正变满 - 这同时您的日志记录也将空间不足。消息队列非常擅长保存您尚未准备好处理的数据。不要限制发送。如果您关心系统管理和磁盘空间，那么您可能更愿意依赖 Window 出色的系统监控工具和磁盘空间使用阈值警报。您不需要为您的应用程序重新设计它。

除非您在仅内存模式下运行队列，但这可能是不必要的。如果您不能足够快地处理消息，那么您肯定有足够的时间让队列管理器将消息保存到磁盘。如果您要扩展到许多服务器上的许多消费者进程并且队列管理器上的磁盘 IO 成为瓶颈，那么您应该只考虑在仅内存模式下运行队列。同一台机器上的一个进程与这种情况相差甚远。 让队列管理器做它最擅长的事情。不要过早优化。

如果您实施指定的服务质量（例如每秒 X 条消息）并为客户处理更高质量的服务收取更多费用，则在接收端进行限制。我已经使用信号量成功完成了此操作，该信号量的资源限制等于每秒消耗的消息数。每个消费者线程都会拍摄消息开始时间的快照，处理 1 条消息，然后等待一秒结束，然后再放弃信号量。这样，如果消息处理时间超过 1 秒，但不会超出服务质量，则线程池可以增长以适应服务质量。

祝你好运！

Answer 2

设计一个系统，使消息的生成速度不超过消息的消耗速度，这是很好的做法，我同意这一点。尽管如此，消息生产者可能会因为队列已满而碰壁，尤其是当配额设置较低时。

为了应对这种情况，您需要监视 Send() 方法是否成功。如果您将消息发送到已满的队列中，则该消息将丢失，并且由于 Send() 返回 void，因此不会立即得出成功或失败的结果。但有一种方法可以检测到这一点。使用 MSMQ 时您应该请求确认。要接收它们，您需要使用管理队列。这样您就可以收到有关发生的不同事情的通知，包括队列已满。

Message msg = new Message
{
    Formatter = new BinaryMessageFormatter(),
    Body = data,
    AdministrationQueue = this.adminQueue,
    AcknowledgeType = AcknowledgeTypes.FullReachQueue
};

this.queue.Send(msg);

Message admMsg = this.adminQueue.Receive();
if (admMsg != null && admMsg.Acknowledgment == Acknowledgment.QueueExceedMaximumSize)
{
    // queue is full
}