博客

1. 
   public
   
   static RedisConfigInfo GetConfig()
   
   
2. {
3. RedisConfigInfo section = (RedisConfigInfo)ConfigurationManager.GetSection(
   
   “RedisConfig”);
   
4. 
   return section;
   
5. }
7. 
   public
   
   static RedisConfigInfo GetConfig(
   
   string sectionName)
   
   
   
8. {
9. RedisConfigInfo section = (RedisConfigInfo)ConfigurationManager.GetSection(
   
   “RedisConfig”);
   
10. 
    if (section ==
    
    null)
    
    
11. 
    throw
    
    new ConfigurationErrorsException(
    
    “Section ” + sectionName +
    
    ” is not found.”);
    
    
    
    
12. 
    return section;
    
13. }

1. 
   /// <summary>
   
2. 
   /// redis配置文件信息
   
3. 
   /// </summary>
   
4. 
   private
   
   static RedisConfigInfo redisConfigInfo = RedisConfigInfo.GetConfig();
   
   
6. 
   private
   
   static PooledRedisClientManager prcm;
   
   
8. 
   /// <summary>
   
9. 
   /// 静态构造方法，初始化链接池管理对象
   
10. 
    /// </summary>
    
11. 
    static RedisManager()
    
12. {
13. CreateManager();
14. }
17. 
    /// <summary>
    
18. 
    /// 创建链接池管理对象
    
19. 
    /// </summary>
    
20. 
    private
    
    static
    
    void CreateManager()
    
    
    
21. {
22. 
    string[] writeServerList = SplitString(redisConfigInfo.WriteServerList,
    
    “,”);
    
    
23. 
    string[] readServerList = SplitString(redisConfigInfo.ReadServerList,
    
    “,”);
    
    
25. prcm =
    
    new PooledRedisClientManager(readServerList, writeServerList,
    
26. 
    new RedisClientManagerConfig
    
27. {
28. MaxWritePoolSize = redisConfigInfo.MaxWritePoolSize,
29. MaxReadPoolSize = redisConfigInfo.MaxReadPoolSize,
30. AutoStart = redisConfigInfo.AutoStart,
31. });
32. }
34. 
    private
    
    static
    
    string[] SplitString(
    
    string strSource,
    
    string split)
    
    
    
    
    
35. {
36. 
    return strSource.Split(split.ToArray());
    
37. }
39. 
    /// <summary>
    
40. 
    /// 客户端缓存操作对象
    
41. 
    /// </summary>
    
42. 
    public
    
    static IRedisClient GetClient()
    
    
43. {
44. 
    if (prcm ==
    
    null)
    
    
45. CreateManager();
47. 
    return prcm.GetClient();
    
48. }

四、写入数据

五、删除数据

在

C# Redis实战(四)

中讲述了如何在Redis中写入key-value型数据，本篇将讲述如何删除Redis中数据。

1、void Delete(T entity);删除函数的运用

[csharp]


view plain


copy

1. 
   using (var redisClient = RedisManager.GetClient())
   
2. {
3. var user = redisClient.GetTypedClient<User>();
4. var newUser =
   
   new User
   
5. {
6. Id = user.GetAll().Count,
7. Name = txtName.Text,
8. Job =
   
   new Job { Position = txtPosition.Text }
   
9. };
10. user.Delete(newUser);
12. }

以上代码直接删除了最后一条数据，效果图如下：

2


、void DeleteById(object id);删除数据函数

[csharp]


view plain


copy

1. 
   using (var redisClient = RedisManager.GetClient())
   
2. {
3. var user = redisClient.GetTypedClient<User>();
4. 
   //var newUser = new User
   
5. 
   //{
   
6. 
   //    Id = user.GetAll().Count,
   
7. 
   //    Name = txtName.Text,
   
8. 
   //    Job = new Job { Position = txtPosition.Text }
   
9. 
   //};
   
10. 
    //user.Delete(newUser);
    
11. user.DeleteById(txtRedisId.Text);
    
    //txtRedisId.Text中为ID值
    
12. }

如下图，删除了ID等于3的一条数据。

3、void DeleteByIds(IEnumerable ids);批量删除函数

[csharp]


view plain


copy

1. 
   using (var redisClient = RedisManager.GetClient())
   
2. {
3. var user = redisClient.GetTypedClient<User>();
4. user.DeleteByIds((txtRedisId.Text).ToList());
   
   //txtRedisId.Text中为ID值
   
6. }

如下图，代码删除了ID分别为：1、2、6的三条数据。

4


、void DeleteAll();删除全部数据

[csharp]


view plain


copy

1. var user = redisClient.GetTypedClient<User>();
2. user.DeleteAll();
   
   //删除全部数据
   

如需转载，请注明出处，

本系列博文示例程序下载地址

六、查询数据

在

C# Redis实战(五)

中介绍了如何删除Redis中数据，本篇将继续介绍Redis中查询的写法。

1、使用Linq匹配关键字查询

[csharp]


view plain


copy

1. 
   using (var redisClient = RedisManager.GetClient())
   
2. {
3. var user = redisClient.GetTypedClient<User>();
4. var userList = user.GetAll().Where(x => x.Job.Position.Contains(txtScreenPosition.Text)).ToList();
6. 
   if (userList.Count > 0)
   
7. {
8. var htmlStr =
   
   string.Empty;
   
9. 
   foreach (var u
   
   in userList)
   
   
10. {
11. htmlStr +=
    
    “<li>ID=” + u.Id +
    
    ”  姓名：” + u.Name +
    
    ”  所在部门：” + u.Job.Position +
    
    “</li>”;
    
    
    
    
12. }
13. lblPeople.Text = htmlStr;
14. }
15. lblShow.Text =
    
    “筛选后共有：” + userList.Count.ToString() +
    
    “人！”;
    
    
17. }

以上代码实现了匹配所在部门来查询数据的功能，输入.NET，过滤掉Java部门的一人。查询结果如下：

2


、通过key来查询数据

在Redis中可以通过输入keys * 来查询当前数据库中所有的key，C#中我们可以通过以下代码来实现相同效果。

[csharp]


view plain


copy

1. var user = redisClient.GetTypedClient<User>();
2. var userKeyList = user.GetAllKeys();

代码中userKeyList中保存了所有的key

细心的读者会发现此处查询到的key数量与数据库保存的数据量不同

我们逐一说明下：

seq:User：用来维护当前类型User的ID自增序列,用作对象唯一ID，也就是使用GetNextSequence()函数可以获取当前数据库最新的ID的原因了。

ids:User：同一类型User中所有对象ID的列表，相当于一个索引，包含了所有同为类型User的ID；

由于维护了这样一个分组信息，所以很容易实现GetAll<User>()这样的功能。

urn:user:1：这才是保存user对象的key。

在redis-client中输入：get urn:user:1 得到json类型数据。

通过上述说明，我们就可以很轻松的通过key来查询value值了，代码如下：

[csharp]


view plain


copy

1. 
   using (var redisClient = RedisManager.GetClient())
   
2. {
3. var keyValue =
   
   string.Empty;
   
4. 
   try
   
5. {
6. var user = redisClient.GetTypedClient<User>();
7. var value = user.GetValue(txtKey.Text);
8. keyValue +=
   
   “ID=” + value.Id +
   
   ”  姓名：” + value.Name +
   
   ”  所在部门：” + value.Job.Position;
   
   
   
9. }
10. 
    catch (Exception ex)
    
11. {
12. keyValue += ex.ToString();
13. }
14. lblPeople.Text = keyValue.ToJson();
15. lblShow.Text =
    
    string.Empty;
    
16. }

效果如下：

如需转载，请注明出处，

本系列博文示例程序下载地址

七、修改数据

在上一篇

C# Redis实战(六)

中介绍了如何查询Redis中数据，本篇将介绍如何修改Redis中相关数据。大家都知道Redis是key-value型存储系统，所以应该可以修改key，也可以根据key来修改value。接下来将是详细的C#语言修改Redis示例。

1、通过key修改单个value

[csharp]


view plain


copy

1. 
   using (var redisClient = RedisManager.GetClient())
   
2. {
3. var user = redisClient.GetTypedClient<User>();
4. var value = user.GetValue(txtChangeKey.Text);
   
   //首先先获取当前key的值
   
5. var changedUser =
   
   new User
   
6. {
7. Id = value.Id,
8. Name = txtChangeName.Text,
9. Job =
   
   new Job { Position = txtChangePosition.Text }
   
10. };
    
    //设置相应的新value值，并使其它数据与原来相统一
    
11. redisClient.Set(txtChangeKey.Text, changedUser);
    
    //修改value
    
12. value = user.GetValue(txtChangeKey.Text);
    
    //根据key获取最新的数据
    
14. var htmlStr =
    
    string.Empty;
    
15. htmlStr +=
    
    “修改后的ID=” + value.Id +
    
    ”  姓名：” + value.Name +
    
    ”  所在部门：” + value.Job.Position;
    
    
    
16. lblPeople.Text = htmlStr;
17. lblShow.Text =
    
    “筛选后共有：1人！”;
    
19. }

代码执行后效果图如下：

以上代码让Redis修改了key为urn:user:1的人所在部门，将原先.NET修改为现在的Python，修改后全部的数据就变成了：

2、通过keys修改多个values

[csharp]


view plain


copy

1. var dictionary =
   
   new Dictionary<
   
   string, User>();
   
   
2. 
   using (var redisClient = RedisManager.GetClient())
   
3. {
4. var user = redisClient.GetTypedClient<User>();
5. var user1 =
   
   new User
   
6. {
7. Id = user.GetNextSequence(),
   
   //获取新的ID
   
8. Name =
   
   “小明”,
   
9. Job =
   
   new Job { Position =
   
   “Python” }
   
   
10. };
11. var user2 =
    
    new User
    
12. {
13. Id = user.GetNextSequence(),
14. Name =
    
    “小红”,
    
15. Job =
    
    new Job { Position =
    
    “Python” }
    
    
16. };
17. var userKeyList = user.GetAllKeys().Where(x => x.StartsWith(
    
    “urn”)).OrderBy(y => y).ToList();
    
    //只获取保存value的key
    
    
18. dictionary.Add(userKeyList[1], user1);
    
    //第二个人
    
19. dictionary.Add(userKeyList[2], user2);
    
    //第三个人
    
20. redisClient.SetAll(dictionary);
    
    //同时修改多个value
    
22. var users = user.GetAll();
23. 
    if (users.Count > 0)
    
24. {
25. var htmlStr =
    
    string.Empty;
    
26. 
    foreach (var u
    
    in users)
    
    
27. {
28. htmlStr +=
    
    “<li>ID=” + u.Id +
    
    ”  姓名：” + u.Name +
    
    ”  所在部门：” + u.Job.Position +
    
    “</li>”;
    
    
    
    
29. }
30. lblPeople.Text = htmlStr;
31. }
32. lblShow.Text =
    
    “筛选后共有：” + users.Count.ToString() +
    
    “人！”;
    
    
33. }

我需要在修改了第一个人所在部门的基础上同时将第二个人和第三个人所在部门、姓名、ID都一并修改，执行后效果图如下：

3、重命名key

以上修改value的示例我们只修改了value，但是并没有改变key值。如果需要重命名key，首先，查询Redis中所有的key

修改key代码如下：

[csharp]


view plain


copy

1. 
   using (var redisClient = RedisManager.GetClient())
   
2. {
3. redisClient.RenameKey(txtKey.Text, txtNewKey.Text);
5. var user = redisClient.GetTypedClient<User>();
6. var userKeyList = user.GetAllKeys();
8. 
   if (userKeyList.Count > 0)
   
9. {
10. lblPeople.Text =
    
    string.Empty;
    
11. var htmlStr =
    
    string.Empty;
    
12. 
    foreach (var u
    
    in userKeyList)
    
    
13. {
14. htmlStr +=
    
    “<li>key=” + u +
    
    “</li>”;
    
    
15. }
16. lblPeople.Text = htmlStr;
17. }
18. lblShow.Text =
    
    “筛选后共有：” + userKeyList.Count.ToString() +
    
    ” Keys！”;
    
    
19. }

这样是可以重命名key的，如下图：

可以看到urn:user:1已经不存在了，取而代之的是urn:user:5，但是如果我们再次运行GetAll<User>()时，却发现只有三条数据了，如图：

在

C# Redis实战(六)

中我已经提到了ids:User的概念，其实在ServiceStack.Redis的Rename中并没有将重命名后的key保存在其中，这样就会导致ids:User中只有原来的三条未修改的数据，但是seq:User中仍有六条数据。

[csharp]


view plain


copy

1. 
   public
   
   void Rename(
   
   string oldKeyname,
   
   string newKeyname)
   
   
   
   
2. {
3. 
   if (oldKeyname ==
   
   null)
   
   
4. 
   throw
   
   new ArgumentNullException(
   
   “oldKeyname”);
   
   
   
5. 
   if (newKeyname ==
   
   null)
   
   
6. 
   throw
   
   new ArgumentNullException(
   
   “newKeyname”);
   
   
   
8. SendExpectSuccess(Commands.Rename, oldKeyname.ToUtf8Bytes(), newKeyname.ToUtf8Bytes());
9. }

但是查询单个key依然可以得到完整的数据：

可以这么理解，可怜的urn:user:5变成了无家可归的孩子，不管是GetAll()，或者DeleteAll()均对其不起作用。

如需转载，请注明出处，

本系列博文示例程序下载地址