个人中心
文章发布
退出
作者热门文章
- Java锁的逻辑（结合对象头和ObjectMonitor）
- 还在用饼状图？来瞧瞧这些炫酷的百分比可视化新图形（附代码实现）⛵
- 自动注册实体类到EntityFrameworkCore上下文，并适配ABP及ABPVNext
- 基于Sklearn机器学习代码实战
29
4
原⼦性(A)⼀致性(C)隔离性(I)持久性(D)
两个或多个事务并发操作相同的数据的时候事务之间的相互访问关系
- 查询当前隔离级别：select @@tx_isolation
- 设置隔离级别：set session transaction isolation level 隔离级别
- 开启事务：start transaction
- 提交事务：commit
- 事务回滚：rollaback
分布式事务：就是指事务的参与者、⽀持事务的服务器（数据库服务器）、资源服务器以及事务的管理器分布在分布式系统的不同节点中
分布式事务：完成事务的多个步骤位于不同的节点上分布式锁：⽤于解决分布式系统中事务之间的并发访问问题
分布式系统设计中的CAP定律和base理论
1、CAP原则⼜称CAP定律，指的是在⼀个分布式系统中的⼀致性（Consistency）、可⽤性（Availability）、分区容错性三者之间的权衡 。
2、CAP 原则指的是，这三个要素最多只能同时实现两点，不可能三者兼顾 。
- 在分布式系统⽆法同时满⾜CA，如果需要满⾜CA，则项⽬结构必须为单体架构
- 在分布式系统中可以满⾜CP 或者 AP，常规情况下微服务架构更多的是满⾜AP
。
1、 （强）⼀致性(Consistency) ：如果系统对⼀个写操作返回成功，那么之后的读请求都必须读到这个新数据；如果写操作返回失败，则所有的读操作都不能读到这个数据，对调⽤者⽽⾔数据具有强⼀致性.
- 强⼀致性：⼀旦写操作成功了，则所有的读操作都必须读取新数据；（如果想要保证数据的强⼀致性，就必须使⽤同⼀个数据存储/数据库）
- 弱⼀致性/最终⼀致性：当写操作成功之后，允许在⼀定的时间内读取到旧数据，但经过⼀段时间之后最终可以读取到新数据，保证数据最终是⼀致的
2、 可⽤性(Availability) ：当⽤户请求服务时，服务⼀定要给与响应，可以是降级响应。3、 分区容错性(Partition tolerance) ：在分布式系统中服务节点都是⽹络分布，⼀个或部分节点出现故障，其他节点仍能对外提供服务。
1、BASE是Basically Available(基本可⽤)，Soft State（软状态）和EventuallyConsistent（最终⼀致性）三个短语的缩写。2、BASE理论，是对CAP中⼀致性和可⽤性权衡的结果，其来源于对⼤规模互联⽹分布式系统实践的总结，是基于CAP定律逐步演化⽽来。其核⼼思想是即使⽆法做到强⼀致性，但每个应⽤都可以根据⾃身业务特点，采⽤适当的⽅式来使系统达到最终⼀致性。
1、 基本可⽤ ：指的是分布式系统中出现不可预知故障，允许其损失⼀部分的功能，但要保证整个系统的可⽤.
2、 软状态 ：允许系统中数据存在中间状态，这个中间状态不会影响系统的可⽤性；也就是允许不同节点的数据副本之间在数据同步过程中存在延时.
1、刚性事务：满⾜ACID特性的事务（强⼀致性）————本地事务2、柔性事务：满⾜BASE理论的事务（最终⼀致性）————分布式事务3、如何保证分布式事务的最终⼀致性？
- XA-2PC
- 补偿
- 异步确保
- 最⼤努⼒通知
XA模型—为分布式事务的多个参与者添加到⼀个事务管理器(事务协调者)
问题：1.性能问题：所有事务的参与者在提交阶段处于阻塞状态，占⽤系统资源（数据库连接）2.可靠性问题：如果事务协调者出现单点故障，将导致所有的参与者都处于锁定状态3.数据⼀致性问题：事务协调者和部分参与者在事务提交阶段挂了，有可能导致数据⼀致性问题优点：近乎100%的保证了数据的⼀致性缺点：实现复杂，牺牲了可⽤性，对性能影响⽐较⼤；适⽤于并发不⾼但是对数据⼀致性要求⽐较⾼的场景。
三段式提交就是在两段式提交进⾏改进的版本：
- 增了⼀个资源检查阶段（询问是否可以提交）
- 增加了超时设置——避免因TM故障导致TC⻓时间等待占⽤系统资源
存在的问题：和2PC提交⼀样，执⾏SQL之后需要保持数据库连接，影响系统性能
TCC, 即Try-Commit-Cancel
优点：1.性能提升：资源占⽤的粒度较⼩，不会⻓时间锁定所有资源2.数据的最终⼀致性：基于commit和cancel的幂等性
3PC——适⽤于对数据⼀致性要求较⾼的场景，对性能会有⼀定损耗TCC——性能优于3PC，但是不能保证数据的强⼀致性，可以保证最终⼀致性
LCN模式是通过代理Connection⽅式实现对本地事务的操作，然后由TxManager统⼀协调管理
1、@LcnTransaction lcn模式LCN模式是通过代理Connection的⽅式实现对本地事务的操作，然后在由TxManager统⼀协调控制事务。当本地 事务提交回滚或者关闭连接时将会执⾏假操作，该代理的连接将由LCN连接池管理。2、@TxcTransaction txc模式TXC模式命名来源于淘宝，实现原理是在执⾏SQL之前，先查询SQL的影响数据，然后保存执⾏的SQL快照信息和 创建锁。当需要回滚的时候就采⽤这些记录数据回滚数据库，⽬前锁实现依赖redis分布式锁控制。3、@TccTransaction tcc模式TCC事务机制相对于传统事务机制（X/Open XA Two-Phase-Commit），其特征在于它不依赖资源管理器(RM)对XA 的⽀持，⽽是通过对（由业务系统提供的）业务逻辑的调度来实现分布式事务。主要由三步操作，Try: 尝试执⾏业务、 Confirm:确认执⾏业务、 Cancel: 取消执⾏业务。
CREATE
TABLE
`t_tx_exception` (
`id`
bigint
(
20
)
NOT
NULL
AUTO_INCREMENT,
`group_id`
varchar
(
64
)
CHARACTER
SET
utf8mb4 COLLATE utf8mb4_general_ci
NULL
DEFAULT
NULL
,
`unit_id`
varchar
(
32
)
CHARACTER
SET
utf8mb4 COLLATE utf8mb4_general_ci
NULL
DEFAULT
NULL
,
`mod_id`
varchar
(
128
)
CHARACTER
SET
utf8mb4 COLLATE utf8mb4_general_ci
NULL
DEFAULT
NULL
,
`transaction_state`
tinyint
(
4
)
NULL
DEFAULT
NULL
,
`registrar`
tinyint
(
4
)
NULL
DEFAULT
NULL
,
`ex_state`
tinyint
(
4
)
NULL
DEFAULT
NULL
COMMENT
'
0 待处理 1已处理
'
,
`remark`
varchar
(
10240
)
NULL
DEFAULT
NULL
COMMENT
'
备注
'
,
`create_time`
datetime
(
0
)
NULL
DEFAULT
NULL
,
PRIMARY
KEY
(`id`) USING BTREE
) ENGINE
=
InnoDB AUTO_INCREMENT
=
967
CHARACTER
SET
=
utf8mb4 COLLATE
=
utf8mb4_general_ci ROW_FORMAT
=
Dynamic;
SET
FOREIGN_KEY_CHECKS
=
1
;
<
dependency
>
<
groupId
>
mysql
</
groupId
>
<
artifactId
>
mysql
-
connector
-
java
</
artifactId
>
<
version
>
5.1
.
47
</
version
>
</
dependency
>
<
dependency
>
<
groupId
>
com.codingapi.txlcn
</
groupId
>
<
artifactId
>
txlcn
-
tm
</
artifactId
>
<
version
>
5.0
.
2
.RELEASE
</
version
>
</
dependency
>
spring.application.name=
TransactionManager
server.port
=8801
#
JDBC 数据库配置
spring.datasource.driver-class-name=
com.mysql.jdbc.Driver
spring.datasource.url
=jdbc:mysql://47.96.11.185:3306/fmmall2?characterEncoding=UTF-8&serverTimeZone=
UTC
spring.datasource.username
=
root
spring.datasource.password
=
admin123
#
数据库⽅⾔
spring.jpa.database-platform=
org.hibernate.dialect.MySQL57Dialect
#
为TM创建持久化数据库表
spring.jpa.hibernate.ddl-auto=
update
#
TM监听Socket端⼝. 默认为 ${server.port} - 100
tx-lcn.manager.port=8070
#
TM后台登陆密码，默认值为codingapi
tx-lcn.manager.admin-key=
admin123
#
雪花算法的sequence位⻓度，默认为12位.
tx-lcn.manager.seq-len=12
#
异常回调开关。开启时请制定ex-url
tx-lcn.manager.ex-url-enabled=
false
#
开启⽇志,默认为false
tx-lcn.logger.enabled=
true
tx
-lcn.logger.driver-class-name=${spring.datasource.driver-
classname}
tx
-lcn.logger.jdbc-url=$
{spring.datasource.url}
tx
-lcn.logger.username=$
{spring.datasource.username}
tx
-lcn.logger.password=$
{spring.datasource.password}
#
redis 的设置信息. 线上请⽤Redis Cluster
spring.redis.host=47.96.11.185
spring.redis.port
=6379
spring.redis.password
=12345678
@SpringBootApplication
@EnableTransactionManagerServer
public
class
TxmanagerApplication {
public
static
void
main(String[] args) {
SpringApplication.run(TxmanagerApplication.
class
, args);
}
}
<dependency>
<groupId>com.codingapi.txlcn</groupId>
<artifactId>txlcn-tc</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<dependency>
<groupId>com.codingapi.txlcn</groupId>
<artifactId>txlcn-txmsg-netty</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
spring:
datasource: null
driver-class-name: com.mysql.jdbc.Driver
url: 'jdbc:mysql://localhost:3306/fmmall2?characterEncoding=utf-8'
username: root
password: admin123
tx-lcn:
client: null
manager-address: 'localhost:8070'
@TccTransaction
@Transactional
public
void
addOrder(Order order) {
orderDAO.insertOrder(order);
ResultVO vo
= repoInvokeService.update(order.getGid(), 1
);
System.out.println(vo);
}
1、@LcnTransaction lcn模式LCN模式是通过代理Connection的⽅式实现对本地事务的操作，然后在由TxManager统⼀协调控制事务。当本地 事务提交回滚或者关闭连接时将会执⾏假操作，该代理的连接将由LCN连接池管理。2、@TxcTransaction txc模式TXC模式命名来源于淘宝，实现原理是在执⾏SQL之前，先查询SQL的影响数据，然后保存执⾏的SQL快⾛信息和 创建锁。当需要回滚的时候就采⽤这些记录数据回滚数据库，⽬前锁实现依赖redis分布式锁控制。3、@TccTransaction tcc模式TCC事务机制相对于传统事务机制（X/Open XA Two-Phase-Commit），其特征在于它不依赖资源管理器(RM)对XA 的⽀持，⽽是通过对（由业务系统提供的）业务逻辑的调度来实现分布式事务。主要由三步操作，Try: 尝试执⾏业务、Confirm:确认执⾏业务、 Cancel: 取消执⾏业务。
最后此篇关于分布式事务保姆级教程的文章就讲到这里了,如果你想了解更多关于分布式事务保姆级教程的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。
29
4
0
我正在使用 PostgREST 将数据库实体暴露给使用这些实体的 Springboot 应用。 我的数据库中有两个实体，分别是 Person 和 City。 我想同时保存 Person 实体和 Cit
1、事务的定义 Redis的事务提供了一种“将多个命令打包， 然后一次性、按顺序地执行”的机制。 redis事务的主要作用就是串联多个命令防止别的命令插队。 但是，事务并不具有传统
SQLite 事务（Transaction） 事务（Transaction）是一个对数据库执行工作单元。事务（Transaction）是以逻辑顺序完成的工作单位或序列，可以是由用户手动操作完成，也可
事务是顺序组操作。 它们作为单个单元运行，并且直到组中的所有操作都成功执行时才终止。 组中的单个故障会导致整个事务失败，并导致对数据库没有影响。 事务符合ACID（原子性，一致性，隔离和耐久性）
我希望将 SqlKata 用于一个项目。但是，项目标准的一部分是查询应该能够作为事务执行。有没有一种方法可以使用 MSSQL 事务执行一个查询或多个查询？ 非常感谢。 最佳答案 SQLKata 使用
我只是以多线程方式测试 PetaPoco 事务... 我有一个简单的测试用例: -- 简单的值对象称之为 MediaDevice -- 插入一条记录，更新1000次 void TransactionT
我正在尝试从 Excel VBA 向 SQL 中插入一些数据。 SQL 命令是在 VBA 脚本的过程中构建的，包括使用一些 SQL 变量。 我试图了解事务在 VBA 中是如何工作的，以及它们是否可以处
情况如下: 一个大型生产客户端/服务器系统，其中一个中央数据库表具有某个列，该列的默认值是 NULL，但现在默认值是 0。但是在该更改之前创建的所有行当然仍然具有 null 值，这会在该系统中生成许多
数据库事务是一个熟悉的概念。 try { ... .. updateDB() .. ... commit(); } catch error { rollback(); }
我想了解使用传播支持进行 Spring 交易的用途。 java 文档提到如果具有 @Transactional(propagation = Propagation.SUPPORTS) 的方法从支持该事
我需要获取 hibernate 的事务 ID。对于每笔交易，此 ID 必须是唯一的。我尝试使用 session.getTransaction().hashCode()，但我相信这个值不是唯一的。 最佳
我从 firebase 收到以下消息:runTransactionBlock:启用持久性时检测到的使用情况。请注意，事务不会在应用重新启动后保留。 那么应用程序重新启动后到底会发生什么？由于主数据库的
我需要在 jdbc 中执行选择、更新、插入查询的序列。 这是我的代码: public String editRequest(){ connection = DatabaseUtil.getServi
Java 是否提供了一种智能“聚合”事务的方法？如果我有多个异构数据存储库，我想保持同步(即用于数据的 Postgres、用于图表的 Neo4j 以及用于索引的 Lucene)，是否有一个范例仅允许
我对标题中的主题有几个问题。首先，假设我们使用 JDBC，并且有 2 个事务 T1 和 T2。在 T1 中，我们在一个特定的行上执行 select 语句。然后我们对该行执行更新。在事务 T2 中，我们
我有一个 Python CGI 处理支付交易。当用户提交表单时，CGI 被调用。提交后，CGI 需要一段时间才能执行信用卡交易。在此期间，用户可能会按下 ESC 或刷新按钮。这样做不会“杀死”CGI，
我有一个代码，类似这样 def many_objects_saving(list_of_objects): for some_object in list_of_objects:
我有一个包含 100,000 条记录的表。我正在考虑使用事务来更新数据。将有一个查询将一列更新为零，并且大约有 5000 个更新，每个更新将更新一条记录。 这些大型事务对内存有何影响？事务运行时选择数
有没有办法在一个命令中执行 SQL 事务？例如 mysql_query(" START TRANSACTION; INSERT INTO table1 ....etc; INSERT INTO tab
真心希望能帮到你! 我使用以下函数在 PHP/MySql 应用程序中发送消息: public function sendMail($sender_id, $recipient_id, $subject
我是一名优秀的程序员,十分优秀！