消息队列实现方式

本地消息表(异步确保)

本地消息表这种实现方式应该是业界使用最多的,其核心思想是将分布式事务拆分成本地事务进行处理,这种思路是来源于ebay。我们可以从下面的流程图中看出其中的一些细节:
在这里插入图片描述
基本思路就是:

消息生产方,需要额外建一个消息表,并记录消息发送状态。消息表和业务数据要在一个事务里提交,也就是说他们要在一个数据库里面。然后消息会经过MQ发送到消息的消费方。如果消息发送失败,会进行重试发送。

消息消费方,需要处理这个消息,并完成自己的业务逻辑。此时如果本地事务处理成功,表明已经处理成功了,如果处理失败,那么就会重试执行。如果是业务上面的失败,可以给生产方发送一个业务补偿消息,通知生产方进行回滚等操作。

生产方和消费方定时扫描本地消息表,把还没处理完成的消息或者失败的消息再发送一遍。如果有靠谱的自动对账补账逻辑,这种方案还是非常实用的。

这种方案遵循BASE理论,采用的是最终一致性,笔者认为是这几种方案里面比较适合实际业务场景的,即不会出现像2PC那样复杂的实现(当调用链很长的时候,2PC的可用性是非常低的),也不会像
TCC那样可能出现确认或者回滚不了的情况。

优点:
一种非常经典的实现,避免了分布式事务,实现了最终一致性。在 .NET中 有现成的解决方案。

缺点:
消息表会耦合到业务系统中,如果没有封装好的解决方案,会有很多杂活需要处理。

MQ 事务消息

有一些第三方的MQ是支持事务消息的,比如RocketMQ,他们支持事务消息的方式也是类似于采用的二阶段提交,但是市面上一些主流的MQ都是不支持事务消息的,比如 RabbitMQ 和 Kafka 都不支持。
以阿里的 RocketMQ 中间件为例,其思路大致为:

第一阶段Prepared消息,会拿到消息的地址。 第二阶段执行本地事务,第三阶段通过第一阶段拿到的地址去访问消息,并修改状态。

也就是说在业务方法内要想消息队列提交两次请求,一次发送消息和一次确认消息。如果确认消息发送失败了RocketMQ会定期扫描消息集群中的事务消息,这时候发现了Prepared消息,它会向消息发送者确认,所以生产方需要实现一个check接口,RocketMQ会根据发送端设置的策略来决定是回滚还是继续发送确认消息。这样就保证了消息发送与本地事务同时成功或同时失败。

在这里插入图片描述
优点:
实现了最终一致性,不需要依赖本地数据库事务。

缺点:
实现难度大,主流MQ不支持,没有.NET客户端,RocketMQ事务消息部分代码也未开源。

相关推荐

  1. Unix消息队列实例

    2024-03-21 16:04:03       12 阅读

最近更新

  1. TCP协议是安全的吗?

    2024-03-21 16:04:03       14 阅读
  2. 阿里云服务器执行yum,一直下载docker-ce-stable失败

    2024-03-21 16:04:03       16 阅读
  3. 【Python教程】压缩PDF文件大小

    2024-03-21 16:04:03       15 阅读
  4. 通过文章id递归查询所有评论(xml)

    2024-03-21 16:04:03       18 阅读

热门阅读

  1. Linux运维_Bash脚本_编译安装PHP-7.4.28

    2024-03-21 16:04:03       18 阅读
  2. Rust字符串深入理解

    2024-03-21 16:04:03       14 阅读
  3. go语言请求http接口示例 并解析json

    2024-03-21 16:04:03       18 阅读
  4. 如何使用PL/SQL工具批量导出表、存储过程、序列

    2024-03-21 16:04:03       19 阅读
  5. Go 利用上下文进行并发计算

    2024-03-21 16:04:03       18 阅读
  6. 使用Go Validator在Go应用中有效验证数据

    2024-03-21 16:04:03       15 阅读
  7. 做好自己,顺应时代

    2024-03-21 16:04:03       19 阅读
  8. jvm相关

    2024-03-21 16:04:03       17 阅读