一些JUNIT测试案例在一起运行所有测试课时，但单独通过

Question

一些Junit测试用例在一起运行所有测试课程时会失败，但要单独通过。

我正在运行Maven“ MVN Clean Anstanc”，我可以看到以下内容。

1. 一个Junit测试类（test1.java）正在失败，但所有其他测试类都通过。但是，如果我单独运行，则相同的测试类Test1.java正在通过。在Eclipse（IDE）和命令行中，我都注意到了相同的。
2. 如果我评论了一个测试类（test2.java）中的所有内容，那么当我一起运行所有测试用例时，test1.java正在工作。

因此，test1.java由于test2.java而失败。但不确定确切原因是什么。如果有人可以提出根本原因，我将不胜感激。谢谢。

junit test1.java：

@RunWith(SpringRunner.class)
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
public class Test1 {

        public static final String REST_API_URI = "/api/someurl/abc";

        @Autowired
        private TestRestTemplate testRestTemplate;
    
        private static final String SVC_QUAL_CHANGE_TOPIC = "tnco-svcqual-change";
    
        @ClassRule
        public static EmbeddedKafkaRule embeddedKafka = new EmbeddedKafkaRule(1,
                true,
                1,
                SVC_QUAL_CHANGE_TOPIC);
        
        @BeforeClass
        public static void setUpBeforeClass() throws IOException {
            System.setProperty("spring.kafka.bootstrap-servers", embeddedKafka.getEmbeddedKafka().getBrokersAsString());
        }
    
        @AfterClass
        public static void tearDownAfterClass() {
            System.clearProperty("spring.kafka.bootstrap-servers");
        }
    
        @Test
        public void testCreateCheckServiceQualification() {
          ...
          //some API test code which send msg to Kafka
        }   
    }

junit test2.java：

@RunWith(SpringRunner.class)
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, properties = { "alm.ishtar.security.enabled = false" })
public class Test2 {

    public static final String REST_API_URI = "/api/someurl/xyz";

    @Autowired
    private TestRestTemplate testRestTemplate;
    
    private static final String MOI_CHANGE_TOPIC = "tnco-moi-change";
    
    @ClassRule
    public static EmbeddedKafkaRule embeddedKafka = new EmbeddedKafkaRule(1,
            true,
            1,
            MOI_CHANGE_TOPIC);
    
    @BeforeClass
    public static void setUpBeforeClass() throws IOException {
        System.setProperty("spring.kafka.bootstrap-servers", embeddedKafka.getEmbeddedKafka().getBrokersAsString());
    }

    @AfterClass
    public static void tearDownAfterClass() {
        System.clearProperty("spring.kafka.bootstrap-servers");
    }

    @Test
    public void testCreateMoiPut() throws Exception {
      ...
      //some API test code which send msg to Kafka
    }
}

在测试失败时在控制台中获取以下错误：

org.springframework.kafka.KafkaException: Send failed; nested exception is org.apache.kafka.common.errors.TimeoutException: Topic tnco-svcqual-change not present in metadata after 60000 ms.
org.springframework.kafka.KafkaException: Send failed; nested exception is org.apache.kafka.common.errors.TimeoutException: Topic tnco-svcqual-change not present in metadata after 60000 ms.
        at org.springframework.kafka.core.KafkaTemplate.doSend(KafkaTemplate.java:573)
        at org.springframework.kafka.core.KafkaTemplate.send(KafkaTemplate.java:401)

注意：测试方法调用REST API和API实现它将消息发送到Kafka主题。

Answer 1

从您提供的错误中，很明显您在并行中运行测试。

这是共享资源：system.setproperty（“ spring.kafka.bootstrap-servers”，embeddedkafka.getembeddedkafka（

）

1. Test1被执行，使用svc_qual_change_topic创建和配置Embeddedkafka，并将其地址设置为共享属性spring.kafka.kafka.bootstrap-servers。
2. 然后test2被执行，将另一个embeddedkafka与moi_change_topic和现在属性spring.kafka.kafka.bootstrap-servers指向第二个Embeddedkafka。
3. 执行了Test1的测试方法，读取属性spring.kafka.kafka.bootstrap-servers并使用“错误” Embeddedkafka。

解决方案是将

1. 依赖于相同资源（System Property Spring.kafka.kafka.bootstrap-servers）排除的测试中排除。并因此运行它们。喜欢这里排除特定的测试，无法在Junit中并行运行。
2. 将这两种测试组合在一起，并将Embeddedkafka与两个主题配置。

请注意，在每个测试之前设置Embeddedkafka（而不是上课之前）无济于事，因为没有任何阻止test.method1在同一时间执行test2.Methodx更改属性。