[OSB, Coherence] OSB Result Cache Invalidation from C++ Client

原文はこちら。
https://blogs.oracle.com/jaylee/entry/osb_result_cache_invalidation_from

---

［訳注］
この方法はサポートされていません。参考にされるのは結構ですが、あくまでも自己責任でお願いします。

最近お客様よりOSB結果キャッシュのデータを無効化したい、との問い合わせを受けました。データを無効かするキーを作成する方法はないので、取り得る最善の方策はフィルタを使うことです。コードスニペットを以下に記載します。

extern "C" void invalidate(char* key) {     try {         String::View vsCacheName = "/osb/service/ResultCache";         NamedCache::Handle hCache = CacheFactory::getCache(vsCacheName);         ValueExtractor::Handle hExtractor = KeyExtractor::create(ReflectionExtractor::create("getToken"));         Filter::View vEqualsFilter = EqualsFilter::create(hExtractor, String::create(key));         hCache->invokeAll(vEqualsFilter, ConditionalRemove::create(AlwaysFilter::getInstance(),true));     }         catch (const std::exception& e) {         std::cerr << "error: " << e.what() << std::endl;     }   }

ここで一つ問題があります。それは、ビジネスサービスのどの結果を無効化すべきかわからないということです。2個のビジネスサービスがたまたま同じトークンを持っている場合、これは両方のトークンを削除することになって望ましいことではありません。また、インデックスが所定の位置にないため、キャッシュサイズが巨大である場合、パフォーマンスの課題も考えられます。現在のところ、Keyのクラスを作成する方法はわかっていません。独力でやってみようとしましたが、どういうわけか、作成したものとOSBが生成したものが異なっていました。そのため、最後には自作のResultCacheロジックを作成し、この目的を達成したのです。

public class ResultCacheHelper {       private static String CACHE_NAME = "dist-test";       public static void put(String key, org.apache.xmlbeans.XmlObject value) throws IOException {         NamedCache cache = CacheFactory.getCache(CACHE_NAME);         cache.put(key, serialize(value));           CacheFactory.log("Cache Key : " + key + " is put in Cache!:" + serialize(value).toString());     }       public static org.apache.xmlbeans.XmlObject get(String key) throws IOException, ClassNotFoundException, XmlException {           XmlObject result;         NamedCache cache = CacheFactory.getCache(CACHE_NAME);           byte[] bytes = (byte[]) cache.get(key);           if(bytes == null) {             String xmlNull = "<cache com.oracle.demoapp.ws="" http:="" xmlns="\">null</cache>";             result = org.apache.xmlbeans.XmlObject.Factory.parse(xmlNull);             CacheFactory.log("Cache Key : " + key + " is not found in Cache!");         }         else {             result = (org.apache.xmlbeans.XmlObject)deserialize(bytes, Thread.currentThread().getContextClassLoader());             CacheFactory.log("Cache Key : " + key + " is found in Cache!:"+result.toString());         }           return result;     }         protected static Object deserialize(byte[] bytes, final ClassLoader cl) throws IOException, ClassNotFoundException {           ObjectInputStream ois = null;           try {               ByteArrayInputStream bais = new ByteArrayInputStream(bytes);             ois = new ObjectInputStream(bais) {                   protected Class resolveClass(ObjectStreamClass desc) throws IOException, ClassNotFoundException {                     return Class.forName(desc.getName(), false, cl);                 }               };               return ois.readObject();         }         finally {             if (ois != null) ois.close();         }     }         protected static byte[] serialize(Object object) throws IOException {           ObjectOutputStream oos = null;           try {             ByteArrayOutputStream baos = new ByteArrayOutputStream();             oos = new ObjectOutputStream(baos);             oos.writeObject(object);             return baos.toByteArray();         }         finally {             if (oos != null) oos.close();         }     } }

これで、キャッシュを無効化することができます。

String::View deleteKey = key; String::View vsCacheName = "dist-test"; NamedCache::Handle hCache = CacheFactory::getCache(vsCacheName); hCache->remove(deleteKey);

近い将来OSBのキャッシュ無効化機能が追加されると信じています。