java - 自动连接 TimerTask 不起作用

Question

我在 Java Sprint 中有一个 API，需要每天执行一项任务，从在 FTP 服务器中生成 txt 的外部系统导入一些数据。我遇到的问题是 Autowiring 字段没有被 Autowiring ......我的意思是，它们是空的。

我使用 @PostConstruct 在每次应用程序启动时执行任务，因此我可以使用计时器安排操作。

尝试1

这是代码(首先是 PostContruct 方法)

@Override
    @PostConstruct
    @Transactional
    public Response importdata(){
        Response response = new Response();
        try {
            System.out.println("*** Setting Import ****");
            Calendar calendar = Calendar.getInstance();
            calendar.set(Calendar.HOUR_OF_DAY, 21);
            calendar.set(Calendar.MINUTE, 5);
            calendar.set(Calendar.SECOND, 0);
            calendar.set(Calendar.MILLISECOND, 0);

            Timer time = new Timer(); // Instantiate Timer Object
            time.schedule(new ImportServiceImpl(), calendar.getTime(), TimeUnit.MILLISECONDS.convert(1, TimeUnit.DAYS));
        } catch (Exception e) {
            e.printStackTrace();
            response.setCode(CodeList.EXCEPTION);
            response.setSuccess(false);
        }
        return response;
    }

因此，我将 Activity 安排在每天 21.05。

这里有 ImportServiceImpl

@Component
public class ImportServiceImpl extends TimerTask  implements ImportService{

    @Autowired
    InvoiceDao invoiceDao;

    @Autowired
    ClientDao clientDao;

    @Override
    @Transactional
    public void run() {
        System.out.println("*** Running **** " + new Date());
        startImport();
    }

    @Override
    @Transactional
    public void startImport() {
        Path dir = Paths.get(ResourcesLocation.IMPORT_ROUTE);
        Boolean success = true;
        try (DirectoryStream<Path> stream = Files.newDirectoryStream(dir)) {
            for (Path entry : stream) {
                if (!Files.isDirectory(entry)) {
                    BufferedReader br = new BufferedReader(
                            new InputStreamReader(new FileInputStream(ResourcesLocation.IMPORT_ROUTE + entry.getFileName().toString())));
                    System.out.println("*** Importing file **** " + ResourcesLocation.IMPORT_ROUTE + entry.getFileName().toString());
                    try {
                        String line;
                        int i = 0;
                        while ((line = br.readLine()) != null) {

                            final String[] parts = line.split("\\|");
                            System.out.println("Line: " + i++ + " Text: " + line);
                            System.out.println("Factura: " + parts[1]);
                            Client client = (Client) this.clientDao.get(parts[0]);
                            String invoiceNumber = this.generateInvoiceNumber(parts[1].substring(1).replace("-", ""));
                            Invoice inv = (Invoice) this.invoiceDao.getByNumber(invoiceNumber);
                            if(inv == null){
                                inv = new Invoice();
                                inv.setClient(client);
                                inv.setNumber(invoiceNumber);
                                inv.setDate(this.convertDate(parts[2]));
                                inv.setTotal(this.convertFloat(parts[3]));
                                inv = (Invoice) this.invoiceDao.addOrUpdate(inv);
                            }
                        }
                    }
                    catch (Exception e) {
                        e.printStackTrace();
                        success = false;
                    }
                    finally {
                        try {
                            br.close();
                        } catch (IOException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                        if(success){
                            try {
                                Files.delete(entry);
                            } catch (IOException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                            }
                        }
                    }
                }
            }
        } catch (IOException e1) {
            // TODO Auto-generated catch block
            e1.printStackTrace();
        }
    }

这里的问题是 this.clientDao 应该 Autowiring ，但它是空的......所以我尝试这样做

if(this.clientDao == null)
    this.clientDao = new ClientDaoImpl();

但是，在 ClientDaoImpl 的 get 方法中我有

@SuppressWarnings("unchecked")
    public Object get(String name) throws Exception
    {
        Query q = sessionFactory.getCurrentSession()
                .createQuery("from " + this.entity + " WHERE name = '" + name + "'");
        return q.uniqueResult();
    }

并且 sessionFactory 为空，因为它没有 Autowiring 。我不认为解决方案是手动初始化每个类...

尝试2

然后我尝试自动连接类 ImportServiceImpl 而不是手动初始化，并更改了我的代码:

@Autowired
    ImportService importService;

和

time.schedule(this.importService, calendar.getTime(), TimeUnit.MILLISECONDS.convert(1, TimeUnit.DAYS));

但是我收到一个错误，因为 this.importService 不是 ImportServiceImpl，它是 ImportService，它是接口(interface)，而该接口(interface)无法扩展 TimerTask。

3次尝试

更改 Autowired 类以 Autowiring 实现而不是接口(interface)。像这样:

@Autowired
    ImportServiceImpl importService;

所以我收到以下错误:

java.lang.IllegalArgumentException: Can not set com.app.services.ImportServiceImpl field com.app.services.InvoiceServiceImpl.importService to com.sun.proxy.$Proxy184

我检查了Why is my Spring @Autowired field null?中的答案

但是手动解决方案不起作用，因为从未设置上下文。我还尝试使用 @Configure 注释，这里也建议这样做，或者我不知道如何使用它，或者它不起作用。

为了简化示例:我有一个 InvoiceServiceImpl 类，它有一个带有注释 @PostConstruct 的 importdata 方法，因此在应用程序启动(该部分没问题)后调用 importdata 方法，为类 ImportServiceImpl 安排一个计时器任务(到目前为止一切顺利)。但是当时机成熟时，该方法会被执行，但timertask类中该方法内的@Autowired属性为空。

Answer 1

已更新

我必须建议对代码的组织方式进行一些小的修改。

首先定义ImportService。

public interface ImportService {
    public void startImport();
}

以及相关的实现。

@Service
public class ImportServiceImpl implements ImportService {

    @Autowired
    private InvoiceDao invoiceDao;

    @Autowired
    private ClientDao clientDao;

    @Override
    @Transactional
    public void startImport() {
        // Process...
    }

然后，您就拥有了 TimerTask 实现。

@Component
public class ImportTimerTask extends TimerTask {

    @Autowired
    private ImportService importService;

    @Override
    public void run() {
        importService.startImport();
    }
}

最后，您可以在任何类中拥有 @PostConstruct 方法。

@Autowired
private ImportTimerTask importTimerTask;

@PostConstruct
@Transactional
public void importData() {
    Calendar calendar = Calendar.getInstance();
    calendar.set(Calendar.HOUR_OF_DAY, 9);
    calendar.set(Calendar.MINUTE, 2);
    calendar.set(Calendar.SECOND, 0);
    calendar.set(Calendar.MILLISECOND, 0);
    Timer time = new Timer();
    time.schedule(importTimerTask, calendar.getTime(),
            TimeUnit.MILLISECONDS.convert(1, TimeUnit.DAYS));
}

通过这样的实现，我的简单测试很好，invoiceDao 和 cliendDao 成功 Autowiring 。

<小时/>

您可以尝试在 @Configuration 类中添加 @EnableAspectJAutoProxy(proxyTargetClass=true) 来实现尝试 3。

更多引用您可以找到here .