LruEvictionPolicyを使用してApache Ignite 1.6でキャッシュデータを試しています。私はキャッシング動作(プロセスキャッシングにおけるApache Ignite/Redis/Memcached/.NET)を観察するためのテストコードを書いています。私はWin10/VS2015で作業しています。使用した場合Evict Policyの使用中にApache IgniteがOOMになる
class IgniteCache : ICache, IDisposable
{
private IIgnite _ignite;
private Apache.Ignite.Core.Cache.ICache<string, string> _cache;
public IgniteCache()
{
var conf = new IgniteConfiguration();
//conf.JvmInitialMemoryMb = 512;
//conf.JvmMaxMemoryMb = 1024;
conf.JvmOptions = new string[] { "-XX:+UseParNewGC",
"-XX:+UseConcMarkSweepGC",
"-XX:+UseTLAB",
"-XX:NewSize=128m",
"-XX:MaxNewSize=128m",
"-XX:MaxTenuringThreshold=0",
"-XX:SurvivorRatio=1024",
"-XX:+UseCMSInitiatingOccupancyOnly",
"-XX:CMSInitiatingOccupancyFraction=60" };
var cacheConf = new CacheConfiguration();
cacheConf.CopyOnRead = false;
cacheConf.EagerTtl = false;
cacheConf.AtomicityMode = CacheAtomicityMode.Atomic;
cacheConf.WriteBehindEnabled = false;
cacheConf.EvictionPolicy = new Apache.Ignite.Core.Cache.Eviction.LruEvictionPolicy()
{
MaxMemorySize = 1073741824
};
cacheConf.Name = "cache";
cacheConf.CacheMode = CacheMode.Local;
cacheConf.Backups = 0;
cacheConf.OffHeapMaxMemory = -1;
cacheConf.EnableSwap = false;
conf.CacheConfiguration = new List<CacheConfiguration>() { cacheConf };
conf.DiscoverySpi = new TcpDiscoverySpi
{
IpFinder = new TcpDiscoveryStaticIpFinder
{
Endpoints = new[] { "127.0.0.1:47500" }
},
SocketTimeout = TimeSpan.FromSeconds(0.3)
};
_ignite = Ignition.Start(conf);
TimeSpan timeSpan = new TimeSpan(6, 0, 0);
_cache = _ignite.GetCache<string, string>("cache").WithExpiryPolicy(new Apache.Ignite.Core.Cache.Expiry.ExpiryPolicy(timeSpan, timeSpan, timeSpan));
}
public void AddValue(string key, string values)
{
_cache.Put(key, values);
}
public void Dispose()
{
_ignite.Dispose();
}
public string GetValue(string key)
{
if (HasElement(key))
{
return _cache.Get(key);
}
return null;
}
public bool HasElement(string key)
{
return _cache.ContainsKey(key);
}
}
"= 1024 conf.JvmMaxMemoryMb;":
static void Main(string[] args)
{
// 64Bit -> size in memory for an atring = 26 + length * 2
// using 512KB string
StringBuilder builder = new StringBuilder(262131);
for (int i = 0; i < 262131; i++)
{
builder.Append('G');
}
ICache cache;
IList<bool> cacheMemTest;
cache = new IgniteCache();
cacheMemTest = TestCache(cache, builder.ToString(), 10);
DrawResult(GetFilestreamForName("IgniteCache"), cacheMemTest);
}
private static IList<bool> TestCache(ICache cache, string testValue, int delay)
{
int numOfElements = 10000;
for (int i = 0; i < numOfElements; i++)
{
var currentString = String.Copy(testValue);
cache.AddValue(i.ToString(), currentString);
currentString = null;
GC.Collect();
}
IList<bool> boolList = new List<bool>(numOfElements);
for (int i = 0; i < numOfElements; i++)
{
boolList.Add(cache.HasElement(i.ToString()));
}
return boolList;
}
IgniteCachクラスは、このようになります。私は記憶がなくなり、LruEvictionPolicyは何もしないようです。 JVM maxを削除するメモリの制限は、プログラムが終了するまで〜5GBを割り当てるまで実行されます。今私は結果をチェックしています:キャッシュされたデータの約2/5はまだキャッシュにあります。それは私の欲しい/期待された動作だが、あまりにも多くのメモリが使用されている。
使用メモリを減らす方法はありますか?
私はoomを実行中に最大ヒープサイズ(最大5GB)として異なる値を使用しました。 CopyOnReadをtrueに設定すると、問題が解決されました。ありがとう。 –