欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

SpringBoot+Dubbo+Seata分布式事務(wù)實戰(zhàn)詳解

 更新時間：2019年07月02日 09:38:08   作者：清幽之地  
這篇文章主要介紹了SpringBoot+Dubbo+Seata分布式事務(wù)實戰(zhàn)詳解，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

前言

Seata 是 阿里巴巴開源的分布式事務(wù)中間件，以高效并且對業(yè)務(wù)0侵入的方式，解決微服務(wù)場景下面臨的分布式事務(wù)問題。

事實上，官方在GitHub已經(jīng)給出了多種環(huán)境下的Seata應(yīng)用示例項目，地址：https://github.com/seata/seata-samples。

為什么筆者要重新寫一遍呢，主要原因有兩點：

  1. 官網(wǎng)代碼示例中，依賴太多，分不清哪些有什么作用
  2. Seata相關(guān)資料較少，筆者在搭建的過程中，遇到了一些坑，記錄一下

一、環(huán)境準(zhǔn)備

本文涉及軟件環(huán)境如下：

  • SpringBoot 2.1.6.RELEASE
  • Dubbo 2.7.1
  • Mybatis 3.5.1
  • Seata 0.6.1
  • Zookeeper 3.4.10

1、業(yè)務(wù)場景

為了簡化流程，我們只需要訂單和庫存兩個服務(wù)。創(chuàng)建訂單的時候，調(diào)用庫存服務(wù)，扣減庫存。

涉及的表設(shè)計如下：

CREATE TABLE `t_order` (
 `id` int(11) NOT NULL AUTO_INCREMENT,
 `order_no` varchar(255) DEFAULT NULL,
 `user_id` varchar(255) DEFAULT NULL,
 `commodity_code` varchar(255) DEFAULT NULL,
 `count` int(11) DEFAULT '0',
 `amount` double(14,2) DEFAULT '0.00',
 PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=38 DEFAULT CHARSET=utf8;

CREATE TABLE `t_storage` (
 `id` int(11) NOT NULL AUTO_INCREMENT,
 `commodity_code` varchar(255) DEFAULT NULL,
 `name` varchar(255) DEFAULT NULL,
 `count` int(11) DEFAULT '0',
 PRIMARY KEY (`id`),
 UNIQUE KEY `commodity_code` (`commodity_code`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
另外還需要一個回滾日志表：
CREATE TABLE `undo_log` (
 `id` bigint(20) NOT NULL AUTO_INCREMENT,
 `branch_id` bigint(20) NOT NULL,
 `xid` varchar(100) NOT NULL,
 `rollback_info` longblob NOT NULL,
 `log_status` int(11) NOT NULL,
 `log_created` datetime NOT NULL,
 `log_modified` datetime NOT NULL,
 `ext` varchar(100) DEFAULT NULL,
 `context` varchar(100) DEFAULT NULL,
 PRIMARY KEY (`id`),
 UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=67 DEFAULT CHARSET=utf8;

2、Seata下載安裝

打開https://github.com/seata/seata/releases，目前最新版本是v0.6.1。

下載解壓后，到seata-server-0.6.1\distribution\bin目錄下可以看到seata-server.bat和seata-server.sh，選擇一個雙擊執(zhí)行。
不出意外的話，當(dāng)你看到-Server started ...等字樣，就正常啟動了。

3、Maven依賴

由于是Dubbo項目，我們先引入Dubbo相關(guān)依賴。

<dependency>
 <groupId>org.apache.dubbo</groupId>
 <artifactId>dubbo</artifactId>
 <version>2.7.1</version>
</dependency>
<dependency>
 <groupId>org.apache.dubbo</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>2.7.1</version>
</dependency>
Dubbo的服務(wù)要注冊到Zookeeper，引入curator客戶端。
<dependency>
 <groupId>org.apache.curator</groupId>
 <artifactId>curator-framework</artifactId>
 <version>2.13.0</version>
</dependency>
<dependency>
 <groupId>org.apache.curator</groupId>
 <artifactId>curator-recipes</artifactId>
 <version>2.13.0</version>
</dependency>

最后，引入Seata。

<dependency>
 <groupId>io.seata</groupId>
 <artifactId>seata-all</artifactId>
 <version>0.6.1</version>
</dependency>

當(dāng)然了，還有其他的如Mybatis、mysql-connector等就不粘了，自行引入即可。

二、項目配置

1、application.properties

這里只需要配置數(shù)據(jù)庫連接信息和Dubbo相關(guān)信息即可。

server.port=8011

spring.datasource.url=jdbc:mysql://127.0.0.1:3306/seata
spring.datasource.username=root
spring.datasource.password=root

dubbo.application.name=order-service
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.protocol.name=dubbo
dubbo.protocol.port=20881
dubbo.consumer.timeout=9999999
dubbo.consumer.check=false

2、數(shù)據(jù)源

Seata 是通過代理數(shù)據(jù)源實現(xiàn)事務(wù)分支，所以需要先配置一個數(shù)據(jù)源的代理，否則事務(wù)不會回滾。

@Bean
public DataSourceProxy dataSourceProxy(DataSource dataSource) {
 return new DataSourceProxy(dataSource);
}

注意，這里的DataSourceProxy類位于io.seata.rm.datasource包內(nèi)。

3、Seata配置

還需要配置全局事務(wù)掃描器。有兩個參數(shù)，一個是應(yīng)用名稱，一個是事務(wù)分組。

@Bean
public GlobalTransactionScanner globalTransactionScanner() {
 return new GlobalTransactionScanner("springboot-order", "my_test_tx_group");
}

事實上，關(guān)于Seata事務(wù)的一系列初始化工作都在這里完成。

4、配置注冊中心

Seata連接到服務(wù)器的時候需要一些配置項，這時候有一個registry.conf文件可以指定注冊中心和配置文件是什么。

這里有很多可選性，比如file、nacos 、apollo、zk、consul。

后面4個都是業(yè)界成熟的配置注冊中心產(chǎn)品，為啥還有個file呢？

官方的初衷是在不依賴第三方配置注冊中心的基礎(chǔ)上快速集成測試seata功能，但是file類型本身不具備注冊中心的動態(tài)發(fā)現(xiàn)和動態(tài)配置功能。

registry.conf文件內(nèi)容如下：

registry {
 type = "file"
 file {
  name = "file.conf"
 }
}
config {
 # file、nacos 、apollo、zk、consul
 type = "file"
 file {
  name = "file.conf"
 }
}

如果你選擇了file類型，通過name屬性指定了file.conf，這個文件中指定了客戶端或服務(wù)器的配置信息。比如傳輸協(xié)議、服務(wù)器地址等。

service {
 #vgroup->rgroup
 vgroup_mapping.my_test_tx_group = "default"
 #only support single node
 default.grouplist = "127.0.0.1:8091"
 #degrade current not support
 enableDegrade = false
 #disable
 disable = false
}

三、業(yè)務(wù)代碼

1、庫存服務(wù)

在庫存服務(wù)中，拿到商品編碼和購買總個數(shù)，扣減即可。

<update id="decreaseStorage">
 update t_storage set count = count-${count} where commodity_code = #{commodityCode}
</update>

然后用Dubbo將庫存服務(wù)扣減接口暴露出去。

2、訂單服務(wù)

在訂單服務(wù)中，先扣減庫存，再創(chuàng)建訂單。最后拋出異常，然后去數(shù)據(jù)庫檢查事務(wù)是否回滾。

@GlobalTransactional
public void createOrder(OrderDTO orderDTO) {

 System.out.println("開始全局事務(wù)。XID="+RootContext.getXID());
 StorageDTO storageDTO = new StorageDTO();
 storageDTO.setCount(orderDTO.getCount());
 storageDTO.setCommodityCode(orderDTO.getCommodityCode());
 
 //1、扣減庫存
 storageDubboService.decreaseStorage(storageDTO);
 
 //2、創(chuàng)建訂單
 orderDTO.setId(order_id.incrementAndGet());
 orderDTO.setOrderNo(UUID.randomUUID().toString());
 Order order = new Order();
 BeanUtils.copyProperties(orderDTO,order);
 orderMapper.createOrder(order);

 throw new RuntimeException("分布式事務(wù)異常..."+orderDTO.getOrderNo());
}

值得注意的是，在訂單服務(wù)事務(wù)開始的方法上，需要標(biāo)注@GlobalTransactional。另外，在庫存服務(wù)的方法里，不需要此注解，事務(wù)會通過Dubbo進(jìn)行傳播。

四、注意事項

1、數(shù)據(jù)源

請切記，Seata 是通過代理數(shù)據(jù)源實現(xiàn)事務(wù)分支，一定不要忘記配置數(shù)據(jù)源代理。

2、主鍵自增

在數(shù)據(jù)庫中，表里的主鍵ID字段都是自增的。如果你的字段不是自增的，那么在Mybatis的insert SQL中，要將列名寫完整。
比如我們可以這樣寫SQL：

INSERT INTO table_name VALUES (值1, 值2,....)

那么這時候就要寫成：

INSERT INTO table_name (列1, 列2,...) VALUES (值1, 值2,....)

3、序列化問題

在訂單表中，amount字段類型為double。在seata0.6.1版本中，默認(rèn)的序列化方式為fastjson，但它會將這個字段序列化成bigdecimal類型，會導(dǎo)致后面類型不匹配。

但是在后續(xù)的seata0.7.0版本中(還未發(fā)布)，已經(jīng)將默認(rèn)的序列化方式改為了jackson。

不過無需擔(dān)心，這個問題一般不會出現(xiàn)。筆者是因為引錯了一個包，才導(dǎo)致發(fā)現(xiàn)這問題。

4、本文代碼

本文示例代碼在：https://github.com/taoxun/springboot-dubbo-zookeeper-seata。

5、其他

歡迎有問題及時交流~

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

相關(guān)文章

  • MyBatis動態(tài)SQL實現(xiàn)配置過程解析

    MyBatis動態(tài)SQL實現(xiàn)配置過程解析

    這篇文章主要介紹了MyBatis動態(tài)SQL實現(xiàn)配置過程解析,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2020-03-03
  • Java在PDF中替換文字詳解及可能遇到的問題

    Java在PDF中替換文字詳解及可能遇到的問題

    本文詳細(xì)介紹了如何使用Java和Spire.PDF?for?Java庫在PDF文檔中批量替換文字,包括替換特定文字的所有實例、第一個實例以及使用正則表達(dá)式,同時,探討了可能遇到的問題及其解決方案,需要的朋友可以參考下
    2024-09-09
  • Spring AOP實現(xiàn)功能權(quán)限校驗功能的示例代碼

    Spring AOP實現(xiàn)功能權(quán)限校驗功能的示例代碼

    本篇文章主要介紹了Spring AOP實現(xiàn)功能權(quán)限校驗功能的示例代碼，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
    2017-12-12
  • WebUploader客戶端批量上傳圖片 后臺使用springMVC

    WebUploader客戶端批量上傳圖片 后臺使用springMVC

    這篇文章主要為大家詳細(xì)介紹了WebUploader客戶端批量上傳圖片，后臺使用springMVC接收實例，具有一定的參考價值，感興趣的小伙伴們可以參考一下
    2018-09-09
  • Servlet虛擬路徑映射配置詳解

    Servlet虛擬路徑映射配置詳解

    這篇文章主要介紹了Servlet虛擬路徑映射配置詳解，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-02-02
  • 在Java編程中定義方法

    在Java編程中定義方法

    這篇文章主要介紹了在Java編程中定義方法,是Java入門學(xué)習(xí)中的基礎(chǔ)知識,需要的朋友可以參考下
    2015-10-10
  • Mybatis動態(tài)SQL foreach標(biāo)簽用法實例

    Mybatis動態(tài)SQL foreach標(biāo)簽用法實例

    這篇文章主要介紹了Mybatis動態(tài)SQL foreach標(biāo)簽用法實例,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2020-10-10
  • Druid關(guān)閉監(jiān)控頁面關(guān)閉不了的問題及解決

    Druid關(guān)閉監(jiān)控頁面關(guān)閉不了的問題及解決

    這篇文章主要介紹了Druid關(guān)閉監(jiān)控頁面關(guān)閉不了的問題及解決方案,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2024-05-05
  • Java內(nèi)存模型詳解

    Java內(nèi)存模型詳解

    JMM全稱Java Memory Model, 中文翻譯Java內(nèi)存模型，一種符合內(nèi)存模型規(guī)范的，屏蔽了各種硬件和操作系統(tǒng)的訪問差異的，本詳細(xì)介紹了Java內(nèi)存模型，感興趣的同學(xué)可以參考一下
    2023-04-04
  • SpringBoot報錯Invalid?bound?statement?(not?found)問題排查和解決方案

    SpringBoot報錯Invalid?bound?statement?(not?found)問題排查和解決方案

    這篇文章主要介紹了SpringBoot報錯Invalid?bound?statement?(not?found)問題排查和解決方案,文中通過圖文結(jié)合的方式講解的非常詳細(xì),對大家的學(xué)習(xí)或工作有一定的幫助,需要的朋友可以參考下
    2024-03-03

最新評論