私のクラスメディエーターコードは次のとおりです。
package wso2.caching;
import org.apache.synapse.MessageContext;
import org.apache.synapse.mediators.AbstractMediator;
import java.util.Date;
import net.sf.ehcache.CacheManager;
import net.sf.ehcache.Element;
import net.sf.ehcache.Cache;
import net.sf.ehcache.config.CacheConfiguration;
public class CacheMe extends AbstractMediator {
String data = "";
CacheManager cacheManager;
CacheConfiguration cacheConfiguration;
Element element;
private Cache mdmCache;
boolean firstTime=true;
public boolean mediate(MessageContext messageContext) {
System.out.println(new Date() + "FirstTime = " + firstTime);
data = String.valueOf(messageContext.getProperty("propertyarray"));
System.out.println("data from proxy service is : " + data);
cacheData(data);
messageContext.setProperty("ResultData", "You got Data");
return true;
}
public void cacheData(String data){
if(firstTime){
cacheManager = new CacheManager();
firstTime=false;
}
System.out.println(new Date() + "FirstTime = " + firstTime);
System.out.println("Checkpoint A");
//mdmCache = new Cache(getCacheConfiguration("mdmCache"));//test
cacheManager.addCache("mdmCache");
System.out.println("Checkpoint B");
this.mdmCache = cacheManager.getCache("mdmCache");
System.out.println("Checkpoint C");
//this.mdmCache = mdmCache;//test
System.out.println(new Date() + " Generating MDM Data...");
System.out.println("mdmCache.size(): " + mdmCache.getSize());
Element eqpElement = new Element("CacheValueKey", data);
mdmCache.put(eqpElement);
System.out.println("mdmCache.size(): " + mdmCache.getSize());
}
}
最終的にプロキシ サービスで呼び出されるように、esb のシーケンスでこのクラス メディエーターを呼び出しています。
<sequence xmlns="http://ws.apache.org/ns/synapse" name="cacheImplementationSeq">
<property xmlns:ns="http://org.apache.synapse/xsd" name="propertyarray" expression="$body"/>
<log level="custom">
<property xmlns:ns="http://org.apache.synapse/xsd" name="PropertyData" expression="get-property('propertyarray')"/>
</log>
<class name="cts.falcon.data.cachable.CacheData"/>
<property xmlns:ns="http://org.apache.synapse/xsd" name="ResultSet" expression="get-property('ResultData')" scope="default" type="STRING"/>
<header name="To" action="remove"/>
<property name="RESPONSE" value="true" scope="default" type="STRING"/>
<property name="NO_ENTITY_BODY" action="remove" scope="axis2"/>
<payloadFactory>
<format>
<resultSetResponse xmlns:ns1="http://www.cts.falcon.data.cachable/">$1</resultSetResponse>
</format>
<args>
<arg xmlns:ns="http://org.apache.synapse/xsd" expression="get-property('ResultSet')"/>
</args>
</payloadFactory>
<send/>
</sequence>
プロキシ サービスを try-it から初めて実行すると、一意のキー (UUID) を持つ応答がキャッシュされ、サービスを再度実行すると、以前のキーが新しいキーと新しい応答値に置き換えられます。私が探しているのは、キーが同じ場合はキャッシュを更新する必要があり、キーが異なる場合は新しいキーで追加され、以前のキャッシュ キーが消えてはならないということです。これを実現するために、プラグインに wso2 esb が付属する ehcache1.5.0 jar を使用しています。回答をお待ちしております。前もって感謝します