南昌市教育局:【Redis】集群NetCore实战

admin 6个月前 (04-11) 科技 40 0

环境准备

1. Redis集群(Windows集群搭建)

启动Redis集群,给每个节点加上Title

start "Redis - 6379" /min redis-server.exe redis.6379.conf
start "Redis - 6380" /min redis-server.exe redis.6380.conf
start "Redis - 6381" /min redis-server.exe redis.6381.conf
start "Redis - 6382" /min redis-server.exe redis.6382.conf
start "Redis - 6383" /min redis-server.exe redis.6383.conf
start "Redis - 6384" /min redis-server.exe redis.6384.conf

2. 安装StackExchange.Redis包

dotnet add package StackExchange.Redis

 

毗邻Redis

var configString = "127.0.0.1:6379";
var options = ConfigurationOptions.Parse(configString);
options.ReconnectRetryPolicy = new ExponentialRetry(5000);
var client = ConnectionMultiplexer.Connect(options);

这里只需要提供一个节点就能接见整个集群

ConnectionMultiplexer 毗邻Redis可以使用ConfigurationOptions,或者直接字符串初始化(内里实现也是挪用ConfigurationOptions.Parse转换)

这里要说一下是他的重连重试机制,在第一次建立毗邻的时刻,StackExchange.Redis会建立一个心跳检测

internal static IDisposable Create(ConnectionMultiplexer connection)
{
    var token = new TimerToken(connection);
    var timer = new Timer(Heartbeat, token, MillisecondsPerHeartbeat, MillisecondsPerHeartbeat);
    token.SetTimer(timer);
    return timer;
}

使用System.Threading.Timer每秒钟检查一次。

StackExchange.Redis 实现两种重试计谋,固然我们也可以实现自己的重现计谋,实现IReconnectRetryPolicy接口

  •  ExponentialRetry(指数)

   凭据指定时间,凭据重试次数不停增大随机数局限

  • LinearRetry(线性)

   凭据指定时间牢固时间距离重试

常用数据结构操作

字符串(String)操作

 

static void RedisStringOperation(ConnectionMultiplexer client)
{
    var db = client.GetDatabase();

    //单个Key操作
    db.StringSet("Key", "Wilson");
    Console.WriteLine($"Get Key : {db.StringGet("Key")}");

    db.StringSet("Nums", 1);
    db.StringIncrement("Nums");
    Console.WriteLine($"Get Nums : {db.StringGet("Nums")}");

    db.StringDecrement("Nums");
    Console.WriteLine($"Get Nums : {db.StringGet("Nums")}");

    //多个Key操作
    db.StringSet(new KeyValuePair<RedisKey, RedisValue>[]
    {
        new KeyValuePair<RedisKey, RedisValue>("{user}Name","Wilson"),
        new KeyValuePair<RedisKey, RedisValue>("{user}Age",30)
    });

    foreach (var value in db.StringGet(new RedisKey[] { "{user}Name", "{user}Age" }))
    {
        Console.WriteLine($"{value}");
    }
}

 

哈希(Hash)操作

 

static void RedisHashOperation(ConnectionMultiplexer client)
{
    var db = client.GetDatabase();

    db.HashSet("person", "name", "Wilson");
    Console.WriteLine(db.HashGet("person", "name"));

    db.HashSet("person", new HashEntry[]
    {
        new HashEntry("name","Wilson"),
        new HashEntry("sex",1)
    });
    Console.WriteLine(string.Join("\n", db.HashGet("person", new RedisValue[] { "name", "sex" })));

    Console.WriteLine(string.Join("\n", db.HashGetAll("person")));
}

 

列表(List) 操作

 

static void RedisListOperation(ConnectionMultiplexer client)
{
    var db = client.GetDatabase();

    db.ListLeftPush("list", 100);
    db.ListLeftPush("list", 200);
    db.ListLeftPush("list", 300);
    db.ListRightPush("list", 400);
    db.ListRightPush("list", 500);

    Console.WriteLine(db.ListLeftPop("list"));
    Console.WriteLine(db.ListRightPop("list"));
    Console.WriteLine(string.Join("\t", db.ListRange("list", 0, 2)));
    Console.WriteLine(db.ListLength("list"));
}

 

聚集(Set)

 

static void RedisSetOperation(ConnectionMultiplexer client)
{
    var db = client.GetDatabase();

    db.SetAdd("user", "Wilson");
    db.SetAdd("user", "Wilson");
    db.SetAdd("user", "Alice");

    Console.WriteLine(db.SetLength("user"));
    Console.WriteLine(db.SetPop("user"));
    Console.WriteLine(string.Join("\n", db.SetMembers("user")));
}

 

有序聚集(Sorted Set)

 

static void RedisSortedSetOperation(ConnectionMultiplexer client)
{
    var db = client.GetDatabase();

    db.KeyDelete("user");

    db.SortedSetAdd("user", "Wilson", 90);
    db.SortedSetAdd("user", "Alice", 85);
    db.SortedSetAdd("user", "Trenary", 12);
    db.SortedSetAdd("user", "Nixon", 30);

    Console.WriteLine(db.SortedSetLength("user"));
    Console.WriteLine(db.SortedSetRemove("user", "Wilson"));
    Console.WriteLine(string.Join("\n", db.SortedSetRangeByRank("user", 0, 2)));
}

 

转发请标明出处:https://www.cnblogs.com/WilsonPan/p/12677478.html

示例代码: https://github.com/WilsonPan/Net.Demos/tree/master/Demo.RedisCluster

参考文章

StackExchange.Redis | General purpose redis client

,

阳光娱乐

阳光娱乐(原诚信在线官网)现已开放阳光在线手机版、阳光在线电脑客户端下载。阳光在线娱乐戏公平、公开、公正,用实力赢取信誉。

AllBetGaming声明:该文看法仅代表作者自己,与本平台无关。转载请注明:南昌市教育局:【Redis】集群NetCore实战

网友评论

  • (*)

最新评论

文章归档

站点信息

  • 文章总数:794
  • 页面总数:0
  • 分类总数:8
  • 标签总数:1349
  • 评论总数:363
  • 浏览总数:32707