linux搭建seata并使用

搭建seata

官网

在linux下搭建

下载1.6.1版本：地址

新建文件夹、上传压缩包并解压

[root@hao ~]# cd /usr/local/software/[root@hao /usr/local/software]# lscanaldockerelkgitlabjdkmysqlnacosnexusnginxrabbitmqredisredis_sentinelxxl-job[root@hao /usr/local/software]# mkdir seata[root@hao /usr/local/software]# lscanaldockerelkgitlabjdkmysqlnacosnexusnginxrabbitmqredisredis_sentinelseataxxl-job[root@hao /usr/local/software]# cd seata/[root@hao /usr/local/software/seata]# ls[root@hao /usr/local/software/seata]# tar -zxvf seata-server-1.6.1.tar.gzseata/Dockerfileseata/LICENSEseata/target/seata-server.jarseata/conf/application.ymlseata/conf/application.example.ymlseata/conf/logback-spring.xmlseata/bin/seata-server.sh

[root@hao /usr/local/software/seata]# lsseataseata-server-1.6.1.tar.gz

在nacos中创建命名空间

在数据库创建表【seata官方给出的步骤】【更改格式：时间戳】

CREATE TABLE `undo_log` (`branch_id` bigint(20) NOT NULL COMMENT 'branch transaction id',`xid` varchar(128) NOT NULL COMMENT 'global transaction id',`context` varchar(128) NOT NULL COMMENT 'undo_log context,such as serialization',`rollback_info` longblob NOT NULL COMMENT 'rollback info',`log_status` int(11) NOT NULL COMMENT '0:normal status,1:defense status',`log_created` datetime(6) NOT NULL COMMENT 'create datetime',`log_modified` datetime(6) NOT NULL COMMENT 'modify datetime',UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='AT transaction mode undo table';

备份原application.yml文件，将application.example.yml文件改为application.yml

[root@hao /usr/local/software/seata/seata]# cd conf/[root@hao /usr/local/software/seata/seata/conf]# lsapplication.example.ymlapplication.ymllogbacklogback-spring.xml[root@hao /usr/local/software/seata/seata/conf]# mv application.yml application.yml.bak[root@hao /usr/local/software/seata/seata/conf]# lsapplication.example.ymlapplication.yml.baklogbacklogback-spring.xml[root@hao /usr/local/software/seata/seata/conf]# mv application.example.yml application.yml[root@hao /usr/local/software/seata/seata/conf]# lsapplication.ymlapplication.yml.baklogbacklogback-spring.xml

配置application.yml文件

配置config模块

console:user:username: seatapassword: 123456seata:config:# support: nacos 、 consul 、 apollo 、 zk、 etcd3type: nacosnacos:# nacos服务器的地址server-addr: 192.168.133.100:8848# nacos中配置的seata的命名空间namespace: seata-id# namespace下组的命名group: SEATA_GROUP

注册中心registry模块

registry:# support: nacos 、 eureka 、 redis 、 zk、 consul 、 etcd3 、 sofatype: nacos# 配置允许连接的ip地址# preferred-networks: 30.240.*nacos:application: seata-serverserver-addr: 192.168.133.100:8848group: SEATA_GROUPnamespace: seata-id

配置store模块

store:# support: file 、 db 、 redismode: redissession:mode: filelock:mode: file

redis:mode: singledatabase: 1min-conn: 10max-conn: 100password:max-total: 100query-limit: 1000# 单个single:host: 192.168.133.100port: 6390# 哨兵模式sentinel:master-name:sentinel-hosts:

配置security模块

seata:#新添加内容，不加会报错security:secretKey: "securityKey"tokenValidityInMilliseconds: 1000000000

配置脚本文件script

[root@hao /usr/local/software/seata/seata/conf]# cd ..[root@hao /usr/local/software/seata/seata]# lsbinconfDockerfileextlibLICENSElogsscripttarget[root@hao /usr/local/software/seata/seata]# cd script/[root@hao /usr/local/software/seata/seata/script]# lsconfig-centerlogstashserver[root@hao /usr/local/software/seata/seata/script]# cd config-center/[root@hao /usr/local/software/seata/seata/script/config-center]# lsapolloconfig.txtconsuletcd3nacosREADME.mdzk[root@hao /usr/local/software/seata/seata/script/config-center]# cd nacos/[root@hao /usr/local/software/seata/seata/script/config-center/nacos]# lsnacos-config-interactive.pynacos-config-interactive.shnacos-config.pynacos-config.sh

编辑nacos-config.sh，【如果运行了nginx，修改端口为7777：自己的代理端口】

运行

sh nacos-config.sh -h 192.168.133.100

进入nacos查看，共103个配置文件

启动seata服务

进入bin文件夹进行启动

[root@hao /usr/local/software/seata/seata/script/config-center/nacos]# cd ..[root@hao /usr/local/software/seata/seata/script/config-center]# cd ..[root@hao /usr/local/software/seata/seata/script]# cd ..[root@hao /usr/local/software/seata/seata]# lsbinconfDockerfileextlibLICENSElogsscripttarget[root@hao /usr/local/software/seata/seata]# cd bin/[root@hao /usr/local/software/seata/seata/bin]# ./seata-server.shapm-skywalking not enabledseata-server is starting, you can check the /usr/local/software/seata/seata/logs/start.out

查看日志

进入nacos网页查看服务列表，查看seata-server服务

开启8091端口

在业务中使用

基于seata的订单业务

订单模块

表

CREATE TABLE `order` (`order_id` bigint NOT NULL AUTO_INCREMENT,`order_product` bigint DEFAULT NULL,`order_num` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '订单号',`order_quantity` int DEFAULT NULL,`order_create_by` varchar(32) DEFAULT NULL,`order_create_time` datetime DEFAULT NULL,`order_update_time` datetime DEFAULT NULL,PRIMARY KEY (`order_id`)) ENGINE=InnoDB AUTO_INCREMENT=15 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;

maven

<dependencies><dependency><groupId>com.wnhz.smart</groupId><artifactId>smart-cloud-store-api</artifactId><version>0.0.1-SNAPSHOT</version></dependency><dependency><groupId>com.wnhz.smart</groupId><artifactId>smart-cloud-common</artifactId><version>0.0.1-SNAPSHOT</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bootstrap</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-seata</artifactId><exclusions><exclusion><groupId>io.seata</groupId><artifactId>seata-all</artifactId></exclusion><exclusion><groupId>io.seata</groupId><artifactId>seata-spring-boot-starter</artifactId></exclusion></exclusions></dependency><dependency><groupId>io.seata</groupId><artifactId>seata-all</artifactId><version>1.6.1</version></dependency><dependency><groupId>io.seata</groupId><artifactId>seata-spring-boot-starter</artifactId><version>1.6.1</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-aop</artifactId></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build>

bootstrap.yml

spring:application:name: smart-cloud-ordercloud:nacos:discovery:server-addr: 192.168.133.100:8848namespace: smart-cloud-idgroup: devregister-enabled: trueconfig:server-addr: 192.168.133.100:8848namespace: smart-cloud-idfile-extension: yamlshared-configs:- dataId: db.yamlgroup: devrefresh: true- dataId: mp.yamlgroup: devrefresh: trueseata:enabled: truetx-service-group: default_tx_groupservice:vgroup-mapping:default_tx_group: defaultgrouplist:default: 192.168.133.100:8091

启动类

package com.wnhz.smart.cloud.order;import org.mybatis.spring.annotation.MapperScan;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.client.discovery.EnableDiscoveryClient;import org.springframework.cloud.openfeign.EnableFeignClients;/** * @author Hao * @date 2023-12-11 16:43 */@SpringBootApplication@MapperScan("com.wnhz.smart.cloud.domain.mapper")@EnableDiscoveryClient@EnableFeignClients("com.wnhz.smart.cloud.store.feign")public class SmartOrderApp {public static void main(String[] args) {SpringApplication.run(SmartOrderApp.class);}}

分布式事务使用

package com.wnhz.smart.cloud.order.service.impl;import cn.hutool.core.util.IdUtil;import com.wnhz.smart.cloud.domain.entity.Order;import com.wnhz.smart.cloud.domain.mapper.OrderMapper;import com.wnhz.smart.cloud.order.service.IOrderService;import com.wnhz.smart.cloud.store.feign.IStoreFeign;import io.seata.spring.annotation.GlobalTransactional;import lombok.extern.slf4j.Slf4j;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Service;import java.util.Date;/** * @author Hao * @date 2023-12-11 16:53 */@Service@Slf4jpublic class OrderServiceImpl implements IOrderService {@Autowiredprivate OrderMapper orderMapper;@Autowiredprivate IStoreFeign iStoreFeign;@GlobalTransactional@Overridepublic String generateOrder(Long productId, Integer quantity) {Order order = new Order().setOrderProduct(productId).setOrderQuantity(quantity).setOrderCreateBy("Linda").setOrderCreateTime(new Date()).setOrderUpdateTime(new Date());log.debug("产生订单对象：{}，准备调用库存组件...", order);orderMapper.insert(order);iStoreFeign.decr(productId, quantity);String orderNum = IdUtil.getSnowflakeNextIdStr();log.debug("去库存成功，完善订单产生订单号:{}", orderNum);order.setOrderNum(orderNum);orderMapper.updateById(order);log.debug("订单生成成功:{}", order);return orderNum;}}

在业务中捕获异常【因为正常情况下在这里调用的是openFeign的接口，所以异常是openFeign的异常，这里是想要知道seata的异常】

package com.wnhz.smart.cloud.order.aop;import io.seata.core.context.RootContext;import io.seata.core.exception.TransactionException;import io.seata.tm.api.GlobalTransactionContext;import lombok.extern.slf4j.Slf4j;import org.aspectj.lang.annotation.AfterThrowing;import org.aspectj.lang.annotation.Aspect;import org.aspectj.lang.annotation.Pointcut;import org.springframework.stereotype.Component;import org.springframework.util.StringUtils;/** * @author Hao * @date 2023-12-11 19:26 */@Aspect@Component@Slf4jpublic class SeataExceptionAop {@Pointcut("@annotation(io.seata.spring.annotation.GlobalTransactional)")private void transactionPointCut() {}@AfterThrowing(throwing = "e", pointcut = "transactionPointCut()")public void globalTransactionalException(Throwable e) throws TransactionException {log.debug("分布式事务异常:{}", e.getMessage());String xid = RootContext.getXID();if (StringUtils.hasText(xid)) {log.debug("XID：{}，执行回滚操作", xid);GlobalTransactionContext.reload(xid).rollback();log.debug("事务:{}回滚完成", xid);// throw new TransactionException("事务处理失败，回滚完成........");}}}

库存模块

表

CREATE TABLE `store` (`store_id` bigint NOT NULL AUTO_INCREMENT,`store_product` bigint DEFAULT NULL,`store_quantity` int DEFAULT NULL,`store_create_by` varchar(32) DEFAULT NULL,`store_create_time` datetime DEFAULT NULL,`store_update_by` datetime DEFAULT NULL,PRIMARY KEY (`store_id`)) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;

bootstrap.yml

spring:application:name: smart-cloud-storecloud:nacos:discovery:server-addr: 192.168.133.100:8848namespace: smart-cloud-idgroup: devregister-enabled: trueconfig:server-addr: 192.168.133.100:8848namespace: smart-cloud-idfile-extension: yamlshared-configs:- dataId: db.yamlgroup: devrefresh: true- dataId: mp.yamlgroup: devrefresh: true

api-feign接口

@FeignClient(value = "smart-cloud-store")public interface IStoreFeign {@GetMapping("/api/store/decr")ResponseResult<Void> decr(@RequestParam("productId") Long productId,@RequestParam("quantity") Integer quantity);}

order端

store端

完成