seata实现分布式事务

1

2

3

4

5

<!--    seata 分布式事务    -->

<dependency>

<groupId>com.alibaba.cloud</groupId>

<artifactId>spring-cloud-starter-alibaba-seata</artifactId>

</dependency>

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

package com.ruben.config;

import com.alibaba.druid.pool.DruidDataSource;

import com.zaxxer.hikari.HikariDataSource;

import io.seata.rm.datasource.DataSourceProxy;

import org.apache.commons.lang3.StringUtils;

import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;

import org.springframework.boot.context.properties.ConfigurationProperties;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import javax.annotation.Resource;

import javax.sql.DataSource;

import java.util.Optional;

/**

 * @ClassName: SeataConfig

 * @Description: 我还没有写描述

 * @Date: 2021/3/14 0014 16:53

 * *

 * @author: <achao1441470436@gmail.com>

 * @version: 1.0

 * @since: JDK 1.8

 */

@Configuration

publicclassSeataConfig {

@Bean

@ConfigurationProperties(prefix = "spring.datasource")

public DataSource druidDataSource(){

returnnewDruidDataSource();

    }

}

1

2

3

4

5

6

7

8

9

10

seata:

enabled:true

application-id:${spring.application.name}

tx-service-group:ruben

config:

type:file

file:

name:file.conf

service:

disable-global-transaction:false

1

2

3

service{

    disableGlobalTransaction = false

}

1

2

3

4

5

6

7

8

9

10

11

@RestController

@RequestMapping("user")

publicclassUserController {

@Resource

private UserService userService;

@GetMapping("order")

public AjaxJson order() {

return userService.order();

    }

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

@Slf4j

@Service

publicclassUserServiceImplimplementsUserService {

@Resource

private MpOrderMapper mpOrderMapper;

@Resource

private ConsumerService consumerService;

@Override

@Transactional

@GlobalTransactional

public AjaxJson order() {

        consumerService.dropWare();

        mpOrderMapper.insert(OrderPO.builder().id(1L).build());

return AjaxJson.success();

    }

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

package com.ruben.feign;

import com.ruben.pojo.dto.PageDTO;

import com.ruben.utils.AjaxJson;

import org.springframework.cloud.openfeign.FeignClient;

import org.springframework.web.bind.annotation.GetMapping;

import org.springframework.web.bind.annotation.RequestBody;

@FeignClient("ruben-consumer")

publicinterfaceConsumerService {

@GetMapping("ware")

    AjaxJson dropWare();

}

1

2

3

4

5

6

7

8

9

package com.ruben.dao;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;

import com.ruben.pojo.po.OrderPO;

import org.apache.ibatis.annotations.Mapper;

@Mapper

publicinterfaceMpOrderMapperextendsBaseMapper<OrderPO> {

}

1

2

3

4

5

6

7

8

9

10

seata:

  enabled: true

  application-id: ${spring.application.name}

  tx-service-group: SEATA_GROUP

  config:

    type: file

    file:

      name: file.conf

  service:

    disable-global-transaction: false

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

package com.ruben.rubenproducerdemo.config;

import com.alibaba.druid.pool.DruidDataSource;

import com.zaxxer.hikari.HikariDataSource;

import io.seata.rm.datasource.DataSourceProxy;

import org.apache.commons.lang3.StringUtils;

import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;

import org.springframework.boot.context.properties.ConfigurationProperties;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import javax.annotation.Resource;

import javax.sql.DataSource;

import java.util.Optional;

/**

 * @ClassName: SeataConfig

 * @Description: 我还没有写描述

 * @Date: 2021/3/14 0014 16:53

 * *

 * @author: <achao1441470436@gmail.com>

 * @version: 1.0

 * @since: JDK 1.8

 */

@Configuration

publicclassSeataConfig {

@Bean

@ConfigurationProperties(prefix = "spring.datasource")

public DataSource druidDataSource(){

returnnewDruidDataSource();

    }

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

package com.ruben.rubenproducerdemo.controller;

import com.ruben.rubenproducerdemo.service.WareService;

import com.ruben.rubenproducerdemo.utils.AjaxJson;

import org.springframework.web.bind.annotation.GetMapping;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

/**

 * @ClassName: WareController

 * @Description: 我还没有写描述

 * @Date: 2021/3/13 0013 22:10

 * *

 * @author: <achao1441470436@gmail.com>

 * @version: 1.0

 * @since: JDK 1.8

 */

@RestController

@RequestMapping("ware")

publicclassWareController {

@Resource

private WareService wareService;

@GetMapping

public AjaxJson dropWare() {

return wareService.dropWare();

    }

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

package com.ruben.rubenproducerdemo.service.impl;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

import com.ruben.dao.WareMapper;

import com.ruben.rubenproducerdemo.pojo.po.WarePO;

import com.ruben.rubenproducerdemo.service.WareService;

import com.ruben.rubenproducerdemo.utils.AjaxJson;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import java.util.Optional;

/**

 * @ClassName: WareServiceImpl

 * @Description: 我还没有写描述

 * @Date: 2021/3/13 0013 22:14

 * *

 * @author: <achao1441470436@gmail.com>

 * @version: 1.0

 * @since: JDK 1.8

 */

@Service

publicclassWareServiceImplextendsServiceImpl<WareMapper, WarePO> implementsWareService {

@Override

@Transactional

public AjaxJson dropWare() {

WarePOware=this.getById("1");

        Optional.ofNullable(ware).map(WarePO::getWare).filter(w -> w <= 0).ifPresent(wi -> {

thrownewRuntimeException("卖光啦！");

        });

        Optional.ofNullable(ware).ifPresent(w -> this.updateById(WarePO.builder().id("1").ware(w.getWare() - 1).build()));

return AjaxJson.success("成功");

    }

}