dotnet core 也能协调分布式事务啦！

2022 年 5 月 24 日，我们发布了 DBPack v0.1.0 版本，该版本主要 release 了分布式事务功能。在我们的规划里，DBPack 是要支持所有微服务开发语言协调分布式事务的，但经过社区反馈，dotnet core 并不支持。于是，我们在 v0.1.1 对 dotnet core 进行了支持。下面就如何支持 dotnet core 做一个说明。

MySql 协议

先请允许我对 MySql 的通信协议做一个简单的介绍。MySql 支持两种协议，一种是文本（Text）协议，一种是二进制（Binary）协议。MySql 客户端使用 COM_QUERY 发出的请求，MySql 服务端会以文本协议响应结果；使用 COM_STMT_EXECUTE 命令发出的请求，会以二进制协议响应结果。

在我们用程序调用 MySql Client SDK 发起请求的时候，不同的 MySql Client SDK 会默认使用不同的协议发送请求，但大部分 MySql Client SDK 都支持文本协议和二进制协议，我们可以通过修改属性配置改变 MySql Client SDK 的默认行为。比如：

• JAVA

@Mapper

public interface ProductMapper {

    @Update("UPDATE /*+ XID('${xid}') */ `product`.`inventory` SET `available_qty` = `available_qty` - #{qty}, allocated_qty = allocated_qty + #{qty} WHERE product_sysno = #{productSysNo} AND available_qty >= #{qty}")

    boolean allocateInventory(@Param("xid") String xid, @Param("productSysNo") long productSysNo, @Param("qty") int qty);

}

在 java 语言编写的微服务中，我们写了一个方法去修改商品的库存，当我们传入参数提交执行的时候，默认该 SQL 请求会被编码成

update /*+ XID('gs/aggregationSvc/81336085455405058') */ product.inventory set available_qty = available_qty - 2, allocated_qty = allocated_qty + 2 where product_sysno = 1 and available_qty >= 2;

通过 COM_QUERY 命令发出。

我们可以通过修改连接字符串，在原来的 jdbc:mysql://dbpack2:13307/product 上加上 useServerPrepStmts=true，改为 jdbc:mysql://dbpack2:13307/product?useServerPrepStmts=true，再次执行时，会首先发出 COM_STMT_PREPARE 请求：

UPDATE /*+ XID('gs/aggregationSvc/2612341069705662465') */ product.inventory set available_qty = available_qty - ?, allocated_qty = allocated_qty + ? WHERE product_sysno = ? and available_qty >= ?

获取到 statement id 后，再将 statement id 和请求参数编码后通过 COM_STMT_EXECUTE 命令发出。

• Golang

Golang MySql driver 默认是以二进制协议发送带参数的 DML 请求的，通过在 dsn 上加上参数 interpolateParams=true，才会以文本协议发送。例如：

dksl:[email protected](127.0.0.1:13306)/employees?interpolateParams=true&timeout=10s&readTimeout=10s&writeTimeout=10s&parseTime=true&loc=Local&charset=utf8mb4,utf8

Dotnet Core

Dotnet core 如果使用 EntityFrameworkCore 或者 Dapper 来访问数据库，目前还不支持使用 Prepared Statement，下面这两个 issue 有相关说明：

https://github.com/dotnet/efcore/issues/5459

https://github.com/DapperLib/Dapper/issues/474

在 v0.1.0 版本，我们只对 COM_STMT_EXECUTE 请求做了拦截处理，来协调分布式事务问题。dotnet core 使用 COM_QUERY 提交请求自然无法协调分布式事务，在 v0.1.1 我们增加了 COM_QUERY 请求协调分布式事务的支持，这样真正做到了支持所有微服务语言协调分布式事务。

dotnet core sample 见：https://github.com/CECTC/dbpack-samples/tree/main/dotnet。

其他特性

本次发版，还修复了一些 bug，增加了 status api 用于查询 dbpack 的运行状态：

$ curl http://localhost:9999/status

$ {

	"listeners": [{

		"protocol_type": "mysql",

		"socket_address": {

			"address": "0.0.0.0",

			"port": 13306

		},

		"active": true

	}],

	"distributed_transaction_enabled": true,

	"is_master": true

}

至此，我们有了

• /live
• /ready
• /status
• /metrics

这些 api 辅助我们查看 dbpack 的运行状态。

完整的版本变更日志请看 https://github.com/CECTC/dbpack/releases。

在下一个版本，我们会增加 tracing 和审计日志的功能。

一些链接

DBPack 项目地址：https://github.com/cectc/dbpack

DBPack 文档：https://cectc.github.io/dbpack-doc/#/

DBPack-samples：https://github.com/cectc/dbpack-samples

DBPack 介绍：https://mp.weixin.qq.com/s/DmXfk5bAcVYdnOwvp8ocHA

事件驱动的分布式事务架构设计：https://mp.weixin.qq.com/s/r43JvRY3LCETMoZjrdNxXA

dotnet core 也能协调分布式事务啦！的更多相关文章

1. .Net Core with 微服务 - 分布式事务 - TCC

   上一次我们讲解了分布式事务的 2PC.3PC .那么这次我们来理一下 TCC 事务.本次还是讲解 TCC 的原理跟 .NET 其实没有关系. TCC Try 准备阶段,尝试执行业务 Confirm 完 ...

2. .Net Core with 微服务 - 分布式事务 - 可靠消息最终一致性

   前面我们讲了分布式事务的2PC.3PC , TCC 的原理.这些事务其实都在尽力的模拟数据库的事务,我们可以简单的认为他们是一个同步行的事务.特别是 2PC,3PC 他们完全利用数据库的事务能力,在一 ...

3. .Net Core with 微服务 - 分布式事务 - 2PC、3PC

   最近比较忙,好久没更新了.这次我们来聊一聊分布式事务. 在微服务体系下,我们的应用被分割成多个服务,每个服务都配置一个数据库.如果我们的服务划分的不够完美,那么为了完成业务会出现非常多的跨库事务.即使 ...

4. .NET Core 事件总线,分布式事务解决方案：CAP

   背景 相信前面几篇关于微服务的文章也介绍了那么多了,在构建微服务的过程中确实需要这么一个东西,即便不是在构建微服务,那么在构建分布式应用的过程中也会遇到分布式事务的问题,那么 CAP 就是在这样的背景 ...

5. 使用TransactionScope做分布式事务协调

   //场景是使用在多个数据库之间的协调,.NET 2.0使用一个新的类型 TransactionScope来进行协调,这与之前的COM+协调是相对来说更加方便的 //需要引用一个新的程序集:System ...

6. .NET Core 事件总线,分布式事务解决方案：CAP 基于Kafka

   背景 相信前面几篇关于微服务的文章也介绍了那么多了,在构建微服务的过程中确实需要这么一个东西,即便不是在构建微服务,那么在构建分布式应用的过程中也会遇到分布式事务的问题,那么 CAP 就是在这样的背景 ...

7. 分布式事务解决方案以及 .Net Core 下的实现（上）

   数据一致性是构建业务系统需要考虑的重要问题 , 以往我们是依靠数据库来保证数据的一致性.但是在微服务架构以及分布式环境下实现数据一致性是一个很有挑战的的问题.最近在研究分布式事物,分布式的解决方案有很 ...

8. asp.net core集成CAP(分布式事务总线)

   一.前言 感谢杨晓东大佬为社区贡献的CAP开源项目,传送门在此:.NET Core 事件总线,分布式事务解决方案:CAP 以及 如何在你的项目中集成 CAP[手把手视频教程],之前也在工作中遇到分布式 ...

9. .net core 下的分布式事务锁

   原文:.net core 下的分布式事务锁 目录 系统分布式锁的用法 锁的实现 锁的使用 API内的范例: 引用链接 系统分布式锁的用法 公司框架新增功能分布式锁: 锁的性能之王: 缓存 > Z ...

10. SqlServer & Windows 可更新订阅立即更新启用分布式事务协调器（MSDTC）

    原文:SqlServer & Windows 可更新订阅立即更新启用分布式事务协调器(MSDTC) 在可更新订阅中,在订阅设置更新方法,将 "排队更新" 设置为 " ...

随机推荐

1. Log4j 简单应用

   #输出日志的包路径log4j.logger.com=DEBUG,FILE log4j.rootLogger=WARN,stdout #控制台日志 log4j.appender.stdout=org.a ...

2. JS 跨源请求

   一个 URL 大概包含的部分:scheme://host:port/path?#hash 比如一个 URL 为 http://www.xxx.com:8888/school/student.html, ...

3. 【转】【公司调查】车来了APP

   http://blog.sina.com.cn/s/blog_83b10acc0102vk7k.html   [APP简介] "车来了"是武汉元光科技有限公司开发的一款查询公交车实 ...

4. VBS 读取文本文件特殊字符前如逗号的值并赋值给变量

   我使用的仿真终端SecureCRT需要使用一个脚本,支持VBS的.我需要实现如下功能: 首先文本文件在:D:\100.txt文本文件的内容为:9 0,randy,9 1,jeff,9 2,sameul ...

5. GPU编程-Thread Hierarchy（3）

   1. 如果处理的数据是二维的或者三维的,应该怎么办呢? 针对的,我们可以按照二维或者三维的方式,组织线程.老规矩,先代码.后解释 // Kernel definition __global__ voi ...

6. Ajax检测用户名是否已经注册

   程序功能 当用户名输入完成(即用户名输入框失去焦点),利用Ajax检测用户名是否已经注册! 实现过程 利用Ajax向CheckUserServlet发送请求,判断该用户名是否可用.这里只是为了演示Aj ...

7. asp.net core 系列 16 Web主机 IWebHostBuilder

   一.概述 在asp.net core中,Host主机负责应用程序启动和生存期管理.host主机包括Web 主机(IWebHostBuilder)和通用主机(IHostBuilder).Web 主机是适 ...

8. 通过.ibd和.frm恢复mysql数据

   背景:因为机器损坏,数据库的索引文件什么的都损坏了.只留下了一个mysql的data目录… 此方法恢复数据的前提:建表用的innodb索引   备注:如果mysql的目录还都在,可以先尝试,将mysq ...

9. [转]用GSON 五招之内搞定任何JSON数组

   关于GSON的入门级使用,这里就不提了,如有需要可以看这篇博文 <Google Gson的使用方法,实现Json结构的相互转换> ,写的很好,通俗易懂. 我为什么写这篇文章呢?因为前几晚跟 ...

10. java 多线程12 ： 无锁 实现CAS原子性操作----原子类

    由于java 多线程11:volatile关键字该文讲道可以使用不带锁的情况也就是无锁使变量变成可见,这里就理解下如何在无锁的情况对线程变量进行CAS原子性及可见性操作 我们知道,在并发的环境下,要实 ...