【问题标题】:Aspect breaking bytecode on specific class在特定类上破坏字节码
【发布时间】:2022-01-08 06:00:41
【问题描述】:

我是 AOP 的新手,我创建了一个方面来跟踪标记有 @Trace 注释的所有方法或类。我正在使用编译时编织。 (Java 8、Aspectj 1.8、Spring 4)

TraceAspect.java

@Aspect
public class TraceAspect {
    private static Map<String, Integer> threadMap = new HashMap<>();

    @Pointcut("@within(Trace) || @annotation(Trace)")
    void annotated(){}
    
    @Around("annotated() && execution(* *(..))")
    public Object trace(final ProceedingJoinPoint joinPoint) throws Throwable {
        String  threadName = Thread.currentThread().getName();

        String indent = indent(inThread(threadName));

        System.out.println(threadName + " : " + indent + "->  " + joinPoint.getSignature().toString());

        long start = System.nanoTime();
        Object ret = joinPoint.proceed();
        long end = System.nanoTime();

        System.out.println(threadName + " : " + indent + "<-  " + joinPoint.getSignature().toString() + " ended (took " + (end - start) + " nanoseconds)");

        outThread(threadName);
        return ret;
    }

    private String indent(int depth) {
        String result = "";
        for (int index = 0; index < depth; index++) {
            result += "   ";
        }
        return result;
    }

    private int inThread(String threadName) {
        if (threadMap.get(threadName) == null) {
            threadMap.put(threadName, 0);
        }

        int stackDepth = threadMap.get(threadName) + 1;
        threadMap.put(threadName, stackDepth);
        return stackDepth;
    }

    private void outThread(String threadName) {
        int stackDepth = threadMap.get(threadName) - 1;
        threadMap.put(threadName, stackDepth);
    }
}

当使用@Trace 标记CryptsyExchange.java(它是一个Spring Bean)时,类加载器在build(..) 方法上抛出ClassFormat 错误,同时在应用程序上下文中初始化该bean...

CryptsyExchange.java

@Trace
public class CryptsyExchange {
    private static final Logger LOGGER = LoggerFactory.getLogger(CryptsyExchange.class);

    private DataService dataService;
    private Configuration config;

    private Converter converter;
    private Exchange exchange;
    private List<CryptsyAccount> accounts = Collections.synchronizedList(new LinkedList<>());
    private CryptsyAccount defaultAccount;

    public static CryptsyExchange build(String name, DataService dataService, ConfigPathBuilder pathBuilder) {
        condition(notNullOrEmpty(name) && notNull(dataService, pathBuilder));

        CryptsyExchange cryptsyExchange = new CryptsyExchange();
        cryptsyExchange.dataService = dataService;


        // Loading configuration
        final Configuration configuration = Configuration.load(pathBuilder.getExchangeConfigPath(name));
        cryptsyExchange.config = configuration;

        // Retrieve corresponding exchange from datastore
        cryptsyExchange.exchange = dataService.registerExchange(cryptsyExchange.config.getString("exchange"));

        // Get accounts from configuration

        Map<String, Map<String, String>> accounts = configuration.getMap("accounts");

        // Initialize accounts
        accounts.entrySet().stream().forEach((entry) -> {
            String key = entry.getKey();
            Map<String, String> accountMap = entry.getValue();

            // Retrieve corresponding datastore account
            Account account = dataService.registerAccount(cryptsyExchange.exchange, key);

            // Initialize cryptsy specific account
            CryptsyAccount cryptsyAccount = new CryptsyAccount(account, accountMap.get("key"), accountMap.get("secret"));

            cryptsyExchange.accounts.add(cryptsyAccount);

            if (notNull(accountMap.get("isDefault")) && Boolean.valueOf(accountMap.get("isDefault"))) {
                cryptsyExchange.defaultAccount = cryptsyAccount;
            }
        });

        // Initializing Converter
        cryptsyExchange.converter = cryptsyExchange.new Converter();

        // Recover associations from configuration
        Map<String, String> exchangeCurrencyToCurrency = configuration.getMap("exchangeCurrencyToCurrency");
        Set<String> markedForRemoval = new HashSet<>();

        exchangeCurrencyToCurrency.entrySet().stream().forEach((entry) -> {
            String cryptsyCurrencyCode = entry.getKey();
            String currencySymbol = entry.getValue();

            com.jarvis.data.entity.Currency currency = dataService.getCurrency(currencySymbol);
            if (notNull(currency)) {
                cryptsyExchange.converter.associateCurrency(currency, cryptsyCurrencyCode);
            } else {
                LOGGER.debug("associated currency [" + currencySymbol + "] does not exist in database, removing from configuration");
                markedForRemoval.add(cryptsyCurrencyCode);
            }
        });

        // Removing currency associations missing from database
        if (!markedForRemoval.isEmpty()) {
            markedForRemoval.forEach((currency) -> configuration.remove("exchangeCurrencyToCurrency", currency));
        }

        Map<String, String> exchangeMarketToMarket = configuration.getMap("exchangeMarketToMarket");
        markedForRemoval.clear();

        exchangeMarketToMarket.entrySet().stream().forEach((entry) -> {
            String cryptsyMarketId = entry.getKey();
            String marketName = entry.getValue();

            Market market = dataService.getMarket(marketName);
            if (notNull(market)) {
                cryptsyExchange.converter.associateMarket(market, Integer.valueOf(cryptsyMarketId));
            } else {
                LOGGER.debug("associated market [+" + marketName + "] does not exist, removing from configuration");
                markedForRemoval.add(cryptsyMarketId);
            }
        });

        // Removing market associations missing from database
        if (!markedForRemoval.isEmpty()) {
            markedForRemoval.forEach((market) -> configuration.remove("exchangeMarketToMarket", market));
        }

        // Update configuration
        configuration.save();

        return cryptsyExchange;
    }

    // Lot of other code there
}

当然还有 stackTrace:

Exception in thread "main" java.lang.ClassFormatError: Illegal local variable table length 288 in method com.jarvis.exchange.cryptsy.CryptsyExchange.build_aroundBody0(Ljava/lang/String;Lcom/jarvis/data/service/DataService;Lcom/jarvis/util/ConfigPathBuilder;Lorg/aspectj/lang/JoinPoint;)Lcom/jarvis/exchange/cryptsy/CryptsyExchange;
    at java.lang.Class.getDeclaredMethods0(Native Method)
    at java.lang.Class.privateGetDeclaredMethods(Class.java:2688)
    at java.lang.Class.getDeclaredMethods(Class.java:1962)
    at org.springframework.util.ReflectionUtils.doWithMethods(ReflectionUtils.java:467)
    at org.springframework.util.ReflectionUtils.doWithMethods(ReflectionUtils.java:451)
    at org.springframework.util.ReflectionUtils.getUniqueDeclaredMethods(ReflectionUtils.java:512)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.getTypeForFactoryMethod(AbstractAutowireCapableBeanFactory.java:663)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.predictBeanType(AbstractAutowireCapableBeanFactory.java:593)
    at org.springframework.beans.factory.support.AbstractBeanFactory.isFactoryBean(AbstractBeanFactory.java:1396)
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.doGetBeanNamesForType(DefaultListableBeanFactory.java:382)
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBeanNamesForType(DefaultListableBeanFactory.java:353)
    at org.springframework.context.support.PostProcessorRegistrationDelegate.invokeBeanFactoryPostProcessors(PostProcessorRegistrationDelegate.java:82)
    at org.springframework.context.support.AbstractApplicationContext.invokeBeanFactoryPostProcessors(AbstractApplicationContext.java:609)
    at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:464)
    at org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:139)
    at org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:83)
    at com.jarvis.Jarvis.<clinit>(Jarvis.java:10)
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:259)
    at com.intellij.rt.execution.application.AppMain.main(AppMain.java:116)

我已经在我的项目中的任何其他类上尝试过这个(注解可以应用于类型或方法)并且它有效,但正是使用这个 bean 构建方法我遇到了问题并且找不到任何解决方法。也许 Aspectj 当前对 Java 8 的支持存在问题,它实际上破坏了字节码。或者我在那里做错了什么?

【问题讨论】:

    标签: java spring aop aspectj bytecode


    【解决方案1】:

    一些问题:

    • 您使用成熟的 AspectJ 还是仅使用带有 @AspectJ 语法的 Spring AOP?
    • 您是使用源/目标级别 1.8 还是仍使用 1.7 进行编译?
    • 完全相同的代码是否适用于 Java 7 和 AspectJ 1.8.0?
    • 如果不是,它是否适用于 Java 7 和 AspectJ 1.7.4?
    • 能否提供一个独立的最小代码示例来重现该问题?甚至可能在 GitHub 上使用 Maven 构建?)您引用的许多类对我来说是不可见的,所以我无法复制它。

    AJ 1.8.0 是全新的,它的一些问题实际上是由 ECJ(Eclipse Java 编译器)引起的。有些已经修复,因此您可以尝试当前的developer build(选择“Last Known Good developer build”。

    更新:

    我能够用一个独立于任何其他类的小代码示例重现该问题。问题不在于注解或简单的forEach lambdas,而显然是嵌套的forEach lambdas。

    我在http://bugs.eclipse.org/bugs/show_bug.cgi?id=435446 上提交了一个 AspectJ 错误。

    更新 2:

    错误单还描述了如何通过从切入点中排除 lambda 调用来解决该问题。

    我刚刚发现的另一个解决方法是使用参数-noverify 运行 JVM。

    更新 3:

    错误修复已完成并可作为开发版本使用。它将成为即将推出的 AspectJ 1.8.1 的一部分。

    【讨论】:

    • 1.我使用纯 AspectJ,spring 与我的方面无关(我有意将它们分开) 2. 我将源/目标级别都编译为 1.8。 3,4。还没有其他java版本(我需要坚持使用java 8)你是对的,那里有很多事情要做,但似乎我找到了问题的根源。我的 CryptsyExchange 中有一个内部类。我将更新该代码,以便您可以看到...(但不幸的是,您将无法重现)
    • 是的,我用过 -noverify(尽管我希望有一天插件会被修复,这样我就不需要这个标志了)
    【解决方案2】:

    我发现问题来自 lambda 表达式的使用 :(

    用常规替换所有 lambdas 以解决问题

    exchangeCurrencyToCurrency.entrySet().stream().forEach((entry) -> {
        String cryptsyCurrencyCode = entry.getKey();
        String currencySymbol = entry.getValue();
    
        com.jarvis.data.entity.Currency currency = dataService.getCurrency(currencySymbol);
        if (notNull(currency)) {
            associateCurrency(currency, cryptsyCurrencyCode);
        } else {
            LOGGER.debug("associated currency [" + currencySymbol + "] does not exist in database, removing from configuration");
            markedForRemoval.add(cryptsyCurrencyCode);
        }
    });
    

    结果

    for(Map.Entry<String, String> entry : exchangeCurrencyToCurrency.entrySet()){
                String cryptsyCurrencyCode = entry.getKey();
                String currencySymbol = entry.getValue();
    
                com.jarvis.data.entity.Currency currency = dataService.getCurrency(currencySymbol);
                if (notNull(currency)) {
                    associateCurrency(currency, cryptsyCurrencyCode);
                } else {
                    LOGGER.debug("associated currency [" + currencySymbol + "] does not exist in database, removing from configuration");
                    markedForRemoval.add(cryptsyCurrencyCode);
                }
            }
    

    【讨论】:

    • @kriegaex 但是我不明白为什么会这样,也许 Aspectj 真的在破坏代码?
    • 最简单的 lambda 会以相同的错误“Arrays.asList("asdf","asdf").forEach((p) -> System.out.println(p)); 破坏代码
    • 我能够通过一个独立于任何其他类的小代码示例重现该问题。问题不在于注释或简单的 forEach lambda,而显然是嵌套的 forEach lambda。我在bugs.eclipse.org/bugs/show_bug.cgi?id=435446 上提交了一个 AspectJ 错误
    • 我仔细检查了,如果 lambdas 是用 javac 编译的,我还看到了编译后的编织工作。我在工单上添加了相应的评论:bugs.eclipse.org/bugs/show_bug.cgi?id=435446#c1。至于你的另一个问题:不,ajc 不操纵源代码,它是 javac 的超集,因此能够理解纯 Java 和 AspectJ。
    • 我(AspectJ 项目负责人)刚刚修复了错误 435446,至少对于包含的测试用例,它现在一切正常。未正确设置invokedynamic 指令的大小,从而损坏了局部变量表。如果您想尝试它,请使用来自eclipse.org/aspectj/downloads.php 的最新开发版本或来自我们快照 maven 存储库的 1.8.1.BUILD-SNAPSHOT:maven.springframework.org/snapshot
    猜你喜欢
    • 1970-01-01
    • 2013-08-06
    • 1970-01-01
    • 1970-01-01
    • 2016-03-04
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2015-02-18
    相关资源
    最近更新 更多