实际生产环境中 实现一个分布式事务就需要写一个RoketMQLocalTransctionListener吗

Answer 1

elinor_0 2021-12-29 18:48:31

可以试试使用反射或者传递函数的方式

try{
            Map params=(Map)var2;
            Class c=(Class) params.get("class");
            Class[] argsClass=(Class[])params.get("argsClass");
            Object[] args=(Object[])params.get("args");
            String methodName=params.get("methodName").toString();
            Method method=c.getMethod(methodName,argsClass);
            method.invoke(c.newInstance(),args);
            return RocketMQLocalTransactionState.COMMIT;
        }catch (Exception e){
            return RocketMQLocalTransactionState.ROLLBACK;
        }

try{
            LocalListenerFunction function=(LocalListenerFunction)var2;
            function.execute();
            return RocketMQLocalTransactionState.COMMIT;
        }catch (Exception e){
            return RocketMQLocalTransactionState.ROLLBACK;
        }
https://blog.csdn.net/qq_41066277/article/details/122070210?spm=1001.2014.3001.5501

• 大目 #1

  点赞，是个路子

Answer 2

elinor_0 2021-12-29 18:44:13

可以通过函数式编程传递函数或者反射实现动态监听本地事务方法

Answer 3

大目 2021-03-26 11:26:59

是的…所以并不方便…

• elinor_0 #1

  老师，用反射的方式或者传递函数的方式进行优化，是否可以
  try{
              Map params=(Map)var2;
              Class c=(Class) params.get("class");
              Class[] argsClass=(Class[])params.get("argsClass");
              Object[] args=(Object[])params.get("args");
              String methodName=params.get("methodName").toString();
              Method method=c.getMethod(methodName,argsClass);
              method.invoke(c.newInstance(),args);
              return RocketMQLocalTransactionState.COMMIT;
          }catch (Exception e){
              return RocketMQLocalTransactionState.ROLLBACK;
          }
  
  try{
              LocalListenerFunction function=(LocalListenerFunction)var2;
              function.execute();
              return RocketMQLocalTransactionState.COMMIT;
          }catch (Exception e){
              return RocketMQLocalTransactionState.ROLLBACK;
          }
  https://blog.csdn.net/qq_41066277/article/details/122070210?spm=1001.2014.3001.5501