我正在实现一个基于 Spring MVC 的 Web 应用程序，其中添加了缓存，但是现在在将更改应用于底层数据库时如何操作缓存方面遇到了问题。
我一直在研究 Ehcache ( http://ehcache.org/documentation ) 上的文档，但没有找到任何好的例子来解决我的问题。
假设我有一个 DAO 类，我选择在两个返回对象列表（不可编译的伪代码）的方法上应用缓存：
@Repository
public class MyEntityDao {
@Autowired
DataSource ds;
@Autowired
EhCacheCacheManager cacheManager;
@Autowired
CacheKeyGenerator keyGenerator;
@Cacheable("myEntityCache")
public List<MyEntity> findByFieldAlpha(String fieldAlpha) {
return ds.query("select * from MyEntity where fieldAlpha = #fieldAlpha").execute();
}
@Cacheable("myEntityCache")
public List<MyEntity> findByFieldBeta(String fieldBeta) {
return ds.query("select * from MyEntity where fieldBeta = #fieldBeta").execute();
}
public void deleteByFieldAlpha(String fieldAlpha) {
ds.query("delete from MyEntity where fieldAlpha = #fieldAlpha").execute();
}
public void deleteByFieldBeta(String fieldBeta) {
ds.query("delete from MyEntity where fieldBeta = #fieldBeta").execute();
}
public void store(MyEntity myEntity) {
ds.insert(myEntity).execute();
}
}
我正在使用自定义 KeyGenerator，所以我知道调用方法时如何生成键：
public class CacheKeyGenerator implements KeyGenerator {
@Override
public Object generate(final Object target, final Method method, final Object... params) {
return generateCacheKey(method.getName(), params);
}
public String generateCacheKey(final String methodName, final Object... params) {
StringBuilder key = new StringBuilder();
key.append(methodName);
for (Object o : params) {
key.append("_").append(o.toString());
}
return key.toString();
}
}
我需要解决的一个明显问题是，当向底层数据库添加或删除数据时，我应该如何实现缓存修改策略。
对于 store 方法，我发现这个问题很容易解决：
...
public void store(MyEntity myEntity) {
boolean success = ds.insert(myEntity).execute();
if (success) {
Cache cache = cacheManager.getCache("myEntityCache")
String keyFieldAlpha = keyGenerator.generateCacheKey("findByFieldAlpha", myEntity.getFieldAlpha());
List cacheListFieldAlpha = (List) cache.get(keyFieldAlpha).getObjectValue();
cacheListFieldAlpha.add(myEntity);
String keyFieldBeta = keyGenerator.generateCacheKey("findByFieldBeta", myEntity.getFieldBeta());
List cacheListFieldBeta = (List) cache.get(keyFieldBeta).getObjectValue();
cacheListFieldBeta.add(myEntity);
}
}
但是对于删除方法，事情变得更加复杂。
这是我迄今为止提出的一种实现，但它似乎比它应该的要复杂得多（昂贵）。如果我的设计模式是正确的，或者是否应该以任何其他方式解决我的问题，任何人都有任何有价值的意见？
public void deleteByFieldAlpha(String fieldAlpha) {
List<MyEntity> myEntititesToBeDeleted = this.findByFieldAlpha(fieldAlpha);
boolean success = ds.query("delete from MyEntity where fieldAlpha = #fieldAlpha").execute();
if (success) {
Cache cache = cacheManager.getCache("myEntityCache")
String keyFieldAlpha = keyGenerator.generateCacheKey("findByFieldAlpha", fieldAlpha);
cache.remove(keyFieldAlpha);
for (MyEntity myEntity : myEntititesToBeDeleted) {
String keyFieldBeta = keyGenerator.generateCacheKey("findByFieldBeta", myEntity.getFieldBeta());
List cacheListFieldBeta = (List) cache.get(keyFieldBeta).getObjectValue();
cacheListFieldBeta.remove(myEntity);
}
}
}
也许这是解决它的正确方法？我还没有偶然发现任何解决这些问题的食谱，所以我在这里是最好的猜测。