LocalStack TestContainer + AWS SQS + Spring Boot -> 无法执行 HTTP 请求

Question

我有这个有趣的问题，很高兴收到任何帮助

当我尝试创建队列时，AmazonSQS 客户端创建队列，但是当我尝试发送消息时，它会抛出此异常无法执行 HTTP 请求

代码：

@TestInstance(TestInstance.Lifecycle.PER_CLASS)
@TestMethodOrder(MethodOrderer.OrderAnnotation.class)
@Testcontainers
public class AwsSqsTest {
private static final Network network = Network.newNetwork();
@Container
static final LocalStackContainer localStack = new LocalStackContainer(
DockerImageName.parse("localstack/localstack:latest"))
.withNetwork(network)
.withNetworkAliases("notthis", "localstack")
.withServices(Service.SQS);

    static AmazonSQS amazonSQSClient;
    final String SqsURL = "http://sqs.us-east-1.localstack:4566/000000000000/";
    
    @BeforeAll
    static void beforeAll() {
        String localStackEndpoint = localStack.getEndpoint().toString();
        amazonSQSClient = amazonSQS(
                localStack.getAccessKey(),
                localStack.getSecretKey(),
                localStack.getRegion(),
                localStackEndpoint
        );
    }
    
    static AmazonSQS amazonSQS(String accessKey, String secretKey, String region, String stackEndpoint) {
        var basicAWSCredentials = new BasicAWSCredentials(accessKey, secretKey);
        var endpointConfiguration = new AwsClientBuilder.EndpointConfiguration(stackEndpoint, region);
        var credentialsProvider = new AWSStaticCredentialsProvider(basicAWSCredentials);
        return AmazonSQSClientBuilder.standard()
                .withEndpointConfiguration(endpointConfiguration)
                .withCredentials(credentialsProvider)
                .build();
    }
    
    @Test
    @Order(1)
    void testSQSClientInitialization() {
        assertNotNull(amazonSQSClient);
    }
    
    @ParameterizedTest
    @ValueSource(strings = {"news", "trends"})
    @Order(2)
    void createQueueTest(String queueName) {
        amazonSQSClient.createQueue(queueName);
    
        var queues = amazonSQSClient.listQueues().getQueueUrls();
    
        assertTrue(queues.contains(SqsURL + queueName));
    }
    
    
    @ParameterizedTest
    @MethodSource("saveToQueue")
    @Order(3)
    void saveToQueue(String queueName, String data) {
        String url = SqsURL + queueName;
        amazonSQSClient.sendMessage(url, data);
    
        var messages = amazonSQSClient.receiveMessage(url);
    
        assertEquals(data, messages.getMessages().getFirst().getBody());
    }
    
    Stream<Arguments> saveToQueue() {
        return Stream.of(
                arguments("trends", "{}"),
                arguments("news", "{}")
        );
    }

}

日志：

Unable to execute HTTP request: sqs.us-east-1.localstack
com.amazonaws.SdkClientException: Unable to execute HTTP request: sqs.us-east-1.localstack
...
Caused by: java.net.UnknownHostException: sqs.us-east-1.localstack
...

sqs.us-east-1.localstack
java.net.UnknownHostException: sqs.us-east-1.localstack
...

在此输入图片描述

我尝试使用 AmazonSQS 的其他实现并使用文档，但没有任何帮助；（

Answer 1

将以下环境变量添加到 LocalStackContainer

.withEnv("LOCALSTACK_HOST", "localhost.localstack.cloud")
.withEnv("SQS_ENDPOINT_STRATEGY", "dynamic")

LOCALSTACK_HOST

保留主机用于LocalStack内部通信，

SQS_ENDPOINT_STRATEGY

从客户端解析主机。