有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

java autowired服务从组件调用,当使用new关键字调用时,该组件提供空指针

我有一个问题,我必须使用arrayblocking队列服务,我的体系结构如下:

控制器:

@controller---
@Autowired
private AdhocService adhocService;

@RequestMapping(value = "/upload", method = RequestMethod.POST)
    public String uploadFile(){
        adhocService.processFile();

}

服务:

我有一种方法,可以使用arrayblocking队列启动新线程进行读写

    @service
-----
    public void processFileData(InputStream inputStream, Character delimiter, Character quoteChar,String fileName,String type, String report, String desc)
        {


        try {
        long startTime = System.nanoTime();

            ExecutorService producerPool = Executors.newFixedThreadPool(1);
            ExecutorService consumerPool = Executors.newFixedThreadPool(1);
            producerPool.submit(new AdhocTasks(false, inputStream, delimiter, quoteChar, fileName, type, report, desc));
            consumerPool.submit(new AdhocTasks(true, null, null, null, null, null, null, null));    
            producerPool.shutdown();
            consumerPool.shutdown();

我这里也有更多的方法

组成部分:

在adhoctask中,文件被声明为组件:

    @Component
    public class AdhocTasks implements Runnable,QueueService {


    @Autowired
    private AdhocService adhocService;


    //CONSTRUCTOR - PARAMETERIZED

    public AdhocTasks(Boolean consumer, InputStream stream, Character delimiter,Character quoteChar,String fileName,String type, String report, String desc) {
        this.isConsumer=consumer;
        this.stream = stream;
        this.delimiter=delimiter;
        this.quoteChar=quoteChar;
        this.fileName = fileName;
        this.type = type;
        this.report = report;
        this.desc = desc;

    }

@Override
    public void run() {


        if(this.isConsumer) {
            consumeFileData();
        }else {
            readFileData();
        }

    }

我有consumeFileData和readFileData的实现。现在的问题是,在consumeFileData中,我何时调用autowired adhocService。消费():

但它不起作用: 给我

空指针,因为adhocService对象为空

有人能帮忙吗


共 (1) 个答案

  1. # 1 楼答案

    调用该方法时不会出现问题,问题会在spring启动时立即出现

    AdhocTasks是一个spring组件。因此,它的构造函数会像对任何bean一样被调用。但由于它的构造函数有参数,每个参数都必须被视为一个依赖项,所以Spring尝试将它们与Springbean连接起来
    第一个问题:大多数参数找不到匹配的候选bean;第二个问题:您不想自动关联这些参数

    作为解决方法,稍微改变一下你的设计。 不要让AdhocTasks成为Springbean,因为你不想这样,不要注入它所需要的服务,而是在实例化时将其作为参数传递:

    @Autowired
    private AdhocService adhocService;
    //..
    producerPool.submit(new AdhocTasks(adhocService, false, inputStream, delimiter, quoteChar, fileName, type, report, desc));