gpt4 book ai didi

java - 修改父类(super class)中的注释值并使用新值动态实例化子类

转载 作者:行者123 更新时间:2023-12-02 11:05:47 25 4
gpt4 key购买 nike

我们使用 Spring Cloud Stream 作为基于微服务的架构中事件消息传递的底层实现。我们希望更进一步,在我们的服务和 Spring Cloud Stream 库之间提供一个抽象层,以允许动态 channel 订阅,而无需在服务本身中添加太多样板配置代码。

最初的想法如下:

messaging-library 提供了一个 BaseHandler 抽象类,所有单独的服务都必须实现该类。特定服务的所有处理程序都希望使用相同的输入 channel ,尽管只会调用与要处理的事件类型相对应的输入 channel 。看起来如下:

public abstract class BaseEventHandler<T extends Event> {
@StreamListener
public abstract void handle(T event);
}

每个服务都提供自己的事件包,其中包含N个事件处理程序。有一些普通的 POJO 必须以编程方式实例化。这看起来如下:

public class ServiceEventHandler extends BaseEventHandler<ImportantServiceEvent> {

@Override
public void handle(ImportantServiceEvent event) {
// todo stuff
}
}

请注意,此时这些是简单的类,而不是 Spring bean,其中 ImportantServiceEvent 实现了 Event

我们的消息库会在启动时尽早进行扫描,并执行处理程序初始化。为此,需要完成以下步骤:

  • 我们扫描类路径中提供某种事件处理的所有可用包,并检索 BaseEventHandler 的所有子类。
  • 我们在子类的层次结构中检索@StreamListener注释,并将其值更改为该服务对应的输入 channel 。
  • 由于我们的处理程序可能需要与其他一些应用程序组件(存储库等)通信,因此我们使用 DefaultListableBeanFactory 将我们的处理程序实例化为单例,如下所示:

    val bean = beanFactory.createBean(eventHandlerClass, AutowireCapableBeanFactory.AUTOWIRE_BY_TYPE, true);
    beanFactory.registerSingleton(eventHandlerClass.getSimpleName(), bean);

此后,我们遇到了几个问题。

Spring Cloud Stream @StreamListener 注解不能被继承,因为它是一个方法注解。尽管如此,某些机制似乎能够在父级上找到它(因为注册了 StreamListenerAnnotationBeanPostProcessor),并尝试在初始化的 ServiceEventHandler 上执行后处理。我们的假设是 Spring Cloud Stream 使用类似 AnnotationElementUtils.findAllMergedAnnotations() 的内容。

因此,我们认为我们可能能够在子类的每次实例化之前更改基类的注释值。因此,我们认为虽然我们的 BaseEventHandler 会简单地获取一个新值,然后在初始化阶段结束时保持不变,但子类将使用正确的 channel 名称进行实例化在实例化时,因为我们不希望重新绑定(bind)。然而,情况并非如此,所使用的 @StreamListener 注释的值始终是基础上的值。

那么问题是:Spring Cloud Stream 能实现我们想要的功能吗?或者我们这里遇到的是一个简单的 Java 问题(似乎并非如此)? Spring Cloud Stream 团队是否预见到了这样的用例,我们的做法是否完全错误?

这个问题也发布在Spring Cloud Stream tracker上以防它可能有助于获得更多关注。

最佳答案

由于同一个人监控 SO 和 GitHub 问题,因此在这两个地方发帖是毫无意义的。 Stack Overflow 是提问的首选。

您应该能够对 BPP 进行子类化;它特别有这个扩展点:

/**
* Extension point, allowing subclasses to customize the {@link StreamListener}
* annotation detected by the postprocessor.
*
* @param originalAnnotation the original annotation
* @param annotatedMethod the method on which the annotation has been found
* @return the postprocessed {@link StreamListener} annotation
*/
protected StreamListener postProcessAnnotation(StreamListener originalAnnotation, Method annotatedMethod) {
return originalAnnotation;
}

然后用你的定义覆盖bean定义

@Bean(name = STREAM_LISTENER_ANNOTATION_BEAN_POST_PROCESSOR_NAME)
public static StreamListenerAnnotationBeanPostProcessor streamListenerAnnotationBeanPostProcessor() {
return new StreamListenerAnnotationBeanPostProcessor();
}

关于java - 修改父类(super class)中的注释值并使用新值动态实例化子类,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/50970269/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com