StackExchange.Redis Cluster

Redis Developer Course	Redis Technical Support	Redis Enterprise Server

for Cluster

Connection, DB commands

connectString에 클러스터 내 노드들의 주소(ip:port)를 입력한다.
ConfigCheckSeconds: 지정한 시간(초) 주기로 클러스터 구성 정보를 업데이트한다. Default 60초

ConnectionMultiplexer redisCluster = null;
try
{
		string connectString = "127.0.0.1:7000,127.0.0.1:7001,127.0.0.1:7002";
		var options = ConfigurationOptions.Parse(connectString);
		options.AllowAdmin = true;
		options.ConfigCheckSeconds = 10;
		options.SyncTimeout = 1000;
		//  options.Password = "password";
		redisCluster = ConnectionMultiplexer.Connect(options);
}
catch (Exception e)
{
		Console.WriteLine(e);
}

int loop = 100000;
IDatabase clusterDb = redisCluster.GetDatabase();
Console.WriteLine("SET Sync " + loop + " - Press any key to start");
Console.ReadKey();
Console.WriteLine("SET Sync " + loop + " - start");

// SET
sw.Reset();
sw.Start();
bool ret3;
for (int i = 0; i < loop; i++)
{
		try
		{
				ret3 = clusterDb.StringSet(key + i, "value" + i);
				Console.WriteLine(key + i + " -> " + ret3);
		}
		catch (Exception e)
		{
				Console.WriteLine(e);

		}
}
sw.Stop();
Console.WriteLine("SET Sync " + loop + " - end -> " + sw.ElapsedMilliseconds.ToString() + "ms");

// SET loop Async
Console.WriteLine("SET Async " + loop + " - Press any key to start");
Console.ReadKey();
Console.WriteLine("SET Async " + loop + " - start");
sw.Reset();
sw.Start();
for (int i = 0; i < loop; i++)
{
		clusterDb.StringSetAsync(key + "-" + i, "value" + "-" + i);
}
sw.Stop();
Console.WriteLine("SET Async " + loop + " - end -> " + sw.ElapsedMilliseconds.ToString() + "ms");

Transaction: multi - exec

cluster에서 multi key transaction을 실행하려면 hash tag({...})를 사용한다.

// transaction: multi - exec
// cluster에서 multi key transaction을 실행하려면 hash tag({...})를 사용한다.
Console.WriteLine("Transaction in Cluster");
try
{   // {key} 사용
		var tran2 = clusterDb.CreateTransaction();
		tran2.StringSetAsync("{key}keyXX-2", "Value2");
		tran2.StringSetAsync("{key}keyXX-3", "Value3");
		tran2.StringSetAsync("{key}keyXX-4", "Value4");
		bool committed2 = tran2.Execute();
		Console.WriteLine("Transaction in Cluster -> " + committed2);
}
catch (Exception e)
{
		Console.WriteLine(e);
}

Pub/Sub

클러스터에서는 한 노드에서 publish하면 클론을 포함한 클러스터내 모든 노드에서 subscribe할 수 있다.

// Pub/Sub
ISubscriber subCluster = redisCluster.GetSubscriber();
Console.WriteLine("Publish ch01 loop 100,000 - start");
try
{
		for (int i = 0; i < 100000; i++)
		{
				subCluster.Publish("ch01", "Hello " + value + i);
		}
}
catch (Exception e)
{
		Console.WriteLine(e);
}

// Subscribe
Console.WriteLine("Wait publish ch01 - Cluster");
subCluster.Subscribe("ch01", (channel, message) => {
		Console.WriteLine(channel + ":" + message);
});

<< Standalone	Cluster	PHPREDIS >>

Email 답글이 올라오면 이메일로 알려드리겠습니다.