分布式事务教程

Neal Ford 是 ThoughtWorks 的总监兼软件架构师。在这一集中，我们讨论了关于软件架构的所有内容，涵盖了他最近的三本书：“软件架构基础”、“软件架构：硬部分”和“构建演化架构”。我们首先讨论了软件架构的定义以及它与软件设计的关系。Neal 随后描述了与权衡相关的软件架构的两

在系统中使用事件很棒，但是您如何确定您是否可靠地调度了事件？事件的传输需要可靠地完成，同时保持整个系统的一致性，无论是最终的还是立即的。在典型的设置中，数据库用于存储信息，队列用于在进程和系统之间发送消息。通常，事件在将信息存储在数据中的同一操作中直接分派到队列。这看起来似乎并没有明显的错误

所有成功的数据驱动组织都有一个共同点；他们有一个高质量和高效的数据创建过程。数据创建通常是数据团队成功与失败之间的区别。 数据创建的架构模式在数据创建中，有三种类型的架构模式：事件溯源EventSourcing变更

如果你想知道Saga模式是否适合你的场景，问问你自己：你的逻辑是否涉及多个步骤，其中一些步骤跨越机器、服务、分片或数据库，对于这些步骤，部分执行是不可取的？ 事实证明，这正是sagas的用武之地。 也许你

在 web 应用程序中，除了更新数据库之外，请求处理通常具有次要效果，例如更新另一个数据源或发送电子邮件。但是很难可靠地控制二次效应发生的时间和条件。 在这篇博文中，我将向您展示如何使用

作为一名软件工程师，我一直想知道事务是如何工作的，以及它们在分布式系统中是如何管理的，所以我用谷歌搜索了一下，发现了很多模式和规范，比如 JTA、2PC、SAGA、事件驱动架构、发件箱等…… 在本文中，我将概述分布式事务，并尝试解释两阶段提交模式。

SAGA是一种必不可少的微服务模式，它解决了分布式系统中维护数据一致性的问题 如果您正在从事 Java 微服务工作或准备需要微服务技能的 Java 开发人员面试，那么您必须准SAGA 模式。SAGA 是一种必不可少的微服务模式，旨在解决微服务架构中

与其他现代大数据平台一样，Kafka 通过将数据分区到集群中的多个节点来实现无限的水平可扩展性。对于 Kafka，这意味着每个主题都有 1 个或多个分区。 主题拥有的分区越多，并发性就越高，因此潜在的吞吐量就越高。

检测重复消息的唯一方法是在生产者端为事件生成一个唯一标识符。只有使用这些标识符，消费者才可能知道它第二次处理同一条消息，而不是具有相同属性的不同消息。 为了防止两次处理同一条消息，常用的方法是将它们存储在指定的表中，通常命名为processed_m

您的应用正在变得越来越好。它有更多的功能，更多的活跃用户，并且每天收集更多的数据。您的数据库现在导致应用程序的其余部分变慢。数据库分片可能是您问题的答案，但许多人不知道它是什么，最重要的是，不知道何时使用它。在本文中，我们将讨论什么是数据库分片、它是如何工作的以及使用它的最佳方式。

微服务/模块之间最常用的通信方式之一是通过事件进行异步通信。实施可靠的消息传递有时可能具有挑战性。在今天的文章中，我将向您介绍如何实现发件箱模式以保证事件的传递和可靠的消息传递。 发件箱模式（事务性发件箱或存储转发事件发布者）是解决方案。<

长期以来，事务数据库一直是应用程序设计中最关键的组成部分。为什么？因为稳定的数据库通常是混乱的分布式世界中正确性的最终实施点。没有他们，我们就会多付钱和少收钱。我们会失去试图从机场回家的乘客，我们会丢失购物车中的物品。我们的在线帐户会丢失、复制或损坏，并变得无法操作。 

由于我的新电动自行车在商店里而无法再次骑着它去上班（这次是因为电线问题导致自行车无法运行！），我开始考虑如何在我的自行车中创造一些冗余设置，这样我就不会因为简单的维护或供应链问题而一次被困在地铁上数周。如果我在修理当前自行车时要骑另一辆自行车怎么办？这肯定会有帮助，但电动自行车很贵，而且我在

在本文中，我想讨论实现 CDC 的几种不同方法，以及一些关键应用程序是什么以及 CDC 如何融入现代数据流架构的大局。 有几种从数据库中提取变更事件的方法，每一种都有自己的优点和缺点。因此，让我们仔细看看每种方法。  

将 ActiveMQ 与 Kafka 进行比较类似于将关系数据库与 NoSQL 进行比较。 ActiveMQ 不像 Kafka 那样适合云。但这并不意味着 ActiveMQ 不再有任何用例。仍然有大量业务用例需要保证信息的交付。

分布式有状态流处理具有挑战性，尤其是在处理故障和恢复方面。在流处理中，最常被问到的问题之一是“我的流处理系统是否保证每条记录都被处理一次且仅一次，即使在处理过程中遇到一些故障？” 通过“ exactly-once（精确一次）”语义，我的意思是每个传