在外部库构造的对象中访问Spring应用程序上下文

Question

@Component
public class ExampleProducerInterceptor extends ProducerInterceptor<Object, Object> {
  @Autowired
  private Environment environment;
  ...
}

spring:
  kafka:
    properties:
      "interceptor.classes": com.example.ExampleproducerInterceptor

像这样访问应用程序的方法有哪些？例如，我可以向Kafka提供一个委托类来调用那里的默认构造函数吗？

在构造kafka之前，我已经有了一些配置它的代码，所以我也可以在前面修改类名：

@Autowired
private List<ProducerInterceptor> producerInterceptors;

List<String> producerClassNames = producerInterceptors
  .map(Object::getClass)
  .map(Class::getName)
  .map(str -> str + "$enhancedBySpring") // Point to delegate class?
  .collect(Collectors.toList());

Answer 1

我不确定您的最后一个代码片段试图实现什么。

根据应用程序的复杂性，您可以将ApplicationContext存储在静态“Holder”类或ThreadLocal中，并在第一次调用send()时初始化拦截器或默认CTOR。

public class ContextHolder {

    private static final ApplicationContext context;

...

}

或

```java
public class ContextHolder {

    private final ThreadLocal<ApplicationContext> contexts = new ThreadLocal<>();

...