Skip to content

This issue was moved to a discussion.

You can continue the conversation there. Go to discussion →

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

How to use BASE transaction with seata? #31703

Closed
WXingSong opened this issue Jun 14, 2024 · 1 comment
Closed

How to use BASE transaction with seata? #31703

WXingSong opened this issue Jun 14, 2024 · 1 comment
Assignees
@linghengqian
Labels
feature: transaction status: pending type: question

Comments

@WXingSong
Copy link

WXingSong commented Jun 14, 2024 •
edited
Loading

version:

Sharding-jdbc: 5.5.0
Seata: 2.0.0
druid: 1.2.21
Springboot 3.2.1
spring cloud alibaba 2022.0.0.0

I also have the same problem with #31715

@AutoConfiguration
public class SeataFeignInterceptorConfiguration implements WebMvcConfigurer {


    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        registry.addInterceptor(new SeataFeignInterceptor()).addPathPatterns("/**");
    }

    public static class SeataFeignInterceptor implements HandlerInterceptor {

        @Override
        public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
            String xid = RootContext.getXID();
            if (xid == null) {
                xid = request.getHeader(RootContext.KEY_XID);
            }

            if (!StringUtils.isBlank(xid) && SeataTransactionHolder.get() == null) {
                RootContext.bind(xid);
                SeataTransactionHolder.set(GlobalTransactionContext.getCurrentOrCreate());
            }

            return true;
        }
    }
}

This is the execution result

SeataTestServiceImplA

2024-06-28 11:28:19.814 |  INFO 19460 | http-nio-48081-exec-1 [TID: N/A] c.i.y.f.a.c.i.ApiAccessLogInterceptor    | [afterCompletion][完成请求 URL(/admin-api/system/notify-message/get-unread-count) 耗时(175 ms)]
2024-06-28 11:28:22.376 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] c.i.y.f.a.c.i.ApiAccessLogInterceptor    | [preHandle][开始请求 URL(/admin-api/system/seataTest/saveSeataTest) 无参数]
2024-06-28 11:28:22.394 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] io.seata.tm.TransactionManagerHolder     | TransactionManager Singleton io.seata.tm.DefaultTransactionManager@527d7e7e
2024-06-28 11:28:22.405 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] i.seata.tm.api.DefaultGlobalTransaction  | Begin new global transaction [192.168.110.43:8091:1108421793403109164]
2024-06-28 11:28:22.413 | DEBUG 19460 | http-nio-48081-exec-2 [TID: N/A] c.i.y.m.s.d.m.s.SeataTset1Mapper.insert  | ==>  Preparing: INSERT INTO seata_test_1 (name, age, create_time, tenant_id) VALUES (?, ?, ?, 1)
2024-06-28 11:28:22.430 | DEBUG 19460 | http-nio-48081-exec-2 [TID: N/A] c.i.y.m.s.d.m.s.SeataTset1Mapper.insert  | ==> Parameters: 张三(String), 13(Integer), 2024-06-28T11:28:22.406878100(LocalDateTime)
2024-06-28 11:28:22.430 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] ShardingSphere-SQL                       | Logic SQL: INSERT INTO seata_test_1 (name, age, create_time, tenant_id) VALUES (?, ?, ?, 1)
2024-06-28 11:28:22.430 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] ShardingSphere-SQL                       | Actual SQL: master ::: INSERT INTO seata_test_1 (name, age, create_time, tenant_id) VALUES (?, ?, ?, 1) ::: [张三, 13, 2024-06-28T11:28:22.406878100]
2024-06-28 11:28:22.602 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] c.a.n.client.config.impl.ClientWorker    | [fixed-dev-127.0.0.1_8848] [subscribe] client.rm.lock.retryInterval+SEATA_GROUP+dev
2024-06-28 11:28:22.602 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] c.a.nacos.client.config.impl.CacheData   | [fixed-dev-127.0.0.1_8848] [add-listener] ok, tenant=dev, dataId=client.rm.lock.retryInterval, group=SEATA_GROUP, cnt=1
2024-06-28 11:28:22.602 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] c.a.nacos.client.config.impl.CacheData   | [fixed-dev-127.0.0.1_8848] [add-listener] ok, tenant=dev, dataId=client.rm.lock.retryInterval, group=SEATA_GROUP, cnt=2
2024-06-28 11:28:22.602 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] c.a.n.client.config.impl.ClientWorker    | [fixed-dev-127.0.0.1_8848] [subscribe] client.rm.lock.retryTimes+SEATA_GROUP+dev
2024-06-28 11:28:22.602 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] c.a.nacos.client.config.impl.CacheData   | [fixed-dev-127.0.0.1_8848] [add-listener] ok, tenant=dev, dataId=client.rm.lock.retryTimes, group=SEATA_GROUP, cnt=1
2024-06-28 11:28:22.602 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] c.a.nacos.client.config.impl.CacheData   | [fixed-dev-127.0.0.1_8848] [add-listener] ok, tenant=dev, dataId=client.rm.lock.retryTimes, group=SEATA_GROUP, cnt=2
2024-06-28 11:28:22.755 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] io.seata.rm.AbstractResourceManager      | branch register success, xid:192.168.110.43:8091:1108421793403109164, branchId:1108421793403109168, lockKeys:seata_test_1:224
2024-06-28 11:28:22.782 |  WARN 19460 | http-nio-48081-exec-2 [TID: N/A] ServiceLoader$InnerEnhancedServiceLoader | Load [io.seata.rm.datasource.undo.parser.ProtostuffUndoLogParser] class fail: io/protostuff/runtime/IdStrategy
2024-06-28 11:28:22.827 | DEBUG 19460 | http-nio-48081-exec-2 [TID: N/A] c.i.y.m.s.d.m.s.SeataTset1Mapper.insert  | <==    Updates: 1
2024-06-28 11:28:22.843 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] com.alibaba.nacos.client.naming          | [SUBSCRIBE-SERVICE] service:infra-server, group:DEFAULT_GROUP, clusters: 
2024-06-28 11:28:22.845 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] com.alibaba.nacos.client.naming          | init new ips(1) service: DEFAULT_GROUP@@infra-server -> [{"instanceId":"192.168.110.43#48082#DEFAULT#DEFAULT_GROUP@@infra-server","ip":"192.168.110.43","port":48082,"weight":1.0,"healthy":true,"enabled":true,"ephemeral":true,"clusterName":"DEFAULT","serviceName":"DEFAULT_GROUP@@infra-server","metadata":{"management.endpoints.web.base-path":"/actuator","preserved.register.source":"SPRING_CLOUD"},"instanceHeartBeatTimeOut":15000,"instanceHeartBeatInterval":5000,"ipDeleteTimeout":30000}]
2024-06-28 11:28:22.845 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] com.alibaba.nacos.client.naming          | current ips:(1) service: DEFAULT_GROUP@@infra-server -> [{"instanceId":"192.168.110.43#48082#DEFAULT#DEFAULT_GROUP@@infra-server","ip":"192.168.110.43","port":48082,"weight":1.0,"healthy":true,"enabled":true,"ephemeral":true,"clusterName":"DEFAULT","serviceName":"DEFAULT_GROUP@@infra-server","metadata":{"management.endpoints.web.base-path":"/actuator","preserved.register.source":"SPRING_CLOUD"},"instanceHeartBeatTimeOut":15000,"instanceHeartBeatInterval":5000,"ipDeleteTimeout":30000}]
2024-06-28 11:28:23.443 |  INFO 19460 | nacos-grpc-client-executor-192.168.110.43-10 [TID: N/A] com.alibaba.nacos.common.remote.client   | [46822bbd-0793-44b0-8ef1-6d486bd86d8c] Receive server push request, request = NotifySubscriberRequest, requestId = 2453
2024-06-28 11:28:23.444 |  INFO 19460 | nacos-grpc-client-executor-192.168.110.43-10 [TID: N/A] com.alibaba.nacos.common.remote.client   | [46822bbd-0793-44b0-8ef1-6d486bd86d8c] Ack server push request, request = NotifySubscriberRequest, requestId = 2453
2024-06-28 11:28:26.255 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] i.seata.tm.api.DefaultGlobalTransaction  | transaction 192.168.110.43:8091:1108421793403109164 will be rollback
2024-06-28 11:28:26.262 |  INFO 19460 | rpcDispatch_RMROLE_1_1_32 [TID: N/A] i.s.c.r.p.c.RmBranchRollbackProcessor    | rm handle branch rollback process:BranchRollbackRequest{xid='192.168.110.43:8091:1108421793403109164', branchId=1108421793403109168, branchType=AT, resourceId='jdbc:mysql://192.168.110.177:33067/runxi', applicationData='null'}
2024-06-28 11:28:26.263 |  INFO 19460 | rpcDispatch_RMROLE_1_1_32 [TID: N/A] io.seata.rm.AbstractRMHandler            | Branch Rollbacking: 192.168.110.43:8091:1108421793403109164 1108421793403109168 jdbc:mysql://192.168.110.177:33067/runxi
2024-06-28 11:28:26.409 |  INFO 19460 | rpcDispatch_RMROLE_1_1_32 [TID: N/A] i.s.r.d.undo.AbstractUndoLogManager      | xid 192.168.110.43:8091:1108421793403109164 branch 1108421793403109168, undo_log deleted with GlobalFinished
2024-06-28 11:28:26.422 |  INFO 19460 | rpcDispatch_RMROLE_1_1_32 [TID: N/A] i.seata.rm.datasource.DataSourceManager  | branch rollback success, xid:192.168.110.43:8091:1108421793403109164, branchId:1108421793403109168
2024-06-28 11:28:26.423 |  INFO 19460 | rpcDispatch_RMROLE_1_1_32 [TID: N/A] io.seata.rm.AbstractRMHandler            | Branch Rollbacked result: PhaseTwo_Rollbacked
2024-06-28 11:28:26.430 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] i.seata.tm.api.DefaultGlobalTransaction  | transaction end, xid = 192.168.110.43:8091:1108421793403109164
2024-06-28 11:28:26.430 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] i.seata.tm.api.DefaultGlobalTransaction  | [192.168.110.43:8091:1108421793403109164] rollback status: Rollbacked
2024-06-28 11:28:26.434 |  INFO 19460 | http-nio-48081-exec-2 [TID: N/A] c.i.y.f.w.c.h.GlobalExceptionHandler     | [serviceExceptionHandler]

SeataTestServiceImplB

2024-06-28 14:05:53.052 |  INFO 28996 | http-nio-48082-exec-3 [TID: N/A] c.i.y.f.a.c.i.ApiAccessLogInterceptor    | [preHandle][开始请求 URL(/rpc-api/infra/api-seataTest/saveSeataTest3) 无参数]
===================RootContext.getXID():192.168.110.43:8091:1108421793403109398
2024-06-28 14:05:53.057 | DEBUG 28996 | http-nio-48082-exec-3 [TID: N/A] c.i.y.m.i.d.m.s.SeataTest3Mapper.insert  | ==>  Preparing: INSERT INTO seata_test_3 (subject, achievement, create_time, tenant_id) VALUES (?, ?, ?, 1)
2024-06-28 14:05:53.064 | DEBUG 28996 | http-nio-48082-exec-3 [TID: N/A] c.i.y.m.i.d.m.s.SeataTest3Mapper.insert  | ==> Parameters: 数学(String), 90(Integer), 2024-06-28T14:05:53.055821300(LocalDateTime)
2024-06-28 14:05:53.065 |  INFO 28996 | http-nio-48082-exec-3 [TID: N/A] ShardingSphere-SQL                       | Logic SQL: INSERT INTO seata_test_3 (subject, achievement, create_time, tenant_id) VALUES (?, ?, ?, 1)
2024-06-28 14:05:53.065 |  INFO 28996 | http-nio-48082-exec-3 [TID: N/A] ShardingSphere-SQL                       | Actual SQL: master ::: INSERT INTO seata_test_3 (subject, achievement, create_time, tenant_id) VALUES (?, ?, ?, 1) ::: [数学, 90, 2024-06-28T14:05:53.055821300]
2024-06-28 14:05:53.204 | DEBUG 28996 | http-nio-48082-exec-3 [TID: N/A] c.i.y.m.i.d.m.s.SeataTest3Mapper.insert  | <==    Updates: 1
2024-06-28 14:05:53.206 |  INFO 28996 | http-nio-48082-exec-3 [TID: N/A] c.i.y.f.a.c.i.ApiAccessLogInterceptor    | [afterCompletion][完成请求 URL(/rpc-api/infra/api-seataTest/saveSeataTest3) 耗时(154 ms)]

I found that the connection used by SeataTestImplB when executing SQL is not Seata's ConnectionProxy, and branch transactions were not registered using ConnectionProxy#processGlobalTransactionCommit(). But I'm not sure if this is the reason why distributed transactions cannot be rolled back.

1719555129815
1719555179001

linghengqian no time check it😂. I really need your help very much @TherChenYang .Thanks~
@WXingSong
Copy link
Author

This is my demo https://github.com/WXingSong/sharding-seata-simple-demo.git @linghengqian
The same problem with #31715. Perform unit testing on the Seata integration module of ShardingSphere in the multi-microservice scenario.

@linghengqian linghengqian self-assigned this Jul 3, 2024
@apache apache locked and limited conversation to collaborators Jul 6, 2024
@terrymanu terrymanu converted this issue into discussion #32006 Jul 6, 2024

This issue was moved to a discussion.

You can continue the conversation there. Go to discussion →

Assignees

@linghengqian linghengqian

Labels
feature: transaction status: pending type: question
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
3 participants
@linghengqian @WXingSong @TherChenYang