开发者社区 > 云原生 > 云消息队列 > 正文

RocketMQ上游修改失败了但广播又发出去了,下游拿了错误的数据是否每次都要判断上游数据的合法性?

RocketMQ上游修改失败了,但广播又发出去了,下游拿了个错误的数据是不是每次都要判断上游数据的合法性?

展开
收起
游客6poszk7nfmalm 2023-07-30 21:57:07 81 0
2 条回答
写回答
取消 提交回答
  • 当上游修改失败,但广播消息已经发送出去时,下游确实需要对接收到的数据进行合法性验证。这是为了确保下游处理的数据是正确和有效的。

    由于消息中间件如RocketMQ只负责消息的传递,并不关心消息的内容和业务逻辑,因此在下游消费者端,您需要自行对接收到的消息进行验证和处理。

    可以考虑以下几种方式来验证上游数据的合法性:

    1. 数据格式验证:检查接收到的消息是否符合预期的数据格式。例如,验证消息的字段是否完整、数据类型是否正确等。

    2. 业务逻辑验证:根据业务需求,对接收到的数据进行进一步的业务逻辑验证。例如,验证数据的取值范围是否正确、逻辑关系是否满足等。

    3. 签名或加密验证:在上游发送消息时,可以使用签名或加密技术对消息进行保护。下游消费者可以对接收到的消息进行签名验证或解密操作,以确保消息的完整性和安全性。

    无论采用哪种方式,都建议在下游消费者端进行严格的数据验证,以避免错误或恶意数据对系统造成影响。

    2023-07-31 14:49:11
    赞同 展开评论 打赏
  • 上游保证改成功了再发, 应该容易吧。
    ——此回答整理自钉群“群2-Apache RocketMQ 中国开发者钉钉群”

    2023-07-30 22:03:37
    赞同 展开评论 打赏

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

相关产品

  • 云消息队列 MQ
  • 相关电子书

    更多
    RocketMQ Client-GO 介绍 立即下载
    RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
    基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载