类 WatchFileCenter


  • public class WatchFileCenter
    extends java.lang.Object
    Unified file change monitoring management center, which uses WatchService internally. One file directory corresponds to one WatchService. It can only monitor up to 32 file directories. When a file change occurs, a FileChangeEvent will be issued
    作者:
    liaochuntao
    • 字段详细资料

      • LOGGER

        private static final org.slf4j.Logger LOGGER
      • MAX_WATCH_FILE_JOB

        private static final int MAX_WATCH_FILE_JOB
        Maximum number of monitored file directories.
      • FILE_SYSTEM

        private static final java.nio.file.FileSystem FILE_SYSTEM
      • CLOSED

        private static final java.util.concurrent.atomic.AtomicBoolean CLOSED
      • NOW_WATCH_JOB_CNT

        private static int NOW_WATCH_JOB_CNT
        The number of directories that are currently monitored.
    • 构造器详细资料

      • WatchFileCenter

        public WatchFileCenter()
    • 方法详细资料

      • registerWatcher

        public static boolean registerWatcher​(java.lang.String paths,
                                              FileWatcher watcher)
                                       throws com.alibaba.nacos.api.exception.NacosException
        Register FileWatcher in this directory.
        参数:
        paths - directory
        watcher - FileWatcher
        返回:
        register is success
        抛出:
        com.alibaba.nacos.api.exception.NacosException - NacosException
      • deregisterAllWatcher

        public static boolean deregisterAllWatcher​(java.lang.String path)
        Deregister all FileWatcher in this directory.
        参数:
        path - directory
        返回:
        deregister is success
      • deregisterWatcher

        public static boolean deregisterWatcher​(java.lang.String path,
                                                FileWatcher watcher)
        Deregister FileWatcher in this directory.
        参数:
        path - directory
        watcher - FileWatcher
        返回:
        deregister is success
      • checkState

        private static void checkState()