Ehcache 多线程场景

Question

我需要一些关于以下多线程场景的建议。我有一个 xml 文件，其中包含一些 Web 应用程序的配置数据。当用户访问网站时，根据用户访问的 url，将读取 XML 文件中的数据以找出附加到该用户请求的一些属性。为了提高读取 xml 文件的性能，我使用了 Ehcache。我正在缓存缓存中来自 xml 的请求和相关配置。

所以，现在我面临的问题是。如果有人开始更新 xml 文件，我需要停止从缓存中读取，直到写入完成，一旦 xml 文件更新操作完成，我想清除缓存。然后缓存将再次重建。对于第二部分，我正在努力研究如何实现多线程来实现这一目标。文件更新可以通过两种方式完成，一种是用户使用 notepad++ 或其他工具直接编辑 xml 文件。另一种方法是使用相同的 Web 应用程序。

Answer 1

您可以使用从共享BlockingQueue 读取的工作线程池刷新缓存；当用户完成他们的编辑时，您将向队列发送一条消息，其中包含有关需要更新的 kv 对的信息。

public class RefreshRequest<K> {
    public final K key;
    public RefreshRequest(K key) { this.key = key; }
}

public final BlockingQueue<RefreshRequest<?>> requestQueue = new ArrayBlockingQueue<>(200);
public final int concurrency = 4;
public final ExecutorService executor = Executors.newFixedThreadPool(4);

for(int i = 0; i < concurrency; i++) {
    executor.execute(new Runnable() {
        public void run() {
            try {
                while(true) {
                    RefreshRequest<?> request = requestQueue.take();
                    // refresh key
                }
            } catch(InterruptedException e) {
                return; // maybe log the exception as well
            }
        }
    };
}

worker 会消费请求来刷新缓存键；您需要在队列中 put 来自完成对 xml 文件更改的代码的新请求。要终止工作人员调用executor.shutdownNow()，它将使用InterruptedException 打破while(true) 循环

---

关于当有人开始写入 xml 时如何停止从缓存中读取，您可以通过“乐观”读取来做到这一点。为每个 xml 文件分配一个版本号，并在写入文件时增加此版本。开始读取时，将文件的版本存储在局部变量中。读取完成后，将本地版本与文件的当前版本进行比较——如果匹配则返回读取值，如果不匹配则重复读取，包括将本地变量更新为当前文件版本。如果需要，您可以有一个“无效”版本（例如，“有效”版本从 0 开始并在每次写入时递增，而“无效”版本为负 1） - 如果读者读到文件“无效”然后它暂停例如5 秒，然后重试。所以一种算法可能是

public Object read(K key) {
    while(true) {
        int version = versionCache.get(key);
        if(version == -1) Thread.sleep(5000);
        else {
            Object returnVal = cache.get(key);
            if(version == versionCache.get(key)) 
                return returnVal;
        }
    }
}