如何在消息队列集成模式中构建数据完整性检查？

Question

我是订阅者应用程序。 我收到来自 Publisher 的消息。一次一条消息。

问题是：我想确保：

1. 我从我的发布者那里收到了相同数量的消息（并且没有丢弃任何内容）
2. 我收到的每条消息都完整准确（包括所有属性）

请告知这是否被隐式覆盖，或者我需要为此做任何特别的事情吗？

Answer 1

您应该使用支持事务和“仅一次”交付的 MQ 产品。通过使用这种软件，第二点 - 准确性 - 得到保证，因为如果出现任何问题，您将无法提交事务。第一点——没有消息被丢弃或跳过——是暗示的。有了事务，您就不能丢弃消息。那不会发生。如果其他订阅者而不是您阅读它们，您可以跳过它们。但是您的图片暗示每个 q 都有一个订阅者，因此您可以睡个好觉。

如果您想防止篡改消息，您可以使用 IBM MQ Advanced Message Security 之类的东西，或者在 MQ 之上构建您自己的应用级协议。

ActiveMQ 或 IBM MQ 非常适合您的用例。