本文介绍如何在.net中使用redis

安装

代码使用

StackExchange.Redis基础使用

StackExchange.Redis中的事务

    • 安装Chocolatey请看Chocolatey安装
    • 安装redis choco install redis-64
    • 运行 redis-server.exe 如果运行失败,设置环境变量 SET PATH=%PATH%;"c:\Program Files\Redis"
    • 创建一个控制台程序,安装Nuget包 StackExchange.Redis
    • 创建ConnectionMultiplexer实例
        public class RedisConnectorHelper
    {
    private static Lazy<ConnectionMultiplexer> lazyConnection;
    static RedisConnectorHelper ()
    {
    lazyConnection = new Lazy<ConnectionMultiplexer>(() =>
    {
    return ConnectionMultiplexer.Connect("localhost");
    });
    }
    public static ConnectionMultiplexer Connection
    {
    get { return lazyConnection.Value; }
    }
    }
    创建这个包含静态构造函数的类的目的,就是避免重复创建ConnectionMultiplexer提高性能和避免Azure限制
    • 保存数据
        public void SavaData()
    {
    IDatabase db = RedisConnectorHelper.Connection.GetDatabase();
    Random rd = new Random();
    for(int i = 0; i < 10000; i++)
    {
    int num = rd.Next();
    db.StringSet($"Ye{i}", num);
    }
    }
    • 读取数据
        public void ReadData()
    {
    IDatabase db = RedisConnectorHelper.Connection.GetDatabase();
    for(int i = 0; i < 10000; i++)
    {
    RedisValue value = db.StringGet($"Ye{i}");
    Console.WriteLine(value);
    }
    Console.ReadKey();
    }
    • ConnectionMultiplexer类实例
        ConnectionMultiplexer类实例最好只创建一次
    ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
    ConnectionMultiplexer类实现了IDisposable接口,你在不需要redis实例的时候可以手动释放他,但是我们一般不这么做,因为我们需要复用这个实例
    • 使用redis数据库
        获取数据库
    写法一,不带数据
    IDatabase db = redis.GetDatabase();
    写法二,带自定义数据
    int databaseNumber = 1;
    object asyncState = 2;
    IDatabase db = redis.GetDatabase();
    使用数据库中的方法
    db.StringAppend("YeJaiWei", "!");
    await db.StringAppendAsync("YeJaiWei", "?");
    可用的redis操作方法可以访问 https://redis.io/commands
    • redis数据库的数据类型
        Strings
    Strings类型的数据,可以包含任何类型的数据,只要最终可以编码成二进制都行
    db.StringSet("a", "你好吗");
    b.StringGet("a")
    Lists
    list就是一个数组类似的结构,由string构成,使用方法如下
    db.ListLeftPush("myList", "b"); // 如果不存在myList结构,那么创建一个名为myList的List集合,将值追加到最前面
    RedisValue result = db.ListGetByIndex("myList", 0); // 根据索引获取结合中的值
    还有很多其他的操作方法,请自行查阅
    list最多的元素可以有4294967295个,访问list中的元素,两端的速度比中间的快
    Sets
    上面讲的list是有序的集合,可以通过索引访问,但是set是无序的,成员都是唯一的不重复,使用方式如下
    db.SetAdd("mySet", "aaa"); // mySet不存在则创建
    RedisValue[] result = db.SetMembers("mySet");
    Hashes
    Hashes顾名思义就是用来表示键值对对象的集合,可存储量非常大,可以有4294967295个键值对,使用方式如下
    db.HashSet("myHash", "name", "yejiawei");
    RedisValue result = db.HashGet("myHash", "name");
    Sorted sets
    此数据类型是redis最引以为傲的成果,作用是使用score将无序的set排个序,从最小的score到最大的score排序
    成员都是唯一的,但是score可以是重复的,由于元素被score排序了,访问set中间的元素也是非常迅速的
    db.SortedSetAdd("mySortedSet","aaa", 11);
    RedisValue result = db.SortedSetScore("mySortedSet","aaa");
    • redis中的pub/sub
        使用pub/sub对开发分布式程序来说帮助很大,订阅和发布之间的通信是通过channel实现的
    使用步骤如下
    首先,创建Subscriber实例
    ISubscriber sub = redis.GetSubscriber();
    使用订阅者
    sub.Subscribe("message", (channel, message) =>
    {
    Console.WriteLine(message);
    });
    使用发布者(这个发布者可以在其他的机器上面运行)
    sub.Publish("message", "你好");
    • 访问单个的服务器
        有时候需要维护数据库,查看数据库相关的信息
    查看redis里面连接的服务器端口号
    EndPoint[] ep = redis.GetEndPoints();
    创建Server实例
    IServer server = redis.GetServer("localhost", 6379);
    访问服务器信息
    DateTime lastSaveTime = server.LastSave(); // 上次保存时间
    • Fire-and-Forget模式的使用
        有的方法会返回值,但是我们对这个值不感兴趣,那么我们可以不让它返回,可以提高性能
    一个使用的例子
    var test = db.StringIncrement("Ye1", 2, CommandFlags.FireAndForget); // 指定了此flag,int类型的都返回默认值0,string类型返回默认值null
    var result = db.StringGet("Ye1");
  1.     写法一,事务写法
    IDatabase db = ConnectionMultiplexer.Connect("localhost").GetDatabase();
    ITransaction tran = db.CreateTransaction(); // 创建一个Transaction实例
    tran.AddCondition(Condition.HashNotExists("YeTran", "Test")); // 给事务添加判断条件
    tran.HashSetAsync("YeTran", "Test", "hahaha");
    bool committed = tran.Execute(); // 执行事务
    if(committed)
    {
    Console.WriteLine("存好了");
    }else
    {
    Console.WriteLine("已经有了");
    }
    写法二,内置操作写法
    IDatabase db = ConnectionMultiplexer.Connect("localhost").GetDatabase();
    bool committed = db.HashSet("YeTran", "Test", "hahaha", When.NotExists);
    if(committed)
    {
    Console.WriteLine("存好了");
    }else
    {
    Console.WriteLine("已经有了");
    }
05-11 18:10
查看更多