junit - 在 Junit 测试用例中 @Autowired 和 @Qualifier 显示无法加载应用程序上下文和非法状态异常

Question

我在我的应用程序中使用@KafkaListener，这就是我使用的原因

@Configuration
static class ContextConfiguration { 
          //create the beans
     }

我的班级使用@Autowired @Qualifier("someName") 进行配置，同时编写符合“someName”资格的测试类配置未加载..

所以它会抛出错误

引起：org.springframework.beans.factory.NoSuchBeanDefinitionException：没有“org.springframework.web.client.RestTemplate”类型的合格bean

---

可用：预计至少有 1 个符合自动装配候选资格的 bean。依赖注解：{@org.springframework.beans.factory.annotation.Autowired(required=true), @org.springframework.beans.factory.annotation.Qualifier(value=someName)}

Answer 1

在这种情况下，主要问题是 @Bean("someName") 未加载到 Spring 容器中，因此在创建 bean 时，破解在 @Bean("someName") 下返回的配置，例如......

@Configuration
    static class ContextConfiguration {
        @Bean
        @Qualifier("InternalKafkaProducer")
        public KafkaTemplate<Object, Object> publishingTemplate(){
            return new KafkaTemplate(new DefaultKafkaProducerFactory<>(getKafkaTemplate()));

        }
    } 
@Autowired
 private KafkaTemplate<Object, Object> kafkaTemplate;
@Test
public void test(){
  //some code
}

private static HashMap<String, Object> getKafkaTemplate() {
        //return the properties;
}
}//test class end

Main class
@Autowired
@Qualifier("someName")
private KafkaTemplate<Object, Object> 
in configuration class
@Bean(name = "InternalKafkaProducer")
    public KafkaTemplate<Object, Object> getKafkaTemplate() {
        final Map<String, Object> properties = new HashMap<String, Object>();
        properties.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootStrapServer);
        properties.put("security.protocol", securityProtocol);
        properties.put("sasl.mechanism", saslMechanism);
        properties.put("sasl.jaas.config", saslJaasConfig);
        properties.put("sasl.login.callback.handler.class", saslOauthCallbackClass);
        properties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        properties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        final KafkaTemplate<Object, Object> template = new KafkaTemplate<Object, Object>(new DefaultKafkaProducerFactory<>(properties));
        template.setProducerListener(new KafkaProducerListener("InternalKafkaProducer", template));
        return template;
  }