java - 带 Spring 的WatchService

我正在尝试用spring执行“WatchService”，但是看起来是不可能的，因为当我尝试在应用程序上下文中运行此服务时，但是当控制权到达时，spring上下文的加载就停止了

key = watcher.take();

由于这种应用程序上下文的加载没有发生。

下面是完整的代码

@Component
public class DirectoryWatchDemo {


    @PostConstruct
    public static void test(){
        try {
            WatchService watcher = FileSystems.getDefault().newWatchService();
            Path dir = Paths.get("C:/test");
            dir.register(watcher, ENTRY_CREATE);

            System.out.println("Watch Service registered for dir: " + dir.getFileName());

            while (true) {
                WatchKey key;
                try {
                    key = watcher.take();
                } catch (InterruptedException ex) {
                    return;
                }

                for (WatchEvent<?> event : key.pollEvents()) {
                    WatchEvent.Kind<?> kind = event.kind();

                    @SuppressWarnings("unchecked")
                    WatchEvent<Path> ev = (WatchEvent<Path>) event;
                    Path fileName = ev.context();

                    System.out.println(kind.name() + ": " + fileName);

                    if (kind == ENTRY_MODIFY &&
                            fileName.toString().equals("DirectoryWatchDemo.java")) {
                        System.out.println("My source file has changed!!!");
                    }
                }

                boolean valid = key.reset();
                if (!valid) {
                    break;
                }
            }

        } catch (IOException ex) {
            System.err.println(ex);
        }
    }

}

我这样做是因为我不想手动执行“WatchService”。

最佳答案

这是因为您有一个无限循环，因此@PostConstruct的方法调用永远不会返回。

(对我来说，这很奇怪，@PostConstruct可与静态方法一起使用，但也许可以使用)

因此，解决方案是为观察者启动一个新线程。您可以通过不同的方式执行此操作:

只需启动一个新线程

向该方法添加@Async(我不知道这是否适用于@PostConstruct方法)(主要缺点是，此操作在初始化完整的应用程序上下文之前开始)

滥用了@Scheduler批注:@Scheduled(fixedDelay = Long.MAX_VALUE)-(与@PostConstruct + @Async相比，它的优点是:它可以正常工作，并且在初始化整个上下文之后才启动)