.net XMS中的IBM-MQ阅读器逐个返回处理过的消息

我正在实现一个组件，该组件读取特定队列中可用的所有消息，但应该只在消息内容被处理并持久化之后才从队列中异步删除消息。我们读取消息的速度比接收消息的速度要快(例如，在准备接收第一条消息之前，我们可能已经读取了10条消息)。当前的实现使用XMS API，但如果XMS不适合这些目的，我们可以切换到MQI。

我们已经尝试了两种方法来解决这个问题，但是这两种方法都有不可接受的缺点。我希望有人能提出一个更好的方法。

第一个实现使用专用线程中的IMessageConsumer来读取所有消息并在它们可用时发布它们的内容。当消息被处理后，将调用message.Acknowledge()方法。会话以"AcknowledgeMode.ClientAcknowledge"创建。这种方法的问题在于，根据文档，这会确认(并删除)所有已接收到的未确认消息。在上面的示例中，这将意味着所有10个读消息都将被第一个调用填充。所以这并不能真正解决问题。由于我们需要读取吞吐量，我们无法真正修改此解决方案，以便在读取第二条消息之前等待第一条消息的返回，等等。

第二个实现在一个确定的线程中使用IQueueBrowser来读取所有消息并发布其内容。这不会在读取队列时将消息从队列中删除。然后，一个单独的专用线程(在BlockingQueue上)等待已处理消息的JMS消息id。对于其中的每一个，它都构造一个专用的IMessageConsumer(使用带有JMSMessageID的消息选择器)来读取并返回消息。(XMS文档队列浏览器一节建议将IQueueBrowser与专用IMessageConsumer配对。)此方法确实可以按预期工作，但是，正如人们所想象的那样，它在MQ服务器上的cpu密集程度太高。