介尘部落

文学|音乐|休闲娱乐|计算机技术|地球科学|社会学——知识成就命运


C# Redis 缓存及消息队列使用之StackExchange

第1章   安装

在.NET平台使用Redis需要做如下准备工作:

创建一个新的Visual Studio应用或者打开一个已经存在的Visual Studio应用。

打开NuGet程序包

搜索并添加StackExchange.Redis程序包

第2章   数据缓存

使用redis做为数据缓存服务

string host = "192.168.200.131";
//取连接对象
ConnectionMultiplexer redis = ConnectionMultiplexer.Connect(host);
//取得DB对象
IDatabase db = redis.GetDatabase();
//设置数据对象
db.StringSet("User", "{Name:\"TOM\"}");
//添加数据对象
db.StringAppend("User", ",{Name:\"JACK\"}");

//取得数据对象
string user = db.StringGet("User");
Console.WriteLine(user);

第3章   订阅及发布

发布消息

static void Main(string[] args)
{
string host = "192.168.28.106";
//取连接对象
ConnectionMultiplexer redis = ConnectionMultiplexer.Connect(host);
//设置数据对象
//取得订阅对象
ISubscriber sub = redis.GetSubscriber();
//发布消息到channel:c1
sub.Publish("c1", "123");
//发送100万个字符的消息
sub.Publish("c1", "zx".PadRight(1000000, 'x'));
string reader = "start send";
while(reader!="exit")
{
reader = Console.ReadLine();
sub.Publish("c1", reader);
}
Console.ReadLine();
}

订阅消息

static void Main(string[] args)
{

string host = "192.168.28.106";
//取连接对象
ConnectionMultiplexer redis = ConnectionMultiplexer.Connect(host);
//设置数据对象
//取得订阅对象
ISubscriber sub = redis.GetSubscriber();
//设置订阅事件
sub.Subscribe("c1", new Action<RedisChannel, RedisValue>(GetMessage));

Console.Read();
Console.ReadLine();
}
/// <summary>
/// 获取消息
/// </summary>
/// <param name="channel"></param>
/// <param name="message"></param>
static void GetMessage(RedisChannel channel, RedisValue message)
{
Console.WriteLine(channel);
Console.WriteLine(message);
}
阅读全文
公众号-介尘阅读时光
赞赏支持

0 Responses to “C# Redis 缓存及消息队列使用之StackExchange”

Leave a Reply

You may use these HTML tags and attributes: <a href="" title=""> <abbr title=""> <acronym title=""> <b> <blockquote cite=""> <cite> <code> <del datetime=""> <em> <i> <q cite=""> <s> <strike> <strong>

(required)

(required)

×