bugfix: can't integrate dubbo with spring

changes/en-us/2.0.0.md

@@ -87,6 +87,7 @@ The version is updated as follows:
 - [[#5887](https://github.com/seata/seata/pull/5887)] fix global transaction hook repeat execute
 - [[#6018](https://github.com/seata/seata/pull/6018)] fix incorrect metric report
 - [[#6024](https://github.com/seata/seata/pull/6024)] fix the white screen after click the "View Global Lock" button on the transaction info page in the console
+- [[#6015](https://github.com/seata/seata/pull/6015)] fix can't integrate dubbo with spring
 
 ### optimize：
 - [[#5966](https://github.com/seata/seata/pull/5966)] decouple saga expression handling and remove evaluator package
@@ -219,6 +220,7 @@ Thanks to these contributors for their code commits. Please report an unintended
 - [Aruato](https://github.com/Aruato)
 - [ptyin](https://github.com/ptyin)
 - [jsbxyyx](https://github.com/jsbxyyx)
+- [xxxcrel](https://github.com/xxxcrel)
 
 
 Also, we receive many valuable issues, questions and advices from our community. Thanks for you all.

changes/zh-cn/2.0.0.md

@@ -86,6 +86,7 @@ Seata 是一款开源的分布式事务解决方案，提供高性能和简单
 - [[#5887](https://github.com/seata/seata/pull/5887)] 修复全局事务钩子重复执行
 - [[#6018](https://github.com/seata/seata/pull/6018)] 修复错误的 metric 上报
 - [[#6024](https://github.com/seata/seata/pull/6024)] 修复控制台点击事务信息页面中的"查看全局锁"按钮之后白屏的问题
+- [[#6015](https://github.com/seata/seata/pull/6015)] 修复在spring环境下无法集成dubbo
 
 
 ### optimize：
@@ -221,6 +222,7 @@ Seata 是一款开源的分布式事务解决方案，提供高性能和简单
 - [ggbocoder](https://github.com/ggbocoder)
 - [ptyin](https://github.com/ptyin)
 - [jsbxyyx](https://github.com/jsbxyyx)
+- [xxxcrel](https://github.com/xxxcrel)
 
 
 

integration-tx-api/src/main/java/io/seata/integration/tx/api/interceptor/parser/DefaultInterfaceParser.java

@@ -53,9 +53,9 @@ protected void initInterfaceParser() {
     }
 
     @Override
-    public ProxyInvocationHandler parserInterfaceToProxy(Object target) throws Exception {
+    public ProxyInvocationHandler parserInterfaceToProxy(Object target, String beanName) throws Exception {
         for (InterfaceParser interfaceParser : ALL_INTERFACE_PARSERS) {
-            ProxyInvocationHandler proxyInvocationHandler = interfaceParser.parserInterfaceToProxy(target);
+            ProxyInvocationHandler proxyInvocationHandler = interfaceParser.parserInterfaceToProxy(target, beanName);
             if (proxyInvocationHandler != null) {
                 return proxyInvocationHandler;
             }

integration-tx-api/src/main/java/io/seata/integration/tx/api/interceptor/parser/DefaultResourceRegisterParser.java

@@ -28,9 +28,9 @@ public class DefaultResourceRegisterParser {
 
     protected static List<RegisterResourceParser> allRegisterResourceParsers = new ArrayList<>();
 
-    public void registerResource(Object target) {
+    public void registerResource(Object target, String beanName) {
         for (RegisterResourceParser registerResourceParser : allRegisterResourceParsers) {
-            registerResourceParser.registerResource(target);
+            registerResourceParser.registerResource(target, beanName);
         }
     }
 

integration-tx-api/src/main/java/io/seata/integration/tx/api/interceptor/parser/GlobalTransactionalInterceptorParser.java

@@ -46,7 +46,7 @@ public class GlobalTransactionalInterceptorParser implements InterfaceParser {
      * @see GlobalLock // GlobalLock annotation
      */
     @Override
-    public ProxyInvocationHandler parserInterfaceToProxy(Object target) throws Exception {
+    public ProxyInvocationHandler parserInterfaceToProxy(Object target, String beanName) throws Exception {
         Class<?> serviceInterface = DefaultTargetClassParser.get().findTargetClass(target);
         Class<?>[] interfacesIfJdk = DefaultTargetClassParser.get().findInterfaces(target);
 

integration-tx-api/src/main/java/io/seata/integration/tx/api/interceptor/parser/InterfaceParser.java

@@ -22,7 +22,7 @@
  */
 public interface InterfaceParser {
 
-    ProxyInvocationHandler parserInterfaceToProxy(Object target) throws Exception;
+    ProxyInvocationHandler parserInterfaceToProxy(Object target, String beanName) throws Exception;
 
 
 }

integration-tx-api/src/main/java/io/seata/integration/tx/api/interceptor/parser/RegisterResourceParser.java

@@ -20,6 +20,6 @@
  */
 public interface RegisterResourceParser {
 
-    void registerResource(Object target);
+    void registerResource(Object target, String beanName);
 
 }

integration-tx-api/src/main/java/io/seata/integration/tx/api/remoting/parser/DefaultRemotingParser.java

@@ -75,6 +75,13 @@ protected void initRemotingParser() {
         }
     }
 
+    /**
+     * register custom remoting parser
+     * @param remotingParser
+     */
+    public void registerRemotingParser(RemotingParser remotingParser) {
+        allRemotingParsers.add(remotingParser);
+    }
     /**
      * is remoting bean ?
      *

integration-tx-api/src/main/java/io/seata/integration/tx/api/util/ProxyUtil.java

@@ -34,12 +34,16 @@ public class ProxyUtil {
     private static final Map<Object, Object> PROXYED_SET = new HashMap<>();
 
     public static <T> T createProxy(T target) {
+        return createProxy(target, target.getClass().getName());
+    }
+
+    public static <T> T createProxy(T target, String beanName) {
         try {
             synchronized (PROXYED_SET) {
                 if (PROXYED_SET.containsKey(target)) {
                     return (T) PROXYED_SET.get(target);
                 }
-                ProxyInvocationHandler proxyInvocationHandler = DefaultInterfaceParser.get().parserInterfaceToProxy(target);
+                ProxyInvocationHandler proxyInvocationHandler = DefaultInterfaceParser.get().parserInterfaceToProxy(target, beanName);
                 if (proxyInvocationHandler == null) {
                     return target;
                 }

integration-tx-api/src/test/java/io/seata/integration/tx/api/interceptor/parser/GlobalTransactionalInterceptorParserTest.java

@@ -33,7 +33,7 @@ void parserInterfaceToProxy() throws Exception {
         GlobalTransactionalInterceptorParser globalTransactionalInterceptorParser = new GlobalTransactionalInterceptorParser();
 
         //when
-        ProxyInvocationHandler proxyInvocationHandler = globalTransactionalInterceptorParser.parserInterfaceToProxy(business);
+        ProxyInvocationHandler proxyInvocationHandler = globalTransactionalInterceptorParser.parserInterfaceToProxy(business, business.getClass().getName());
 
         //then
         Assertions.assertNotNull(proxyInvocationHandler);

spring/src/main/java/io/seata/spring/annotation/GlobalTransactionScanner.java

@@ -41,8 +41,10 @@
 import io.seata.integration.tx.api.interceptor.handler.GlobalTransactionalInterceptorHandler;
 import io.seata.integration.tx.api.interceptor.handler.ProxyInvocationHandler;
 import io.seata.integration.tx.api.interceptor.parser.DefaultInterfaceParser;
+import io.seata.integration.tx.api.remoting.parser.DefaultRemotingParser;
 import io.seata.rm.RMClient;
 import io.seata.spring.annotation.scannercheckers.PackageScannerChecker;
+import io.seata.spring.remoting.parser.RemotingFactoryBeanParser;
 import io.seata.spring.util.OrderUtil;
 import io.seata.spring.util.SpringProxyUtils;
 import io.seata.tm.TMClient;
@@ -279,7 +281,7 @@ protected Object wrapIfNecessary(Object bean, String beanName, Object cacheKey)
                     return bean;
                 }
                 interceptor = null;
-                ProxyInvocationHandler proxyInvocationHandler = DefaultInterfaceParser.get().parserInterfaceToProxy(bean);
+                ProxyInvocationHandler proxyInvocationHandler = DefaultInterfaceParser.get().parserInterfaceToProxy(bean, beanName);
                 if (proxyInvocationHandler == null) {
                     return bean;
                 }
@@ -472,6 +474,8 @@ public void afterPropertiesSet() {
     @Override
     public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
         this.applicationContext = applicationContext;
+        RemotingFactoryBeanParser remotingFactoryBeanParser = new RemotingFactoryBeanParser(applicationContext);
+        DefaultRemotingParser.get().registerRemotingParser(remotingFactoryBeanParser);
         this.setBeanFactory(applicationContext);
     }
 

spring/src/main/java/io/seata/spring/remoting/parser/RemotingFactoryBeanParser.java

@@ -27,7 +27,11 @@
  */
 public class RemotingFactoryBeanParser extends AbstractedRemotingParser {
 
-    public static ApplicationContext applicationContext;
+    public ApplicationContext applicationContext;
+
+    public RemotingFactoryBeanParser(ApplicationContext applicationContext) {
+        this.applicationContext = applicationContext;
+    }
 
     /**
      * if it is proxy bean, check if the FactoryBean is Remoting bean
@@ -36,7 +40,7 @@ public class RemotingFactoryBeanParser extends AbstractedRemotingParser {
      * @param beanName           the bean name
      * @return boolean boolean
      */
-    protected static Object getRemotingFactoryBean(Object bean, String beanName) {
+    protected Object getRemotingFactoryBean(Object bean, String beanName) {
         if (!SpringProxyUtils.isProxy(bean)) {
             return null;
         }
@@ -55,7 +59,8 @@ public boolean isReference(Object bean, String beanName) {
         if (factoryBean == null) {
             return false;
         }
-        return DefaultRemotingParser.get().isReference(bean, beanName);
+        String factoryBeanName = "&" + beanName;
+        return DefaultRemotingParser.get().isReference(factoryBean, factoryBeanName);
     }
 
     @Override
@@ -64,7 +69,8 @@ public boolean isService(Object bean, String beanName) {
         if (factoryBean == null) {
             return false;
         }
-        return DefaultRemotingParser.get().isReference(bean, beanName);
+        String factoryBeanName = "&" + beanName;
+        return DefaultRemotingParser.get().isService(factoryBean, factoryBeanName);
     }
 
     @Override
@@ -73,12 +79,13 @@ public RemotingDesc getServiceDesc(Object bean, String beanName) throws Framewor
         if (factoryBean == null) {
             return null;
         }
-        return DefaultRemotingParser.get().getServiceDesc(bean, beanName);
+        String factoryBeanName = "&" + beanName;
+        return DefaultRemotingParser.get().getServiceDesc(factoryBean, factoryBeanName);
     }
 
-
     @Override
     public short getProtocol() {
         return 0;
     }
+
 }

spring/src/main/java/io/seata/spring/tcc/TccAnnotationProcessor.java

@@ -103,7 +103,7 @@ public void addTccAdvise(Object bean, String beanName, Field field, Class servic
                 RemotingDesc remotingDesc = new RemotingDesc();
                 remotingDesc.setServiceClass(serviceClass);
 
-                Object proxyBean = ProxyUtil.createProxy(bean);
+                Object proxyBean = ProxyUtil.createProxy(bean, beanName);
                 field.setAccessible(true);
                 field.set(bean, proxyBean);
                 LOGGER.info("Bean[" + bean.getClass().getName() + "] with name [" + field.getName() + "] would use proxy");

tcc/src/main/java/io/seata/rm/tcc/interceptor/parser/TccActionInterceptorParser.java

@@ -37,13 +37,13 @@
 public class TccActionInterceptorParser implements InterfaceParser {
 
     @Override
-    public ProxyInvocationHandler parserInterfaceToProxy(Object target) {
-        boolean isTxRemotingBean = TxBeanParserUtils.isTxRemotingBean(target, target.toString());
+    public ProxyInvocationHandler parserInterfaceToProxy(Object target, String beanName) {
+        boolean isTxRemotingBean = TxBeanParserUtils.isTxRemotingBean(target, beanName);
         if (isTxRemotingBean) {
             RemotingDesc remotingDesc = DefaultRemotingParser.get().getRemotingBeanDesc(target);
             if (remotingDesc != null) {
                 if (remotingDesc.isService()) {
-                    DefaultResourceRegisterParser.get().registerResource(target);
+                    DefaultResourceRegisterParser.get().registerResource(target, beanName);
                 }
                 if (remotingDesc.isReference()) {
                     //if it is a tcc remote reference

tcc/src/main/java/io/seata/rm/tcc/resource/parser/TccRegisterResourceParser.java

@@ -41,8 +41,8 @@
 public class TccRegisterResourceParser implements RegisterResourceParser {
 
     @Override
-    public void registerResource(Object target) {
-        boolean isTxRemotingBean = TxBeanParserUtils.isTxRemotingBean(target, target.toString());
+    public void registerResource(Object target, String beanName) {
+        boolean isTxRemotingBean = TxBeanParserUtils.isTxRemotingBean(target, beanName);
         if (isTxRemotingBean) {
             RemotingDesc remotingDesc = DefaultRemotingParser.get().getRemotingBeanDesc(target);
             if (remotingDesc != null) {

tcc/src/test/java/io/seata/rm/tcc/interceptor/parser/TccActionInterceptorParserTest.java

@@ -33,7 +33,7 @@ void parserInterfaceToProxy() {
         NormalTccActionImpl tccAction = new NormalTccActionImpl();
 
         //when
-        ProxyInvocationHandler proxyInvocationHandler = tccActionInterceptorParser.parserInterfaceToProxy(tccAction);
+        ProxyInvocationHandler proxyInvocationHandler = tccActionInterceptorParser.parserInterfaceToProxy(tccAction, tccAction.getClass().getName());
 
         //then
         Assertions.assertNotNull(proxyInvocationHandler);