如何正确停止并启动localstack实例

Question

我正在使用LocalStack编写集成测试。我要测试的方案之一是何时AWS服务引发错误。我的测试看起来像是

    void saveEventsAsync_snsError() throws Exception{

       
        localSns.stop();

        mvc.perform( MockMvcRequestBuilders
                        .post("/events-async")
                        .content(validRequest())
                        .contentType(MediaType.APPLICATION_JSON)
                        .accept(MediaType.APPLICATION_JSON))
                .andExpect(status().isInternalServerError());


    }

这样做会互相互相测试，而错误。大概是在测试运行时开始的容器。 我在这里有什么选择？使用localsns.isrunning（） loping; t; t似乎

在这里有帮助的完整测试CLA以供参考

package ....

import org.junit.jupiter.api.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.boot.test.context.TestConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Profile;
import org.springframework.http.MediaType;
import org.springframework.test.annotation.DirtiesContext;
import org.springframework.test.context.ActiveProfiles;
import org.springframework.test.context.DynamicPropertyRegistry;
import org.springframework.test.context.DynamicPropertySource;
import org.springframework.test.web.servlet.MockMvc;
import org.springframework.test.web.servlet.request.MockMvcRequestBuilders;
import org.testcontainers.containers.localstack.LocalStackContainer;
import org.testcontainers.containers.wait.strategy.DockerHealthcheckWaitStrategy;
import org.testcontainers.junit.jupiter.Container;
import org.testcontainers.junit.jupiter.Testcontainers;
import org.testcontainers.utility.DockerImageName;
import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;
import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider;
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.sns.SnsClient;
import software.amazon.awssdk.services.sns.model.CreateTopicRequest;
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;
import static org.testcontainers.containers.localstack.LocalStackContainer.Service.SNS;

@SpringBootTest
@AutoConfigureMockMvc
@ActiveProfiles("test")
@Testcontainers
@TestMethodOrder(MethodOrderer.OrderAnnotation.class)
class EventReportingControllerTest {

    @Autowired
    MockMvc mvc;

    @Container
    private static final LocalStackContainer localSns =
            new LocalStackContainer(DockerImageName.parse("localstack/localstack:0.11.3"))
                    .withServices(SNS);

    private static SnsClient snsClient;

    private static String topicArn ;

    @BeforeAll
    static void beforeAll() {
        localSns.start();

        snsClient = SnsClient.builder()
                .endpointOverride(localSns.getEndpointOverride(SNS))
                .credentialsProvider(
                        StaticCredentialsProvider.create(
                                AwsBasicCredentials.create(localSns.getAccessKey(), localSns.getSecretKey())
                        )
                )
                .region(Region.of(localSns.getRegion()))
                .build();

        topicArn = snsClient.createTopic(CreateTopicRequest.builder().name("testTopic").build()).topicArn();
    }

    @DynamicPropertySource
    public static void overrideProps(DynamicPropertyRegistry registry){
        registry.add("events.sns.topic.arn", () -> snsClient.createTopic(CreateTopicRequest.builder().name("testTopic").build()).topicArn());
    }

    @TestConfiguration
    public static class SnsClientConfig {
        @Bean
        @Profile("test")
        public SnsClient amazonSNSClient() {
            return snsClient;
        }
    }

    @Test
    void saveEventsAsync_success() throws Exception{
        mvc.perform( MockMvcRequestBuilders
                        .post("/events-async")
                        .content(validRequest())
                        .contentType(MediaType.APPLICATION_JSON)
                        .accept(MediaType.APPLICATION_JSON))
                .andExpect(status().isAccepted()
                );
    }

    @Test
  
    void saveEventsAsync_invalidRequest() throws Exception{
        mvc.perform( MockMvcRequestBuilders
                        .post("/events-async")
                        .content(invalidRequest())
                        .contentType(MediaType.APPLICATION_JSON)
                        .accept(MediaType.APPLICATION_JSON))
                .andExpect(status().isBadRequest());
    }

    @Test
    void saveEventsAsync_snsError() throws Exception{

    
        localSns.stop();
        mvc.perform( MockMvcRequestBuilders
                        .post("/events-async")
                        .content(validRequest())
                        .contentType(MediaType.APPLICATION_JSON)
                        .accept(MediaType.APPLICATION_JSON))
                .andExpect(status().isInternalServerError());


    }

   
}

Answer 1

使用@TestConainers和@Container用于您的设置时，TestContainers将为您管理容器的生命周期。

因此，您目前有自我束缚和“由测试范围管理”的混合。

如果您想接管生命周期处理，请删除两个注释，然后根据自己的喜好启动/停止容器。

PS：如果您使用的是最近的Spring Cloud AWS版本，则覆盖AWS SDK客户端现在更简单。