遇到错误“考虑在您的配置中定义一个 'java.util.concurrent.atomic.AtomicReference' 类型的 bean”

Question

我在启动 Spring Boot 应用程序时遇到以下错误。

注入点有如下注解：

• @org.springframework.beans.factory.annotation.Autowired(required=true)

行动：

考虑定义一个 bean 类型 'java.util.concurrent.atomic.AtomicReference' 在您的配置中。

下面是代码。

package de.summer.sampleapplayerv1;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.transaction.annotation.EnableTransactionManagement;

@SpringBootApplication(scanBasePackages = {"de.summer.sampleapplayerv1"})
@EnableConfigurationProperties
@EnableJpaRepositories (basePackages ="de.summer.sampleapplayerv1.repository")
@EnableTransactionManagement
public class Sampleapplayerv1Application {

    public static void main(String[] args) {
        SpringApplication.run(Sampleapplayerv1Application.class, args);
    }

}

package de.summer.sampleapplayerv1.service;

import de.summer.sampleapplayerv1.domain.QueueAndPublish;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List;
import java.util.UUID;
import java.util.concurrent.atomic.AtomicReference;
import java.util.stream.Collectors;

@Slf4j
@Service
public class QueueAndPublishServiceImpl implements QueueAndPublishService{

    private final AtomicReference<List<QueueAndPublish>> currentJob;

    public QueueAndPublishServiceImpl(
            @Qualifier("currentJob") AtomicReference<List<QueueAndPublish>> currentJob
    ){
        this.currentJob=currentJob;
    }

    @Override
    public QueueAndPublish getJobStatus(UUID jobId) {
        return (QueueAndPublish) currentJob.get().stream()
                        .filter(j -> j.getJobId()==jobId)
                        .collect(Collectors.toList());
    }

    @Override
    public List<QueueAndPublish> getAllJobStatus() {
        return currentJob.get();
    }

    @Override
    public QueueAndPublish getCategoryDataProcess() {
        List<QueueAndPublish> processList=new ArrayList<QueueAndPublish>();
        QueueAndPublish process=QueueAndPublish.builder()
                                                .jobId(UUID.randomUUID())
                                                .jobName("Name for Job")
                                                .jobStatus("Not Yet Started")
                                                .build();
        Thread t1=new Thread(process.getJobId().toString()){
          @Override
          public void run(){
              log.info("How are you doing");
              process.setJobStatus("Completed");
          }
        };
        t1.start();
        processList.add(process);
        currentJob.set(processList);
        return process;
    }

    @Override
    public QueueAndPublish getCatgeoryDataProcessStatus() {
        return null;
    }
}

package de.summer.sampleapplayerv1.domain;

import lombok.Builder;
import lombok.Getter;
import lombok.Setter;

import javax.persistence.Entity;
import javax.persistence.Id;
import java.io.Serializable;
import java.util.UUID;

@Getter
@Setter
@Builder
@Entity
public class QueueAndPublish implements Serializable {

    @Id
    private UUID jobId;
    private String jobName;
    private String jobStatus;
}

如果我删除构造函数，spring boot 应用程序将启动而没有任何错误。如果包含，则启动失败并出现不满足的依赖错误。

有人可以帮忙看看配置有什么问题吗？

Answer 1

您希望 Spring 为 QueueAndPublishService 的实现创建一个类 QueueAndPublishServiceImpl 的实例。该实例需要注入 AtomicReference<List<QueueAndPublish>> 类型的构造函数参数。

但您显然没有定义任何该类型的 Spring bean（Bean、组件、服务...）。

编辑：

public QueueAndPublishServiceImpl(
            @Qualifier("currentJob") AtomicReference<List<QueueAndPublish>> currentJob
    ){
        this.currentJob=currentJob;
    }

在这里，您定义一个构造函数参数以具有AtomicReference<List<QueueAndPublish>>，甚至使用@Qualifier 指定它。所以需要给这个类的Spring bean提供这个限定符，否则Spring无法将其注入到构造函数调用中。

Answer 2

考虑在您的配置中定义一个“java.util.concurrent.atomic.AtomicReference”类型的 bean。

表示“类似”将其添加到您的Sampleapplayerv1Application：

@Bean("currentJob") AtomicReference<List<QueueAndPublish>> currentJob() {
   // or a list implementation of your choice.
   return new AtomicReference<>(new java.util.ArrayList<>()); 
}