Spring Boot应用如何基于实例类型控制SqsListener的启动

在Spring Boot多实例部署的场景下，我们常常需要让不同角色的实例承担不同的任务，比如Web实例只处理接口请求，Worker实例才消费SQS消息。这时候就需要基于实例类型控制SqsListener的启动，避免不符合要求的实例加载消息监听逻辑。

方案一：通过配置文件配合@ConditionalOnProperty控制

这种方式适合实例类型可以通过配置项区分的场景，我们在不同实例的配置文件中添加标识，再通过条件注解控制SqsListener的加载。

第一步：添加实例类型配置

在Web实例的application.yml中添加如下配置：

# Web实例配置
instance:
  type: web

在Worker实例的application.yml中添加如下配置：

# Worker实例配置
instance:
  type: worker

第二步：创建带条件注解的SqsListener配置类

将SqsListener的注册逻辑放到单独的配置类中，通过@ConditionalOnProperty注解判断实例类型：

import io.awspring.cloud.sqs.annotation.SqsListener;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Configuration;

@Configuration
// 仅当instance.type为worker时加载该配置类
@ConditionalOnProperty(name = "instance.type", havingValue = "worker")
public class WorkerSqsConfig {

    @SqsListener("test-queue")
    public void handleMessage(String message) {
        System.out.println("接收到SQS消息：" + message);
        // 消息处理逻辑
    }
}

方案二：自定义条件注解通过环境变量判断

如果实例类型是通过环境变量传入的，我们可以自定义条件注解实现更灵活的判断逻辑。

第一步：定义实例类型条件注解

import org.springframework.context.annotation.Conditional;

import java.lang.annotation.*;

@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Conditional(InstanceTypeCondition.class)
public @interface ConditionalOnInstanceType {
    String value();
}

第二步：实现条件判断逻辑

import org.springframework.context.annotation.Condition;
import org.springframework.context.annotation.ConditionContext;
import org.springframework.core.type.AnnotatedTypeMetadata;

import java.util.Map;

public class InstanceTypeCondition implements Condition {
    @Override
    public boolean matches(ConditionContext context, AnnotatedTypeMetadata metadata) {
        // 从环境变量中获取实例类型，也可以从配置、启动参数等位置获取
        String instanceType = context.getEnvironment().getProperty("instance.type");
        Map<String, Object> attributes = metadata.getAnnotationAttributes(ConditionalOnInstanceType.class.getName());
        if (attributes == null) {
            return false;
        }
        String targetType = (String) attributes.get("value");
        return targetType.equals(instanceType);
    }
}

第三步：使用自定义注解控制SqsListener

import io.awspring.cloud.sqs.annotation.SqsListener;
import org.springframework.context.annotation.Configuration;

@Configuration
@ConditionalOnInstanceType("worker")
public class CustomWorkerSqsConfig {

    @SqsListener("test-queue")
    public void processMessage(String content) {
        System.out.println("自定义条件处理消息：" + content);
        // 具体业务处理
    }
}

方案三：通过动态注册SqsListener实现运行时控制

如果需要在应用启动后动态调整SqsListener的状态，可以通过手动注册监听容器的方式实现。

import io.awspring.cloud.sqs.listener.SqsMessageListenerContainer;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class DynamicSqsConfig {

    @Value("${instance.type}")
    private String instanceType;

    @Bean
    public SqsMessageListenerContainer<String> sqsListenerContainer() {
        // 如果不是worker实例，返回空容器不启动监听
        if (!"worker".equals(instanceType)) {
            return null;
        }
        SqsMessageListenerContainer<String> container = new SqsMessageListenerContainer<>();
        container.setQueueNames("test-queue");
        container.setMessageListener(message -> {
            System.out.println("动态注册接收到消息：" + message.getPayload());
        });
        return container;
    }
}

方案对比与选择建议

三种方案各有适用的场景，我们可以通过下面的表格快速选择：

注意事项

• 实例类型的标识需要保证唯一且稳定，避免不同实例出现类型判断错误
• 如果使用AWS SQS的自动配置，需要确保非worker实例不会加载相关的监听自动配置类，避免不必要的资源占用
• 动态注册容器时，要注意容器的启动和停止逻辑，避免内存泄漏

实际落地时可以根据团队的运维习惯选择方案，大多数场景下方案一就能满足需求，不需要过度设计复杂的条件逻辑。

以上就是基于实例类型控制SqsListener启动的几种实现方式，开发者可以根据自身业务场景选择合适的方案，合理分配实例资源，提升应用运行效率。

Spring_BootSqsListener实例类型消息队列条件启动修改时间：2026-05-30 23:50:51