在Java应用系统中,我们经常需要配置文件来定制系统行为,这些配置文件可能包括:类路径下的文件和文件夹、非类路径下的绝对路径和相对路径的文件和文件夹,在分布式环境中,还需要通过HTTP从统一集中的Web服务器中获得配置信息,如何对这些配置信息进行自动加载并实时检测变化呢?
Java分布式中文分词组件 - word分词已经实现了这个功能,我们看看是如何实现的:
package org.apdplat.word.util; import java.io.BufferedReader; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.net.MalformedURLException; import java.net.URL; import java.nio.file.FileVisitResult; import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.Paths; import java.nio.file.SimpleFileVisitor; import java.nio.file.StandardWatchEventKinds; import java.nio.file.WatchEvent; import java.nio.file.attribute.BasicFileAttributes; import java.util.ArrayList; import java.util.Enumeration; import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Set; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; import redis.clients.jedis.JedisPubSub; /** * 资源变化自动检测 * @author 杨尚川 */ public class AutoDetector { private static final Logger LOGGER = LoggerFactory.getLogger(AutoDetector.class); //已经被监控的文件 private static final Set<String> fileWatchers = new HashSet<>(); private static final Set<String> httpWatchers = new HashSet<>(); private static final Map<DirectoryWatcher, String> resources = new HashMap<>(); private static final Map<DirectoryWatcher, ResourceLoader> resourceLoaders = new HashMap<>(); private static final Map<DirectoryWatcher.WatcherCallback, DirectoryWatcher> watcherCallbacks = new HashMap<>(); /** * 加载资源并自动检测资源变化 * 当资源发生变化的时候重新自动加载 * @param resourceLoader 资源加载逻辑 * @param resourcePaths 多个资源路径,用逗号分隔 */ public static void loadAndWatch(ResourceLoader resourceLoader, String resourcePaths) { LOGGER.info("开始加载资源"); LOGGER.info(resourcePaths); long start = System.currentTimeMillis(); List<String> result = new ArrayList<>(); for(String resource : resourcePaths.split("[,,]")){ try{ resource = resource.trim(); if(resource.startsWith("classpath:")){ //处理类路径资源 result.addAll(loadClasspathResource(resource.replace("classpath:", ""), resourceLoader, resourcePaths)); }else if(resource.startsWith("http:")){ //处理HTTP资源 result.addAll(loadHttpResource(resource, resourceLoader)); }else{ //处理非类路径资源 result.addAll(loadNoneClasspathResource(resource, resourceLoader, resourcePaths)); } }catch(Exception e){ LOGGER.error("加载资源失败:"+resource, e); } } LOGGER.info("加载资源 "+result.size()+" 行"); //调用自定义加载逻辑 resourceLoader.clear(); resourceLoader.load(result); long cost = System.currentTimeMillis() - start; LOGGER.info("完成加载资源,耗时"+cost+" 毫秒"); } /** * 加载类路径资源 * @param resource 资源名称 * @param resourceLoader 资源自定义加载逻辑 * @param resourcePaths 资源的所有路径,用于资源监控 * @return 资源内容 * @throws IOException */ private static List<String> loadClasspathResource(String resource, ResourceLoader resourceLoader, String resourcePaths) throws IOException{ List<String> result = new ArrayList<>(); LOGGER.info("类路径资源:"+resource); Enumeration<URL> ps = AutoDetector.class.getClassLoader().getResources(resource); while(ps.hasMoreElements()) { URL url=ps.nextElement(); LOGGER.info("类路径资源URL:"+url); if(url.getFile().contains(".jar!")){ //加载jar资源 result.addAll(load("classpath:"+resource)); continue; } File file=new File(url.getFile()); boolean dir = file.isDirectory(); if(dir){ //处理目录 result.addAll(loadAndWatchDir(file.toPath(), resourceLoader, resourcePaths)); }else{ //处理文件 result.addAll(load(file.getAbsolutePath())); //监控文件 watchFile(file, resourceLoader, resourcePaths); } } return result; } /** * 加载HTTP资源 * @param resource 资源URL * @param resourceLoader 资源自定义加载逻辑 * @return 资源内容 */ private static List<String> loadHttpResource(String resource, ResourceLoader resourceLoader) throws MalformedURLException, IOException { List<String> result = new ArrayList<>(); try (BufferedReader reader = new BufferedReader(new InputStreamReader(new URL(resource).openConnection().getInputStream(), "utf-8"))) { String line = null; while((line = reader.readLine()) != null){ line = line.trim(); if("".equals(line) || line.startsWith("#")){ continue; } result.add(line); } } watchHttp(resource, resourceLoader); return result; } private static void watchHttp(String resource, final ResourceLoader resourceLoader){ String[] attrs = resource.split("/"); final String channel = attrs[attrs.length-1]; if(httpWatchers.contains(channel)){ return; } httpWatchers.add(channel); Thread thread = new Thread(new Runnable() { @Override public void run() { String host = WordConfTools.get("redis.host", "localhost"); int port = WordConfTools.getInt("redis.port", 6379); String channel_add = channel+".add"; String channel_remove = channel+".remove"; LOGGER.info("redis服务器配置信息 host:" + host + ",port:" + port + ",channels:[" + channel_add + "," + channel_remove+"]"); while(true){ try{ JedisPool jedisPool = new JedisPool(new JedisPoolConfig(), host, port); final Jedis jedis = jedisPool.getResource(); LOGGER.info("redis守护线程启动"); jedis.subscribe(new HttpResourceChangeRedisListener(resourceLoader), new String[]{channel_add, channel_remove}); jedisPool.returnResource(jedis); LOGGER.info("redis守护线程结束"); break; }catch(Exception e){ LOGGER.info("redis未启动,暂停一分钟后重新连接"); try { Thread.sleep(60000); } catch (InterruptedException ex) { LOGGER.error(ex.getMessage(), ex); } } } } }); thread.setDaemon(true); thread.setName("redis守护线程,用于动态监控资源:"+channel); thread.start(); } private static final class HttpResourceChangeRedisListener extends JedisPubSub { private ResourceLoader resourceLoader; public HttpResourceChangeRedisListener(ResourceLoader resourceLoader){ this.resourceLoader = resourceLoader; } @Override public void onMessage(String channel, String message) { LOGGER.debug("onMessage channel:" + channel + " and message:" + message); if(channel.endsWith(".add")){ this.resourceLoader.add(message); }else if(channel.endsWith(".remove")){ this.resourceLoader.remove(message); } } @Override public void onPMessage(String pattern, String channel, String message) { LOGGER.debug("pattern:" + pattern + " and channel:" + channel + " and message:" + message); onMessage(channel, message); } @Override public void onPSubscribe(String pattern, int subscribedChannels) { LOGGER.debug("psubscribe pattern:" + pattern + " and subscribedChannels:" + subscribedChannels); } @Override public void onPUnsubscribe(String pattern, int subscribedChannels) { LOGGER.debug("punsubscribe pattern:" + pattern + " and subscribedChannels:" + subscribedChannels); } @Override public void onSubscribe(String channel, int subscribedChannels) { LOGGER.debug("subscribe channel:" + channel + " and subscribedChannels:" + subscribedChannels); } @Override public void onUnsubscribe(String channel, int subscribedChannels) { LOGGER.debug("unsubscribe channel:" + channel + " and subscribedChannels:" + subscribedChannels); } } /** * 加载非类路径资源 * @param resource 资源路径 * @param resourceLoader 资源自定义加载逻辑 * @param resourcePaths 资源的所有路径,用于资源监控 * @return 资源内容 * @throws IOException */ private static List<String> loadNoneClasspathResource(String resource, ResourceLoader resourceLoader, String resourcePaths) throws IOException { List<String> result = new ArrayList<>(); Path path = Paths.get(resource); boolean exist = Files.exists(path); if(!exist){ LOGGER.error("资源不存在:"+resource); return result; } boolean isDir = Files.isDirectory(path); if(isDir){ //处理目录 result.addAll(loadAndWatchDir(path, resourceLoader, resourcePaths)); }else{ //处理文件 result.addAll(load(resource)); //监控文件 watchFile(path.toFile(), resourceLoader, resourcePaths); } return result; } /** * 递归加载目录下面的所有资源 * 并监控目录变化 * @param path 目录路径 * @param resourceLoader 资源自定义加载逻辑 * @param resourcePaths 资源的所有路径,用于资源监控 * @return 目录所有资源内容 */ private static List<String> loadAndWatchDir(Path path, ResourceLoader resourceLoader, String resourcePaths) { final List<String> result = new ArrayList<>(); try { Files.walkFileTree(path, new SimpleFileVisitor<Path>() { @Override public FileVisitResult visitFile(Path file, BasicFileAttributes attrs) throws IOException { result.addAll(load(file.toAbsolutePath().toString())); return FileVisitResult.CONTINUE; } }); } catch (IOException ex) { LOGGER.error("加载资源失败:"+path, ex); } if(fileWatchers.contains(path.toString())){ //之前已经注册过监控服务,此次忽略 return result; } fileWatchers.add(path.toString()); DirectoryWatcher.WatcherCallback watcherCallback = new DirectoryWatcher.WatcherCallback(){ private long lastExecute = System.currentTimeMillis(); @Override public void execute(WatchEvent.Kind<?> kind, String path) { //一秒内发生的多个相同事件认定为一次,防止短时间内多次加载资源 if(System.currentTimeMillis() - lastExecute > 1000){ lastExecute = System.currentTimeMillis(); LOGGER.info("事件:"+kind.name()+" ,路径:"+path); synchronized(AutoDetector.class){ DirectoryWatcher dw = watcherCallbacks.get(this); String paths = resources.get(dw); ResourceLoader loader = resourceLoaders.get(dw); LOGGER.info("重新加载数据"); loadAndWatch(loader, paths); } } } }; DirectoryWatcher directoryWatcher = DirectoryWatcher.getDirectoryWatcher(watcherCallback, StandardWatchEventKinds.ENTRY_CREATE, StandardWatchEventKinds.ENTRY_MODIFY, StandardWatchEventKinds.ENTRY_DELETE); directoryWatcher.watchDirectoryTree(path); watcherCallbacks.put(watcherCallback, directoryWatcher); resources.put(directoryWatcher, resourcePaths); resourceLoaders.put(directoryWatcher, resourceLoader); return result; } /** * 加载文件资源 * @param path 文件路径 * @return 文件内容 */ private static List<String> load(String path) { List<String> result = new ArrayList<>(); try{ InputStream in = null; LOGGER.info("加载资源:"+path); if(path.startsWith("classpath:")){ in = AutoDetector.class.getClassLoader().getResourceAsStream(path.replace("classpath:", "")); }else{ in = new FileInputStream(path); } try(BufferedReader reader = new BufferedReader(new InputStreamReader(in,"utf-8"))){ String line; while((line = reader.readLine()) != null){ line = line.trim(); if("".equals(line) || line.startsWith("#")){ continue; } result.add(line); } } }catch(Exception e){ LOGGER.error("加载资源失败:"+path, e); } return result; } /** * 监控文件变化 * @param file 文件 */ private static void watchFile(final File file, ResourceLoader resourceLoader, String resourcePaths) { if(fileWatchers.contains(file.toString())){ //之前已经注册过监控服务,此次忽略 return; } fileWatchers.add(file.toString()); LOGGER.info("监控文件:"+file.toString()); DirectoryWatcher.WatcherCallback watcherCallback = new DirectoryWatcher.WatcherCallback(){ private long lastExecute = System.currentTimeMillis(); @Override public void execute(WatchEvent.Kind<?> kind, String path) { if(System.currentTimeMillis() - lastExecute > 1000){ lastExecute = System.currentTimeMillis(); if(!path.equals(file.toString())){ return; } LOGGER.info("事件:"+kind.name()+" ,路径:"+path); synchronized(AutoDetector.class){ DirectoryWatcher dw = watcherCallbacks.get(this); String paths = resources.get(dw); ResourceLoader loader = resourceLoaders.get(dw); LOGGER.info("重新加载数据"); loadAndWatch(loader, paths); } } } }; DirectoryWatcher fileWatcher = DirectoryWatcher.getDirectoryWatcher(watcherCallback, StandardWatchEventKinds.ENTRY_MODIFY, StandardWatchEventKinds.ENTRY_DELETE); fileWatcher.watchDirectory(file.getParent()); watcherCallbacks.put(watcherCallback, fileWatcher); resources.put(fileWatcher, resourcePaths); resourceLoaders.put(fileWatcher, resourceLoader); } public static void main(String[] args){ AutoDetector.loadAndWatch(new ResourceLoader(){ @Override public void clear() { System.out.println("清空资源"); } @Override public void load(List<String> lines) { for(String line : lines){ System.out.println(line); } } @Override public void add(String line) { System.out.println("add:"+line); } @Override public void remove(String line) { System.out.println("remove:"+line); } }, "d:/DIC, d:/DIC2, d:/dic.txt, classpath:dic2.txt,classpath:dic"); } }
相关推荐
Java 3DMenu 界面源码,有人说用到游戏中不错,其实平时我信编写Java应用程序时候也能用到吧,不一定非要局限于游戏吧,RES、SRC资源都有,都在压缩包内。 Java zip压缩包查看程序源码 1个目标文件 摘要:Java源码...
Java 3DMenu 界面源码,有人说用到游戏中不错,其实平时我信编写Java应用程序时候也能用到吧,不一定非要局限于游戏吧,RES、SRC资源都有,都在压缩包内。 Java zip压缩包查看程序源码 1个目标文件 摘要:Java源码...
Java 3DMenu 界面源码,有人说用到游戏中不错,其实平时我信编写Java应用程序时候也能用到吧,不一定非要局限于游戏吧,RES、SRC资源都有,都在压缩包内。 Java zip压缩包查看程序源码 1个目标文件 摘要:Java...
Java 3DMenu 界面源码,有人说用到游戏中不错,其实平时我信编写Java应用程序时候也能用到吧,不一定非要局限于游戏吧,RES、SRC资源都有,都在压缩包内。 Java zip压缩包查看程序源码 1个目标文件 摘要:Java...
Java 3DMenu 界面源码,有人说用到游戏中不错,其实平时我信编写Java应用程序时候也能用到吧,不一定非要局限于游戏吧,RES、SRC资源都有,都在压缩包内。 Java zip压缩包查看程序源码 1个目标文件 摘要:Java...
Java 3DMenu 界面源码,有人说用到游戏中不错,其实平时我信编写Java应用程序时候也能用到吧,不一定非要局限于游戏吧,RES、SRC资源都有,都在压缩包内。 Java zip压缩包查看程序源码 1个目标文件 摘要:Java源码...
Java 3DMenu 界面源码 5个目标文件 内容索引:Java源码,窗体界面,3DMenu Java 3DMenu 界面源码,有人说用到游戏中不错,其实平时我信编写Java应用程序时候也能用到吧,不一定非要局限于游戏吧,RES、SRC资源都有,都...
Java 3DMenu 界面源码 5个目标文件 内容索引:Java源码,窗体界面,3DMenu Java 3DMenu 界面源码,有人说用到游戏中不错,其实平时我信编写Java应用程序时候也能用到吧,不一定非要局限于游戏吧,RES、SRC资源都有,都...
CIN:OS/2改变控制文件用于跟踪INI文件中的变化 CLASS:Java类文件 CLP:Windows 剪贴板文件 CLL:Crick Software Clicker文件 CLS:Visual Basic类文件 CMD:Windows NT,OS/2的命令文件;DOS CD/M命令文件;...
~代码注释比较丰富,而且资源文件完整,还有文档,看上去一切都很规范,压缩包有9M多,值得参阅的Android游戏源代码。源代码内包括了封装图片ID与 图片本身的工具类,来自疯狂Java联盟。 根据游戏状态来绘制游戏...
§7.1 应用系统环境规划和Oracle系统安装考虑 91 §7.1.1 操作系统安装考虑 91 §7.1.2 Oracle系统安装考虑 92 §7.2 关于创建多个Oracle实例问题 93 §7.3 Oracle系统安装后的优化基础工作 94 §7.3.1 Oracle系统...
在没有保护机制的操作系统下(如DOS),写数据到这个地址会导致立即当机,而在健壮的操作系统中,如Windows等,这个操作会马上被系统的保护机制捕获,其结果就是由操作系统强行关闭出错的应用程序,以防止其错误扩大。...
开发与系统集成:采用VC++、java和OpenGL以动态库或者组件的应用开发;模型库建立建模工具可以采用目前流行的工具建模软件应用,如3Dmax6.0、LightScape3.0、maya、AutoCAD2004设计开发;模型库管理与系统集成; 3)三...
E-Test是一款功能强大、简单易用的网站测试解决方案,可有效确保企业级Web应用程序、.NET应用程序、Java应用程序、Web Service,以及如Siebel, PeopleSoft 等公司出品的应用程序的性能和可靠性。E-TEST使你更加自信...
四、在Vista系统中安装IIS7.0相对于早先的版本,IIS 7.0 带来了许多引人注目的新特色新功能,比如基于 Microsoft .NET Framework 的全局配置文件,可简单地通过文本编辑器或 Microsoft Visual Studio 编辑;...
目前市场业务中在产品以及其他项目的认证和检测方面存在诸多不便,用户需要实地考察并频繁与检测单位沟通,填写繁琐的纸质检测报告、当面送递样品,对于检测环节中存在的问题难以及时交互并处理。市场上相应的检测...
在MastPage中引用脚本资源 2.0正式版中callback的一些变化+使用示例(ASP.NET 2.0) asp.net 2.0 新特性 Visual Web Development 2005开发ASP.NET使用小技巧 ASP.NET 2.0 异步页面原理浅析 [1] [原] 自定义通用...