StackExchange.Redis Introduction

Redis Developer Course	Redis Technical Support	Redis Enterprise Server

Redis Client for C#

C# 용 Redis Client입니다.
StackExchange.Redis Github
Visual Studio C# -> 프로젝트 -> NuGet 패키지 관리 -> StackExchange.Redis
이 문서는 StackExchange.Redis 버전 1.2.6, 레디스 버전 4.0.6을 기준으로 만들었습니다.

Connection, DB commands

allowAdmin: true로 설정하면 info, config 같은 서버 관련 명령을 실행할 수 있습니다.
redis.GetDatabase(): set, get 같은 DB 관련 명령을 실행 수 있습니다.
redis.GetServer(): info, dbsize, config 같은 특정 서버와 관련된 명령을 실행할 수 있습니다.
Sync, Async 명령을 실행할 수 있습니다.

using System;
using System.Linq;
using System.Collections.Generic;
using System.Diagnostics;		// Stopwatch
using StackExchange.Redis; // from nuGet "StackExchange.Redis"

// 127.0.0.1:6000 Standalone master
ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("127.0.0.1:6000,allowAdmin=true,ConnectTimeout=3000");
IDatabase db = redis.GetDatabase();
// for Server Commands
IServer server = redis.GetServer("127.0.0.1", 6000);

Console.Write("SET mykey ");
string value = Console.ReadLine();
db.StringSet("mykey", value);

string ret = db.StringGet("mykey");
Console.WriteLine(ret);
Console.WriteLine("Press any key to SET Sync loop test");
Console.ReadKey();

Stopwatch sw = new Stopwatch();
//--------------------------
// SET loop Sync
//--------------------------
Console.WriteLine("SET Sync 10000 - start");
sw.Start();
string key = "key";
for (int i = 0; i < 10000; i++)
{
		db.StringSet(key + i, "value" + i);
}
sw.Stop();
Console.WriteLine("SET Sync 10000 - end -> " + sw.ElapsedMilliseconds.ToString() + "ms");

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

long dbsize = server.DatabaseSize();
Console.WriteLine("dbsize -> " + dbsize);
Console.ReadKey();

Transaction: multi - exec

// transaction: multi - exec
var tran = db.CreateTransaction();
tran.StringSetAsync("keyXX-2", "Value2");
tran.StringSetAsync("keyXX-3", "Value3");
tran.StringSetAsync("keyXX-4", "Value4");
bool committed = tran.Execute();
Console.WriteLine("Transaction in Standalone server -> " + committed);
Console.ReadKey();

Pub/Sub

redis.GetSubscriber()을 이용합니다.

//--------------------------
// Pub/Sub
//--------------------------
Console.WriteLine("Pub/Sub channel ch01");
ISubscriber sub = redis.GetSubscriber();
// Wait publish
sub.Subscribe("ch01", (channel, message) => {
		Console.WriteLine(channel + ":" + message);
});
Console.ReadKey();

Server commands

redis.GetServer()을 이용합니다.

// server commands
try
{
		// info
		Console.WriteLine("server commands");
		Console.WriteLine("info - Press any key to continue");
		Console.ReadKey();
		IGrouping<string, KeyValuePair<string, string>>[] info = server.Info();
		for (int i = 0; i < info.Length; i++)
		{
				Console.WriteLine(info[i].Key);
				foreach (KeyValuePair<string, string> kvp in info[i])
				{
						Console.WriteLine("{0} -> {1}", kvp.Key, kvp.Value);
				}
		}
		// config get
		Console.WriteLine("");
		Console.WriteLine("config get - Press any key to continue");
		Console.ReadKey();
		KeyValuePair<string, string>[] config = server.ConfigGet("*");
		foreach (KeyValuePair<string, string> kvp in config)
		{
				Console.WriteLine("{0} -> {1}", kvp.Key, kvp.Value);
		}

}
catch (Exception e)
{
		Console.WriteLine(e);
}
Console.ReadKey();

	Standalone	StackExchange.Redis Cluster >>

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