@Component
public class ReactorDispatcher implements JNotifyListener,Runnable {private CycleBarrier monitor = new CycleBarrier(2);private Deque<FSEvent> queue = new ArrayDeque<>(); private int watcherId;private Thread thread;private boolean state = true;// 这里使用了lombok// data注解会自动为下面的字段添加Getter和Setter// allArgsConstructor会给这个类添加一个默认的含有全部字段的构造方法@Data@AllArgsConstructorprivate class FSEvent {private String path;private String name;private int type;}// 初始化方法，spring完成装配后会首先执行他。@PostConstructpublic void initialize() {try {// 使用JNotify开始监听文件系统watcherId = JNotify.addWatcher(new File("files").getAbsolutePath(),JNotify.FILE_CREATED|JNotify.FILE_DELETED);// 创建线程，其实是不是也可以作为守护线程处理呢，// 不过守护线程的特点我不熟悉，就还是用来普通的方法。thread = new Thread(this);thread.setName("reactor - fs listener");thread.start();}catch(Exception e) {}}// 销毁方法，清理用。@PreDestorypublic void destory() {try {JNotify.removeWatcher(watcherId);state = false;} catch(Exception e) {}}/*** 这几种方法是监听器的方法，他会在文件发生变化的时候被回调。* 通过这些方法可以将监听到的内容变为事件对象，然后存入队列。*/public void fileCreated(int type,String path,String name) {FSEvent event = new FSEvent(JNotify.FILE_CREATED,path,name);this.emit(event);}/*** 这几种方法是监听器的方法，他会在文件发生变化的时候被回调。* 通过这些方法可以将监听到的内容变为事件对象，然后存入队列。*/public void fileRemoved(int type,String path,String name) {FSEvent event = new FSEvent(JNofiy.FILE_DELETED,path,name);this.emit(event);}// 省略不必要的监听方法，其实JNotify还有两个监听方法，这里就不在列举了。// 业务处理private void resolveEvent(FSEvent event) {// 在这里进行业务处理，ReactorDispatcher还会进行批量注入，将实现某个接口的实例作为list// 注入进来（但是这段代码里面我没写，因为这个是需要根据实际情况设计的）即通过接// 口注入一组业务逻辑的处理器// 然后在这里根据type进行分发，虽然标准的reactor是单线程的，但是我的业务处理很多// 时候是需要消耗相当的时间，所以我在这里用了线程池，所有的event都是异步处置，根据不同的// 场景，时间消耗较低的可以直接单线程。当然以nio为基础的话，这里完全可以单线程的。// 不过nio处理相对复杂一点，容易出现回调地狱这种问题，因此在没有好的处理方式之前，// 还不如直接线程池异步处理，只要小心锁的问题就是了。}public void emit(FSEvent event) {if(queue.isEmpty()) {quque.addFirst(event);try {monitor.await();} catch(Exception e) {}} else {quque.addFirst(event);}}public void run() {while(state) {try{// 阻塞线程，直到Event出现。monitor.await();if(queue.isEmpty()) {continue;}// removeLast 在没有下一个的时候会抛出空指针异常，需要catch一下，不然线程有// 异常后会直接退出，连报错都没有。之前遇到线程莫名自动退出的问题，就是因为run// 里面出现了异常。while(!quque.isEmpty()) {FSEvent event = queue.removeLast();this.resolveEvent(event);}mointor.reset();}catch(Exception e) {}}} }