Camel AWS 2.21.x如何覆盖QueueURL/EndpointURI对接Localstack？

虽然2.22版本才新增了专门的配置属性，但2.21.x可以通过以下两种方法对接Localstack：

方法一：直接在Endpoint URI中指定参数 #

可以在aws-sqs的端点URI里直接通过queueUrl和endpointOverride参数覆盖默认地址，示例如下：

aws-sqs://my-queue?queueUrl=http://localhost:4566/000000000000/my-queue&endpointOverride=http://localhost:4566

• queueUrl：指定Localstack上的完整队列地址，格式为http://<localstack-host>:<port>/<account-id>/<queue-name>，Localstack默认账号ID是000000000000
• endpointOverride：覆盖AWS SQS的服务端点，指向Localstack的地址

方法二：自定义AWS SQS客户端 #

通过构建自定义的AmazonSQS客户端并注入到Camel组件中，全局覆盖端点配置，避免每个URI重复设置：

// 构建Localstack专用的SQS客户端
AmazonSQS sqsClient = AmazonSQSClientBuilder.standard()
    .withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(
        "http://localhost:4566", "us-east-1")) // Localstack地址和区域（可根据实际调整）
    .withCredentials(new AWSStaticCredentialsProvider(
        new BasicAWSCredentials("test", "test"))) // Localstack不需要真实凭证，随便填即可
    .build();

// 将客户端绑定到Camel的SQS组件
SqsComponent sqsComponent = new SqsComponent();
sqsComponent.setAmazonSQSClient(sqsClient);
camelContext.addComponent("aws-sqs", sqsComponent);

配置完成后，使用普通的aws-sqs://my-queue URI即可对接Localstack的队列。

内容的提问来源于stack exchange，提问作者JoelHess