5

cassandra .net ドライバーを使用すると、次の問題に直面しています。パラメーター化された INSERT で多くの行を挿入すると、アプリケーションのメモリ使用量が継続的に増加します。

class Program
{
    static Cluster cluster = Cluster.Builder()
        .AddContactPoints(ConfigurationManager.AppSettings["address"])
        .Build();
    static Session session = cluster
        .Connect(ConfigurationManager.AppSettings["keyspace"]);
    static int counter = 0;

    static void Main(string[] args)
    {
        for (int i = 0; i < 50; i++)
        {
            new Thread(() =>
            {
                while (true)
                {
                    new Person()
                    {
                        Name = Interlocked.Increment(ref counter).ToString(),
                        ID = Guid.NewGuid(),
                        Data = new byte[4096],
                    }.Save(session);
                }
            }).Start();
        }

        Console.ReadLine();
    }
}

class Person
{
    public Guid ID
    {
        get;
        set;
    }

    public string Name
    {
        get;
        set;
    }

    public byte[] Data
    {
        get;
        set;
    }

    public void Save(Session session)
    {
        Stopwatch w = Stopwatch.StartNew();

        session.Execute(session.Prepare(
            "INSERT INTO Person(id, name, data) VALUES(?, ?, ?);")
            .Bind(this.ID, this.Name, this.Data));

        Console.WriteLine("{1} saved in {0} ms",
            w.Elapsed.TotalMilliseconds, this.Name);
    }
}

作成されたメモリ ダンプによると、マネージ ヒープには大量の小さなバイト配列 (ほとんどが第 2 世代) が含まれており、内部 TypeInterpreter クラスの cassandra ドライバーのバイト変換メソッド (InvConvert*) にまでさかのぼることができます。

この問題を解決するためのアドバイスやアイデアはありますか?

4

3 に答える 3

5

これに遭遇する他の人のために。ステートメントCassandra.ISessionを介して正しく破棄していたにもかかわらず、多くの s を作成するとメモリの問題が発生しました。usingシングルを再利用するISessionようにコードを変更すると、修正されたようです。これが最善の解決策かどうかはわかりません。

于 2015-02-26T18:09:09.493 に答える