如何从消息队列中删除消息（仅当其格式良好时）？

Question

我想从一个队列中获取消息并将其发送到数据库。我只想在特定格式下才这样做。

如果我直接使用 Receive 方法，并且在访问消息的 Body 时发生一些异常，那么由于 的 Receive 方法，我会丢失消息MessageQueue 从队列中删除消息。

为了避免消息丢失，现在我首先Peek消息，如果其格式正确，我使用Receive方法将其从队列中删除以将其发送到数据库。

我写的代码是这样的：

 Message msg = _queue.Peek(new TimeSpan(0, 0, LoggingService.Configuration.ReceiveTimeout));

// LogMessage is my own class which is adding some more stuff to original message from MessageQueue                
LogMessage message = null;

                if (msg != null)
                {
                    if (!(msg.Formatter is BinaryMessageFormatter))
                        msg.Formatter = new BinaryMessageFormatter();

                    message = LogMessage.GetLogMessageFromFormattedString((string) msg.Body);

                    // Use Receive method to remove the message from queue. This line will we executed only if the above line does not
                    // throw any exception i.e. if msg.Body does not have any problem
                    Message wellFormattedMsg =
                         _queue.ReceiveById(msg.Id);

                      SendMessageToDatabase(message);
                }

先用Peek，再用Receive，这样的逻辑对吗？或者还有其他更好的方法来实现同样的目标吗？请注意，我不想一次收到所有消息。 MessageQueue 是非事务性的。

Answer 1

这与我每次手动将一条消息出队时所采用的方法相同，并且我没有遇到任何问题。

您似乎没有处理的一件事是如何处理队列上不具有所需格式的消息。您打算将其留在队列中吗？如果是这样，您最终可能会得到一个非常大的队列，并且在查看队列中尚未预期的消息时会遇到各种问题。如果无法删除这些消息，则将那些不具有所需格式的消息也出队并将它们存储在其他地方似乎更有意义。

Answer 2

“如果我直接使用 Receive 方法，并且在访问消息正文时发生一些异常，我会丢失消息，因为 MessageQueue 的 Receive 方法会从队列中删除消息。”

您应该使用事务接收，以便在事务中止时消息返回到队列。

干杯
约翰·布瑞克威尔