Spring单例Bean属性修改异常问题求助

问题原因分析 #

你遇到的计数重置、跳变问题，核心原因是你的MyKafkaConsumer被创建了多个实例，而非单纯的线程安全问题。

从添加synchronized后的输出就能明确判断：虽然打印的是同一个线程，但计数出现了“5之后回到3”的情况——如果是同一个实例，单线程执行下计数必然是连续递增的，绝不可能出现倒回的情况。这说明当前有多个MyKafkaConsumer实例在同时处理消息，每个实例都有自己独立的messageCount属性，输出的是不同实例的计数结果，看起来就像是跳变或重置了。

为什么会创建多个实例？问题出在你的配置类上：

• Spring Boot的@EnableAutoConfiguration注解会自动扫描主类所在包及其子包下的组件（如果你的主类MyApplication在mypackages包下的话）。
• 你又手动添加了@ComponentScan(basePackages = {"mypackages"})，这会导致Spring重复扫描同一个包路径，进而重复创建MyKafkaConsumer的实例。

另外，最初代码里用普通int作为计数变量确实存在线程安全隐患，但添加synchronized后依然异常，说明线程安全不是当前的核心矛盾——多实例才是。

解决方案 #

1. 修正配置类，避免重复扫描 #

把MyApplication类上的@ComponentScan注解去掉，改用@SpringBootApplication（它已经包含了@Configuration、@EnableAutoConfiguration、@ComponentScan的功能），同时保留@EnableDiscoveryClient：

@SpringBootApplication(exclude = EmbeddedMongoAutoConfiguration.class)
@EnableDiscoveryClient
public class MyApplication {

    public static void main(String[] args) {
        SpringApplication.run(MyApplication.class, args);
        System.out.println("MyApplication is ready........");
    }
}

如果必须手动指定扫描包，直接用@SpringBootApplication(scanBasePackages = {"mypackages"})统一配置即可，避免重复扫描。

2. 验证实例数量 #

可以在MyKafkaConsumer的构造方法里添加打印，确认是否被多次实例化：

@Component
public class MyKafkaConsumer{

    public int messageCount = 0;

    public MyKafkaConsumer() {
        System.out.println("MyKafkaConsumer instance created: " + this);
    }

    @KafkaListener
    public void consumeMessage(MyPayload payload){
        synchronized (this){
            messageCount++;
            System.out.println("Instance: " + this + " messageCount - "+ messageCount);
        }
    } 
}

如果输出里出现多个不同的实例对象，就验证了我们的判断。

3. 改用线程安全的计数变量 #

即使解决了多实例问题，Kafka消费者默认是多线程处理的（可通过concurrency配置线程数），建议把int换成AtomicInteger，避免后续出现线程安全问题：

@Component
public class MyKafkaConsumer{

    private AtomicInteger messageCount = new AtomicInteger(0);

    @KafkaListener
    public void consumeMessage(MyPayload payload){
        int count = messageCount.incrementAndGet();
        System.out.println("messageCount - "+ count);
    } 
}

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