Skip to content

Commit

Permalink
optimize: Upload the tcc fence transaction isolation level (#6679)
Browse files Browse the repository at this point in the history
  • Loading branch information
chengliefeng committed Aug 19, 2024
1 parent 79a6744 commit 53e3dcc
Show file tree
Hide file tree
Showing 3 changed files with 62 additions and 0 deletions.
5 changes: 5 additions & 0 deletions common/src/main/java/org/apache/seata/common/Constants.java
Original file line number Diff line number Diff line change
Expand Up @@ -101,6 +101,11 @@ public interface Constants {
*/
String TX_ACTION_CONTEXT = "actionContext";

/**
* isolation
*/
String TX_ISOLATION = "isolation";

/**
* default charset name
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,9 @@
import org.apache.seata.integration.tx.api.interceptor.TwoPhaseBusinessActionParam;
import org.apache.seata.integration.tx.api.interceptor.handler.AbstractProxyInvocationHandler;
import org.apache.seata.rm.tcc.api.TwoPhaseBusinessAction;
import org.apache.seata.rm.tcc.utils.MethodUtils;
import org.slf4j.MDC;
import org.springframework.transaction.annotation.Transactional;


import static org.apache.seata.common.ConfigurationKeys.TCC_ACTION_INTERCEPTOR_ORDER;
Expand Down Expand Up @@ -82,6 +84,7 @@ protected Object doInvoke(InvocationWrapper invocation) throws Throwable {
}
try {
TwoPhaseBusinessActionParam businessActionParam = createTwoPhaseBusinessActionParam(businessAction);
initTransactionalAnnotationContext(method, targetBean, businessActionParam.getBusinessActionContext());
//Handler the TCC Aspect, and return the business result
return actionInterceptorHandler.proceed(method, invocation.getArguments(), xid, businessActionParam,
invocation::proceed);
Expand All @@ -99,6 +102,13 @@ protected Object doInvoke(InvocationWrapper invocation) throws Throwable {
return invocation.proceed();
}

private void initTransactionalAnnotationContext(Method method, Object targetBean, Map<String, Object> businessActionContext) {
Transactional transactionalAnnotation = MethodUtils.getTransactionalAnnotationByMethod(method, targetBean);
if (transactionalAnnotation != null) {
businessActionContext.put(Constants.TX_ISOLATION, transactionalAnnotation.isolation().value());
}
}

private Annotation parseAnnotation(Method methodKey) throws NoSuchMethodException {
Annotation result = parseAnnotationCache.computeIfAbsent(methodKey, method -> {
Annotation twoPhaseBusinessAction = method.getAnnotation(getAnnotationClass());
Expand Down
47 changes: 47 additions & 0 deletions tcc/src/main/java/org/apache/seata/rm/tcc/utils/MethodUtils.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,47 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.seata.rm.tcc.utils;

import java.lang.reflect.Method;

import org.apache.seata.common.exception.ShouldNeverHappenException;
import org.springframework.core.annotation.AnnotatedElementUtils;
import org.springframework.transaction.annotation.Transactional;



public class MethodUtils {
/**
* Retrieve the Transactional annotation of a business method
* @param interfaceMethod interface method object
* @param targetTCCBean target tcc bean
* @return the @Transactional annotation
*/
public static Transactional getTransactionalAnnotationByMethod(Method interfaceMethod, Object targetTCCBean) {
String methodName = interfaceMethod.getName();
Class<?>[] parameterTypes = interfaceMethod.getParameterTypes();

Class<?> clazz = targetTCCBean.getClass();
Method implementationMethod;
try {
implementationMethod = clazz.getMethod(methodName, parameterTypes);
} catch (NoSuchMethodException e) {
throw new ShouldNeverHappenException(e);
}
return AnnotatedElementUtils.findMergedAnnotation(implementationMethod, Transactional.class);
}
}

0 comments on commit 53e3dcc

Please sign in to comment.